VxWorks中如何处理TCP/IP网络通信

本示例演示在VxWorks系统中如何使用TCP/IP协议进行网络通信，包括创建套接字、绑定IP和端口、监听请求和发送/接收数据等操作。

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

STATUS tcpServer(int port)
{
    int      serverSock, newSock;
    int      sockAddrSize;
    char     buffer[1024];
    int      recvBytes, sendBytes;
    struct sockaddr_in serverAddr;

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

    //绑定IP和端口
    memset((char*)&serverAddr, 0, sizeof(serverAddr));
    serverAddr.sin_family      = AF_INET;
    serverAddr.sin_port        = htons(port);
    serverAddr.sin_addr.s_addr = htonl(INADDR_ANY);
    if(bind(serverSock, (struct sockaddr*)&serverAddr, sizeof(serverAddr)) == ERROR)
    {
        perror("Error binding socket.");
        close(serverSock);
        return ERROR;
    }

    //监听请求
    if(listen(serverSock, 5) == ERROR)
    {
        perror("Error listening on socket.");
        close(serverSock);
        return ERROR;
    }
    printf("Waiting for connection...\n");

    //接受并处理客户端请求
    while(1)
    {
        sockAddrSize = sizeof(struct sockaddr_in);
        newSock = accept(serverSock, (struct sockaddr*)&serverAddr, &sockAddrSize);
        if(newSock == ERROR)
        {
            perror("Error accepting connection.");
            close(serverSock);
            return ERROR;
        }
        printf("Accepted connection from %s\n", inet_ntoa(serverAddr.sin_addr));

        //接收数据
        memset(buffer, 0, sizeof(buffer));
        recvBytes = recv(newSock, buffer, sizeof(buffer), 0);
        if(recvBytes == ERROR)
        {
            perror("Error receiving data.");
            close(newSock);
            continue;
        }
        printf("Received %d bytes: %s\n", recvBytes, buffer);

        //发送数据
        sendBytes = send(newSock, buffer, recvBytes, 0);
        if(sendBytes == ERROR)
        {
            perror("Error sending data.");
            close(newSock);
            continue;
        }
        printf("Sent %d bytes: %s\n", sendBytes, buffer);

        //关闭连接
        close(newSock);
        printf("Connection closed.\n");
    }

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

    return OK;
}

void main()
{
    int port = 8888;    //服务器监听端口号
    tcpServer(port);
}

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