Linux C socket 编程之UDP

发送方：

/*

* File: main.c

* Author: tianshuai

*

* Created on 2011年11月29日, 下午10:34

*

* 主要实现：发送20个文本消息，然后再发送一个终止消息

*/

#include <stdio.h>

#include <stdlib.h>

#include <string.h>

#include <sys/socket.h>

#include <netinet/in.h>

#include <arpa/inet.h>

#include <netdb.h>

int port=6789;

int main(int argc, char** argv) {

int socket_descriptor; //套接口描述字

int iter=0;

char buf[80];

struct sockaddr_in address;//处理网络通信的地址

bzero(&address,sizeof(address));

address.sin_family=AF_INET;

address.sin_addr.s_addr=inet_addr("127.0.0.1");//这里不一样

address.sin_port=htons(port);

//创建一个 UDP socket

socket_descriptor=socket(AF_INET,SOCK_DGRAM,0);//IPV4 SOCK_DGRAM 数据报套接字（UDP协议）

for(iter=0;iter<=20;iter++)

{

/*

* sprintf(s, "%8d%8d", 123, 4567); //产生：" 123 4567"

* 将格式化后到 字符串存放到s当中

*/

sprintf(buf,"data packet with ID %d\n",iter);

/*int PASCAL FAR sendto( SOCKET s, const char FAR* buf, int len, int flags,const struct sockaddr FAR* to, int tolen);　　

* s：一个标识套接口的描述字。　

* buf：包含待发送数据的缓冲区。　　

* len：buf缓冲区中数据的长度。　

* flags：调用方式标志位。　　

* to：（可选）指针，指向目的套接口的地址。　

* tolen：to所指地址的长度。

　　 */

sendto(socket_descriptor,buf,sizeof(buf),0,(struct sockaddr *)&address,sizeof(address));

}

sprintf(buf,"stop\n");

sendto(socket_descriptor,buf,sizeof(buf),0,(struct sockaddr *)&address,sizeof(address));//发送stop 命令

close(socket_descriptor);

printf("Messages Sent,terminating\n");

exit(0);

return (EXIT_SUCCESS);

}

接受方：

/*

* File: main.c

* Author: tianshuai

*

* Created on 2011年11月29日, 下午10:34

*/

#include <stdio.h>

#include <stdlib.h>

#include <string.h>

#include <sys/socket.h>

#include <netinet/in.h>

#include <arpa/inet.h>

#include <netdb.h>

int port=6789;

int main(int argc, char** argv) {

int sin_len;

char message[256];

int socket_descriptor;

struct sockaddr_in sin;

printf("Waiting for data form sender \n");

bzero(&sin,sizeof(sin));

sin.sin_family=AF_INET;

sin.sin_addr.s_addr=htonl(INADDR_ANY);

sin.sin_port=htons(port);

sin_len=sizeof(sin);

socket_descriptor=socket(AF_INET,SOCK_DGRAM,0);

bind(socket_descriptor,(struct sockaddr *)&sin,sizeof(sin));

while(1)

{

recvfrom(socket_descriptor,message,sizeof(message),0,(struct sockaddr *)&sin,&sin_len);

printf("Response from server:%s\n",message);

if(strncmp(message,"stop",4) == 0)//接受到的消息为 “stop”

{

printf("Sender has told me to end the connection\n");

break;

}

}

close(socket_descriptor);

exit(0);

return (EXIT_SUCCESS);

}