异常
Internal error: unable to determine timeout reason
创新互联公司致力于互联网网站建设与网站营销,提供网站建设、成都做网站、网站开发、seo优化、网站排名、互联网营销、重庆小程序开发、公众号商城、等建站开发,创新互联公司网站建设策划专家,为不同类型的客户提供良好的互联网应用定制解决方案,帮助客户在新的全球化互联网环境中保持优势。
场景
在调用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的连接。