RabbitMQ第四课多线程收发异常-创新互联

异常
   Internal error: unable to determine timeout reason

为濉溪等地区用户提供了全套网页设计制作服务,及濉溪网站建设行业解决方案。主营业务为成都网站设计、网站建设、濉溪网站设计,以传统方式定制建设网站,并提供域名空间备案等一条龙服务,秉承以专业、用心的态度为用户提供真诚的服务。我们深信只要达到每一位用户的要求,就会得到认可,从而选择与我们长期合作。这样,我们也可以走得更远!

场景
   在调用rabbitMQ接收数据的时候,出现如上的错误。代码断点在amqp_consume_message函数,发现如果consume阻塞时,其他线程用该socket去发送数据,会导RabbitMQ里面amqp_tcp_socket.c里面amqp_tcp_socket_recv会退出,导致调用amqp_tcp_socket_recv的wait_frame_inner里面报异常

原因
   刚开始还以为多线程情况下,同时收发,没有设置接收超时,就会出现上述问题,提出如下的解决方案:
 timeval valTimeOut;
 valTimeOut.tv_sec = 1;
 valTimeOut.tv_usec = 0;
 ret = amqp_consume_message(m_connState, &envelope, &valTimeOut, 0);
实际上并不是如此

解决
   C语言版本打开一个连接后是用一个结构体amqp_connection_state_t_作为句柄标示一个连接;该句柄不是线程安全的,库是基于单线程,事件响应来设计的,多个线程同时使用,肯定会冲突的。因此收发都需要实例化不同的amqp_connection_state_t_连接,进行RabbitMQ的连接。

另外有需要云服务器可以了解下创新互联scvps.cn,海内外云服务器15元起步,三天无理由+7*72小时售后在线,公司持有idc许可证,提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案,具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势,专为企业上云打造定制,能够满足用户丰富、多元化的应用场景需求。


网站名称:RabbitMQ第四课多线程收发异常-创新互联
文章URL:http://azwzsj.com/article/cojdso.html