ACE_Svc_Handler的类中向已连接的客户端发送消息的问题

peakzhang

研究ACE时间不长,正在刚开始体验就卡壳了,恳请各位有经验的前辈给予指点,多谢~!
在这里我没有完全的贴出代码,主要是怕多了反而说不到点子上,所以只贴出关键代码.
我的问题是继承了ACE_Svc_Handler的类中SVC()函数中我希望向已经连接了(我知道已经连接成功的原因是这个类的hanle_input函数可能确实收到客户端的消息)的用户发送消息,却不成功,不知道为什么,我在ACE程序员教程中也见过完全类似的应用.
最主要的就是这个继承了ACE_Svc_Handler的类,这个类管理着用户的连接,我可以正确的接受用户发送来的消息,但是却不能给用户发数据,下面我用&&&&&&&&&&&&指出问题的地方

2. class Jabber_Session
3.   : public ACE_Svc_Handler<ACE_SOCK_STREAM, ACE_NULL_SYNCH> {
4. protected:
5. //  ACE_FILE_IO log_file_; // File of log records.
6.   // Connection to peer service handler.
7.   //Jabber_Session logging_handler_;
8. public:
9.   int recv_msg (ACE_Message_Block *&mblk);
10.   virtual int open (void *);
11.   virtual int svc (void);
12.   virtual int handle_input (ACE_HANDLE handle);
13.   virtual int handle_close
14.     (ACE_HANDLE = ACE_INVALID_HANDLE,
15.      ACE_Reactor_Mask = ACE_Event_Handler::ALL_EVENTS_MASK);
16.   //接收发送的消息
17.   virtual int put (ACE_Message_Block *mblk,
18.                    ACE_Time_Value *timeout = 0)
19.   { return putq (mblk, timeout); }
20. };
22. ////////////////////////////////////////////////////////////////////////////////////
23. ////////////////////////////////////////////////////////////////////////////////////
24. int Jabber_Session::svc (void) {
25.   ACE_DEBUG((LM_DEBUG, "into Jabber_Session->svc\n"));
26.   while(1)
27.   for (ACE_Message_Block *log_blk; getq (log_blk) != -1; ) {
28. ACE_DEBUG((LM_DEBUG, "Jabber_Session send  a msg!\n"));
29. //循环,不停从队列中获取消息块,并且发用户
30. //ACE_DEBUG((LM_DEBUG, "peer state is ::%s\n", peer()->));
31. int result = 9;
32. // char * msg = log_blk->rd_ptr();
33. // if(result=peer().send_n(log_blk) == -1)
34. char * msg = "server msg to client\n";
35.     ACE_DEBUG((LM_DEBUG, "msg::%s",msg));
36. if(result=peer().send_n(msg,ACE_OS::strlen(msg)) == -1)
37.     ACE_DEBUG((LM_DEBUG, "Jabber_Session send error!"));
38. &&&&&&&&&&&&&&&&&&&&&&&不论我是想把log_blk作为参数send_n给对端,还是用一个常量字符串,发送的&&&&&&&&&&&&&&&&&&&&&&&result都是0,这是不是说没有成功?为什么呢?
39. ACE_DEBUG((LM_DEBUG, "Jabber_Session send result = %d\n",result));
40. log_blk->release ();
41.    }
42. //ACE_DEBUG((LM_DEBUG, "got msg over\n"));
43. return 0;
44. }
45. 下面是这个类的全部定义代码,供参考:
46. int Jabber_Session::open (void *) {
47. ACE_DEBUG((LM_DEBUG, "one user has connected\n"));
48. reactor()->register_handler(this, ACE_Event_Handler::READ_MASK);
49. return activate (THR_NEW_LWP | THR_DAEMON);
50. }
51. int Jabber_Session::svc (void) {
52.   ACE_DEBUG((LM_DEBUG, "into Jabber_Session->svc\n"));
53.   while(1)
54.   for (ACE_Message_Block *log_blk; getq (log_blk) != -1; ) {
55. ACE_DEBUG((LM_DEBUG, "Jabber_Session send  a msg!\n"));
56. //循环,不停从队列中获取消息块,并且发给每个用户
57. //ACE_DEBUG((LM_DEBUG, "peer state is ::%s\n", peer()->));
58. int result = 9;
59. // char * msg = log_blk->rd_ptr();
60. // if(result=peer().send_n(log_blk) == -1)
61. char * msg = "server msg to client\n";
62.     ACE_DEBUG((LM_DEBUG, "msg::%s",msg));
63. if(result=peer().send_n(msg,ACE_OS::strlen(msg)) == -1)
64.     ACE_DEBUG((LM_DEBUG, "Jabber_Session send error!"));
65. ACE_DEBUG((LM_DEBUG, "Jabber_Session send result = %d\n",result));
66. log_blk->release ();
67.    }
68. //ACE_DEBUG((LM_DEBUG, "got msg over\n"));
69. return 0;
70. }
72. int Jabber_Session::handle_input (ACE_HANDLE h) {
73.   //接收消息,然后放进一个mblk中,然后把mblk放到Msg_Switcher的队列中
74.   ACE_DEBUG((LM_DEBUG, "%Igot one user's massage\n"));
75.   ACE_Message_Block *mblk = 0;
76.   if (recv_msg (mblk) == -1)
77.   {
78. ACE_DEBUG((LM_INFO,"recv_msg error or client disconnect!\n"));
79.     return -1;
80.   }
81.   else
82.   {
83.    ACE_DEBUG((LM_INFO,"put msg into switcher\n"));
84.    if(MSG_SWITCHER_HANDLER::instance()->put(mblk)==-1){
85.   mblk->release();
86.   return -1;
87.    }
88.   return 0;
89.   }
90. }
91. int Jabber_Session::handle_close (ACE_HANDLE h,
92.                                         ACE_Reactor_Mask mask) {
93.   ACE_DEBUG((LM_DEBUG,"%IJabberSession handle_close!\n"));
94.   MSG_SWITCHER_HANDLER::instance()->remove_jabber_session(this);
95.   delete this;
96.   return 0;
97. }
99.   int Jabber_Session::recv_msg (ACE_Message_Block *&mblk)
100. {
101.   // Align the Message Block for a CDR stream
102. size_t result = -1;
103. char buff[1024];
104. result = peer().recv(buff,1024);
105. if(result == -1)return -1;
106. // cout<<"客户端: ";
107. ACE_DEBUG((LM_DEBUG,"%I客户端::"));
108. for(int i=0;i<result;i++)
109.   ACE_DEBUG((LM_DEBUG,"%c",buff[i]));
110. ACE_DEBUG((LM_DEBUG,"%I\n"));
111. // cout<<buff[i];
112. // cout<<endl;
114. //ACE_DEBUG((LM_DEBUG,"recv_msg buff = %s\n",iov[0].iov_base));
115. ACE_NEW_RETURN(mblk,
116.       ACE_Message_Block(i),
117.       -1);
118. mblk->copy(buff,i);
119.     return result;
120. }

复制代码

peakzhang

是我犯了低级错误,这儿发送数据其实是成功了,错误出在我的客户端.

可以使用send_n()的第三个参数,这个参数才是说明成功的发送了多少个字节,而函数的返回值只是说明发送成功与否?-1表示失败,而0应该是成功.

多谢flowstar.

结帖.