異常
   Internal error: unable to determine timeout reason

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

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

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

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

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

網(wǎng)站欄目：RabbitMQ第四課多線程收發(fā)異常-創(chuàng)新互聯(lián)
URL鏈接：http://weahome.cn/article/cojdso.html