使用VxWorks实现网络通信

本示例展示了如何使用VxWorks操作系统进行网络通信。实现方式是通过建立TCP/IP连接，使用Socket API来传输数据。代码中包括发送和接收数据的例程。

#include <vxWorks.h>
#include <sockLib.h>
#include <inetLib.h>
#define SERVER_PORT_NUM 10000
char sendBuf[1024]={"Hello, World!\n"};
char recvBuf[1024];
int sockfd, newSockfd, peerAddrLen;
struct sockaddr_in serverAddr, peerAddr;
int connect_create_sock()
{
    if((sockfd = socket(AF_INET, SOCK_STREAM, 0)) == ERROR) {
        printf("socket failed\n");
        return ERROR;
    }
    bzero((char *)&serverAddr, sizeof(serverAddr));
    serverAddr.sin_family = AF_INET;
    serverAddr.sin_len = sizeof(serverAddr);
    serverAddr.sin_port = htons(SERVER_PORT_NUM);
    serverAddr.sin_addr.s_addr = htonl(INADDR_ANY);
    if (bind(sockfd, (struct sockaddr *)&serverAddr, sizeof(serverAddr)) == ERROR) {
        printf("bind failed\n");
        return ERROR;
    }
    if (listen(sockfd, 5) == ERROR) {
        printf("listen failed\n");
        return ERROR;
    }
    printf("Waiting for connection...\n");
    peerAddrLen = sizeof(peerAddr);
    if ((newSockfd = accept(sockfd, (struct sockaddr *)&peerAddr, (int *)&peerAddrLen)) == ERROR) {
        printf("accept failed\n");
        return ERROR;
    }

    return OK;
}

void connect_close_sock()
{
    close(newSockfd);
    close(sockfd);
    printf("Connection closed.\n");
}

void connect_send_recv_msg() 
{
    if (send(newSockfd, sendBuf, strlen(sendBuf) + 1, 0) == ERROR) {
        printf("send failed\n");
        return;
    }
    printf("Message sent: %s\n", sendBuf);
    if (recv(newSockfd, recvBuf, sizeof(recvBuf), 0) == ERROR) {
        printf("recv failed\n");
        return;
    }
    printf("Message received: %s\n", recvBuf);
}

int appStart()
{
    if(connect_create_sock()==ERROR)
    {
        printf("Create connection failed!\n");
        return ERROR;
    }
    connect_send_recv_msg();
    connect_close_sock();

    return OK;
}

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