面向连接的echo服务编程实例

以下是echo_serv.c的源码，提供创建服务端，绑定套接字到本机IP的8080端口，当收到客户端发送的字符串就在屏幕上打印出来，并且把字符串发送给客户端

 // echo_serv.c – gcc –o s echo_serv.c

 #include <sys/types.h>

 #include <sys/socket.h>

 #include <netinet/in.h>

 #include <arpa/inet.h>

 #include <unistd.h>

 #include <stdio.h>

 #include <errno.h>

 #define EHCO_PORT 8080

 #define MAX_CLIENT_NUM 10

 int main()

 {

   int sock_fd;

   struct sockaddr_in serv_addr;

   int clientfd;

   struct sockaddr_in clientAdd;

   char buff[];

   socklen_t len;

   int closing =;

   int n;

   /* 创建socket */

   sock_fd = socket(AF_INET, SOCK_STREAM, );

   if(sock_fd==-) {

     perror("create socket error!");

     return ;

   } else {

     printf("Success to create socket %d\n", sock_fd);

   }

   /* 设置server地址结构 */

   bzero(&serv_addr, sizeof(serv_addr));                // 初始化结构占用的内存

   serv_addr.sin_family = AF_INET;                    // 设置地址传输层类型

   serv_addr.sin_port = htons(EHCO_PORT);            // 设置监听端口

   //serv_addr.sin_addr.s_addr = htons(INADDR_ANY);    // 设置服务器地址  //用这个不能实现在不同主机上的通讯

   serv_addr.sin_addr.s_addr = inet_addr("192.168.13.145");    // 设置服务器地址

   bzero(&(serv_addr.sin_zero), );

   /* 把地址和套接字绑定 */

   if(bind(sock_fd, (struct sockaddr*)&serv_addr, sizeof(serv_addr))!= ) {

     printf("bind address fail! %d\n", errno);

     close(sock_fd);

     return ;

   } else {

     printf("Success to bind address!\n");

   }

   /* 设置套接字监听 */

   if(listen(sock_fd ,MAX_CLIENT_NUM) != ) {

     perror("listen socket error!\n");

     close(sock_fd);

     return ;

   } else {

     printf("Success to listen\n");

   }

   /* 创建新连接对应的套接字 */

   len = sizeof(clientAdd);

   clientfd = accept(sock_fd, (struct sockaddr*)&clientAdd, &len);

   if (clientfd<=) {

     perror("accept() error!\n");

     close(sock_fd);

     return ;

   }

   /* 接收用户发来的数据 */

   while((n = recv(clientfd,buff, , )) > ) {

     buff[n] = '\0'; // 给字符串加入结束符

     printf("number of receive bytes = %d data = %s\n", n, buff);        // 打印字符串长度和内容

     fflush(stdout);

     send(clientfd, buff, n, );            // 发送字符串内容给客户端

     if(strncmp(buff, "quit", ) == )        // 判断是否是退出命令

       break;

   }

   close(clientfd);                        // 关闭新建的连接

   close(sock_fd);                    // 关闭服务端监听的socket

   return ;

 }

然后是客户端程序，在和服务器建立连接后发送字符串到服务器端，并且接受服务器发送的字符串显示在屏幕上

 // echo_client – gcc –o c echo_client.c

 #include <sys/types.h>

 #include <sys/socket.h>

 #include <netinet/in.h>

 #include <arpa/inet.h>

 #include <unistd.h>

 #include <stdio.h>

 #include <errno.h>

 #define EHCO_PORT 8080

 #define MAX_COMMAND 5

 int main()

 {

   int sock_fd;

   struct sockaddr_in serv_addr;

   char *buff[MAX_COMMAND] = {"abc", "def", "test", "hello", "quit"};

   char tmp_buf[];

   socklen_t len;

   int n, i;

   /* 创建socket */

   sock_fd = socket(AF_INET, SOCK_STREAM, );

   if(sock_fd==-) {

     perror("create socket error!");

     return ;

   } else {

     printf("Success to create socket %d\n", sock_fd);

   }

   /* 设置server地址结构 */

   bzero(&serv_addr, sizeof(serv_addr));                // 初始化结构占用的内存

   serv_addr.sin_family = AF_INET;                    // 设置地址传输层类型

   serv_addr.sin_port = htons(EHCO_PORT);            // 设置监听端口

   //serv_addr.sin_addr.s_addr = htons(INADDR_ANY);        // 设置服务器地址  //用这个不能实现在不同主机上的通讯

   serv_addr.sin_addr.s_addr = inet_addr("192.168.13.145");    // 设置服务器地址

   bzero(&(serv_addr.sin_zero), );

   /* 连接到服务端 */

   if (-==connect(sock_fd, (struct sockaddr*)&serv_addr, sizeof(serv_addr))) {

     perror("connect() error!\n");

     close(sock_fd);

     return ;

   }

   printf("Success connect to server!\n");

   /* 发送并接收缓冲的数据 */

   for (i=;i<MAX_COMMAND;i++) {

     send(sock_fd, buff[i], , );                        // 发送数据给服务端

     n = recv(sock_fd, tmp_buf, , );                    // 从服务端接收数据

     tmp_buf[n] = '\0';  // 给字符串添加结束标志

     printf("data send: %s receive: %s\n", buff[i], tmp_buf);        // 打印字符串

     if (==strncmp(tmp_buf, "quit", ))                    // 判断是否是退出命令

       break;

   }

   close(sock_fd);                                    // 关闭套接字

   return ;

 }

关于htos补充一下，也是摘自其它博主的吧

在C/C++写网络程序的时候，往往会遇到字节的网络顺序和主机顺序的问题。这是就可能用到htons(), ntohl(), ntohs()，htons()这4个函数。
网络字节顺序与本地字节顺序之间的转换函数：

htonl()--"Host to Network Long"
ntohl()--"Network to Host Long"
htons()--"Host to Network Short"
ntohs()--"Network to Host Short"

之所以需要这些函数是因为计算机数据表示存在两种字节顺序：NBO与HBO

网络字节顺序NBO(Network Byte Order): 按从高到低的顺序存储，在网络上使用统一的网络字节顺序，可以避免兼容性问题。

主机字节顺序(HBO，Host Byte Order): 不同的机器HBO不相同，与CPU设计有关，数据的顺序是由cpu决定的,而与操作系统无关。
如 Intel x86结构下, short型数0x1234表示为34 12, int型数0x12345678表示为78 56 34 12
如 IBM power PC结构下, short型数0x1234表示为12 34, int型数0x12345678表示为12 34 56 78

由于这个原因不同体系结构的机器之间无法通信,所以要转换成一种约定的数序,也就是网络字节顺序,其实就是如同power pc那样的顺序. 在PC开发中有ntohl和htonl函数可以用来进行网络字节和主机字节的转换.

说白了其实不过只是大端方式小端方式的转换

巴特西

面向连接的echo服务编程实例

最新文章

热门文章