随笔 - 96  文章 - 255  trackbacks - 0
<2008年1月>
303112345
6789101112
13141516171819
20212223242526
272829303112
3456789

E-mail:zbln426@163.com QQ:85132383 长期寻找对战略游戏感兴趣的合作伙伴。

常用链接

留言簿(21)

随笔分类

随笔档案

SDL相关网站

我的个人网页

我的小游戏

资源下载

搜索

  •  

积分与排名

  • 积分 - 488878
  • 排名 - 37

最新评论

阅读排行榜

评论排行榜

从TCP三次握手的原理我们可以看到,TCP有“保障”的连接实际上可以看做是两个单向的连接:一个通道只负责发送,另外一个只负责接收。并且,传送的信息是以字节为单位保证顺序的。
在socket机制中,应用层的程序以send()函数将数据首先发送到本机系统的发送缓存中,我们称之为SendQ,意指这是一个FIFO(先进先出)的队列。这个缓存是系统决定的,并不是在我们的程序中指定的。然后socket机制负责将SendQ中的数据以字节为单位,按照顺序发送给对方的接收缓存RecvQ中。RecvQ也是一个属于系统的FIFO缓存队列。从程序员的角度看,send()函数只负责把数据送入SendQ,而SendQ何时将数据发送则是不可控的。所以,send()通常不会阻塞,只有在不能立即将数据发送给SendQ的时候才会阻塞,这往往是因为SendQ缓存已满。另外,SendQ并不负责统计每次send()所发送来的字节流的长度,事实上这个长度在TCP中没有意义,因为所有数据都以字节为单位按照FIFO的形式排列在队列中,而并不在乎来自于哪一次的send()。这也就是所谓的TCP无边缘保证,TCP的send()并不在乎每次传送的数据有多少,而只是致力于将数据以字节为单位按照FIFO的形式排列在SendQ队列中。我们看一下TCPServerSock和TCPClientSock的TCPSend()方法:
int TCPServerSock::TCPSend(const char* send_data,
                           
const int& data_length) const
{
    
if (data_length > preBufferSize) {
        sockClass::error_info(
"Data is too large, resize preBufferSize.");
    }

    
int sent_length = send(    sockFD,
                            send_data,
                            data_length,
                            
0);
    
if (sent_length < 0) {
        sockClass::error_info(
"send() failed.");
    } 
else if (sent_length != data_length) {
        sockClass::error_info(
"sent unexpected number of bytes.");
    }

    
return sent_length;
}
int TCPClientSock::TCPSend(const char* send_data,
                           
const int& data_length) const
{
    
if (data_length > preBufferSize) {
        sockClass::error_info(
"Data is too large, resize preBufferSize.");
    }

    
int sent_length = send(    sockFD,
                            send_data,
                            data_length,
                            
0);
    
if (sent_length < 0) {
        sockClass::error_info(
"send() failed.");
    } 
else if (sent_length != data_length) {
        sockClass::error_info(
"sent unexpected number of bytes.");
    }

    
return sent_length;
}
可以看到,这两个方法除了分属于不同的类名字不一样,其他都是一样的。send()的返回值是实际发送的字节长度。
在收信息的另外一边,当RecvQ没有数据时,recv()就会阻塞(默认情况下),每当有数据可接收,recv()就会返回实际接收到的数据长度。recv()同样不在乎每次接收的数据有多少,其参数只有一个最大长度限制,这个限制是应用程序分配给每次recv()储存数据的缓存大小。所以TCP的send()和recv()不是一一对应的:send()只负责将数据写入本机的SendQ,而recv()只负责把本机RecvQ中的数据读出来。假设send()传送了m+n字节,但是第一次到达远程目的地的RecvQ中只有m字节,于是这里的recv()就会马上返回m字节;剩下的n字节第二次才姗姗来迟,那么就需要第二次调用recv()来接收。
int TCPServerSock::TCPReceive() const
{
    preReceivedLength 
= recv(    sockFD,
                                preBuffer,
                                preBufferSize,
                                
0);
    
if (preReceivedLength < 0) {
        sockClass::error_info(
"recv() failed.");
    } 
else if (preReceivedLength == 0) {
        std::cout 
<< "Client has been disconnected.\n";
        
return 0;
    }
    
return preReceivedLength;
}
int TCPClientSock::TCPReceive() const
{
    preReceivedLength 
= recv(    sockFD,
                                preBuffer,
                                preBufferSize,
                                
0);
    
if (preReceivedLength < 0) {
        sockClass::error_info(
"recv() failed.");
    } 
else if (preReceivedLength == 0) {
        std::cout 
<< "Disconnected from server.\n";
        
return 0;
    }
    
return preReceivedLength;
}
可以看到这2个方法也几乎是一模一样——除了名字和对异常信息的描述。因为我们这里并不知道需要recv()的确切长度,所以这里的TCPReceive()也跟recv()一样,有数据就返回。需要验证数据长度的,比如echo服务,我们另外写验证长度的代码。
最后需要说明的是,虽然SYN和FIN都会占用一个字节的数据,但是对于应用层的send()和recv()来说是不可见的。FIN会让recv()返回0,表示连接正常断开。
posted on 2010-06-07 20:09 lf426 阅读(4004) 评论(1)  编辑 收藏 引用 所属分类: SDL入门教程socket 编程入门教程

FeedBack:
# re: socket 编程入门教程(三)TCP原理:6、字节流的发送与接收 2010-12-09 10:18 new
"我们称之为SendQ,意指这是一个FIFO(先进先出)的队列。这个缓存是系统决定的,并不是在我们的程序中指定的"

在 winsocket 中 这个缓存是不是可以设置的在程序里?
例如:SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReceiveBuffer, value);
  回复  更多评论
  

只有注册用户登录后才能发表评论。
网站导航: 博客园   IT新闻   BlogJava   知识库   博问   管理