ACE_SOCK_TCP.rar_ACE_ACE TCP C++_ACE tcp_ace-6

#include "ace/Log_Msg.h" //使用ACE输出包含的头 #include "ace/INET_Addr.h" //使用ACE_INET_Addr包含的头 #include "ace/SOCK_Stream.h" //使用ACE_SOCK_Stream包含的头 #include "ace/SOCK_Connector.h" //使用ACE_SOCK_Connector包含的头 #include "ace/SString.h" //使用ACE_SString包含的头 #include "ace/Thread.h" #include <iostream> using namespace std; void *woker(ACE_SOCK_Stream *peer) { ACE_TCHAR strBuffer[1024]; ssize_t bytes_received = 0; while (true) { //把strBuffer填充为空用以接收数据 ACE_OS::memset(strBuffer, 0, sizeof(strBuffer)); bytes_received = peer->recv(strBuffer, sizeof(strBuffer)); //显示接收到的数据 if (bytes_received > 0) { ACE_DEBUG( (LM_INFO, ACE_TEXT("receive from server: %s\n"), strBuffer) ); } peer->send("123456",7); //断开连接 } return NULL; } int ACE_TMAIN(int argc, ACE_TCHAR** argv) { //声明地址对象绑定本机5000端口 ACE_INET_Addr svr(8892, "113.18.10.66"); ACE_SOCK_Stream peer; ACE_SOCK_Connector connector; //ACE_TCHAR strBuffer[1024]; ACE_SString strSend; ssize_t bytes_received = 0; //与服务器建立连接 返回-1连接失败 if(connector.connect(peer, svr) == -1) { //输出调试时错误信息以及进程号 ACE_DEBUG( (LM_ERROR, ACE_TEXT("--> %p|%t onnectfailed\n"), ACE_TEXT("connect")) ); return -1; } //连接成功 ACE_DEBUG( (LM_INFO, ACE_TEXT("connect server ok\n") ) ); ACE_Thread::spawn(ACE_THR_FUNC(woker),&peer,THR_JOINABLE | THR_NEW_LWP,0); while (true) { char temp[50]; cin>>temp; strSend = temp; //发送数据 peer.send_n(strSend.c_str(), strSend.length()); // //把strBuffer填充为空用以接收数据 // ACE_OS::memset(strBuffer, 0, sizeof(strBuffer)); // bytes_received = peer.recv(strBuffer, sizeof(strBuffer)); // //显示接收到的数据 // if (bytes_received > 0) // { // ACE_DEBUG( (LM_INFO, ACE_TEXT("receive from server: %s\n"), strBuffer) ); // } //断开连接 } peer.close(); return 0; }