springboot + rabbitmq 用了訊息確認機制，感覺掉坑裡了
阿新 • • 發佈：2020-07-01
>本文收錄在個人部落格：[www.chengxy-nds.top](http://www.chengxy-nds.top)，技術資源共享，一起進步
最近部門號召大夥多組織一些技術分享會，說是要活躍公司的技術氛圍，但早就看穿一切的我知道，這 T M 就是為了刷`KPI`。不過，話說回來這的確是件好事，與其開那些沒味的扯皮會，多做技術交流還是很有助於個人成長的。
於是乎我主動報名參加了分享，咳咳咳~ ，真的不是為了那點`KPI`，就是想和大夥一起學習學習！
這次我分享的是 `springboot` + `rabbitmq` 如何實現訊息確認機制，以及在實際開發中的一點踩坑經驗，其實整體的內容比較簡單，有時候事情就是這麼神奇，越是簡單的東西就越容易出錯。
可以看到使用了 `RabbitMQ` 以後，我們的業務鏈路明顯變長了，雖然做到了系統間的解耦，但可能造成訊息丟失的場景也增加了。例如：
- 訊息生產者 - > rabbitmq伺服器（訊息傳送失敗）
- rabbitmq伺服器自身故障導致訊息丟失
- 訊息消費者 - > rabbitmq服務（消費訊息失敗）
所以說能不使用中介軟體就儘量不要用，如果為了用而用只會徒增煩惱。開啟訊息確認機制以後，儘管很大程度上保證了訊息的準確送達，但由於頻繁的確認互動，`rabbitmq` 整體效率變低，吞吐量下降嚴重，不是非常重要的訊息真心不建議你用訊息確認機制。
---
下邊我們先來實現`springboot` + `rabbitmq`訊息確認機制，再對遇到的問題做具體分析。
## 一、準備環境
#### 1、引入 rabbitmq 依賴包
```javascript
org.springframework.boot
```
#### 2、修改 application.properties 配置
配置中需要開啟 `傳送端`和 `消費端` 的訊息確認。
```javascript
spring.rabbitmq.host=127.0.0.1
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest
# 傳送者開啟 confirm 確認機制
spring.rabbitmq.publisher-confirms=true
# 傳送者開啟 return 確認機制
spring.rabbitmq.publisher-returns=true
####################################################
# 設定消費端手動 ack
spring.rabbitmq.listener.simple.acknowledge-mode=manual
# 是否支援重試
spring.rabbitmq.listener.simple.retry.enabled=true
```
#### 3、定義 Exchange 和 Queue
定義交換機 `confirmTestExchange` 和佇列 `confirm_test_queue` ，並將佇列繫結在交換機上。
```javascript
@Configuration
public class QueueConfig {
@Bean(name = "confirmTestQueue")
public Queue confirmTestQueue() {
return new Queue("confirm_test_queue", true, false, false);
}
@Bean(name = "confirmTestExchange")
public FanoutExchange confirmTestExchange() {
return new FanoutExchange("confirmTestExchange");
}
@Bean
public Binding confirmTestFanoutExchangeAndQueue(
@Qualifier("confirmTestExchange") FanoutExchange confirmTestExchange,
@Qualifier("confirmTestQueue") Queue confirmTestQueue) {
return BindingBuilder.bind(confirmTestQueue).to(confirmTestExchange);
}
}
```
>