vxworks-network网络通信模块资源-CSDN下载

共2个文件

h：1个

c：1个

需积分: 9 63 浏览量 2022-09-30 00:28:45 上传评论收藏 4KB ZIP 举报

VxWorks是一个实时操作系统（RTOS），广泛应用于嵌入式系统，尤其在航空、航天、通信等领域。在VxWorks中，网络通信是其核心功能之一，对于设备间的数据交互至关重要。"vxworks-network网络通信模块"是VxWorks内核的一部分，它提供了UDP和TCP这两种常用传输协议的API接口，允许开发者方便地实现网络通信功能。我们来详细了解一下TCP（Transmission Control Protocol）和UDP（User Datagram Protocol）这两种协议： 1. TCP：是一种面向连接的、可靠的传输协议。它通过建立连接、数据分片、顺序传输、确认应答和重传机制来确保数据的准确无误传输。TCP适用于对数据完整性要求高的应用场景，如HTTP、FTP和SMTP等应用层协议。 2. UDP：是一种无连接的、不可靠的传输协议。它不保证数据包的顺序到达或丢失重传，但具有更低的延迟和更高的传输效率。UDP适用于实时性要求高、对数据丢失有一定容忍度的应用，如DNS查询、视频流媒体和在线游戏等。在VxWorks中，这两个协议的API接口通常包含以下部分： - **TCP API**： - `sockCreate()`: 创建一个套接字，用于后续的连接或监听操作。 - `tcpConnect()`: 连接到指定的服务器地址和端口。 - `tcpListen()`: 设置套接字为监听模式，等待客户端连接。 - `tcpAccept()`: 接受一个来自客户端的连接请求。 - `tcpSend()`: 向连接的对端发送数据。 - `tcpReceive()`: 从连接的对端接收数据。 - `tcpClose()`: 关闭套接字。 - **UDP API**： - `sockCreate()`: 与TCP相同，创建一个UDP套接字。 - `udpBind()`: 绑定套接字到本地的IP地址和端口。 - `udpSendTo()`: 向指定的远程地址和端口发送数据。 - `udpRecvFrom()`: 接收来自任何源的UDP数据，并获取发送者的地址信息。 - `udpClose()`: 关闭UDP套接字。文件`NetFunc.c`和`NetFunc.h`很可能包含了VxWorks网络通信模块的实现和声明。`NetFunc.c`可能包含了上述提到的API函数的具体实现，如封装TCP和UDP的系统调用，处理数据的读写、连接管理等。而`NetFunc.h`则可能定义了这些函数的原型，以及相关的结构体和常量，供其他模块进行引用和调用。在实际开发中，开发者可以根据需求选择合适的网络协议，调用这些API来实现客户端和服务端的功能。例如，创建一个TCP服务器，需要先创建套接字，然后绑定到特定端口并开始监听；客户端则需要创建套接字，连接到服务器，然后进行数据的收发。对于UDP，服务器通常会先绑定到端口，然后通过`udpRecvFrom`接收数据，而客户端则直接使用`udpSendTo`发送数据。 "vxworks-network网络通信模块"是VxWorks操作系统中不可或缺的部分，它为开发者提供了高效、便捷的网络编程接口，使得在各种嵌入式设备之间实现可靠或高效的通信成为可能。理解和熟练掌握这些API，对于进行VxWorks系统的网络应用开发至关重要。

资源详情

资源评论

资源推荐

收起资源包目录

network.zip （2个子文件）

NetFunc.c 16KB

NetFunc.h 999B

