Basic(消息)的一些屬性及方法
阿新 • • 發佈:2019-02-17
utf encoding key var 交換 all fir conf com
AMQP協議:是一個金融級的消息隊列,確保消息萬無一失
1、消息發布端的確認
手動確認消息是否已經發送
場景:發布消息到RabbitMQ中,我們需要知道這個消息是否發布成功了。
*發布確認影響性能 confirm機制對性能的影響 《 tx機制對性能的影響
1)、confirm機制
1 channel.ConfirmSelect(); 2 channel.BasicPublish("headersExchange", string.Empty, properties, Encoding.UTF8.GetBytes("來自.net的問候")); 3 var isAllPublished = channel.WaitForConfirms();
2)、tx機制
1 try 2 { 3 //發布消息 4 //String exchange, 交換機名稱 5 //String routingKey, routingKey 6 //IBasicProperties basicProperties, 發布屬性 7//Byte[] body 消息內容 8 channel.TxSelect(); 9 channel.BasicPublish("headersExchange", string.Empty, properties, Encoding.UTF8.GetBytes("來自.net的問候")); 10 channel.TxCommit(); 11 } 12 catch (Exception) 13 {14 channel.TxRollback(); 15 }
2、消息消費端的確認
Basic(消息)的一些屬性及方法