异常
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的连接。
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
