首页 > 编程语言 >Socket通信(C++)

Socket通信(C++)

时间：2024-07-29 11:26:16浏览次数：15  
标签：addr socket int 通信 C++ include id Socket

文章目录

什么是Socket

Socket是用于计算机之间进行网络通信的端口的抽象。提供了应用进程利用底层网络协议交换数据的机制。

通过TCP/IP协议栈进行网络通信的过程中，每个设备都需要唯一的IP地址信息进行标识，Socket允许应用程序通过IP地址进行通信，而不需要关心底层TCP/IP协议的具体实现，在这个过程中，可以将Socket理解为对TCP/IP的进一步封装。

同时，Socket也可以在本地进程之间通信，Socket允许应用绑定本地Socket文件，通过Socket文件进行进程之间数据的交换。

Socket通信过程

Socket通信

  • 服务端：
    1. 创建Socket
    2. 绑定Socket: Socket支持绑定本地Socket或者IP端口
    3. 服务端开始监听客户端连接请求，当监听到连接请求后，调用accept()接收连接请求，建立服务端客户端连接
    4. 服务端客户端开始通信
      • send(): 通过send接口发送数据
      • receive(): 通过receive接口接收数据
    5. 服务端客户端处理通信异常信息
    6. 服务端主动关闭连接，或监听到客户端异常断开后，关闭连接
  • 客户端：
    1. 创建Socket
    2. 请求连接服务端Socket
    3. 服务端客户端开始通信
      • send(): 通过send接口发送数据
      • receive(): 通过receive接口接收数据
    4. 服务端客户端处理通信异常信息
    5. 客户端主动关闭连接，或监听到服务端异常断开后，关闭连接

C++ Socket通信API

C++在进行Socket通信时，通常有以下常用接口：

int socket(int domain, int type, int protocol);

以下参数信息为常用参数信息，更多内容参考man socket

  • int socket(int domain, int type, int protocol)：用于创建Socket
  • 头文件：
    • #include <sys/types.h>
    • #include <sys/socket.h>
  • 参数：
    • domain：网络连接协议簇的标识
      • AF_INET：IPv4协议簇
      • AF_INET6：IPv6协议簇
      • AF_UNIX/AF_LOCAL：本地Socket
    • type：Socket通信的语义类型
      • SOCK_STREAM：提供有序、可靠、双向、基于连接的字节流。可以支持带外数据传输机制（TCP通信常用）
      • SOCK_DGRAM：支持数据报（固定最大长度的无连接、不可靠的消息）（UDP通信常用）。
    • protocol：与Socket通信语义相匹配的协议类型，注意，protocol的选择需要和语义类型匹配，不可以随意组合
      • 0：根据type自动匹配protocol
      • IPPROTO_TCP：TCP协议
      • IPPROTO_UDP：UDP协议
  • 返回值：
    • 成功：返回Socket文件描述符ID
    • 失败：返回-1，并设置errno

int bind(int sockfd, const struct sockaddr *addr, socklen_t addrlen);

  • int bind(int sockfd, const struct sockaddr *addr, socklen_t addrlen)：socket()创建socket指定其协议类型后，我们还需要把socket绑定到具体的地址上才可以使用
  • 头文件：
    • #include <sys/types.h>
    • #include <sys/socket.h>
  • 参数：
    • sockfd：上述通过socket()函数创建的socketID信息
    • addr：socket绑定的协议地址，该参数需要与socket创建时指定的协议类型相关联
    • addrlen：addr结构的字节大小
  • 返回值：
    • 成功：返回0
    • 失败：返回-1，并设置errno

struct sockaddr

#include <sys/types.h>
#include <sys/socket.h>

struct sockaddr {
    sa_family_t sa_family;      // socket addr family
    char        sa_data[14];    // socket addr data
}

在sockaddr结构体中，数据信息混合在了一起，针对TCP/UDP这种包含IP和Port等多个数据的类型时，不是很好区分，所以一般情况下通过定义对应协议的addr信息，然后通过类型转换为soctaddr结构体

struct sockaddr_un

#include <sys/socket.h>
#include <sys/un.h>

