基于事件驱动模型的Linux网络编程库

自己写的网络函数库，使用非常方便。
当有数据可读时，系统就会调用用户注册的函数。
当有新的客户连接时，系统就会调用用户注册的函数。
源码下载地址：
https://sourceforge.net/projects/libsocketc/

测试代码

1. #include "libsocket.h"
   
2. #include <signal.h>
   
3. #include <stdio.h>
   
4. #include <string.h>
   
5. #include <stdlib.h>
   
6. #include <unistd.h>
   
7. #include <stdbool.h>
   
8. 
   
9. #define PORT 8888
   
10. 
    
11. #define UDP_TEST           0
    
12. #define TCP_C_TEST         1
    
13. #define TCP_S_TEST         2
    
14. 
    
15. // 修改下面的数字，选择你要测试的项目。修改后，重新执行make，即可运行test
    
16. #define TEST                 0
    
17. 
    
18. bool QUIT = false;
    
19. void handle(int sig)
    
20. {
    
21.         if (sig == SIGINT)
    
22.                 QUIT = true;
    
23. }
    
24. 
    
25. // 有数据可读，将调用此函数
    
26. static void readCallback(Socket *sp)
    
27. {
    
28.         int n;
    
29.         char buf[1024] = {0};
    
30.         n = readSocket(sp, buf, 1000);
    
31.        
    
32.         if (n == 0)
    
33.         {
    
34.                 printf("The peer had shutdown\n");
    
35.                 return;
    
36.         }
    
37.        
    
38.         printf("------------------------------\n");
    
39.         if (TEST == UDP_TEST)
    
40.         {
    
41.                 printf("read from %s:%d\n", inet_ntoa(sp->pAddr.sin_addr), ntohs(sp->pAddr.sin_port));
    
42.                 writeSocket(sp, buf, strlen(buf) + 1, W_PEER);        // 向对端地址发送数据(用于UDP)
    
43.                 //writeSocket(sp, buf, strlen(buf) + 1, W_DST);        // 向指定的目标地址发送数据(用于UDP)
    
44.         }
    
45.         else if (TEST == TCP_C_TEST)
    
46.         {
    
47.                 printf("read from %s:%d\n", inet_ntoa(sp->dAddr.sin_addr), ntohs(sp->dAddr.sin_port));
    
48.                 writeSocket(sp, buf, strlen(buf) + 1, 0);
    
49.         }
    
50.         else if (TEST == TCP_S_TEST)
    
51.         {
    
52.                 printf("read from %s:%d\n", inet_ntoa(sp->pAddr.sin_addr), ntohs(sp->pAddr.sin_port));
    
53.                 writeSocket(sp, buf, strlen(buf) + 1, 0);
    
54.         }
    
55.         printf("%s\n", buf);
    
56. }
    
57. 
    
58. #if TEST == TCP_S_TEST
    
59. // 当有新的客户连接时，将调用此函数
    
60. static void callbackAccept(Socket *sp)
    
61. {
    
62.         Socket *sp_c = acceptSocket(sp, readCallback);
    
63.         printf("New connection:%s:%d\n", inet_ntoa(sp_c->pAddr.sin_addr), ntohs(sp_c->pAddr.sin_port));
    
64.        
    
65. }
    
66. #endif
    
67. 
    
68. int main(int argc, char **argv)
    
69. {
    
70.        
    
71.         signal(SIGINT, handle);
    
72.        
    
73.         // 初始化libsocket
    
74.         libSocketInit();
    
75.        
    
76. // UDP Test
    
77. #if TEST == UDP_TEST
    
78.        
    
79.         printf("UDP Test\n");
    
80. 
    
81.         if (argc != 3)
    
82.         {
    
83.                 fprintf(stderr, "Usage:%s ip port\n", argv[0]);
    
84.                 return -1;
    
85.         }
    
86.        
    
87.         // 创建数据报套接字
    
88.         Socket *sp = createSocket(SOCK_DGRAM, SOCKET_BROADCAST, readCallback);
    
89.         if (sp == NULL)
    
90.                 return -1;
    
91.        
    
92.         // 指定要发送的目标地址
    
93.         if (connectSocket(sp, argv[1], atoi(argv[2])) < 0)
    
94.                 return -1;
    
95.        
    
96.         // 绑定本地端口
    
97.         listenSocket(sp, PORT);
    
98.        
    
99.         printf("listen on %d\n", PORT);
    
100.                
     
101. #elif TEST == TCP_C_TEST
     
102. // TCP Client Test
     
103.         int n, fd;
     
104.         char buf[1024] = {0};
     
105.        
     
106.         printf("Tcp Client Test\n");
     
107.        
     
108.         if (argc != 3)
     
109.         {
     
110.                 fprintf(stderr, "Usage:%s ip port\n", argv[0]);
     
111.                 return -1;
     
112.         }
     
113.        
     
114.         // 创建流式套接字
     
115.         Socket *sp = createSocket(SOCK_STREAM, 0, readCallback);
     
116.         if (sp == NULL)
     
117.                 return -1;
     
118.        
     
119.         // 连接指定的服务器
     
120.         if (connectSocket(sp, argv[1], atoi(argv[2])) < 0)
     
121.                 return -1;
     
122. 
     
123. #elif TEST == TCP_S_TEST
     
124. // TCP Server Test
     
125.        
     
126.         printf("Tcp Server Test\n");
     
127.         // 创建流式套接字
     
128.         Socket *sp = createSocket(SOCK_STREAM, 0, callbackAccept);
     
129.         if (sp == NULL)
     
130.                 return -1;
     
131.        
     
132.         // 绑定本地端口，并监听
     
133.         listenSocket(sp, 8888);
     
134.         printf("listen on %d\n", PORT);
     
135. #endif
     
136. 
     
137.         while (!QUIT)
     
138.                 sleep(1);
     
139.                
     
140.         sleep(1);
     
141. 
     
142.         // 释放libsocket资源
     
143.         libSocketDeinit();
     
144.         printf("quit\n");
     
145.         return 0;
     
146. }

复制代码

如何使用啊，请指点，谢谢，我的邮箱：13714765431@qq.com

自己看测试代码