关于ACE_Event_Handler

chennut0802

大家好，有关ACE_Event_Handler的问题，需要请教大家。源代码和问题如下：
服务端代码：

1. #include "stdafx.h"
2. #include <ace/OS.h>
3. #include <ace/Reactor.h>
4. #include <ace/SOCK_Connector.h>
5. #include <ace/SOCK_Acceptor.h>
6. #include <ace/Auto_Ptr.h>
7. #include <iostream>
9. #pragma comment(lib, "ace.lib")
10. #pragma comment(lib, "aced.lib")
12. class ClientService : public ACE_Event_Handler
13. {
14. public:
15.     ACE_SOCK_Stream &peer (void) { return this->sock_; }
17.     int open (void)
18.     {
19.         //注册读就绪回调函数
20.         return this->reactor ()->register_handler(this, ACE_Event_Handler::READ_MASK);
21.     }
23.     virtual ACE_HANDLE get_handle (void) const { return this->sock_.get_handle (); }
25.     virtual int handle_input (ACE_HANDLE fd )
26.     {
27.         //一个简单的EchoServer，将客户端的信息返回
28.         int rev = peer().recv(buf,100);
29.         if(rev<=0)
30.             return -1;
31.         buf[rev]='\0';
32.         std::cout<<"Receive from client:"<<buf<<std::endl;
35.         peer().send(buf,rev);
36.         std::cout<<"Send to client:"<<buf<<std::endl;
37.         return 0;
38.     }
40.     // 释放相应资源
41.     virtual int handle_close (ACE_HANDLE, ACE_Reactor_Mask mask)
42.     {
43.         if (mask == ACE_Event_Handler::WRITE_MASK)
44.             return 0;
45.         mask = ACE_Event_Handler::ALL_EVENTS_MASK |
46.             ACE_Event_Handler::DONT_CALL;
47.         this->reactor ()->remove_handler (this, mask);
48.         this->sock_.close ();
49.         delete this;    //socket出错时，将自动删除该客户端，释放相应资源
50.         return 0;
51.     }
53. protected:
54.     char buf[100];
55.     ACE_SOCK_Stream sock_;
56. };
58. class ClientAcceptor : public ACE_Event_Handler
59. {
60. public:
61.     virtual ~ClientAcceptor (){this->handle_close (ACE_INVALID_HANDLE, 0);}
63.     int open (const ACE_INET_Addr &listen_addr)
64.     {
65.         if (this->acceptor_.open (listen_addr, 1) == -1)
66.         {
67.             ACE_OS::printf("open port fail");
68.             return -1;
69.         }
70.         //注册接受连接回调事件
71.         return this->reactor ()->register_handler(this, ACE_Event_Handler::ACCEPT_MASK);
72.     }
74.     virtual ACE_HANDLE get_handle (void) const
75.     { return this->acceptor_.get_handle (); }
77.     virtual int handle_input (ACE_HANDLE fd )
78.     {
79.         ClientService *client = new ClientService();
80.         auto_ptr<ClientService> p (client);
82.         if (this->acceptor_.accept (client->peer ()) == -1)
83.         {
84.             ACE_OS::printf("accept client fail \n");
85.             return -1;
86.         }
87.         p.release ();
88.         client->reactor (this->reactor ());
89.         if (client->open () == -1)
90.             client->handle_close (ACE_INVALID_HANDLE, 0);
91.         return 0;
92.     }
94.     virtual int handle_close (ACE_HANDLE handle,
95.         ACE_Reactor_Mask close_mask)
96.     {
97.         if (this->acceptor_.get_handle () != ACE_INVALID_HANDLE)
98.         {
99.             ACE_Reactor_Mask m = ACE_Event_Handler::ACCEPT_MASK |
100.                 ACE_Event_Handler::DONT_CALL;
101.             this->reactor ()->remove_handler (this, m);
102.             this->acceptor_.close ();
103.         }
104.         return 0;
105.     }
107. protected:
108.     ACE_SOCK_Acceptor acceptor_;
109. };
111. int main(int argc, char *argv[])
112. {
113.     ACE_INET_Addr addr(3000,"127.0.0.1");
114.     ClientAcceptor server;
115.     server.reactor(ACE_Reactor::instance());
116.     server.open(addr);
118.     while(true)
119.     {
120.         ACE_Reactor::instance()->handle_events();
121.     }
123.     return 0;
124. }

复制代码

客户端代码：

1. #include "stdafx.h"
2. #include <iostream>
3. #include <string>
5. #include <ace/ACE.h>
6. #include <ace/INET_Addr.h>
7. #include <ace/SOCK_Connector.h>
8. #include <ace/SOCK_Stream.h>
10. #pragma comment(lib, "ace.lib")
11. #pragma comment(lib, "aced.lib")
13. int _tmain(int argc, _TCHAR* argv[])
14. {
15.     ACE::init();
16.     std::string str="Hello Server \n";
18.     ACE_INET_Addr svr_addr(3000, "127.0.0.1");
19.     ACE_SOCK_STREAM stream;
21.     ACE_SOCK_Connector connector;
22.     int ret=connector.connect(stream, svr_addr);
23.     if(0 != ret)
24.     {
25.         std::cout<<"Error in connect"<<std::endl;
26.         return -1;
27.     }
29.     std::cout<<"sending data:"<<std::endl<<str<<std::endl;
30.     ret=stream.send(str.c_str(), str.length());
31.     if(-1 == ret)
32.     {
33.         std::cout<<"Error in send"<<std::endl;
34.         return -1;
35.     }
37.     str.erase();
38.     str.resize(1024);
39.     ret=stream.recv((void *)str.c_str(), str.length());
40.     if(-1 == ret)
41.     {
42.         std::cout<<"Error in recv"<<std::endl;
43.         return -1;
44.     }
46.     std::cout<<"recived data::"<<std::endl<<str<<std::endl;
47.     ACE::fini();
48.     return 0;
49. }

复制代码

请问：
客户端socket只发送了一次数据给服务端，但是为什么ClientService的handle_input会执行两次呢？
谢谢大家！

wesom

估计你是在win下面跑，默认使用ACE_WFMO_Reacotr,该复用是边缘触发方式，
当你recv后，状态复位，由可读变为不可读，使得读事件再度被激发，其中未必真的有数据到达。

wesom

今天再次阅读发现自己的回答有误，更正下。
第二次触发应该是你socket关闭产生的事件，而且是非优雅的关闭，recv返回-1，楼主大意了
我说的那个lt/et的问题应该是output中有所区别，特此说明