Go语言视频零基础入门到精通

admin

转自：http://blog.csdn.net/tianshuai11/article/details/7027444
发送方：

1. /*
2. * File:   main.c
3. * Author: tianshuai
4. *
5. * Created on 2011年11月29日, 下午10:34
6. *
7. * 主要实现：发送20个文本消息，然后再发送一个终止消息
8. */
10. #include <stdio.h>
11. #include <stdlib.h>
13. #include <string.h>
14. #include <sys/socket.h>
15. #include <netinet/in.h>
16. #include <arpa/inet.h>
17. #include <netdb.h>
19. int port=6789;
20. int main(int argc, char** argv) {
21.     int socket_descriptor; //套接口描述字
22.     int iter=0;
23.     char buf[80];
24.     struct sockaddr_in address;//处理网络通信的地址
26.     bzero(&address,sizeof(address));
27.     address.sin_family=AF_INET;
28.     address.sin_addr.s_addr=inet_addr("127.0.0.1");//这里不一样
29.     address.sin_port=htons(port);
31.     //创建一个 UDP socket
33.     socket_descriptor=socket(AF_INET,SOCK_DGRAM,0);//IPV4  SOCK_DGRAM 数据报套接字（UDP协议）
35.     for(iter=0;iter<=20;iter++)
36.     {
37.          /*
38.          * sprintf(s, "%8d%8d", 123, 4567); //产生：" 123 4567"
39.          * 将格式化后到 字符串存放到s当中
40.          */
41.         sprintf(buf,"data packet with ID %d\n",iter);
42.       
43.         /*int PASCAL FAR sendto( SOCKET s, const char FAR* buf, int len, int flags,const struct sockaddr FAR* to, int tolen);　　
44.          * s：一个标识套接口的描述字。　
45.          * buf：包含待发送数据的缓冲区。　　
46.          * len：buf缓冲区中数据的长度。　
47.          * flags：调用方式标志位。　　
48.          * to：（可选）指针，指向目的套接口的地址。　
49.          * tolen：to所指地址的长度。  
50. 　　      */
51.         sendto(socket_descriptor,buf,sizeof(buf),0,(struct sockaddr *)&address,sizeof(address));
52.     }
54.     sprintf(buf,"stop\n");
55.     sendto(socket_descriptor,buf,sizeof(buf),0,(struct sockaddr *)&address,sizeof(address));//发送stop 命令
56.     close(socket_descriptor);
57.     printf("Messages Sent,terminating\n");
59.     exit(0);
61.     return (EXIT_SUCCESS);
62. }

复制代码

接收方：

1. /*
2. * File:   main.c
3. * Author: tianshuai
4. *
5. * Created on 2011年11月29日, 下午10:34
6. */
8. #include <stdio.h>
9. #include <stdlib.h>
11. #include <string.h>
12. #include <sys/socket.h>
13. #include <netinet/in.h>
14. #include <arpa/inet.h>
15. #include <netdb.h>
17. int port=6789;
19. int main(int argc, char** argv) {
21.     int sin_len;
22.     char message[256];
24.     int socket_descriptor;
25.     struct sockaddr_in sin;
26.     printf("Waiting for data form sender \n");
28.     bzero(&sin,sizeof(sin));
29.     sin.sin_family=AF_INET;
30.     sin.sin_addr.s_addr=htonl(INADDR_ANY);
31.     sin.sin_port=htons(port);
32.     sin_len=sizeof(sin);
34.     socket_descriptor=socket(AF_INET,SOCK_DGRAM,0);
35.     bind(socket_descriptor,(struct sockaddr *)&sin,sizeof(sin));
37.     while(1)
38.     {
39.         recvfrom(socket_descriptor,message,sizeof(message),0,(struct sockaddr *)&sin,&sin_len);
40.         printf("Response from server:%s\n",message);
41.         if(strncmp(message,"stop",4) == 0)//接受到的消息为 “stop”
42.         {
44.             printf("Sender has told me to end the connection\n");
45.             break;
46.         }
47.     }
49.     close(socket_descriptor);
50.     exit(0);
52.     return (EXIT_SUCCESS);
53. }

复制代码