VxWorks本地TCP-client-C语言开发

TCP socket通信过程：

• 创建套接字
• 连接套接字connect
• 收发数据
• 关闭套接字

长连接TCP client

#include "string.h"
#include "stdio.h"
#include "vxWorks.h"
#include "sockLib.h"
//#include "telnetLib.h"
#include "inetLib.h"
#include "stdioLib.h"
#include "strLib.h"
#include "hostLib.h"
#include "ioLib.h"

// server地址及端口
#define TCP_SERVER_NAME "172.18.101.1"
#define TCP_SERVER_PORT 8888

// 缓冲buffer长度，最大message长度
#define BUFFER_SIZE 20480
#define MAX_MSG_LENGTH 20480
#define STRING_MAX_SIZE 20480

// 全局变量
char buffer[STRING_MAX_SIZE];

// TCP client 主动连接：输入TCP服务端地址和端口，返回client_socket
int tcp_client_conn(char *server_name, int port)
{
    struct sockaddr_in server_addr;
    int client_socket;

    /*创建套接字*/
    client_socket = socket(AF_INET, SOCK_STREAM, 0);
    if (client_socket < 0)
    {
        printf("Create Socket Failed! \n");
        return -1;
    }

    // 填充server地址信息
    bzero((char *)&server_addr, sizeof(server_addr));
    server_addr.sin_family = AF_INET;
    if (((server_addr.sin_addr.s_addr = inet_addr(server_name)) == ERROR) &&
        ((server_addr.sin_addr.s_addr = hostGetByName(server_name)) == ERROR))
    {
        printf("Get Server Address Error! \n");
        return -1;
    }
    server_addr.sin_port = htons(port);
    server_addr.sin_len = sizeof(server_addr);

    /* connect to server */
    if (connect(client_socket, (struct sockaddr *)&server_addr, sizeof(server_addr)) == ERROR)
    {
        printf("Connet to Server Error! \n");
        return -1;
    }

    return client_socket;
}

// TCP client 发送数据到目标TCP
void tcp_client_send_data(int client_socket)
{
    char send_buffer[BUFFER_SIZE];

    /* send request to server */
    bzero(send_buffer, BUFFER_SIZE);
    strcpy(send_buffer, "Hello TCP server! \n");
    // buffer发送长度+1，目的带上'\0'结束符，strlen()函数读取到'\0'结束
    int ret = send(client_socket, send_buffer, (strlen(send_buffer) + 1), 0);
    if (ret == ERROR)
    {
        printf("Send Data to Server Error! \n");
        return;
    }

    printf("send data to server: %s \n", send_buffer);
}

// TCP client 接收服务端返回的数据
void tcp_client_receive_data(int client_socket)
{
    char receive_buffer[BUFFER_SIZE];
    int length;

    // 接受服务器返回的状态信息
    bzero(receive_buffer, BUFFER_SIZE);
    if ((length = recv(client_socket, receive_buffer, MAX_MSG_LENGTH, 0)) == ERROR)
    {
        printf("Client Recieve Data Failed! \n");
        return;
    }

    bzero(buffer, STRING_MAX_SIZE);
    strncpy(buffer, receive_buffer, (strlen(receive_buffer) > STRING_MAX_SIZE ? STRING_MAX_SIZE : strlen(receive_buffer)));

    printf("receive data from server: %s \n", buffer);
}

// 当前TCP通道结束条件：接收到OVER，关闭当前TCP通道
int finish_operation(int sock)
{
    char temp[BUFFER_SIZE];
    bzero(temp, BUFFER_SIZE);
    strncpy(temp, buffer, (strlen(buffer) > BUFFER_SIZE ? BUFFER_SIZE : strlen(buffer)));

    if (strcmp(temp, "OVER") == 0)
    {
        close(sock);
        return 1;
    }
    else
    {
        return 0;
    }
}

int main(void)
{
    // 初始化并连接TCP server
    int tcp_client_socket = tcp_client_conn(TCP_SERVER_NAME, TCP_SERVER_PORT);
    if (tcp_client_socket < 0)
    {
        return -1;
    }
    // 完成连接

    // 数据交互
    while (1)
    {
        tcp_client_send_data(tcp_client_socket);
        tcp_client_receive_data(tcp_client_socket);

        if (finish_operation(tcp_client_socket))
        {
            break;
        }
    }

    //  异常结束，关闭socket
    close(tcp_client_socket);

    return 0;
}

短连接TCP client

针对上文代码，主要更改main函数即可实现

int main(void)
{
    // 初始化并连接TCP server
    int tcp_client_socket = tcp_client_conn(TCP_SERVER_NAME, TCP_SERVER_PORT);
    if (tcp_client_socket < 0)
    {
        return -1;
    }
    // 完成连接

    // 数据交互
    tcp_client_send_data(tcp_client_socket);
    tcp_client_receive_data(tcp_client_socket);

    //  关闭socket
    close(tcp_client_socket);

    return 0;
}

参考文章地址：
https://blog.csdn.net/woqunokia/article/details/40507307
https://github.com/niushiqi/TcpServer/tree/master/vxworks%E5%AE%98%E6%96%B9%E4%BE%8B%E5%AD%90