struct sockaddr_un {
    sa_family_t sun_family;     // AF_UNIX
    char        sun_path[108];  // 本地Socket路径
};

struct sockaddr_in / struct sockaddr_in6

#include <netinet/in.h>

struct sockaddr_in {
    sa_family_t     sin_family;     // AF_INET
    in_port_t       sin_port;       // Port: 端口号
    struct in_addr  sin_addr;       // IPv4地址信息
};

struct sockaddr_in6 {
    sa_family_t     sin6_family;    // AF_INET6
    in_port_t       sin6_port;      // Port: 端口号
    uint32_t        sin6_flowinfo;  // IPv6流标识符，用于标识特定的数据流，在发送数据时附加到数据包头部
    struct in6_addr sin6_addr;      // IPv6地址信息
    uint32_t        sin6_scope_id;  // Scope Id：用于确定IPv6地址的使用范围和权限
};

int connect(int sockfd, const struct sockaddr *addr, socklen_t addrlen);

  • int connect(int sockfd, const struct sockaddr *addr, socklen_t addrlen)：客户端向服务端发送连接请求，等待连接
  • 头文件：
    • #include <sys/types.h>
    • #include <sys/socket.h>
  • 参数：
    • sockfd：上述通过socket()函数创建的socketID信息，该sockfd为客户端向服务端发起请求的socket
    • addr：socket绑定的协议地址，该参数需要与socket创建时指定的协议类型相关联
    • addrlen：addr结构的字节大小
  • 返回值：
    • 成功：返回0
    • 失败：返回-1，并设置errno

int listen(int sockfd, int backlog);

  • int listen(int sockfd, int backlog)：设置socket队列，监听socket请求，以处理客户端的连接、断开操作
  • 头文件：
    • #include <sys/types.h>
    • #include <sys/socket.h>
  • 参数：
    • sockfd：上述通过socket()函数创建的socketID信息
    • backlog: socket监听可能的最大连接长度，若队列已满，新的客户端连接请求会收到ECONNREFUSED错误
  • 返回值：
    • 成功：返回0
    • 失败：返回-1，并设置errno

int accept(int sockfd, struct sockaddr *addr, socklen_t *addrlen);

  • int accept(int sockfd, struct sockaddr *addr, socklen_t *addrlen)：监听sockfd队列的第一个连接请求，创建连接socket，并返回引用该socket的文件描述符
  • 头文件：
    • #include <sys/types.h>
    • #include <sys/socket.h>
  • 参数：
    • sockfd：上述通过socket()函数创建的socketID信息，该sockfd为客户端向服务端发起请求的socket
    • addr：socket绑定的协议地址，该参数需要与socket创建时指定的协议类型相关联
    • addrlen：addr结构的字节大小
  • 返回值：
    • 成功：返回socket文件描述符ID
    • 失败：返回-1，并设置errno

ssize_t send(int sockfd, const void *buf, size_t len, int flags);

socket 数据的常用发送接收还有read(),write()和其他方法。

read()和write()方法在遇到\0类型数据时会终止，所以通过该方法发送数据是受限的，这里不做介绍

  • ssize_t send(int sockfd, const void *buf, size_t len, int flags)：发送指定长度的数据
  • 头文件：
    • #include <sys/types.h>
    • #include <sys/socket.h>
  • 参数：
    • sockfd：客户端和服务端已建立的socketID文件描述符信息
    • buf：需要发送的数据内容
    • len: buffer数据长度
    • flags: 消息发送或运算的特性，默认可为0
  • 返回值：
    • 成功：成功发送数据的字节数
    • 失败：返回-1，并设置errno

ssize_t recv(int sockfd, void *buf, size_t len, int flags);

  • ssize_t recv(int sockfd, void *buf, size_t len, int flags)：接收指定长度的数据
  • 头文件：
    • #include <sys/types.h>
    • #include <sys/socket.h>
  • 参数：
    • sockfd：客户端和服务端已建立的socketID文件描述符信息
    • buf：接收数据的地址
    • len: buffer数据长度
    • flags: 消息接收或运算的特性，默认可为0
  • 返回值：
    • 成功：成功发送数据的字节数
    • 失败：返回-1，并设置errno

