溫馨提示×

您好，登錄后才能下訂單哦！

密碼登錄×
登錄注冊(cè)×
其他方式登錄
點(diǎn)擊 登錄注冊(cè) 即表示同意《億速云用戶服務(wù)條款》

RabbitMQ第四課 多線程收發(fā)異常

發(fā)布時(shí)間：2020-07-18 20:11:22 來(lái)源：網(wǎng)絡(luò) 閱讀：3540 作者：fengyuzaitu 欄目：編程語(yǔ)言

異常
    Internal error: unable to determine timeout reason

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

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

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


向AI問(wèn)一下細(xì)節(jié)

免責(zé)聲明：本站發(fā)布的內(nèi)容（圖片、視頻和文字）以原創(chuàng)、轉(zhuǎn)載和分享為主，文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱：is@yisu.com進(jìn)行舉報(bào)，并提供相關(guān)證據(jù)，一經(jīng)查實(shí)，將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI
助
手