RabbitMQ第四课 多线程收发异常

发布时间:2020-07-18 20:11:22 作者:fengyuzaitu
来源:网络 阅读:3539

异常
    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的连接。


推荐阅读:
  1. RabbitMQ中如何使用rabbitmq-c
  2. C#多线程技术提高RabbitMQ消费吞吐率(二)

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

rabbitmq 多线程 收发异常

上一篇:MongoDB mapReduce案例分析一

下一篇:oracle安装及简介

相关阅读

您好,登录后才能下订单哦!

密码登录
登录注册
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》