int close(int fd);

  • int close(int fd)：关闭socket连接
  • 头文件：
    • #include <unistd.h>
  • 参数：
    • fd：已连接的文件描述符ID
  • 返回值：
    • 成功：0
    • 失败：返回-1，并设置errno

C++ Socket通信

若要使用IPv4-TCP通信，请注释UNIX，取消注释IPv4

本示例不对IPv6通信进行说明

服务端

// socket
#include <sys/types.h>
#include <sys/socket.h>

// socket addr
#include <sys/un.h>
#include <netinet/in.h>

// file close
#include <unistd.h>

// htons
#include <arpa/inet.h>

#include <iostream>


int main() {
    // 1. 创建服务端Socket
    // IPv4
    // int server_socket = socket(AF_INET, SOCK_STREAM, 0);
    // UNIX
    int server_socket = socket(AF_UNIX, SOCK_STREAM, 0);

    if (server_socket < 0) {
        std::cerr << "socket error: 创建失败" << std::endl;
        throw std::runtime_error("socket error: 创建失败");
    } else {
        std::cout << "socket 创建成功，socketId：" << server_socket << std::endl;
    }

    // 2. 绑定Socket
    // IPv4
    // struct sockaddr_in server_addr;
    // server_addr.sin_family = AF_INET;
    // // INADDR_ANY: 0.0.0.0(绑定到本机的所有网卡上)
    // server_addr.sin_addr.s_addr = INADDR_ANY;
    // // htons: 将 unsigned short 转换为网络字节序
    // server_addr.sin_port = htons(8888);

    // UNIX
    struct sockaddr_un server_addr;
    server_addr.sun_family = AF_UNIX;
    strcpy(server_addr.sun_path, "/var/tmp/socket_test");

    if (bind(server_socket, (struct sockaddr*)&server_addr, sizeof(server_addr)) < 0) {
        std::cerr << "socket bind error: 绑定套接字失败，请检查本地套接字是否被占用" << std::endl;
        throw std::runtime_error("socket bind error: 绑定套接字失败，请检查本地套接字是否被占用");
    }

    // 3. 创建socket监听队列，并开始监听
    int listen_ret = listen(server_socket, 2048);
    if (listen_ret < 0) {
        std::cerr << "socket listen error: Socket监听失败" << std::endl;
        throw std::runtime_error("socket listen error: Socket监听失败");
    } 

    // 4. 接收客户端连接请求
    // IPv4
    // struct sockaddr_in client_addr;
    // UNIX
    struct sockaddr_un client_addr;
    
    int client_addr_len = sizeof(client_addr);
    int client_socket = accept(server_socket, (struct sockaddr*)&client_addr, (socklen_t *) &client_addr_len);
    if (client_socket < 0) {
        std::cerr << "socket client accpet error: Socket监听失败" << std::endl;
        throw std::runtime_error("socket listen error: Socket监听失败");
    }

    // 5. 接收客户端发送信息
    int recv_data_length = 15;
    char recv_data[recv_data_length];
    if (recv(client_socket, recv_data, recv_data_length, 0) < 0) {
        std::cerr << "socket recv error: 接收数据失败" << std::endl;
        throw std::runtime_error("socket recv error: 接收数据失败");
    } else {
        std::cout << "socket recv data: " << recv_data << std::endl;
    }

    // 6. 关闭socket
    close(server_socket);
    close(client_socket);

    return 0;
}

客户端

// socket
#include <sys/types.h>
#include <sys/socket.h>

// socket addr
#include <sys/un.h>
#include <netinet/in.h>

// file close
#include <unistd.h>

// htons
#include <arpa/inet.h>

#include <iostream>
#include <string.h>


