1 files changed, 97 insertions, 0 deletions

diff --git a/testClient.c b/testClient.c
new file mode 100644
index 0000000..bbd2529
--- /dev/null
+++ b/testClient.c
@@ -0,0 +1,97 @@
+// 编写一段C程序，使用pthread创建两个线程
+// 发送线程将数据发送到127.0.0.1的5001端口，每0.5s一次
+// 接收线程接收127.0.0.1的5001端口的数据并打印
+
+#include <arpa/inet.h>
+#include <errno.h>
+#include <fcntl.h>
+#include <netinet/in.h>
+#include <pthread.h>
+#include <stdbool.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <sys/socket.h>
+#include <termios.h>
+#include <unistd.h>
+
+pthread_t udpSend, udpRecv;
+pthread_mutex_t mutex;
+int port = 5001;
+char clientIP[20] = "127.0.0.1";
+
+void udpSenderThread() {
+    struct sockaddr_in serverAddr;
+    int sockfd = -1;
+
+    // 创建UDP套接字
+    if ((sockfd = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP)) == -1) {
+        fprintf(stderr, "Error: Failed to create socket\n");
+        return;
+    }
+
+    memset((char *)&serverAddr, 0, sizeof(serverAddr));
+    serverAddr.sin_family = AF_INET;
+    serverAddr.sin_port = htons(port);
+    serverAddr.sin_addr.s_addr = inet_addr(clientIP);
+
+    while (1) {
+        char values[100] = {0};
+        // strcpy(values, "Hello, world!");
+        pthread_mutex_lock(&mutex);
+        printf("Input the data you want to send: ");
+        scanf("%s", values);
+        pthread_mutex_unlock(&mutex);
+        sendto(sockfd, values, strlen(values), 0,
+               (struct sockaddr *)&serverAddr, sizeof(serverAddr));
+        // printf("Send: %s\n", values);
+        sleep(1);
+    }
+}
+
+void udpReceiverThread() {
+    int sockfd = -1;
+    struct sockaddr_in serverAddr;
+    struct sockaddr_in clientAddr;
+    socklen_t clientAddrLen = sizeof(clientAddr);
+    char buffer[1024] = {0};
+
+    // 创建UDP套接字
+    if ((sockfd = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP)) == -1) {
+        fprintf(stderr, "Error: Failed to create socket\n");
+        return;
+    }
+
+    memset((char *)&serverAddr, 0, sizeof(serverAddr));
+    serverAddr.sin_family = AF_INET;
+    serverAddr.sin_port = htons(port - 1);
+    serverAddr.sin_addr.s_addr = htonl(INADDR_ANY);
+
+    if (bind(sockfd, (struct sockaddr *)&serverAddr, sizeof(serverAddr)) ==
+        -1) {
+        fprintf(stderr, "Error: Failed to bind socket\n");
+        close(sockfd);
+        return;
+    }
+
+    while (1) {
+        pthread_mutex_lock(&mutex);
+        int len = recvfrom(sockfd, buffer, 1024, 0,
+                           (struct sockaddr *)&clientAddr, &clientAddrLen);
+        pthread_mutex_unlock(&mutex);
+        if (len == -1) {
+            fprintf(stderr, "Error: Failed to receive data\n");
+            close(sockfd);
+            return;
+        }
+        buffer[len] = '\0';
+        printf("Received: %s\n", buffer);
+    }
+}
+
+int main() {
+    pthread_create(&udpSend, NULL, udpSenderThread, NULL);
+    // pthread_create(&udpRecv, NULL, udpReceiverThread, NULL);
+    pthread_join(udpSend, NULL);
+    // pthread_join(udpRecv, NULL);
+}
\ No newline at end of file