VxWorks系统中网络通信的实现

本示例代码展示了如何在VxWorks实时操作系统中实现TCP/IP协议的网络通信功能。通过创建套接字、绑定端口、监听连接、数据传输等步骤，实现了基于TCP协议的网络通信。

#include <stdio.h>
#include <string.h>
#include <vxWorks.h>
#include <socklib.h>
#include <inetLib.h>

#define SERVER_PORT_NUM 5001

void serverTask(void) {
    int listenFd;
    int connFd;
    struct sockaddr_in serverAddr;
    struct sockaddr_in clientAddr;
    char buffer[256];
    int bytesReceived;

    /* 创建套接字并绑定端口 */
    if ((listenFd = socket(AF_INET, SOCK_STREAM, 0)) == ERROR) {
        perror("socket");
        return;
    }

    memset(&serverAddr, 0, sizeof(serverAddr));
    serverAddr.sin_family = AF_INET;
    serverAddr.sin_port = htons(SERVER_PORT_NUM);
    serverAddr.sin_addr.s_addr = htonl(INADDR_ANY);

    if (bind(listenFd, (struct sockaddr *)&serverAddr, sizeof(serverAddr)) == ERROR) {
        perror("bind");
        return;
    }

    /* 监听连接请求 */
    if (listen(listenFd, 5) == ERROR) {
        perror("listen");
        return;
    }

    printf("Server running on port %d\n", SERVER_PORT_NUM);

    /* 接收连接并传输数据 */
    while (1) {
        int addrlen = sizeof(clientAddr);
        printf("Waiting for connection...\n");
        if ((connFd = accept(listenFd, (struct sockaddr *)&clientAddr, &addrlen)) == ERROR) {
            perror("accept");
            return;
        }
        printf("Connection received from %s\n", inet_ntoa(clientAddr.sin_addr));

        while (1) {
            bytesReceived = read(connFd, buffer, sizeof(buffer));

            if (bytesReceived == ERROR) {
                perror("read");
                close(connFd);
                break;
            }

            if (bytesReceived == 0) {
                printf("Connection closed by client\n");
                close(connFd);
                break;
            }

            printf("Received %d bytes: %s\n", bytesReceived, buffer);
        }
    }
}

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