int main() {
    // 1. 创建客户端Socket
    // IPv4
    // int client_socket = socket(AF_INET, SOCK_STREAM, 0);
    // UNIX
    int client_socket = socket(AF_UNIX, SOCK_STREAM, 0);

    if (client_socket < 0) {
        std::cerr << "socket error: 创建失败" << std::endl;
        throw std::runtime_error("socket error: 创建失败");
    } else {
        std::cout << "socket 创建成功，socketId：" << client_socket << std::endl;
    }

    // 2. 绑定Socket
    // IPv4
    // struct sockaddr_in client_addr;
    // client_addr.sin_family = AF_INET;
    // // INADDR_ANY: 0.0.0.0(绑定到本机的所有网卡上)
    // client_addr.sin_addr.s_addr = INADDR_ANY;
    // // htons: 将 unsigned short 转换为网络字节序
    // client_addr.sin_port = htons(8888);

    // UNIX
    struct sockaddr_un client_addr;
    client_addr.sun_family = AF_UNIX;
    strcpy(client_addr.sun_path, "/var/tmp/socket_test");

    if (connect(client_socket, (struct sockaddr*)&client_addr, sizeof(client_addr)) < 0) {
        std::cerr << "socket connect error: 连接服务端socket失败" << std::endl;
        throw std::runtime_error("socket connect error: 连接服务端socket失败");
    }

    // 3. 客户端发送信息
    std::string send_data = "Hello, Focus!!!";
    if (send(client_socket, send_data.c_str(), send_data.length(), 0) < 0) {
        std::cerr << "socket send error: 发送数据失败" << std::endl;
        throw std::runtime_error("socket send error: 发送数据失败");
    } 

    // 4. 关闭socket
    close(client_socket);

    return 0;
}

C++ Socket通信改进

以上代码可以实现简单的Socket通信流程，但是存在问题：

  • 服务端在第一次启动时，会创建本地Socket套接字文件，在以IP协议进行通信的Socket网络通信中，Socket关闭会释放端口，但是以UNIX本地Socket进行通信的Socket网络通信在关闭后，不会主动删除创建的Socket文件。在再次通信的过程中，会绑定失败
    • 解决方案：在程序第一次绑定时，判断文件是否存在，存在则删除
  • 在Socket通信过程中，send,recv,accept,connect等函数为阻塞函数，所以一旦调用此类方法，程序阻塞，就不能接收其他连接和处理了
    • 解决方案1：采用非阻塞模型进行Socket通信
    • 解决方案2：采用线程的方式，当新的socket连接建立后，将socket通信的过程放在线程中执行，线程结束释放该socket通信，这样可以通过accept方法以阻塞的方式一直等待新的客户端连接
    • 这里采用方案2进行改进
  • Socket通信过程中，采用send，recv方法虽然解决了write，read方法不能发送\0的问题，但是存在的问题是，通过send，recv传输数据需要已知数据大小，在数据大小确定的情况下，该方案很符合场景需要，但是在数据大小不确定的情况下。
    • 解决方案1: 确定"大"数据长度，数据长度不足后面补标志位、
    • 解决方案2：在传输数据前，先发送数据大小，然后初始化buffer接收数据
    • 这里采用方案2进行改进

在以下改进中，统一采用UNIX模型进行通信，IP模型请自行替换

UNIX socket文件已存在

#include <unistd.h>

#include <iostream>
#include <string.h>


void make_sure_socket_path(char *socket_path) {
    // F_OK：判断文件是否可读，若文件不存在则不可读
    if (access(socket_path, F_OK) == 0) {
        // unlink：删除文件
        if (unlink(socket_path) < 0) {
            std::cerr << "删除 socket：" << socket_path << " 失败" << std::endl;
            throw std::runtime_error("socket error: 创建失败");
        }
    }
}

子线程通信

头文件：

// socket
#include <sys/types.h>
#include <sys/socket.h>

// socket addr
#include <sys/un.h>
#include <netinet/in.h>

#include <pthread.h>

#include <unistd.h>

// htons
#include <arpa/inet.h>

#include <iostream>

class UnixSocketServer {
    private:
        std::string socket_path;

        // 记录服务端socket配置
        int socket_id;

        // 客户端最大连接数
        int max_client = 5;

        static void *thread_working(void *args);

    public:
        UnixSocketServer(std::string socket_path);

        ~UnixSocketServer();

        void run();
};

#include "socket.h"

