通过VxWorks实现网络套接字通信

本示例代码演示了如何使用VxWorks操作系统实现网络套接字通信。通过创建服务器和客户端，实现数据的传输。本示例使用的是TCP/IP协议。

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

#define SERVER_PORT_NUM 5001
#define SERVER_MAX_CONNECTIONS 4

int serverTask(void);

void vxworks_socket_communication_demo()
{
    //启动服务器任务
    taskSpawn("tServer", 50, VX_FP_TASK, 20000, serverTask,
              0, 0, 0, 0, 0, 0, 0, 0, 0, 0);

    //等待服务器完成初始化
    taskDelay(1000);

    //启动客户端任务，向服务器发送数据
    taskSpawn("tClient", 50, VX_FP_TASK, 20000, clientTask,
              0, 0, 0, 0, 0, 0, 0, 0, 0, 0);

    return;
}

int serverTask (void)
{
    int listenSock, acceptSock;
    char buffer[256];
    struct sockaddr_in serverAddr, clientAddr;
    int sockAddrSize;
    int nRead;

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

    //绑定服务器端口
    serverAddr.sin_family = AF_INET;
    serverAddr.sin_port = htons(SERVER_PORT_NUM);
    serverAddr.sin_addr.s_addr = htonl(INADDR_ANY);
    bzero(serverAddr.sin_zero, sizeof(serverAddr.sin_zero));
    if (bind(listenSock, (struct sockaddr *)&serverAddr, sizeof(serverAddr)) == ERROR)
    {
        perror("bind");
        return(ERROR);
    }

    //开始监听
    if (listen(listenSock, SERVER_MAX_CONNECTIONS) == ERROR)
    {
        perror("listen");
        return(ERROR);
    }

    sockAddrSize = sizeof(clientAddr);

    //等待客户端连接
    if ((acceptSock = accept(listenSock, (struct sockaddr *)&clientAddr, &sockAddrSize)) == ERROR)
    {
        perror("accept");
        return(ERROR);
    }

    //接收客户端数据
    while ((nRead = recv(acceptSock, buffer, sizeof(buffer), 0)) > 0)
    {
        printf("Received %d bytes from client:\n", nRead);
        printf("%s\n", buffer);

        //发送响应数据
        send(acceptSock, buffer, strlen(buffer), 0);

        bzero(buffer, sizeof(buffer));
    }

    //关闭套接字
    close(acceptSock);
    close(listenSock);

    return OK;
}

int clientTask (void)
{
    int sockFd;
    char buffer[256];
    struct sockaddr_in sockAddr;
    int sockAddrSize;
    char *serverAddress = "192.168.0.2"; //服务器IP地址

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

    //设置服务器地址和端口
    sockAddr.sin_family = AF_INET;
    sockAddr.sin_port = htons(SERVER_PORT_NUM);
    inet_pton(AF_INET, serverAddress, &sockAddr.sin_addr);

    //连接服务器
    if (connect(sockFd, (struct sockaddr *)&sockAddr, sizeof(sockAddr)) == ERROR)
    {
        perror("connect");
        return(ERROR);
    }

    //发送数据到服务器
    sprintf(buffer, "Hello, this is client.");
    printf("Send data to server:\n%s\n", buffer);
    if (send(sockFd, buffer, strlen(buffer), 0) == ERROR)
    {
        perror("send");
        return(ERROR);
    }

    bzero(buffer, sizeof(buffer));

    //接收服务器响应
    if (recv(sockFd, buffer, sizeof(buffer), 0) == ERROR)
    {
        perror("recv");
        return(ERROR);
    }
    printf("Received data from server:\n%s\n", buffer);

    //关闭套接字
    close(sockFd);

    return OK;
}

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