1. 程式人生 > >Basic(消息)的一些屬性及方法

Basic(消息)的一些屬性及方法

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(消息)的一些屬性及方法