初版测试Socket部分的Demo

socket/SocketClient.c

+#include "../lib/sock_msg.h"
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <unistd.h>
+#include <sys/socket.h>
+#include <netinet/in.h>
+#include <arpa/inet.h>
+
+#define PORT 8888    // 服务器端口号
+#define MAXLINE 1024 // 缓冲区大小
+#define IP "192.168.232.129"
+
+int main(int argc, char *argv[])
+{
+    int sockfd;                  // 连接套接字
+    struct sockaddr_in servaddr; // 服务器地址结构
+    char buf[MAXLINE];           // 缓冲区
+    int n;                       // 读写字节数
+
+    // 创建连接套接字，使用TCP协议
+    inet_pton(AF_INET, IP, &servaddr.sin_addr);
+    sockfd = sock_init(0, servaddr.sin_addr.s_addr, PORT);
+
+    // 循环从标准输入读取数据，并发送给服务器，然后接收服务器的回复，并打印
+    while (fgets(buf, MAXLINE, stdin) != NULL)
+    {
+        sock_write(sockfd, buf, strlen(buf)); // 发送数据
+        n = sock_read(sockfd, buf, MAXLINE);  // 接收数据
+        if (n == 0)
+        {
+            printf("the other side has been closed.\n");
+            break;
+        }
+        write(STDOUT_FILENO, buf, n); // 打印数据
+    }
+
+    // 关闭连接套接字
+    close(sockfd);
+
+    return 0;
+}

socket/SocketServer.c

+#include "../lib/sock_msg.h"
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <unistd.h>
+#include <sys/socket.h>
+#include <netinet/in.h>
+#include <arpa/inet.h>
+
+#define PORT 8888 // 服务器端口号
+
+int main()
+{
+    int listenfd, connfd;                 // 监听套接字和连接套接字
+    struct sockaddr_in servaddr, cliaddr; // 服务器和客户端地址结构
+    socklen_t cliaddr_len;                // 客户端地址长度
+    char buf[BUFFER_SIZE];                // 缓冲区
+    char str[INET_ADDRSTRLEN];            // IP地址字符串
+    int n;                                // 读写字节数
+
+    // 创建监听套接字，使用TCP协议
+    inet_pton(AF_INET, INADDR_ANY, &servaddr.sin_addr);
+    listenfd = sock_init(1, servaddr.sin_addr.s_addr, PORT);
+
+    // 接受客户端连接请求，返回连接套接字
+    cliaddr_len = sizeof(cliaddr);
+    connfd = accept(listenfd, (struct sockaddr *)&cliaddr, &cliaddr_len);
+    if (connfd < 0)
+    {
+        perror("accept error");
+    }
+    // 打印客户端的IP地址和端口号
+    printf("connected client IP: %s, port: %d\n",
+           inet_ntop(AF_INET, &cliaddr.sin_addr, str, sizeof(str)),
+           ntohs(cliaddr.sin_port));
+
+    while (1)
+    {
+
+        // 循环读取客户端发送的数据，并回复
+        int reg_success = sock_ev_register(connfd, sock_read, SOCK_READ);
+        if (reg_success != 0)
+        {
+            printf("[%s],[%d],[%d]\n", __FILE__, __LINE__, reg_success);
+            perror("register fail");
+            return -1;
+        }
+
+        // 关闭连接套接字
+        close(connfd);
+    }
+
+    // 关闭监听套接字
+    close(listenfd);
+
+    return 0;
+}