UnixSocketServer::UnixSocketServer(std::string socket_path) {
    this->socket_path = socket_path;

    if (access(this->socket_path.c_str(), F_OK) == 0) {
        // unlink：删除文件
        if (unlink(this->socket_path.c_str()) < 0) {
            std::cerr << "删除 socket：" << this->socket_path << " 失败" << std::endl;
            throw std::runtime_error("socket error: 创建失败");
        }
    }

    // 1. 创建服务端socket
    this->socket_id = socket(AF_UNIX, SOCK_STREAM, 0);
    if (this->socket_id < 0) {
        std::cerr << "socket error: 创建失败" << std::endl;
        throw std::runtime_error("socket error: 创建失败");
    } else {
        std::cout << "socket 创建成功，socketId：" << this->socket_id << std::endl;
    }
    
    // 2. 绑定Socket
    struct sockaddr_un server_addr;
    server_addr.sun_family = AF_UNIX;
    strcpy(server_addr.sun_path, this->socket_path.c_str());

    if (bind(this->socket_id, (struct sockaddr*)&server_addr, sizeof(server_addr)) < 0) {
        std::cerr << "socket bind error: 绑定套接字失败，请检查本地套接字是否被占用" << std::endl;
        throw std::runtime_error("socket bind error: 绑定套接字失败，请检查本地套接字是否被占用");
    }

    // 3. 创建socket监听队列，并开始监听
    int listen_ret = listen(this->socket_id, this->max_client);
    if (listen_ret < 0) {
        std::cerr << "socket listen error: Socket监听失败" << std::endl;
        throw std::runtime_error("socket listen error: Socket监听失败");
    } 
}

UnixSocketServer::~UnixSocketServer() {
    close(this->socket_id);
    unlink(this->socket_path.c_str());
}

void *UnixSocketServer::thread_working(void *args) {
   
}

void UnixSocketServer::run() {
    while(true) {

        struct sockaddr_un client_addr;
    
        int client_addr_len = sizeof(client_addr);
        int client_id = accept(this->socket_id, (struct sockaddr*)&client_addr, (socklen_t *) &client_addr_len);
        if (client_id < 0) {
            std::cerr << "socket client accpet error: Socket监听失败" << std::endl;
            throw std::runtime_error("socket listen error: Socket监听失败");
        } else {
            std::cout << "socket client accpet success: 客户端：" << client_id << "连接成功" << std::endl;
        }

        pthread_t thread_id = client_id;
        pthread_create(&thread_id, NULL, this->thread_working, (void *) &client_id);
        pthread_detach(thread_id);
    }
}

int main() {
    UnixSocketServer *unixSocketServer = new UnixSocketServer("/var/tmp/socket_test");

    unixSocketServer->run();

    return 0;
}

Socket通信流程改进

服务端

核心代码
void *UnixSocketServer::thread_working(void *args) {
    int client_id = *(int *) args;

    while (true) {
        // 1. 接收数据长度
        // 注意这里不能采用 size_t 等类型定义，该类型会导致在不同架构编译器生成的 sizeof 大小不一致
        int receive_data_length;
        
        if (recv(client_id, &receive_data_length, sizeof(receive_data_length), 0) <= 0) {
            std::cerr << "socket communication error: 接收客户端数据长度失败" << std::endl;
            break;
        } else {
            std::cout << "socket communication success: 客户端原始数据长度：" << receive_data_length << std::endl;
        }

        // 2. 接收数据
        char receive_data[receive_data_length];
        if (recv(client_id, &receive_data, receive_data_length, 0) <= 0) {
            std::cerr << "socket communication error: 接收客户端数据失败" << std::endl;
            break;
        } else { 
            // 这里通过 std::string 构造函数初始化接收数据
            // 接收数据长度没有 `\0`，C/C++在输出 char 时，遇到 `\0` 才会停止
            std::cout << "socket communication success: 客户端原始数据：" << std::string(receive_data, receive_data_length) << std::endl;
        }

        // 3. 发送数据长度
        std::string send_data = "Hello, Focus!!!";
        int send_data_length = send_data.length();

        if (send(client_id, &send_data_length, sizeof(send_data_length), 0) < 0) {
            std::cerr << "socket communication error: 发送客户端数据长度失败" << std::endl;
            break;
        }

        // 4. 发送数据
        if (send(client_id, send_data.c_str(), send_data_length, 0) < 0) {
            std::cerr << "socket communication error: 发送客户端数据失败" << std::endl;
            break;
        } 
    }

    std::cout << "socket client close：客户端 " << client_id << " 已断开连接" << std::endl;
    close(client_id);
}
头文件
// socket
#include <sys/types.h>
#include <sys/socket.h>

