初学practor的问题，不能收数据

peakzhang

我写了一个简单的程序，就是accept一个连接，然后从这个连接收数据。程序如下所示。现在的问题是，当有新的连接连上时，accept是正确的，但是确不能收到数据，也就是handle_read_stream总是不能被回调。请行家帮我看看怎么回事，多谢多谢。

2. #include "ace/ACE.h"
3. #include "ace/SOCK_Stream.h"
4. #include "ace/SOCK_Acceptor.h"
5. #include "ace/Proactor.h"
6. #include "ace/Asynch_IO.h"
7. #include "ace/Message_Block.h"
8. #include <typeinfo.h>
9. u_short g_listen_port = 9990;
10. class TestHandler : public ACE_Handler
11. {
12. public:
13. void startup(ACE_Proactor *init_proactor)
14. {
15.   m_proactor = init_proactor;
16.   if (m_acceptor.open(ACE_INET_Addr(g_listen_port)) == -1)
17.   {
18.    printf("can not open acceptor\n");
19.   }
20.   if (m_asynch_accept.open(*this,
21.    m_acceptor.get_handle(), 0, m_proactor) == -1)
22.   {
23.    printf("can not open asynch acceptor\n");
24.   }
25.   m_rd_mb = new ACE_Message_Block(500);
26.   m_asynch_accept.accept(*m_rd_mb, 0);
27. }
28. protected:
29. virtual void handle_read_stream (const ACE_Asynch_Read_Stream::Result &result)
30. {
31.   printf("?\n");
32.   if (result.success () && result.bytes_transferred () != 0)
33.   {
34.    printf("recv bytes %u\n", result.bytes_transferred());
35.    m_asynch_rd_strm.read(*m_rd_mb, 6);
36.   }
37. }
38. virtual void handle_accept (const ACE_Asynch_Accept::Result &result)
39. {
40.   if (result.success())
41.   {
42.    printf("accept a connection\n");
43.    printf("\tbytes_to_read %u\n", result.bytes_to_read());
44.    if (m_asynch_rd_strm.open(*this, result.accept_handle()) == -1)
45.    {
46.     printf("can not open asynchronous stream\n");
47.    }
48.    printf("\taccept handle 0x%08x\n", (int)result.accept_handle());
49.    m_asynch_rd_strm.read(*m_rd_mb, 6);
50.   }
51. }
52. private:
53. ACE_Asynch_Accept m_asynch_accept;
54. ACE_Asynch_Read_Stream m_asynch_rd_strm;
55. ACE_SOCK_Acceptor m_acceptor;
56. ACE_Proactor *m_proactor;
57. ACE_Message_Block *m_rd_mb;
58. };
59. int ACE_TMAIN(int argc, ACE_TCHAR *argv[])
60. {
61. ACE::init();
62. ACE_Proactor my_proactor;
63. printf("%s\n", typeid(*my_proactor.implementation()).name());
64. TestHandler test_handler;
65. test_handler.startup(&my_proactor);
66. my_proactor.proactor_run_event_loop();
67. ACE::fini();
68. return 0;
69. }

复制代码

peakzhang

需要你自己主动的投递一次异步的读操作，光等是没用的。

peakzhang

推荐你看一下ACE的实例程序，里面有如何使用。