#include <stdio.h> #include <taskLib.h> #include <sockLib.h> #include <inetLib.h> #include <time.h> #include <fcntl.h> #include "NetFunc.h" #define MS_TO_TIMEVAL(x, y) do { \ y.tv_sec = x / 1000; \ y.tv_usec = (x % 1000) * 1000; \ } while (0) STATUS NET_SetFdAttr(int iFd, int iFlag) { int iVal; int attr = 1; if( ioctl(iFd, FIONBIO, &attr) < 0 ) { perror("[net] ioctl failed"); return ERROR; } #if(0) if ((iVal = fcntl(iFd, F_GETFL, 0)) < 0) { perror("[net] fcntl failed"); return ERROR; } iVal |= iFlag; if (fcntl(iFd, F_SETFL, iVal) < 0) { perror("[net] fcntl failed"); return ERROR; } #endif return OK; } /** *@brief 创建UDP Socket * *@param[in] pDstIP目的IP地址 *@param[in] iDstPort目的端口 *@param[in] iLocalPort本地监听端口 * *@return *@retval -1 创建失败 *@retval 返回UDP socket操作句柄 */ int NET_UDPBuildSocket(int iLocalPort) { int iSocketFd = -1; int iRet = -1; int opt = 1; int iIndex = 0; struct sockaddr_in localAddr; iSocketFd = socket(AF_INET, SOCK_DGRAM, 0); if (iSocketFd < 0) { perror("[net] UDPClient: opening socket failed "); return (ERROR); } /* 本地网络地址 */ localAddr.sin_family = AF_INET; localAddr.sin_len = SA_LEN; localAddr.sin_port = htons(iLocalPort); localAddr.sin_addr.s_addr = htonl(INADDR_ANY); /*避免服务器出现意外而没有释放端口时，可以重新绑定端口，否则会提示绑定失败*/ setsockopt(iSocketFd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt)); iRet = bind(iSocketFd, (struct sockaddr *) &localAddr, SA_LEN); if (iRet == ERROR) { close(iSocketFd); perror("[net] UDPServer: Failed to bind socket"); return (ERROR); } #if(0) if (-1 == NET_SetFdAttr(iSocketFd, O_NONBLOCK)) { //设置为非阻塞方式 close(iSocketFd); return (ERROR); } #endif return iSocketFd; } /** *@brief UDP写入数据 * *@param[in] iSocketFd UDP通信socket句柄 *@param[in] pDstIP 目的IP地址 *@param[in] iPort 目的端口 *@param[in] pBuff 存储了需要发送的数据 *@param[in] iSize 发送数据的长度 *@param[in] ms 写入数据的超时时间(单位为毫秒)。-1表示 *要成功写完所有数据才返回。0表示不管是否写完所有数据 *都立即返回。大于0表示写入数据的超时时间。 * *@return 返回写数据状态 *@retval ERROR表示数据发送失败 *@retval OK表示数据发送成功 */ STATUS NET_UDPWriteData(int iSocketFd, char *pDstIP, int iPort, char *pBuff, int iSize, int ms) { int iRet = -1; struct sockaddr_in saddr; struct timeval tval; fd_set write_set; if( (iSocketFd < 0) || (NULL == pBuff) || (NULL == pDstIP)) { return ERROR; } saddr.sin_family = AF_INET; saddr.sin_len = SA_LEN; saddr.sin_port = htons(iPort); saddr.sin_addr.s_addr = inet_addr(pDstIP); if (ms >= 0)//有超时时间 { MS_TO_TIMEVAL(ms, tval); } while (1) { FD_ZERO(&write_set); FD_SET(iSocketFd, &write_set); iRet = select(iSocketFd + 1, NULL, &write_set, NULL, (ms < 0) ? NULL : &tval); if (-1 == iRet) { //select error return ERROR; } else if (0 == iRet) { //time out return ERROR; } else { if (FD_ISSET(iSocketFd, &write_set)) { //可以发送报文 if (-1 != sendto(iSocketFd, pBuff, iSize, 0, (struct sockaddr *) &saddr, SA_LEN)) { //发送报文成功 return OK; } else { perror("[net] sendto failed "); return ERROR; } } } } return OK; } /** *@brief UDP读取socket数据 * *@param[in] iSocketFd UDP通信socket句柄 *@param[in] pBuff 存储数据空间 *@param[in] iSize 存储数据空间长度 *@param[in] ms 读取数据的超时时间(单位为毫秒)。-1表示 *要成功读取所有数据才返回。0表示不管是否读取所有数据 *都立即返回。大于0表示读取数据的超时时间。 *@param[out] pDstIP 目的IP地址 * *@return 返回读取数据状态 *@retval ERROR表示数据读取失败 *@retval 0表示超时 *@retval 大于0表示读取到数据长度 */ STATUS NET_UDPReadData(int iSocketFd, char *pBuff, int iSize, int ms, char *pDstIP) { int iRet = -1; int iAddrLen = SA_LEN; int iRcvLen = 0; struct timeval tval; fd_set read_set; struct sockaddr_in addr; if( (iSocketFd < 0) || (NULL == pBuff) || (NULL == pDstIP)) { return ERROR; } if (ms >= 0)//有超时时间 { MS_TO_TIMEVAL(ms, tval); } while (1) { FD_ZERO(&read_set); FD_SET(iSocketFd, &read_set); iRet = select(iSocketFd + 1, &read_set, NULL, NULL, (ms < 0) ? NULL : &tval); if (-1 == iRet) { //select error return ERROR; } else if (0 == iRet) { //time out return 0; } else { if (FD_ISSET(iSocketFd, &read_set)) { //接收到报文 iRcvLen = recvfrom(iSocketFd, pBuff, iSize, 0, (struct sockaddr *) &addr, &iAddrLen); if (-1 != iRcvLen) { /* 成功接收到报文 */ snprintf(pDstIP, IP_ADDR_LEN, "%s", inet_ntoa(addr.sin_addr)); //pAddress->sDesPort = addr.sin_port; return iRcvLen; } else { perror("[net] recvfrom failed "); return ERROR; } } } } return OK; } /** *@brief 创建TCP Client客户端 * *@param[in] pDstIP tcp服务端IP地址 *@param[in] iPort 端口 * *@return *@retval -1 创建失败 *@retval socket操作句柄 */ int NET_TCPBuildClientSocket(char *pDstIP, int iPort) { int iRet = -1; int iSocketFd = -1; struct sockaddr_in desAddr; struct timeval wait; if(NULL == pDstIP) return ERROR; iSocketFd = socket(AF_INET, SOCK_STREAM, 0); if (iSocketFd < 0) { perror("[net] Failed to create TCP Client Socket "); return ERROR; } #if(1) if (-1 == NET_SetFdAttr(iSocketFd, O_NONBLOCK)) { //设置为非阻塞方式 return (ERROR); } #endif desAddr.sin_family = AF_INET; desAddr.sin_len = SA_LEN; desAddr.sin_port = htons(iPort); desAddr.sin_addr.s_addr = inet_addr(pDstIP); wait.tv_sec = 20; wait.tv_usec = 0; iRet = connectWithTimeout(iSocketFd, (struct sockaddr *) &desAddr, SA_LEN, &wait); if (iRet < 0) { close(iSocketFd); perror("[net] Failed to connect TCP Server "); return ERROR; } return iSocketFd; } /** *@brief 创建TCP Server服务端 * *@param[in] iPort 服务端监听端口，绑定地址为INADDR_ANY * *@return *@retval -1 创建失败 *@retval socket操作句柄 */ int NET_TCPBuildServerSocket(int iPort) { int iRet = -1; int iSocketFd = -1; int opt = 1; struct sockaddr_in localAddr; iSocketFd = socket(AF_INET, SOCK_STREAM, 0); if (iSocketFd < 0) { perror("[net] Failed to create TCP Server Socket.\n"); return ERROR; } localAddr.sin_family = AF_INET; localAddr.sin_len = SA_LEN; localAddr.sin_port = htons(iPort); localAddr.sin_addr.s_addr = htonl(INADDR_ANY); /*避免服务器出现意外而没有释放端口时，可以重新绑定端口，否则会提示绑定失败*/ setsockopt(iSocketFd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt)); iRet = bind(iSocketFd, (struct sockaddr *) &localAddr, SA_LEN); if (iRet == ERROR) { close(iSocketFd); perror("[net] Failed to bind TCP socket\n"); return ERROR; } iRet = listen(iSocketFd, 5); if (iRet == ERROR) { close(iSocketFd); perror("