// socket addr
#include <sys/un.h>
#include <netinet/in.h>

#include <pthread.h>

#include <unistd.h>

// htons
#include <arpa/inet.h>

#include <iostream>

class UnixSocketServer {
    private:
        std::string socket_path;

        // 记录服务端socket配置
        int socket_id;

        // 客户端最大连接数
        int max_client = 5;

        static void *thread_working(void *args);

    public:
        UnixSocketServer(std::string socket_path);

        ~UnixSocketServer();

        void run();
};
全代码
#include "socket.h"

UnixSocketServer::UnixSocketServer(std::string socket_path) {
    this->socket_path = socket_path;

    if (access(this->socket_path.c_str(), F_OK) == 0) {
        // unlink：删除文件
        if (unlink(this->socket_path.c_str()) < 0) {
            std::cerr << "删除 socket：" << this->socket_path << " 失败" << std::endl;
            throw std::runtime_error("socket error: 创建失败");
        }
    }

    // 1. 创建服务端socket
    this->socket_id = socket(AF_UNIX, SOCK_STREAM, 0);
    if (this->socket_id < 0) {
        std::cerr << "socket error: 创建失败" << std::endl;
        throw std::runtime_error("socket error: 创建失败");
    } else {
        std::cout << "socket 创建成功，socketId：" << this->socket_id << std::endl;
    }
    
    // 2. 绑定Socket
    struct sockaddr_un server_addr;
    server_addr.sun_family = AF_UNIX;
    strcpy(server_addr.sun_path, this->socket_path.c_str());

    if (bind(this->socket_id, (struct sockaddr*)&server_addr, sizeof(server_addr)) < 0) {
        std::cerr << "socket bind error: 绑定套接字失败，请检查本地套接字是否被占用" << std::endl;
        throw std::runtime_error("socket bind error: 绑定套接字失败，请检查本地套接字是否被占用");
    }

    // 3. 创建socket监听队列，并开始监听
    int listen_ret = listen(this->socket_id, this->max_client);
    if (listen_ret < 0) {
        std::cerr << "socket listen error: Socket监听失败" << std::endl;
        throw std::runtime_error("socket listen error: Socket监听失败");
    } 
}

UnixSocketServer::~UnixSocketServer() {
    close(this->socket_id);
    unlink(this->socket_path.c_str());
}

void *UnixSocketServer::thread_working(void *args) {
    int client_id = *(int *) args;

    while (true) {
        // 1. 接收数据长度
        // 注意这里不能采用 size_t 等类型定义，该类型会导致在不同架构编译器生成的 sizeof 大小不一致
        int receive_data_length;
        
        if (recv(client_id, &receive_data_length, sizeof(receive_data_length), 0) <= 0) {
            std::cerr << "socket communication error: 接收客户端数据长度失败" << std::endl;
            break;
        } else {
            std::cout << "socket communication success: 客户端原始数据长度：" << receive_data_length << std::endl;
        }

        // 2. 接收数据
        char receive_data[receive_data_length];
        if (recv(client_id, &receive_data, receive_data_length, 0) <= 0) {
            std::cerr << "socket communication error: 接收客户端数据失败" << std::endl;
            break;
        } else { 
            // 这里通过 std::string 构造函数初始化接收数据
            // 接收数据长度没有 `\0`，C/C++在输出 char 时，遇到 `\0` 才会停止
            std::cout << "socket communication success: 客户端原始数据：" << std::string(receive_data, receive_data_length) << std::endl;
        }

        // 3. 发送数据长度
        std::string send_data = "Hello, Focus!!!";
        int send_data_length = send_data.length();

        if (send(client_id, &send_data_length, sizeof(send_data_length), 0) < 0) {
            std::cerr << "socket communication error: 发送客户端数据长度失败" << std::endl;
            break;
        }

        // 4. 发送数据
        if (send(client_id, send_data.c_str(), send_data_length, 0) < 0) {
            std::cerr << "socket communication error: 发送客户端数据失败" << std::endl;
            break;
        } 
    }

    std::cout << "socket client close：客户端 " << client_id << " 已断开连接" << std::endl;
    close(client_id);
}

