基于消息机制的异步架构之对消息队列的处理

/*  *   handle.h  */ #ifndef HANDLE_H_ #define HANDLE_H_ #include "msgqueue.h" typedef struct HANDLER{ int send_sock; char send_ip[128]; uint16 send_port; int ind; pthread_t  thread_id; //WORKER* fath

>>阅读原文<<