RabbitMQ 訊息實現過程+事務+訊息確認
阿新 • • 發佈：2022-04-10
服務端（生產者）
1、引用 rabbitmq 包
2、建立連線工廠 connectionfactory
3、建立 頻道 createchannel
4、在頻道中 繫結訊息佇列
5、釋出basicpubilsh 訊息
服務端和rabbitmq 的事務（多條訊息傳送--必須保證全部成功）
txSelect() 開啟事務
txCommit 提交事務
txrollback 回滾
服務端和rabbitmq 進行訊息確認（防止rabbitmq 故障）
channel.confirmSelect() 開啟訊息確認
channel.WaitForConfirms() 接收rabbit 的反饋訊息 bool 是否成功
channel.WaitForConfirmOrDie() 無返回值，成功在此方法後繼續執行邏輯
客戶端（消費者）
1、引用 rabbitmq 包
2、建立連線工廠 connectionfactory
3、建立 頻道 createchannel
4、在頻道中 繫結訊息佇列
5、定義Consumer 繫結channel，consumer.Received+=(model,ea)=>{接受訊息（二進位制）}
6、消費basicConsume訊息
rabbitmq 和消費者的訊息確認