服务端发往客户端的报文，客户端为何收不到？

peakzhang

1. 以下内容为程序代码:
4.   ACE_Message_Block *send_mb = 0;
5.   //处理数据,并回应数据
6.   if (ProcessPacket(&msg_blck, send_mb))
7.   {
8.   ws.write (*send_mb, send_mb->length());
9.   }
10. ////////////////
11. BOOL Asynch_Receiver::ProcessPacket(ACE_Message_Block *in_mb, ACE_Message_Block *&out_mb)
12. {
13. //假定包正确
14. MsgHead *hd = (MsgHead*)in_mb->rd_ptr();
16. if(hd->type == MSG_REQUEST)
17. {
18.   switch(hd->req_type)
19.   {
20.   case REQ_LOGIN:
21.    {
22.     ReqLogin *msg = (ReqLogin*)in_mb->rd_ptr();
23.     ACE_DEBUG ((LM_DEBUG, "user %s logined\n", msg->name));
24.     AfxMessageBox(msg->name);
25.     ReplyLogin repy;
26.     repy.hd.identifier = hd->identifier + 1;
27.     repy.hd.length = sizeof(ReplyLogin) - sizeof(MsgHead);
28.     repy.hd.req_type = REPLY_LOGIN;
29.     repy.hd.retry_times = 999;
30.     repy.hd.type = MSG_REPLY;
31.     repy.success = TRUE;
32.     out_mb = this->aio_->malloc(DEFAULT_MAX_BLOCK_SIZE);
33.     ACE_ASSERT(out_mb);
34.     out_mb->socket_handle(this->handle());
35.     out_mb->remote_ip(this->remote_addr_.get_ip_address());
36.     out_mb->wr_ptr((char*)&repy);
37.     out_mb->wr_ptr(sizeof(ReplyLogin));
38.     out_mb->length(sizeof(ReplyLogin));
39.     break;
40.    }
41.   }
42.   
43.   return TRUE;
44. }
46. return FALSE;
47. }

复制代码

peakzhang

出现这个错误的原因可能性有很多的。调试也比较容易。
1、确定是否客户端和服务器无法进行连接，是否有连接存在。
2、是任何数据都收不到，还是你自己定义的数据收不到。
3、使用ethereal进行追踪很方便。
4、MsgHead *hd = (MsgHead*)in_mb->rd_ptr();

if(hd->type == MSG_REQUEST) - 你能保证数据是正确的吗？

peakzhang

验证数据正确性，涉及安全和加密等问题。一般来说，只要符合我们自己设计的规则，就是正确的。
比如头部有标记什么的。
你得先检验是否可以正常连接，发送数据，然后才谈得上正确与否。