void UnixSocketServer::run() {
    while(true) {

        struct sockaddr_un client_addr;
    
        int client_addr_len = sizeof(client_addr);
        int client_id = accept(this->socket_id, (struct sockaddr*)&client_addr, (socklen_t *) &client_addr_len);
        if (client_id < 0) {
            std::cerr << "socket client accpet error: Socket监听失败" << std::endl;
            throw std::runtime_error("socket listen error: Socket监听失败");
        } else {
            std::cout << "socket client accpet success: 客户端：" << client_id << "连接成功" << std::endl;
        }

        pthread_t thread_id = client_id;
        pthread_create(&thread_id, NULL, this->thread_working, (void *) &client_id);
        pthread_detach(thread_id);
    }
}

int main() {
    UnixSocketServer *unixSocketServer = new UnixSocketServer("/var/tmp/socket_test");

    unixSocketServer->run();

    return 0;
}

客户端

// socket
#include <sys/types.h>
#include <sys/socket.h>

// socket addr
#include <sys/un.h>
#include <netinet/in.h>

// file close
#include <unistd.h>

// htons
#include <arpa/inet.h>

#include <iostream>
#include <string.h>

int socket_connect(const char *socket_path) {
    // 1. 创建客户端Socket
    int client_socket = socket(AF_UNIX, SOCK_STREAM, 0);

    if (client_socket < 0) {
        std::cerr << "socket error: 创建失败" << std::endl;
        throw std::runtime_error("socket error: 创建失败");
    } else {
        std::cout << "socket 创建成功，socketId：" << client_socket << std::endl;
    }

    // 2. 绑定Socket
    struct sockaddr_un client_addr;
    client_addr.sun_family = AF_UNIX;
    strcpy(client_addr.sun_path, socket_path);

    if (connect(client_socket, (struct sockaddr*)&client_addr, sizeof(client_addr)) < 0) {
        std::cerr << "socket connect error: 连接服务端socket失败" << std::endl;
        throw std::runtime_error("socket connect error: 连接服务端socket失败");
    }
    return client_socket;
}

int socket_close(int client_socket) {
    close(client_socket);
}

void socket_communication(const char *socket_path, std::string send_data) {
    int client_socket = socket_connect(socket_path);

    // 1. 发送数据长度
    int send_data_length = send_data.length();

    if (send(client_socket, &send_data_length, sizeof(send_data_length), 0) < 0) {
        std::cerr << "socket communication error: 发送客户端数据长度失败" << std::endl;
    }

    // 2. 发送数据
    if (send(client_socket, send_data.c_str(), send_data_length, 0) < 0) {
        std::cerr << "socket communication error: 发送客户端数据失败" << std::endl;
    } 

    // 3. 接收数据长度
    int receive_data_length;
        
    if (recv(client_socket, &receive_data_length, sizeof(receive_data_length), 0) <= 0) {
        std::cerr << "socket communication error: 接收客户端数据长度失败" << std::endl;
    } else {
        std::cout << "socket communication success: 客户端原始数据长度：" << receive_data_length << std::endl;
    }

    // 2. 接收数据
    char receive_data[receive_data_length];
    if (recv(client_socket, &receive_data, receive_data_length, 0) <= 0) {
        std::cerr << "socket communication error: 接收客户端数据失败" << std::endl;
    } else {
        std::cout << "socket communication success: 客户端原始数据：" << receive_data << std::endl;
    }

    socket_close(client_socket);
}

int main() {
    std::string data = R"({"args":null,"function":"select_all_algorithm_log","module":"dal","package":"log"})";

    socket_communication("/var/tmp/socket_test", data);
    return 0;
}

标签：addr,socket,int,通信,C++,include,id,Socket
From： https://blog.csdn.net/qq_42482078/article/details/140766885

