myserver是一个基于epoll模型的异步通信、返回结果为JSON的高性能服务器。它使用C++编写，需要通过mylog以及myconf这二者做编译依赖。和外界交互为JSON格式(使用开源库repidjson)。用户只需要配置好服务器，开始服务器，然后写通过用户自定义回调函数就可以轻松搭建一个高性能服务器。
会自动下载mylog以及myconf
my_server_t* my_server_create(const char* conf_path, const char* conf_file, const char* server_name);
conf_path: 服务配置路径
conf_file: 服务器配置文件
server_name : webserver名称
_server_sample_server_port ： 服务器监听端口, 默认2000<br>
_server_sample_listen_back : 监听backlog，默认20
_server_sample_pool_size : 线程池大小，默认200
_server_sample_thread_num ：线程数，默认10
_server_sample_timeout ：epool超时，默认0
int my_server_set_callback(my_server_t* server, callback_proc call_func);
server : 运行的服务器
call_func : 自定义的回调函数，返回值必须是int
int my_server_run(my_server_t* server);
uint32 my_server_get_read_size();
void* my_server_get_read_buf();
uint32 my_server_get_write_size();
void* my_server_get_write_buf();
int my_server_set_write_size(uint32 write_size);
这个必须有。
int my_server_close(my_server_t* server);
这个必须得有。
_server_sample_cut_off_len : 20000
_server_sample_server_port : 2000
_server_sample_listen_back : 20
_server_sample_pool_size : 200
_server_sample_thread_num : 10
_server_sample_timeout : 0
MYLOG_PATH=$(WORKROOT)/mylog/output/
MYCONF_PATH=$(WORKROOT)/myconf/output/
MYSERVER_PATH=$(WORKROOT)/myserver/output/
MYSERVER_PRO_PATH=$(WORKROOT)/myserver/
MY_SERVER_THIRD=$(MYSERVER_PRO_PATH)/third/
RAPID_JSON_PATH=$(MY_SERVER_THIRD)/rapidjson/
WORKROOT 在Makefile里面有指定
#include "myserver.h"
#include <unistd.h>
#include <signal.h>
#include <iostream>
using namespace std;
my_server_t* server;
int my_callback()
{
uint32 read_size = my_server_get_read_size();
//cout << "read_size is " << read_size << endl;
char* read_data = (char*)my_server_get_read_buf();
//cout << "read buf is " << read_data << endl;
char* write_data = (char*)my_server_get_write_buf();
uint32 write_size = my_server_get_write_size();
write_size = snprintf(write_data, write_size, "input is [%s], return succ", read_data);
my_server_set_write_size(write_size);
return 0;
}
void signal_process(int sig_no)
{
cout << "closing server\n";
my_server_close(server);
cout << "colsed server\n";
}
int main()
{
my_log_init("./log", "sample.log", "sample.log.wf", 16);
signal(SIGINT,signal_process);
server = my_server_create("./conf/", "myserver.conf", "sample");
if(server == NULL)
{
cout << "create sever fail\n";
return -1;
}
my_server_set_callback(server, my_callback);
my_server_run(server);
return 0;
}
<?php
$address = '127.0.0.1';
$port = 2000;
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
if($socket == NULL){
echo "socket create fail\n";
}
@$result = socket_connect($socket, $address, $port);
if($result == false){
echo "socket connect fail\n";
exit(1);
}
$in = "test input";
socket_write($socket, $in, strlen($in));
$out = socket_read($socket, 8192);
$res = json_decode($out,true);
var_dump($res);
socket_close($socket);
#include <stdio.h>
#include <stdlib.h>
#include <errno.h>
#include <string.h>
#include <netdb.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <sys/un.h>
#include <sys/socket.h>
#include <sys/unistd.h>
#include<arpa/inet.h>
#include <iostream>
#include <pthread.h>
using namespace std;
#define MAX_THREAD_NUM 7
#define RECV_LEN 1024
typedef struct cfg_main_t
{
char host[1024];
int port;
}cfg_main;
cfg_main g_cfg;
void* thread_test(void* args)
{
int sockfd;
struct sockaddr_in dest_addr; /* will hold the destination addr */
if((sockfd=socket(AF_INET, SOCK_STREAM, 0)) == -1)
{
cout << "create socket error\n";
return NULL;
}
dest_addr.sin_family = AF_INET;
dest_addr.sin_port = htons(g_cfg.port);
dest_addr.sin_addr.s_addr = inet_addr(g_cfg.host);
bzero(&(dest_addr.sin_zero), 8);
if(connect(sockfd, (struct sockaddr *)&dest_addr, sizeof(struct sockaddr)) == -1)
{
printf("connect fail with server_port[%s:%d]", g_cfg.host, g_cfg.port);
return NULL;
}
char *sendmsg = "消息内容";
char recv[RECV_LEN];
if( write(sockfd, sendmsg, strlen(sendmsg) + 1) < 0 )
{
cout << "send messgage fail\n";
return NULL;
}
if( read(sockfd, recv, RECV_LEN) < 0 )
{
cout << "recv fail\n";
}
cout << "read data is " << recv << endl;
close(sockfd);
pthread_exit(NULL);
}
void show_usage()
{
cout << "usage: ./client -h [host](default:127.0.0.1) -p [port]" << endl;
}
/** 解析参数 */
int main_parse_option(int argc, char **argv)
{
int c;
//reset 获取参数的位置，多次调用时这个会出现问题
while ((c = getopt(argc, argv, "h:p:")) != -1)
{
switch (c)
{
case 'h':
sprintf(g_cfg.host, optarg);
break;
case 'p':
g_cfg.port = atoi(optarg);
break;
default:
show_usage();
fflush(stdout);
return -1;
}
}
return 0;
}
int main(int argc, char* argv[])
{
if( 0 != main_parse_option(argc, argv) )
{
return -1;
}
if( strlen(g_cfg.host) == 0 ){
strncpy(g_cfg.host, "127.0.0.1", 1024);
}
if( g_cfg.port <= 0){
show_usage();
return -1;
}
pthread_t th[MAX_THREAD_NUM];
for(int i=0; i<MAX_THREAD_NUM; i++)
{
pthread_create(&th[i], NULL, thread_test, (void*)argv);
}
for(int i=0; i<MAX_THREAD_NUM; i++)
{
pthread_join(th[i], NULL);
}
return 0;
}
==> sample.log.wf <==
WARNING: 2014-01-09 16:03:56 [myconf.cpp:268] logid[0] reqid[] mod[sample] exec_time[281(us)] conf key[_server_sample_read_size] is empty , return default value 100
WARNING: 2014-01-09 16:03:56 [myconf.cpp:268] logid[0] reqid[] mod[sample] exec_time[292(us)] conf key[_server_sample_write_size] is empty , return default value 100
==> sample.log <==
TRACE: 2014-01-09 16:04:05 [myserver.cpp:343] logid[7] reqid[127.0.0.1] mod[sample] exec_time[8900489(us)] write data is {"errno":0,"data":"input is [test input], return succ"}
==> sample.log.wf <==
WARNING: 2014-01-09 16:04:05 [myserver.cpp:457] logid[7] reqid[127.0.0.1] mod[sample] exec_time[8901267(us)] client close connect
liujun05@cq01-rdqa-dev012.cq01:~/test/myserver/sample$ php client.php
array(2) {
["errno"]=>
int(0)
["data"]=>
string(34) "input is [test input], return succ"
}
liujun05@cq01-rdqa-dev012.cq01:~/myserver/sample_client$ ./client -p2000
read data is {"errno":0,"data":"input is [消息内容], return succ"}
read data is {"errno":0,"data":"input is [消息内容], return succ"}
read data is {"errno":0,"data":"input is [消息内容], return succ"}
read data is {"errno":0,"data":"input is [消息内容], return succ"}
read data is {"errno":0,"data":"input is [消息内容], return succ"}
read data is {"errno":0,"data":"input is [消息内容], return succ"}
read data is {"errno":0,"data":"input is [消息内容], return succ"}