C语言实现多线程TCP/IP通信：含数据包组合解析及心跳机制

以下是一个使用 C 语言实现的简单示例程序，包含了您所描述的功能： ```c #include <stdio.h> #include <stdlib.h> #include <string.h> #include <pthread.h> #include <unistd.h> #include <sys/socket.h> #include <netinet/in.h> #include <arpa/inet.h> // 定义数据包结构体 typedef struct { unsigned char frameHeader; unsigned short functionCode; unsigned short subFunctionCode; unsigned char placeholder; unsigned char dataLength; unsigned char *data; unsigned short checksum; unsigned char frameTail; } Packet; // 组合数据包函数 Packet *createPacket(unsigned short functionCode, unsigned short subFunctionCode, unsigned char placeholder, unsigned char dataLength, unsigned char *data) { Packet *packet = (Packet *)malloc(sizeof(Packet)); packet->frameHeader = 0x00; packet->functionCode = functionCode; packet->subFunctionCode = subFunctionCode; packet->placeholder = placeholder; packet->dataLength = dataLength; packet->data = (unsigned char *)malloc(dataLength); memcpy(packet->data, data, dataLength); packet->checksum = 0; // 此处可根据实际情况计算校验值 packet->frameTail = 0xff; return packet; } // 解析数据包函数 void parsePacket(Packet *packet) { printf("Function Code: 0x%04x\n", packet->functionCode); printf("Sub Function Code: 0x%04x\n", packet->subFunctionCode); printf("Placeholder: 0x%02x\n", packet->placeholder); printf("Data Length: 0x%02x\n", packet->dataLength); printf("Data: "); for (int i = 0; i < packet->dataLength; i++) { printf("0x%02x ", packet->data[i]); } printf("\n"); printf("Checksum: 0x%04x\n", packet->checksum); } // TCP1 服务器线程函数 void *tcp1ServerThread(void *arg) { int server_fd, new_socket; struct sockaddr_in address; int addrlen = sizeof(address); unsigned char buffer[1024] = {0}; // 创建 TCP 套接字 if ((server_fd = socket(AF_INET, SOCK_STREAM, 0)) == 0) { perror("Socket creation failed"); pthread_exit(NULL); } address.sin_family = AF_INET; address.sin_addr.s_addr = INADDR_ANY; address.sin_port = htons(8080); // 选择一个端口 // 绑定套接字 if (bind(server_fd, (struct sockaddr *)&address, sizeof(address)) < 0) { perror("Bind failed"); pthread_exit(NULL); } // 监听套接字 if (listen(server_fd, 5) < 0) { perror("Listen failed"); pthread_exit(NULL); } printf("TCP1 Server is listening...\n"); if ((new_socket = accept(server_fd, (struct sockaddr *)&address, (socklen_t *)&addrlen)) < 0) { perror("Accept failed"); pthread_exit(NULL); } while (1) { int received = recv(new_socket, buffer, sizeof(buffer), 0); if (received <= 0) { perror("Receive failed"); break; } Packet *packet = (Packet *)buffer; if (packet->frameHeader == 0x00 && packet->frameTail == 0xff) { parsePacket(packet); if (memcmp(packet->data, "0000aaff", 8) == 0) { send(new_socket, "0000aaff", 8, 0); } } } close(new_socket); close(server_fd); pthread_exit(NULL); } // TCP2 服务器线程函数 void *tcp2ServerThread(void *arg) { int server_fd, new_socket; struct sockaddr_in address; int addrlen = sizeof(address); unsigned char buffer[1024] = {0}; // 创建 TCP 套接字 if ((server_fd = socket(AF_INET, SOCK_STREAM, 0)) == 0) { perror("Socket creation failed"); pthread_exit(NULL); } address.sin_family = AF_INET; address.sin_addr.s_addr = INADDR_ANY; address.sin_port = htons(8081); // 选择一个不同的端口 // 绑定套接字 if (bind(server_fd, (struct sockaddr *)&address, sizeof(address)) < 0) { perror("Bind failed"); pthread_exit(NULL); } // 监听套接字 if (listen(server_fd, 5) < 0) { perror("Listen failed"); pthread_exit(NULL); } printf("TCP2 Server is listening...\n"); if ((new_socket = accept(server_fd, (struct sockaddr *)&address, (socklen_t *)&addrlen)) < 0) { perror("Accept failed"); pthread_exit(NULL); } while (1) { // 主动发送数据 Packet *packet = createPacket(0x1234, 0x5678, 0xAB, 5, (unsigned char *)"Hello"); send(new_socket, (unsigned char *)packet, sizeof(Packet), 0); int received = recv(new_socket, buffer, sizeof(buffer), 0); if (received <= 0) { perror("Receive failed"); break; } Packet *packet = (Packet *)buffer; if (packet->frameHeader == 0x00 && packet->frameTail == 0xff) { parsePacket(packet); if (memcmp(packet->data, "0000aaff", 8) == 0) { send(new_socket, "0000aaff", 8, 0); } } } close(new_socket); close(server_fd); pthread_exit(NULL); } // UDP 服务器线程函数 void *udpServerThread(void *arg) { int sockfd; struct sockaddr_in servaddr, cliaddr; // 创建 UDP 套接字 if ((sockfd = socket(AF_INET, SOCK_DGRAM, 0)) < 0) { perror("Socket creation failed"); pthread_exit(NULL); } memset(&servaddr, 0, sizeof(servaddr)); memset(&cliaddr, 0, sizeof(cliaddr)); servaddr.sin_family = AF_INET; servaddr.sin_addr.s_addr = INADDR_ANY; servaddr.sin_port = htons(8082); // 选择一个不同的端口 // 绑定套接字 if (bind(sockfd, (const struct sockaddr *)&servaddr, sizeof(servaddr)) < 0) { perror("Bind failed"); pthread_exit(NULL); } printf("UDP Server is listening...\n"); int len, n; unsigned char buffer[1024]; while (1) { len = sizeof(cliaddr); n = recvfrom(sockfd, buffer, sizeof(buffer), 0, (struct sockaddr *)&cliaddr, &len); if (n <= 0) { perror("Receive failed"); break; } Packet *packet = (Packet *)buffer; if (packet->frameHeader == 0x00 && packet->frameTail == 0xff) { parsePacket(packet); } // 主动发送数据 Packet *packet = createPacket(0xABCD, 0xEF12, 0x34, 6, (unsigned char *)"World"); sendto(sockfd, (unsigned char *)packet, sizeof(Packet), 0, (const struct sockaddr *)&cliaddr, len); } close(sockfd); pthread_exit(NULL); } int main() { pthread_t tcp1Thread, tcp2Thread, udpThread; // 创建线程 if (pthread_create(&tcp1Thread, NULL, tcp1ServerThread, NULL)!= 0) { perror("TCP1 thread creation failed"); return 1; } if (pthread_create(&tcp2Thread, NULL, tcp2ServerThread, NULL)!= 0) { perror("TCP2 thread creation failed"); return 1; } if (pthread_create(&udpThread, NULL, udpServerThread, NULL)!= 0) { perror("UDP thread creation failed"); return 1; } // 等待线程结束 pthread_join(tcp1Thread, NULL); pthread_join(tcp2Thread, NULL); pthread_join(udpThread, NULL); return 0; } ``` 这只是一个简单的示例程序，实际应用中还需要处理更多的错误情况、优化性能和添加更多的功能。特别是校验值的计算、网络异常处理等方面需要根据具体需求进行完善。 ######[AI写代码神器 | 2231点数解答 | 2024-11-17 23:56:36]