现在,我们通过accept()创建了新的socket,也就是我们类中的数据成员communicationSock,现在,我们就可以通过这个socket进行通讯了。

       TCP通讯模型

       在介绍函数之前,我们应该了解一些事实。TCP的Server/Client模型类似这样:

       ServApp——ServSock——Internet——ClntSock——ClntApp

       当然,我们这里的socket指的就是用于“通讯”的socket。TCP的server端至少有两个socket,一个用于监听,一个用于通讯;TCP的server端可以只有一个socket,这个socket同时“插”在server的两个socket上。当然,插上listen socket的目的只是为了创建communication socket,创建完备后,listen是可以关闭的。但是,如果这样,其他的client就无法再连接上server了。

       我们这个模型,是client的socket插在server的communication socket上的示意。这两个socket,都拥有完整的本地地址信息以及远程计算机地址信息,所以,这两个socket以及之间的网络实际上形成了一条形式上“封闭”的管道。数据包只要从一端进来,就能知道出去的目的地,反之亦然。这正是TCP协议,数据流形式抽象化以及实现。因为不再需要指明“出处”和“去向”,对这样的socket(实际上是S/C上的socket对)的操作,就如同对本地文件描述符的操作一样。但是,尽管我们可以使用read()和write(),但是,为了完美的控制,我们最好使用recv()和send()。

       recv()和send()

C++代码
  1. int send(int socket, const void* msg, unsigned int msgLength, int flags);  
  2. int recv(int socket, void* rcvBuffer, unsigned int bufferLength, int flags);  

       在Linux中的实现为:

C++代码
  1. #include <sys/socket.h>  
  2.   
  3. /* Send N bytes of BUF to socket FD.  Returns the number sent or -1. 
  4.  
  5.    This function is a cancellation point and therefore not marked with 
  6.    __THROW.  */  
  7. extern ssize_t send (int __fd, __const void *__buf, size_t __n, int __flags);  
  8.   
  9. /* Read N bytes into BUF from socket FD. 
  10.    Returns the number read or -1 for errors. 
  11.  
  12.    This function is a cancellation point and therefore not marked with 
  13.    __THROW.  */  
  14. extern ssize_t recv (int __fd, void *__buf, size_t __n, int __flags);  

       这两个函数的第一个参数是用于“通讯”的socket,第二个参数是发送或者接收数据的起始点指针,第三个参数是数据长度,第四个参数是控制符号(默认属性设置为0就可以了)。失败时候传回-1,否则传回实际发送或者接收数据的大小,返回0往往意味着连接断开了。

       处理echo行为

C++代码
  1. void TcpServer::handleEcho()  
  2. {  
  3.     const int BUFFERSIZE = 32;  
  4.     char buffer[BUFFERSIZE];  
  5.     int recvMsgSize;  
  6.     bool goon = true;  
  7.   
  8.     while ( goon == true ) {  
  9.         if ( (recvMsgSize = recv(communicationSock, buffer, BUFFERSIZE, 0)) < 0 ) {  
  10.             throw "recv() failed";  
  11.         } else if ( recvMsgSize == 0 ) {  
  12.             goon = false;  
  13.         } else {  
  14.             if ( send(communicationSock, buffer, recvMsgSize, 0) != recvMsgSize ) {  
  15.                 throw "send() failed";  
  16.             }  
  17.         }  
  18.     }  
  19.   
  20.     close(communicationSock);  
  21. }  

       本小节最后要讲的函数是close(),它包含在<unistd.h>中

C++代码
  1. #include <unistd.h>  
  2.   
  3. /* Close the file descriptor FD. 
  4.  
  5.    This function is a cancellation point and therefore not marked with 
  6.    __THROW.  */  
  7. extern int close (int __fd);  

       这个函数用于关闭一个文件描述符,自然,也就可以用于关闭socket。

       下一小节是完整的源代码。默认的监听端口是5000。我们可以通过

       $telnet 127.0.0.1 5000

       验证在本机运行的echo server程序。

除非特别注明,鸡啄米文章均为原创
转载请标明本文地址:http://www.jizhuomi.com/software/412.html
2015年7月24日
作者:鸡啄米 分类:软件开发 浏览: 评论:0