//服务器段
int mian(int argc,char *argv[]){
ACE_SOCK_Acceptor acceptor_;
ACE_INET_Addr server_addr;
server_addr.set(9999,"");
acceptor_.open(server_addr,1);for(;;)
{
ACE_INET_Addr logging_peer_addr;
if(acceptor().accept(logging_handler_.peer(),&logging_peer_addr) == -1)
{
ACE_ERROR_RETURN((LM_ERROR,"%p\n","accept()"),1);
}
ACE_SOCK_Acceptor 进行压力测试,看能顶住多少连接,我开一个客户端, 跑了 3 分钟都没有ACE_SOCK_Acceptor 就拒绝接受外面的连接了,把所有客户端停下,等 几分钟后,又可以提供服务了,也就是 accept 能成功了,很是郁闷,难道 ace 这么脆弱吗????
ACE_DEBUG((LM_DEBUG,"Accepted connection from %s\n",logging_peer_addr.get_host_name()));logging_handler_.peer().close();
}
}//客户端
int main(int argc,char * argv[])
{
ACE_INET_Addr server_addr;
server_addr.set(9999,"");
for(;;)
{
ACE_SOCK_Connector connector;
ACE_SOCK_Stream logging_peer_;
if(connector.connect(logging_peer_,server_addr) < 0 )
{
//ACE_ERROR_RETURN((LM_ERROR,"%p\n","connect()"),1);
ACE_DEBUG((LM_ERROR,"connect %s fail\n",logger_host),1);
ACE_OS::sleep(ACE_Time_Value(30,0));
continue;
}
}
}
int mian(int argc,char *argv[]){
ACE_SOCK_Acceptor acceptor_;
ACE_INET_Addr server_addr;
server_addr.set(9999,"");
acceptor_.open(server_addr,1);for(;;)
{
ACE_INET_Addr logging_peer_addr;
if(acceptor().accept(logging_handler_.peer(),&logging_peer_addr) == -1)
{
ACE_ERROR_RETURN((LM_ERROR,"%p\n","accept()"),1);
}
ACE_SOCK_Acceptor 进行压力测试,看能顶住多少连接,我开一个客户端, 跑了 3 分钟都没有ACE_SOCK_Acceptor 就拒绝接受外面的连接了,把所有客户端停下,等 几分钟后,又可以提供服务了,也就是 accept 能成功了,很是郁闷,难道 ace 这么脆弱吗????
ACE_DEBUG((LM_DEBUG,"Accepted connection from %s\n",logging_peer_addr.get_host_name()));logging_handler_.peer().close();
}
}//客户端
int main(int argc,char * argv[])
{
ACE_INET_Addr server_addr;
server_addr.set(9999,"");
for(;;)
{
ACE_SOCK_Connector connector;
ACE_SOCK_Stream logging_peer_;
if(connector.connect(logging_peer_,server_addr) < 0 )
{
//ACE_ERROR_RETURN((LM_ERROR,"%p\n","connect()"),1);
ACE_DEBUG((LM_ERROR,"connect %s fail\n",logger_host),1);
ACE_OS::sleep(ACE_Time_Value(30,0));
continue;
}
}
}
SeekTruth(鹤舞白沙) ( ) 信誉:101我心飞翔
这个是程序的一部分功能,我简化出来了,现在修改后能彻底编译通过
//服务器段
#include "ace/sock_acceptor.h"
int main(int argc,char *argv[])
{
ACE_SOCK_Acceptor acceptor_;
ACE_INET_Addr server_addr;
server_addr.set(9999,"");
acceptor_.open(server_addr,1); for(;;)
{
ACE_INET_Addr logging_peer_addr;
ACE_SOCK_Stream logging_handler_;
if(acceptor_.accept(logging_handler_,&logging_peer_addr) == -1)
{
ACE_ERROR_RETURN((LM_ERROR,"%p\n","accept()"),1);
} //ACE_SOCK_Acceptor 进行压力测试,看能顶住多少连接,我开一个客户端, 跑了 3 分钟都没有ACE_SOCK_Acceptor 就拒绝接受外面的连接了,把所有客户端停下,等 几分钟后,又可以提供服务了,也就是 accept 能成功了,很是郁闷,难道 ace 这么脆弱吗???? ACE_DEBUG((LM_DEBUG,"Accepted connection from %s\n",logging_peer_addr.get_host_name())); logging_handler_.close();
}
}
//客户端
#include "ace/os.h"
#include "ace/sock_connector.h"
int main(int argc,char * argv[])
{
ACE_INET_Addr server_addr;
server_addr.set(9999,"localhost");
for(;;)
{
ACE_SOCK_Connector connector;
ACE_SOCK_Stream logging_peer_;
if(connector.connect(logging_peer_,server_addr) < 0 )
{
ACE_DEBUG((LM_ERROR,"connect %s fail\n",server_addr.get_host_name()),1);
ACE_OS::sleep(ACE_Time_Value(30,0));
continue;
}
logging_peer_.close();
}
}使用 netstat -a 查看,9999 端口上由很多 time_OUT 的连接,不知道是不是 close 失败了..
int iret = 1;
//bool bDontLinger = true;
if(logging_handler_.peer ().set_option (SOL_SOCKET, SO_DONTLINGER, &iret,sizeof(int)) == -1)
ACE_ERROR_RETURN ((LM_ERROR,
ACE_TEXT ("(%t) %p\n"),
ACE_TEXT ("Synch_Receiver::open ")
ACE_TEXT ("set_option SO_LINGER")),
-1);设置了 SOL_SOCKET ,准备粗暴关闭 socket ,还是没有成功,一样进入了 time_out 状态
这不是ACE的问题,是你使用上欠考虑。
第一,你的ACE_SOCK_Acceptor 打开的时候,默认的后备队列只有5,
int open (const ACE_Addr &local_sap, int reuse_addr=0, int protocol_family=PF_UNSPEC, int backlog=ACE_DEFAULT_BACKLOG, int protocol=0)
ACE_DEFAULT_BACKLOG 默认是5,在Unix网络编程里面,关于这个值的含义,有详细的阐述。最主要的就是,这个值依赖于系统的实现,其实有所差别,但是它含义是已经连接的socket + 等待队列中的socket,而不仅仅是后者的数量。所以,我建议你加大这个数值,比如200,试试看。
第二,ACE用面向对象的方法封装了OS的各种API,后面其实还是这些,你必须懂这些API,才能更好的利用ACE发挥能力。比如,如果你要求大量的网络连接,可以使用异步的acceptor,在windows下面是AcceptEx,效能很高!
第三,ACE绝不脆弱,相信2000多高手的的智慧吧。──────────────────────
国内专业的ACE论坛开通:
www.acejoy.com
www.acedevelop.com
涉及ACE使用和开发,服务器端软件的设计,P2P技术,
网络编程等内容。
欢迎加入,大家一起交流、学习成长!