关于ACE Socket编程问题（附源码）

peakzhang

客户端代码：

2. #include "ace/INET_Addr.h"
3. #include "ace/SOCK_Stream.h"
4. #include "ace/Log_Msg.h"
5. #include "ace/SOCK_Connector.h"
6. #include "ace/OS.h"
7. int ACE_TMAIN(int, ACE_TCHAR* [])
8. {
9.    ACE_INET_Addr srvr(50000, ACE_LOCALHOST);
10.    ACE_SOCK_CONNECTOR connector;
11.    ACE_SOCK_Stream peer;
12.    if (connector.connect(peer, srvr) == -1)         // 发送数据前建立连接，发送成功后发送第二条数据失败!
13.       return -1;
14.    int bc = 0, i = 0;
15.    char buf[64] = {0};
16.    ssize_t bytes_sended = 0;
17.    while (1)
18.    {
19.        // if (connector.connect(peer, srvr) == -1)         // 每次发送数据前建立连接 OK
20.        //     return -1;
22.        char data[16] = {0};
23.        ACE_OS::sprintf(data, "uptime-%d", i);
24.        bytes_sended = peer.send_n(data, ACE_OS::strlen(data));
25.        if (bytes_sended < 0)
26.        {
27.            int error = ACE_OS::last_error();
28.            continue;
29.        }
30.        bc = peer.recv(buf, sizeof(buf));
31.        ACE_DEBUG((LM_INFO, "receive from server data is [%s]\n", buf));
32.        ACE_OS::sleep(10);
33.        i++;
34.        //peer.close();
35.        bytes_sended = 0;
36.        bc = 0;
37.    }
38.     peer.close();
39.    return 0;
40. }
41. 服务端代码：
42. #include "ace/INET_Addr.h"
43. #include "ace/SOCK_Stream.h"
44. #include "ace/SOCK_Acceptor.h"
45. #include "ace/Log_Msg.h"
46. #include "ace/Time_Value.h"
47. int ACE_TMAIN(int, ACE_TCHAR* [])
48. {
49.     ACE_INET_Addr port_to_listen(50000);
50.     ACE_SOCK_Acceptor acceptor;
51.     if (acceptor.open(port_to_listen, 1) == -1)
52.         return -1;
53.     while (1)
54.     {
55.         ACE_SOCK_Stream peer;
56.         ACE_INET_Addr peer_addr;
57.         ACE_Time_Value timeout(10, 0);
58.         if (acceptor.accept(peer, &peer_addr) == -1)
59.         {
60.             break;
61.         }
62.         else
63.         {
64.             ACE_TCHAR peer_name[256] = {0};
65.             peer_addr.addr_to_string(peer_name, 256);
66.             ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) Connection from %s\n"), peer_name));
67.             ssize_t bytes_received = 0;
68.             char buffer[4096] = {0};
69.             bytes_received = peer.recv(buffer, sizeof(buffer));
70.             if (bytes_received > 0)
71.             {
72.                 ACE_DEBUG((LM_INFO, "receive data is : [%s]\n", buffer));
73.                 peer.send_n(buffer, bytes_received);
74.             }  
75.             peer.close();
76.          }
77.      }
78.      return 0;
79. }

复制代码

我先问问大侠们，客户端对于ACE的 ACE_SOCK_CONNECTOR 每次在send_n时候都需要先建立连接后，才能往客户段发送数据，难道没有建立常连接后，发送数据，也就是说建立一次连接，然后不停发送数据？不知是不是我的使用方式有误，请坛友们指点！谢谢（注意红色部分，当每次发送数据都建立连接，则程序正常）

peakzhang

你写错了。peer.close();
tcp链接是你自己关闭的，ACE在忠实的执行你要求的操作。

peakzhang

好意思，那个写错了peer.close();应该在while循环外。

同样的存在问题，不知何故？哪位大侠能讲解下原理，谢谢了！

peakzhang

accept阻塞了，移到while循环外面就ok！