VxWorks网络编程实例：TCP服务器与客户端通信

本示例演示如何使用VxWorks实现一个简单的TCP服务器与客户端通信。服务器在指定端口监听连接，客户端连接后发送消息，服务器接收并回复。涉及套接字创建、绑定、监听、接受、发送和接收等基本网络编程操作。

#include <stdio.h>
#include <sockLib.h>
#include <inetLib.h>

void tcpServer() {
    int listenSock, clientSock;
    struct sockaddr_in serverAddr, clientAddr;
    int clientAddrLen = sizeof(clientAddr);
    char buffer[1024];

    // 创建套接字
    if ((listenSock = socket(AF_INET, SOCK_STREAM, 0)) == ERROR) {
        perror("socket creation error");
        return;
    }

    // 配置服务器地址结构
    bzero((char *)&serverAddr, sizeof(serverAddr));
    serverAddr.sin_family = AF_INET;
    serverAddr.sin_port = htons(1234);
    serverAddr.sin_addr.s_addr = htonl(INADDR_ANY);

    // 绑定套接字
    if (bind(listenSock, (struct sockaddr *)&serverAddr, sizeof(serverAddr)) == ERROR) {
        perror("bind error");
        close(listenSock);
        return;
    }

    // 监听连接
    if (listen(listenSock, 5) == ERROR) {
        perror("listen error");
        close(listenSock);
        return;
    }

    printf("等待客户端连接...\n");

    // 接受连接
    if ((clientSock = accept(listenSock, (struct sockaddr *)&clientAddr, &clientAddrLen)) == ERROR) {
        perror("accept error");
        close(listenSock);
        return;
    }

    printf("客户端连接成功，开始通信。\n");

    // 接收消息
    recv(clientSock, buffer, sizeof(buffer), 0);
    printf("客户端消息：%s\n", buffer);

    // 发送回复
    send(clientSock, "服务器收到消息", sizeof("服务器收到消息"), 0);

    // 关闭套接字
    close(listenSock);
    close(clientSock);
}

void tcpClient() {
    int clientSock;
    struct sockaddr_in serverAddr;
    char buffer[1024];

    // 创建套接字
    if ((clientSock = socket(AF_INET, SOCK_STREAM, 0)) == ERROR) {
        perror("socket creation error");
        return;
    }

    // 配置服务器地址结构
    bzero((char *)&serverAddr, sizeof(serverAddr));
    serverAddr.sin_family = AF_INET;
    serverAddr.sin_port = htons(1234);
    serverAddr.sin_addr.s_addr = inet_addr("服务器IP地址");

    // 连接服务器
    if (connect(clientSock, (struct sockaddr *)&serverAddr, sizeof(serverAddr)) == ERROR) {
        perror("connection error");
        close(clientSock);
        return;
    }

    // 发送消息
    send(clientSock, "Hello, VxWorks!", sizeof("Hello, VxWorks!"), 0);

    // 接收回复
    recv(clientSock, buffer, sizeof(buffer), 0);
    printf("服务器回复：%s\n", buffer);

    // 关闭套接字
    close(clientSock);
}

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