RabbitMQ第四課多線程收發(fā)異常-創(chuàng)新互聯(lián)

異常
   Internal error: unable to determine timeout reason

為濉溪等地區(qū)用戶提供了全套網(wǎng)頁設計制作服務，及濉溪網(wǎng)站建設行業(yè)解決方案。主營業(yè)務為成都網(wǎng)站設計、網(wǎng)站建設、濉溪網(wǎng)站設計，以傳統(tǒng)方式定制建設網(wǎng)站，并提供域名空間備案等一條龍服務，秉承以專業(yè)、用心的態(tài)度為用戶提供真誠的服務。我們深信只要達到每一位用戶的要求，就會得到認可，從而選擇與我們長期合作。這樣，我們也可以走得更遠！

場景
   在調用rabbitMQ接收數(shù)據(jù)的時候，出現(xiàn)如上的錯誤。代碼斷點在amqp_consume_message函數(shù)，發(fā)現(xiàn)如果consume阻塞時，其他線程用該socket去發(fā)送數(shù)據(jù)，會導RabbitMQ里面amqp_tcp_socket.c里面amqp_tcp_socket_recv會退出，導致調用amqp_tcp_socket_recv的wait_frame_inner里面報異常

原因
   剛開始還以為多線程情況下，同時收發(fā)，沒有設置接收超時，就會出現(xiàn)上述問題，提出如下的解決方案：
 timeval valTimeOut;
 valTimeOut.tv_sec = 1;
 valTimeOut.tv_usec = 0;
 ret = amqp_consume_message(m_connState, &envelope, &valTimeOut, 0);
實際上并不是如此

解決
   C語言版本打開一個連接后是用一個結構體amqp_connection_state_t_作為句柄標示一個連接；該句柄不是線程安全的，庫是基于單線程，事件響應來設計的，多個線程同時使用，肯定會沖突的。因此收發(fā)都需要實例化不同的amqp_connection_state_t_連接，進行RabbitMQ的連接。

另外有需要云服務器可以了解下創(chuàng)新互聯(lián)scvps.cn，海內外云服務器15元起步，三天無理由+7*72小時售后在線，公司持有idc許可證，提供“云服務器、裸金屬服務器、高防服務器、香港服務器、美國服務器、虛擬主機、免備案服務器”等云主機租用服務以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡單易用、服務可用性高、性價比高”等特點與優(yōu)勢，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應用場景需求。

當前名稱：RabbitMQ第四課多線程收發(fā)異常-創(chuàng)新互聯(lián)
網(wǎng)頁URL：http://m.jiaotiyi.com/article/cojdso.html