SylixOS-UDP网络应用编程

                                                UDP回射客户端程序

#include <stdio.h>
#include <string.h>
#include <sys/socket.h>

#define __UDP_ECHO_TYPE_CLIENT        	1  		/* 客户端模式                 	*/
#define __UDP_ECHO_TYPE_SERVER       	2 		/* 服务器模式                 	*/
												/* 当前模式选择              	*/
#define __UDP_ECHO_TYPE                	(__UDP_ECHO_TYPE_CLIENT)
              									/* 客户端 IP 地址           	*/
#define __UDP_ECHO_IP_CLIENT         	;192.168.1.16;
              									/* 服务器 IP 地址            	*/
#define __UDP_ECHO_IP_SERVER           	;192.168.1.17;
#define __UDP_ECHO_PORT_CLIENT     		8000 	/* 客户端端口号              	*/
#define __UDP_ECHO_PORT_SERVER        	8001	/* 服务器端口号             	*/

#define __UDP_ECHO_BUFF_SIZE_CLIENT   	257		/* 客户端接收缓冲区大小      	*/
#define __UDP_ECHO_BUFF_SIZE_SERVER	257		/* 服务器接收缓冲区大小      	*/

static int  __UdpEchoClient (void)
{
    int                	 sockFd      = -1;     	/* socket 描述符         	  	*/
        											/* 地址结构大小               	*/
    socklen_t           	 uiAddrLen	= sizeof(struct sockaddr_in);
    register ssize_t   	 sstRecv     = 0;    		/* 接收到的数据长度           	*/
    register ssize_t  	 sstSend     = 0;  		/* 接收到的数据长度         	*/
    												/* 需要发送的字符串          	*/
    const char          	*pcSendData = ;SylixOS Hello!
;; 
    												/* 接收缓冲区                 	*/
    char                 	 cRecvBuff[__UDP_ECHO_BUFF_SIZE_CLIENT] ={0};
    struct sockaddr_in	 sockaddrinRemote;		/* 远端地址                  	*/
    
    fprintf(stdout, ;UDP echo client start.
;);
                      								/* 创建 socket            	  	*/
    sockFd = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
    if (sockFd < 0) {
        fprintf(stderr, ;UDP echo client socket error.
;);
        return  (-1);
    }
    /*
     * 初始化远端地址结构
     */
    memset(&sockaddrinRemote, 0, sizeof(sockaddrinRemote));
     											/* 地址转换错误               	*/
    if (!inet_aton(__UDP_ECHO_IP_SERVER, &sockaddrinRemote.sin_addr)) {
        close(sockFd);              				/* 关闭已经创建的 socket      	*/
        fprintf(stderr, ;UDP echo client get addr error.
;);
        return  (-1);                   			/* 错误返回                   	*/
    }
          										/* 地址结构大小               	*/
    sockaddrinRemote.sin_len   	= sizeof(struct sockaddr_in);
    sockaddrinRemote.sin_family	= AF_INET;		/* 地址族                     	*/
       											/* 绑定服务器端口             	*/
    sockaddrinRemote.sin_port	= htons(__UDP_ECHO_PORT_SERVER);
    for (;;) {
        fprintf(stdout, ;Send Data: %s;, pcSendData);
        sstRecv = strlen(pcSendData);			/* 获取发送字符串长度         	*/
        sstSend = sendto(sockFd,
                            (const void *)pcSendData,
                             sstRecv,
                             0,
                            (const struct sockaddr *)&sockaddrinRemote,
                             uiAddrLen); 			/* 发送数据到指定的服务器端    	*/
        if (sstSend <= 0) { 						/* 发送数据失败               	*/
            if ((errno != ETIMEDOUT  ) &&
                (errno != EWOULDBLOCK)) {			/* 非超时与非阻塞              	*/
                 close(sockFd);                  	/* 关闭已经创建的 socket	  	*/
                
                 fprintf(stderr, ;UDP echo client sendto error.
;);
                 return  (-1);    					/* 错误返回                   	*/
            }
            continue;        						/* 超时或非阻塞后重新运行      	*/
        }
        memset(&cRecvBuff[0], 0, __UDP_ECHO_BUFF_SIZE_CLIENT);
        sstRecv = recvfrom(sockFd,
                               (void *)&cRecvBuff[0],
                               __UDP_ECHO_BUFF_SIZE_SERVER,
                               0,
                              (struct sockaddr *)&sockaddrinRemote,
                               &uiAddrLen);		    	/* 从远端接收数据             	*/
        if (sstRecv <= 0) {     					/* 接收数据失败                	*/
            if ((errno != ETIMEDOUT  ) &&
                (errno != EWOULDBLOCK)) {   		/* 非超时与非阻塞               */
                 close(sockFd);      				/* 关闭已经创建的 socket       */
                 fprintf(stderr, ;UDP echo client recvfrom error.
;);
                 return  (-1);      				/* 错误返回                     */
            }
            continue;                     			/* 超时或非阻塞后重新运行        */
        }
        fprintf(stdout, ;Recv Data: ;);
        cRecvBuff[sstRecv] = 0;
        fprintf(stdout, %s
;, &cRecvBuff[0]);
        sleep(5);                     				/* 休眠一段时间                  */
    }
    return  (0);
}