首先建立 工作exchange和工作queue，指定工作隊列的x-dead-letter-exchange到重試exchenge
var
workQueueArgs =
new
Dictionary
<
string
,
object
> {
{
"x-dead-letter-exchange"
, RETRY_EXCHANGE },
};
channel.ExchangeDeclare(WORK_EXCHANGE,
"direct"
);
channel.QueueDeclare(WORK_QUEUE,
true
,
false
,
false
, workQueueArgs);
channel.QueueBind(WORK_QUEUE, WORK_EXCHANGE,
""
,
null
);
之后建立重試exchange和重試queue
var
queueArgs =
new
Dictionary
<
string
,
object
> {
{
"x-dead-letter-exchange"
, WORK_EXCHANGE },
{
"x-message-ttl"
, RETRY_DELAY }
};
channel.ExchangeDeclare(RETRY_EXCHANGE,
"direct"
);
channel.QueueDeclare(RETRY_QUEUE,
true
,
false
,
false
, queueArgs);
channel.QueueBind(RETRY_QUEUE, RETRY_EXCHANGE,
""
,
null
);
重試隊列需要2個屬性，一個是 x-dead-letter-exchange，指向到工作exchange
一個是過期時間（這里等于是多少秒后重試）
?
監聽工作隊列，處理消息
QueueingBasicConsumer
consumer =
new
QueueingBasicConsumer
(channel);
channel.BasicConsume(WORK_QUEUE,
false
, consumer);
while
(
true
)
{
BasicDeliverEventArgs
e = (
BasicDeliverEventArgs
)consumer.Queue.Dequeue();
var
message =
Encoding
.UTF8.GetString(e.Body);
try
{
//throw new Exception("");
channel.BasicAck(e.DeliveryTag,
false
);
}
catch
{
channel.BasicNack(e.DeliveryTag,
false
,
false
);
}
}
處理成功調用ack，處理不成功調用nack，
調用nack后，會根據工作隊列的x-dead-letter-exchange自動把消息發到重試隊列
重試隊列等幾秒（x-message-ttl）后，就認為是自動失敗了，又會根據重試隊列的x-dead-letter-exchange發送回工作隊列
更多文章、技術交流、商務合作、聯系博主
微信掃碼或搜索：z360901061
微信掃一掃加我為好友
QQ號聯系： 360901061
您的支持是博主寫作最大的動力，如果您喜歡我的文章，感覺我的文章對您有幫助，請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧，狠狠點擊下面給點支持吧，站長非常感激您！手機微信長按不能支付解決辦法：請將微信支付二維碼保存到相冊，切換到微信，然后點擊微信右上角掃一掃功能，選擇支付二維碼完成支付。
【本文對您有幫助就好】元
