自己实现的基于UDP的客户端--服务器

1480阅读　0评论2014-10-27　lt6419
分类：嵌入式

    Linux内核中已经把TCP/UDP封装在了协议栈中，从编程的角度来说，就是如何使用这些协议栈的问题了，其中，Linux提供了一种叫socket的特殊文件，其实也是一种特殊的操作系统接口，通过这个接口，我们可以利用Linux内核中的协议栈，因此，对编程来说就会变得比较容易，使用UDP或者TCP仅仅是函数接口传递的参数不同而已，大部分的代码是相同的，自己实现的基于UDP的客户端--服务器如下：

点击(此处)折叠或打开

  1. #include <stdio.h>
  2. #include <stdlib.h>
  3. #include <sys/socket.h>
  4. #include <netinet/in.h>
  5. #include <arpa/inet.h>

  7. /***********************************************************
  8.  * 函数功能：基于UDP实现简单的客户端服务器，客户端给服务器发
  9.  * 数据，服务器负责接收数据并把数据打印在终端。
  10.  * 服务器端实现的基本步骤：
  11.  * 1. 创建套接字
  12.  * 2. 给套接字绑定服务器的端口和IP地址
  13.  * 3. 监听套接字
  14.  * 4. 接收客户端发送的数据
  15.  ***********************************************************/
  16.  
  17. //./server ip port
  18. int main(int argc, const char *argv[])
  19. {
  20.     int n;
  21.     int sockfd;
  22.     char buf[1024];
  23.     struct sockaddr_in server_addr;
  24.     struct sockaddr_in peer_addr;
  25.     socklen_t addrlen = sizeof(struct sockaddr);

  27.     if(argc < 3)
  28.     {
  29.         fprintf(stderr,"Usage : %s \n",argv[0]);
  30.         exit(EXIT_FAILURE);
  31.     }

  33.     //1. 创建套接字
  34.     sockfd = socket(AF_INET,SOCK_DGRAM,0);
  35.     if(sockfd < 0){
  36.         perror("Fail to socket");
  37.         exit(EXIT_FAILURE);
  38.     }

  40.     //2. 给套接字绑定服务器的端口和IP地址
  41.     server_addr.sin_family = AF_INET;
  42.     server_addr.sin_addr.s_addr = inet_addr(argv[1]);
  43.     server_addr.sin_port = htons(atoi(argv[2]));
  44.     //3. 监听套接字,实质上是在等待是否有客户端对该套接字进行请求
  45.     if(bind(sockfd,(struct sockaddr *)&server_addr,sizeof(server_addr)) < 0)
  46.     {
  47.         perror("Fail to bind");
  48.         exit(EXIT_FAILURE);
  49.     }
  50.     
  51.     while(1)
  52.     {
  53.      // 4. 接收客户端发送的数据，其中第三个参数可以获取客户端的端口和IP地址信息
  54.         n = recvfrom(sockfd,buf,sizeof(buf) - 1,0,(struct sockaddr *)&peer_addr,&addrlen);
  55.         buf[n] = '\0';

  57.         //在服务器端打印客户端发送的数据、客户端的端口、IP地址
  58.         printf("-----------------------------\n");
  59.         printf("Port : %d\n",ntohs(peer_addr.sin_port));
  60.         printf("Ip : %s\n",inet_ntoa(peer_addr.sin_addr));
  61.         printf("buf : %s\n",buf);
  62.         printf("-----------------------------\n");
  63.     }

  65.     
  66.     return 0;
  67. }
客户端实现代码如下：

点击(此处)折叠或打开

  1. #include <stdio.h>
  2. #include <stdlib.h>
  3. #include <string.h>
  4. #include <sys/socket.h>
  5. #include <netinet/in.h>
  6. #include <arpa/inet.h>

  8. /***********************************************************
  9.  * 函数功能：基于UDP实现简单的客户端服务器，客户端给服务器发
  10.  * 数据，服务器负责接收数据并把数据打印在终端。
  11.  * 客户端实现的基本步骤：
  12.  * 1. 创建套接字
  13.  * 2. 给套接字绑定服务器的端口和IP地址
  14.  * 3. 给服务器发送数据
  15.  ***********************************************************/
  16. //./client ip port
  17. int main(int argc, const char *argv[])
  18. {
  19.     int n;
  20.     int sockfd;
  21.     char buf[1024];
  22.     struct sockaddr_in server_addr;
  23.     struct sockaddr_in client_addr;
  24.     struct sockaddr_in peer_addr;
  25.     socklen_t addrlen = sizeof(struct sockaddr);

  27.     //输入参数检查
  28.     if(argc < 3)
  29.     {
  30.         fprintf(stderr,"Usage : %s \n",argv[0]);
  31.         exit(EXIT_FAILURE);
  32.     }

  34.     //创建套接字，注意第二个参数必须是SOCK_DGRAM
  35.     sockfd = socket(AF_INET,SOCK_DGRAM,0);
  36.     if(sockfd < 0){
  37.         perror("Fail to socket");
  38.         exit(EXIT_FAILURE);
  39.     }

  41.     //填充服务器的端口和IP地址，因为要给别的服务器发生数据，至少需要知道两个参数：端口和IP
  42.     server_addr.sin_family = AF_INET;
  43.     server_addr.sin_addr.s_addr = inet_addr(argv[1]);//填充的IP地址必须转化为网络字节序
  44.     server_addr.sin_port = htons(atoi(argv[2]));
  45.     
  46.     //完成从标准输入读取字符，然后发送给服务器。
  47.     while(1)
  48.     {
  49.         printf("input >");
  50.         fgets(buf,sizeof(buf),stdin); //按行读取，包括'\n'
  51.         buf[strlen(buf) - 1] = '\0'; //把读入的'\n'用'\0'替换，保证buf中的字符串是以'\0'结尾

  53.         //客户端给服务器发送数据，第三个参数表示服务器的地址
  54.         n = sendto(sockfd,buf,strlen(buf),0,(struct sockaddr *)&server_addr,addrlen);
  55.         if(n < 0){
  56.             perror("Fail to sendto");
  57.             exit(EXIT_FAILURE);
  58.         }
  59.     }

  61.     return 0;
  62. }
测试结果如下：

点击(此处)折叠或打开

  1. ubuntu@ubuntu:~/network/udp/udp/server$ ./server 192.168.127.131 8888
  2. -----------------------------
  3. Port : 59438
  4. Ip : 192.168.127.131
  5. Buf : hi
  6. -----------------------------
  7. -----------------------------
  8. Port : 59438
  9. Ip : 192.168.127.131
  10. Buf : i am client
  11. -----------------------------

点击(此处)折叠或打开

  1. ubuntu@ubuntu:~/network/udp/udp/client$ vi client.c
  2. ubuntu@ubuntu:~/network/udp/udp/client$ ./client 192.168.127.131 8888
  3. input >hi
  4. input >i am client
  5. input >

上一篇：ntohs, ntohl, htons,htonl的英文记忆方法总结
下一篇：基于TCP的客户端--服务器