更改，利用多线程让客户端能够向多个网关建立链接

src/controller_ubuntu/connecter_controler.cpp

@@ -0,0 +1,72 @@
+#include <iostream>
+#include <string>
+#include <thread>
+#include <sys/socket.h>
+#include <netinet/in.h>
+#include <unistd.h>
+#include <arpa/inet.h>
+
+#define BUFFER_SIZE 1024
+
+void connect_to_gateway(const std::string& ip, int port) {
+    int sock = socket(AF_INET, SOCK_STREAM, 0);
+    if (sock == -1) {
+        std::cerr << "Could not create socket" << std::endl;
+        return;
+    }
+
+    struct sockaddr_in server_addr;
+    server_addr.sin_family = AF_INET;
+    server_addr.sin_port = htons(port);
+
+    if (inet_aton(ip.c_str(), &server_addr.sin_addr) == 0) {
+        std::cerr << "Invalid IP address" << std::endl;
+        close(sock);
+        return;
+    }
+
+    if (connect(sock, (struct sockaddr *)&server_addr, sizeof(server_addr)) < 0) {
+        std::cerr << "Connection to the server failed" << std::endl;
+        close(sock);
+        return;
+    }
+
+    std::cout << "Connected to gateway at " << ip << ":" << port << std::endl;
+
+    char buffer[BUFFER_SIZE];
+    // 发送测试消息
+    std::string message = "Hello, Gateway!";
+    if (send(sock, message.c_str(), message.size(), 0) < 0) {
+        std::cerr << "Send failed" << std::endl;
+        close(sock);
+        return;
+    }
+
+    // 接收网关响应
+    int nbytes = recv(sock, buffer, BUFFER_SIZE, 0);
+    if (nbytes < 0) {
+        std::cerr << "Recv failed" << std::endl;
+    } else if (nbytes == 0) {
+        std::cout << "Gateway disconnected" << std::endl;
+    } else {
+        std::cout << "Gateway said: " << buffer << std::endl;
+    }
+
+    close(sock);
+}
+
+int main() {
+    std::string ip;
+    int port;
+
+    std::cout << "Enter the gateway IP address: ";
+    std::cin >> ip;
+    std::cout << "Enter the gateway port: ";
+    std::cin >> port;
+
+    // 多线程连接网关
+    std::thread client_thread(&connect_to_gateway, ip, port);
+    client_thread.join();  // 等待连接完成
+
+    return 0;
+}

src/controller_ubuntu/connecter_gateway.cpp

@@ -0,0 +1,86 @@
+#include <iostream>
+#include <thread>
+#include <cstring>
+#include <sys/socket.h>
+#include <netinet/in.h>
+#include <unistd.h>
+#include <arpa/inet.h>
+
+#define PORT 8080
+#define MAX_CLIENTS 5
+#define BUFFER_SIZE 1024
+
+// 声明 handle_client 函数
+void handle_client(int client_socket);
+
+int main() {
+    int server_fd, new_socket;
+    struct sockaddr_in server_addr, client_addr;
+    socklen_t client_len = sizeof(client_addr);
+    char buffer[BUFFER_SIZE];
+    int opt = 1;
+
+    // 创建套接字
+    server_fd = socket(AF_INET, SOCK_STREAM, 0);
+    if (server_fd < 0) {
+        perror("socket creation failed");
+        exit(EXIT_FAILURE);
+    }
+
+    // 设置选项，允许重用地址
+    if (setsockopt(server_fd, SOL_SOCKET, SO_REUSEADDR | SO_REUSEPORT, &opt, sizeof(opt))) {
+        perror("setsockopt failed");
+        exit(EXIT_FAILURE);
+    }
+
+    server_addr.sin_family = AF_INET;
+    server_addr.sin_addr.s_addr = INADDR_ANY;
+    server_addr.sin_port = htons(PORT);
+
+    // 绑定
+    if (bind(server_fd, (struct sockaddr *)&server_addr, sizeof(server_addr)) < 0) {
+        perror("bind failed");
+        exit(EXIT_FAILURE);
+    }
+
+    // 监听
+    if (listen(server_fd, MAX_CLIENTS) < 0) {
+        perror("listen failed");
+        exit(EXIT_FAILURE);
+    }
+
+    std::cout << "Server listening on port " << PORT << std::endl;
+
+    while (true) {
+        client_len = sizeof(client_addr);
+        new_socket = accept(server_fd, (struct sockaddr *)&client_addr, &client_len);
+        if (new_socket < 0) {
+            perror("accept failed");
+            exit(EXIT_FAILURE);
+        }
+
+        std::cout << "New client connected from " << inet_ntoa(client_addr.sin_addr) << " port " << ntohs(client_addr.sin_port) << std::endl;
+
+        // 创建并启动线程处理客户端
+        std::thread(handle_client, new_socket).detach();
+    }
+
+    close(server_fd);
+    return 0;
+}
+
+// 定义 handle_client 函数
+void handle_client(int client_socket) {
+    while (true) {
+        char buffer[BUFFER_SIZE];
+        memset(buffer, 0, BUFFER_SIZE); // 清空缓冲区
+        int nbytes = read(client_socket, buffer, BUFFER_SIZE);
+        if (nbytes <= 0) {
+            std::cout << "Client disconnected." << std::endl;
+            close(client_socket);
+            break;
+        }
+        std::cout << "Received message from client: " << buffer << std::endl;
+        // 这里可以添加更多的处理逻辑
+    }
+}