开源一个网络框架

前面有几篇文章介绍过一个基于linux epoll的网络接口，但并未将接口组合成一个方便使用的网络框架。

下面先简单介绍下以前发布过的网络接口：

首先是基本接口：

KendyNet.h KendyNet.c  https://github.com/sniperHW/kendylib/blob/master/include/KendyNet.h

此接口提供了最简单的单线程网络收发模型，并未提供封包解包等功能，使用者可在此之上根据自己的需求封装出合适的网络框架

第二组接口在第一组接口上提供了封包和解包：

Connection.h Connectionc https://github.com/sniperHW/kendylib/blob/master/include/Connection.h

这个封装提供了一种比较高效的封包方式，（封包方式的介绍可参看前面的文章）如果使用者觉得这种封包方式可以满足需求，可在此之上

封装合适的网络框架.

最后，也就是本文介绍的主题，利用第二组接口封装出来的，网络与逻辑分离的多线程网络框架.

此框架的核心是一个消息队列，用于在网络层和逻辑层之间通信，网络层将接收到的数据包，网络事件(连接断开，新到连接)通过消息队列传送到逻辑层，

供逻辑层处理.逻辑层需要发送的数据，操作(主动关闭套接口)通过消息队列传送到网络层。所有线程之间的同步操作，基本上都围绕着消息队列，使用者

基本不用考虑锁问题。(关于消息队列的设计和效率，可以参考前一篇文章)

下面贴出简单的echo测试程序:

#include "netservice.h"
#include "msg_loop.h"
#include "datasocket.h"
#include "SysTime.h"

int32_t count = 0;

void server_process_packet(datasocket_t s,rpacket_t r)
{
    wpacket_t w = wpacket_create_by_rpacket(NULL,r);
    data_send(s,w);
}

void process_new_connection(datasocket_t s)
{
    ++count;
    printf("%d\n",count);
}

void process_connection_disconnect(datasocket_t s,int32_t reason)
{
    release_datasocket(&s);
    --count;
    printf("%d\n",count);    
}

const char *ip;
uint32_t port;
int main(int argc,char **argv)
{
    init_system_time(10);
    ip = argv[1];
    port = atoi(argv[2]);
    signal(SIGPIPE,SIG_IGN);
    init_mq_system();
    init_clients();
    if(InitNetSystem() != 0)
    {
        printf("Init error\n");
        return 0;
    }
    
    netservice_t n = create_net_service(1);//创建一个网络服务框架，只使用一个网络线程
    net_add_listener(n,ip,port);           //添加监听
    //创建主消息循环对象
    msg_loop_t m = create_msg_loop(server_process_packet,process_new_connection,process_connection_disconnect);
    
    while(1)
    {
        //不断从消息队列中提取消息并处理
        msg_loop_once(m,n,100);    
    }

    return 0;
}

项目地址:https://github.com/sniperHW/kendylib/tree/master/netframework

 

分类: 网络程序