QNX下实现socket通信的示例代码

该示例代码展示了如何在QNX操作系统下实现两个进程之间的socket通信，并实现了基本的客户端和服务器端的功能。

// 客户端代码
#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 argc, char *argv[])
{
    int client_fd;
    struct sockaddr_in server_addr;
    char buffer[1024] = {0};

    // 创建socket连接
    if ((client_fd = socket(AF_INET, SOCK_STREAM, 0)) < 0) {
        printf("create socket failed\n");
        return -1;
    }

    memset(&server_addr, 0, sizeof(server_addr));
    server_addr.sin_family = AF_INET;
    server_addr.sin_port = htons(PORT);
    server_addr.sin_addr.s_addr = inet_addr(argv[1]);

    // 连接服务器
    if (connect(client_fd, (struct sockaddr *)&server_addr, sizeof(server_addr)) < 0) {
        printf("connect server failed\n");
        return -1;
    }

    // 发送消息
    strncpy(buffer, "hello world", strlen("hello world"));
    send(client_fd, buffer, strlen(buffer), 0);

    // 接收服务器返回的消息
    memset(buffer, 0, sizeof(buffer));
    recv(client_fd, buffer, 1024, 0);
    printf("server response: %s\n", buffer);

    close(client_fd);

    return 0;
}

// 服务器端代码
#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 server_fd, client_fd;
    struct sockaddr_in server_addr, client_addr;
    int client_addr_len = sizeof(client_addr);
    char buffer[1024] = {0};

    // 创建socket连接
    if ((server_fd = socket(AF_INET, SOCK_STREAM, 0)) < 0) {
        printf("create socket failed\n");
        return -1;
    }

    memset(&server_addr, 0, sizeof(server_addr));
    server_addr.sin_family = AF_INET;
    server_addr.sin_port = htons(PORT);
    server_addr.sin_addr.s_addr = INADDR_ANY;

    // 绑定socket地址
    if (bind(server_fd, (struct sockaddr *)&server_addr, sizeof(server_addr)) < 0) {
        printf("bind socket failed\n");
        return -1;
    }

    // 监听socket连接
    if (listen(server_fd, 5) < 0) {
        printf("listen socket failed\n");
        return -1;
    }

    // 接收客户端连接
    if ((client_fd = accept(server_fd, (struct sockaddr *)&client_addr, &client_addr_len)) < 0) {
        printf("accept client failed\n");
        return -1;
    }

    // 接收客户端发送的消息
    memset(buffer, 0, sizeof(buffer));
    recv(client_fd, buffer, 1024, 0);
    printf("client message: %s\n", buffer);

    // 发送消息给客户端
    strncpy(buffer, "receive client message", strlen("receive client message"));
    send(client_fd, buffer, strlen(buffer), 0);

    close(server_fd);
    close(client_fd);

    return 0;
}

免责申明：文章和图片全部来源于公开网络，如有侵权，请通知删除 server@dude6.com