相关文章

  • 【从0制作自己的ros导航小车：上、下位机通信篇】上、下位机串口DMA通信
    从0制作自己的ros导航小车前言一、准备工作二、下位机端（STM32）三、上位机端（旭日x3派）四、测试前言下位机的电机驱动、轮速读取、偏航角读取都已经完成，接下来就是上下位机的桥梁：串口通信。使用USB转TTL模块连接上位机（旭日x3派）和下位机（stm32），只需要连接RX、TX、GND即可......
  • C++自学笔记32（虚析构函数）
    在以往的笔记中我们讲到过析构函数和虚函数。析构函数是释放被初始化的变量，虚函数是告诉编译器有重名的函数被复写去派生类找对应函数。虚析构函数就是在基类析构函数前加入virtual表示派生类引用析构函数需要找派生类。看以下栗子。#include<iostream>classBase{publi......
  • 计算机毕业设计项目推荐，基于Echarts的高校就业数据可视化管理系统 81461（开题答辩+程序
    摘 要信息化社会内需要与之针对性的信息获取途径，但是途径的扩展基本上为人们所努力的方向，由于站在的角度存在偏差，人们经常能够获得不同类型信息，这也是技术最为难以攻克的课题。针对高校就业管理等问题，对高校就业管理进行研究分析，然后开发设计出高校就业数据可视化管理系统......
  • C/C++ 头文件注意事项总结
    C/C++头文件在编程中扮演着至关重要的角色，它们用于声明函数、类、宏、常量等，使得这些声明可以在多个源文件中共享。然而，在使用头文件时，需要注意一些关键事项以避免编译错误、提高代码的可维护性和可读性。以下是一些关于C/C++头文件使用的注意事项：1.防止头文件重复包含头文......
  • 使用 WebSocket 实现实时聊天
    个人名片......
  • 最细哈希表相关的力扣题和讲解和Java、C++常用的数据结构（哈希法）来源于代码随想录，十分
    20240725一、什么时候适用什么样的结构。1.java中1.1HashSet：1.2TreeSet：1.3LinkedHashSet：1.4HashMap：1.5TreeMap：1.6LinkedHashMap：1.7总结2.c++中2.1std::unordered_set：2.2std::set：2.3std::multiset：2.4std::unordered_map：2.5std::map：2.6std::multimap：3代码......
  • Dev-C++ 的功能与外观优化
    预备安装安装Dev-C++5.11：官方下载：https://sourceforge.net/projects/orwelldevcpp/（若下载缓慢可选择ProblemDownloading->Auto-select）蓝奏云下载：https://wwu.lanzouq.com/iTwwW07r28ni运行安装包即可。更改语言如果界面语言为英文，选择Tools->EnvironmentOptions......
  • OI 中各种输入方式的速度比较（C++，大量实测数据，附图表）
    测试信息本次共测试了以下几种输入方式的速度：scanfcin快读位运算快读fread()+位运算快读关闭同步流的cin开启tie绑定并关闭同步流的cin每组测试各输入方式均使用相同数据，为随机生成的\(1000000\)（1E6）个整数，范围在\([-(2^{31}-1),2^{31}-1]\)（即int范围）。所用......
  • C++ 中缀表达式判断合法性并求值
    中缀表达式值题目描述输入一个中缀表达式（由0−9组成的运算数、加+减−乘∗除/四种运算符、左右小括号组成。注意“−”也可作为负数的标志，表达式以“@”作为结束符）。判断表达式是否合法，如果不合法，请输出“NO”；否则请把表达式转换成后缀形式，再求出后缀表达式的值并......
  • VS2022创建C C++ GTEST工程
    原因需要对带代码进行单元测试，选择在Visualstudio中使用GTEST框架。实施创建一个常规的控制台可执行程序。然后使用NUGET安装包安装GTEST头文件和动态库，同时安装GTESTADAPTER。安装可能提示找不到包源，此时需要根据提示配置一下，注意通配符很关键，不要问为甚吗，就是有bug......

赞助商

阅读排行

网站主页关于我们联系我们网站地图

本网站内容转载自其他媒体，侵权联系[admin##ips99.com]。

Copyright © 2020-2023 IPS99 版权所有 IPS99