日韩成人免费在线_国产成人一二_精品国产免费人成电影在线观..._日本一区二区三区久久久久久久久不

當前位置:首頁 > 科技  > 軟件

Spring Boot項目集成RabbitMQ實戰以及坑點講解

來源: 責編: 時間:2024-02-01 12:51:51 238觀看
導讀本文給大家介紹一下在 Spring Boot 項目中如何集成消息隊列 RabbitMQ,包含對 RibbitMQ 的架構介紹、應用場景、坑點解析以及代碼實戰。最后文末有免費領取龍年紅包封面以及騰訊云社區答題領獎福利,歡迎大家領取。我將使

本文給大家介紹一下在 Spring Boot 項目中如何集成消息隊列 RabbitMQ,包含對 RibbitMQ 的架構介紹、應用場景、坑點解析以及代碼實戰。最后文末有免費領取龍年紅包封面以及騰訊云社區答題領獎福利,歡迎大家領取。UGT28資訊網——每日最新資訊28at.com

我將使用 waynboot-mall 項目作為代碼講解,項目地址:https://github.com/wayn111/waynboot-mall。本文大綱如下,UGT28資訊網——每日最新資訊28at.com

圖片圖片UGT28資訊網——每日最新資訊28at.com

RabbitMQ 架構介紹

圖片圖片UGT28資訊網——每日最新資訊28at.com

RibbitMQ 是一個基于 AMQP 協議的開源消息隊列系統,具有高性能、高可用、高擴展等特點。通常作為在系統間傳遞消息的中間件,它可以實現異步處理、應用解耦、流量削峰等功能。UGT28資訊網——每日最新資訊28at.com

圖片圖片UGT28資訊網——每日最新資訊28at.com

RibbitMQ 的主要組件介紹如下,UGT28資訊網——每日最新資訊28at.com

  • producter:生產者,創建消息,然后將消息發布(發送)到 RabbitMQ。
  • channel: 信道,多路復用連接中的一條獨立的雙向數據流通道。信道是建立在真實的 TCP 連接內地虛擬鏈接,AMQP 命令都是通過信道發出去的,不管是發布消息、訂閱隊列還是接收消息,這些動作都是通過信道完成。因為對于操作系統來說,建立和銷毀 TCP 都是非常昂貴的開銷,所以引入了信道的概念,以復用一條 TCP 連接。
  • broker: 標識消息隊列服務器實體 rabbitmq-server。
  • 連接器:這是負責接收客戶端連接請求和建立連接的組件。RabbitMQ 支持多種連接器,如 AMQP 0-9-1, AMQP 1.0, MQTT, STOMP 等。
  • v-host:虛擬主機,這是 RabbitMQ 的邏輯隔離單元,每個虛擬主機相當于一個獨立的代理,擁有自己的交換器、隊列、綁定、權限等。不同的虛擬主機之間是相互隔離的,不能共享資源。一個 RabbitMQ 實例可以創建多個虛擬主機,以滿足不同的業務需求。
  • exchange:交換機,這是負責接收生產者發送的消息,并根據路由規則將消息分發到相應的隊列或者其他交換器的組件。RabbitMQ 支持多種類型的交換器,如 fanout, direct, topic, headers 等。
  • binding:綁定,這是負責將交換器和隊列之間建立關聯關系的組件。綁定可以指定一個路由鍵或者模式匹配規則,以決定哪些消息可以被路由到哪些隊列。
  • queue:隊列,這是負責存儲消費者需要消費的消息的組件。隊列可以有多種屬性和特性,如持久化、排他性、自動刪除、死信隊列、優先級隊列等。隊列可以綁定到一個或多個交換器上,并指定一個或多個路由鍵或者模式匹配規則。
  • consuemer:消費者,連接到 RabbitMQ 服務器,并訂閱到隊列上,接收來自隊列的消息。

應用場景

圖片圖片UGT28資訊網——每日最新資訊28at.com

RabbitMQ 是一個非常強大和靈活的消息中間件,它可以應用于多種場景和需求。以下是一些常見的 RabbitMQ 應用場景和實戰經驗:UGT28資訊網——每日最新資訊28at.com

  • 異步處理:當系統需要執行一些耗時或者不重要的任務時,可以使用 RabbitMQ 將任務封裝成消息發送到隊列中,然后由專門的消費者來異步地執行這些任務。這樣可以提高系統的響應速度和用戶體驗,同時也可以避免因為任務失敗或超時而影響主流程的執行。例如在 waynboot-mall 項目中,用戶下單后需要發送郵件通知,這個任務就可以使用 RabbitMQ 異步處理。
  • 流量削峰:當系統面臨突發的高并發請求時,如果直接讓所有請求打到后端服務器上,可能會導致服務器崩潰或者響應緩慢。這時可以使用 RabbitMQ 作為一個緩沖層,將請求先發送到隊列中,然后由后端服務器按照自己的處理能力從隊列中拉取請求進行處理。這樣可以平滑地分攤請求壓力,避免系統崩潰或者服務降級。例如,在 waynboot-mall 項目中,每天晚上八點有秒殺活動,這時可以使用 RabbitMQ 來削峰限流,保證系統的穩定運行。
  • 消息廣播:當系統需要將消息發送到多個接收方時,可以使用 RabbitMQ 的發布/訂閱模式,將消息發送到一個 fanout 類型的交換器上,然后由多個隊列綁定到這個交換器上,從而實現消息的廣播功能。這樣可以實現一對多的消息通信,同時也可以根據不同的業務需求,訂閱不同的消息內容。例如,在 waynboot-mall 項目中,當商品信息發生變化時,需要通知搜索系統、推薦系統、緩存系統等多個系統,這時可以使用 RabbitMQ 的消息廣播功能。
  • 消息路由:當系統需要根據不同的條件將消息發送到不同的接收方時,可以使用 RabbitMQ 的路由模式,將消息發送到一個 direct 或者 topic 類型的交換器上,然后由多個隊列綁定到這個交換器上,并指定不同的路由鍵或者模式匹配規則,從而實現消息的路由功能。這樣可以實現多對多的消息通信,同時也可以靈活地控制消息的分發和消費。例如,在 waynboot-mall 項目中,當訂單狀態發生變化時,需要通知不同的系統進行不同的處理,這時可以使用 RabbitMQ 的消息路由功能。

坑點解析

圖片圖片UGT28資訊網——每日最新資訊28at.com

在使用 RabbitMQ 的過程中,有一些常見的問題需要注意:UGT28資訊網——每日最新資訊28at.com

  • 消息確認:消息確認是 RabbitMQ 保證消息可靠傳遞的機制。消息確認分為生產者確認和消費者確認。生產者確認是指生產者發送消息后,等待 RabbitMQ 返回一個確認消息,表明消息已經被正確接收和存儲。消費者確認是指消費者接收消息后,向 RabbitMQ 發送一個確認消息,表明消息已經被正確處理和消費。在 waynboot-mall 項目中,消費者開啟了手動消息確認。
  • 消息持久化:消息持久化是指將消息存儲到磁盤上,以防止 RabbitMQ 重啟或者崩潰時丟失消息。消息持久化需要滿足以下三個條件:交換器、隊列和消息都需要設置為持久化。持久化會影響 RabbitMQ 的性能,因為需要進行磁盤 IO 操作。建議根據業務需求選擇是否需要持久化消息,并合理地配置磁盤空間和清理策略。在 waynboot-mall 項目中,交換器、隊列設置了持久化,消息沒有設置持久化(消息設置持久化會對 RabbitMQ 的性能造成較大影響)。
  • 死信隊列:死信隊列是指存儲那些因為某些原因無法被正常消費的消息的隊列。死信隊列可以用來處理一些異常或者失敗的情況,如消息過期、隊列達到最大長度、消費者拒絕等。建議使用死信隊列來監控和處理這些情況,并根據業務需求選擇合適的重試或者補償策略。在 waynboot-mall 項目中,當訂單消費者處理消息失敗重試三次后,會將訂單消息發送到死信隊列。
  • 集群和鏡像:集群和鏡像是 RabbitMQ 實現高可用和高擴展的兩種方式。集群是指將多個 RabbitMQ 實例組成一個邏輯單元,共享元數據和負載均衡。鏡像是指將同一個隊列在多個節點上創建副本,實現數據冗余和容錯。建議根據業務需求選擇合適的集群模式和鏡像類型,并注意集群中的網絡分區、腦裂等問題。

代碼實戰

在 waynboot-mall 項目中,消息層包含兩個模塊 waynboot-message-core 以及 waynboot-message-consumer,目錄結構如下,UGT28資訊網——每日最新資訊28at.com

|-- waynboot-message-core     // 核心消息配置,供其他服務集成使用|   |-- config|   |-- constant|   |-- dto|-- waynboot-message-consumer // 消息消費服務,訂閱隊列接收消息,調用其他服務執行一些具體的業務邏輯|   |-- api|   |-- config|   |-- consumer

waynboot-message-core 包目錄說明如下,UGT28資訊網——每日最新資訊28at.com

  • config:核心消息配置目錄,包含業務上使用的訂單消息、郵件消息、死信消息、延遲消息的交換機、隊列、路由綁定配置以及 RabbitTemplate 配置。
  • constants:核心消息配置的相關常量目錄,包含 MQ 的常量類,這里面會定義訂單、郵件、死信、延遲消息的交換機名稱、隊列名稱、路由鍵名稱等。
  • dto:核心消息配置的數據轉換實體目錄,包含 OrderDTO 等。

waynboot-message-consumer 包目錄說明如下,UGT28資訊網——每日最新資訊28at.com

  • api:消息消費服務調用其他服務定義的 api 包目錄,包含 MobileApi 類用來調用 moibile-api。
  • config:消息消費服務的核心配置目錄,包含 RestTemplate 配置類。
  • consumer:消息消費服務的消費者包目錄,包含下單、發送郵件、未支付訂單超時取消等消費者。

添加 POM 依賴

<dependency>    <groupId>org.springframework.boot</groupId>    <artifactId>spring-boot-starter-amqp</artifactId>    <version>${spring-boot.version}</version></dependency>

指定虛擬主機

圖片圖片UGT28資訊網——每日最新資訊28at.com

在 waynboot-mall 項目中,通過 yml 文件的 spring.rabbitmq.virtual-host=“/” 屬性來指定虛擬主機名稱。UGT28資訊網——每日最新資訊28at.com

建議大家在使用 RabbitMQ 時都配置好自己項目的虛擬主機名稱,來達到各系統資源隔離的目的。當然如果 RabbitMQ 服務只有一個項目在用,那就用默認的 / 作為虛擬主機名稱也是可以的。UGT28資訊網——每日最新資訊28at.com

小知識:出于多租戶和安全因素設計的,vhost 把 AMQP 的基本組件劃分到一個虛擬的分組中。每個 vhost 本質上就是一個 mini 版的 RabbitMQ 服務器,擁有自己的隊列、交換機、綁定和權限機制。當多個不同的用戶使用同一個 RabbitMQ 服務器時,可以劃分出多個虛擬主機。RabbitMQ 默認的虛擬主機路徑是 /。UGT28資訊網——每日最新資訊28at.com

生產者發送消息

在 waynboot-mall 項目中,用訂單消息來舉例,生產者發送消息需要經過三個步驟UGT28資訊網——每日最新資訊28at.com

1. 創建訂單消息的交換機、隊列以及路由綁定

public class MQConstants {    public static final String ORDER_DIRECT_QUEUE = "order_direct_queue";    public static final String ORDER_DIRECT_EXCHANGE = "order_direct_exchange";    public static final String ORDER_DIRECT_ROUTING = "order_direct_routing";}@Configurationpublic class BusinessRabbitConfig {    @Bean    public Queue orderDirectQueue() {        return new Queue(MQConstants.ORDER_DIRECT_QUEUE);    }    @Bean    DirectExchange orderDirectExchange() {        return new DirectExchange(MQConstants.ORDER_DIRECT_EXCHANGE);    }    @Bean    Binding bindingOrderDirect() {        return BindingBuilder.bind(orderDirectQueue()).to(orderDirectExchange()).with(MQConstants.ORDER_DIRECT_ROUTING);    }}

在 BusinessRabbitConfig 中,我們創建了訂單交換機、隊列以及路由綁定關系。在 Spring 項目中,項目啟動時,就會自動在 RabbitMQ 服務器上創建好這些東西。UGT28資訊網——每日最新資訊28at.com

交換機列表交換機列表UGT28資訊網——每日最新資訊28at.com

隊列列表隊列列表UGT28資訊網——每日最新資訊28at.com

2. 生產者配置

圖片UGT28資訊網——每日最新資訊28at.com

生產者的消息發送確認主要包含兩部分,UGT28資訊網——每日最新資訊28at.com

producter -> rabbitmq broker exchange -> queueUGT28資訊網——每日最新資訊28at.com

  • 消息從 producte( 生產者)發送到 rabbitmq broker(RabbitMQ 服務器)的交換機中,發送后會觸發 confirmCallBack 回調
  • 消息從 exchange 發送到 queue,投遞失敗則會調用 returnCallBack 回調

waynboot-mall 項目的 yml 中關于 RabbitMQ 的相關配置如下,UGT28資訊網——每日最新資訊28at.com

spring:  # 配置rabbitMq 服務器  rabbitmq:    host: 127.0.0.1    port: 5672    username: guest    password: guest    # 消息確認配置項    # 確認消息已發送到交換機(Exchange)    publisher-confirm-type: correlated    # 確認消息已發送到隊列(Queue)    publisher-returns: true    # 虛擬主機名稱    virtual-host: /
publisher-confirm-type 屬性

可以看到,我們設置了 publisher-confirm-type 屬性為 correlated,表示開啟發布確認模式,用來確認消息已發送到交換機,publisher-confirm-type 有三個選項:UGT28資訊網——每日最新資訊28at.com

  • NONE:禁用發布確認模式,是默認值
  • CORRELATED:發布消息成功到交換器后會觸發回 confirmCallBack 回調方法
  • SIMPLE:經測試有兩種效果,其一效果和 CORRELATED 值一樣會觸發回調方法,其二在發布消息成功后使用 rabbitTemplate 調用 waitForConfirms 或 waitForConfirmsOrDie 方法等待 broker 節點返回發送結果,根據返回結果來判定下一步的邏輯,要注意的點是 waitForConfirmsOrDie 方法如果返回 false 則會關閉 channel,則接下來無法發送消息到 broker。
publisher-returns 屬性

在 RabbitMQ 中,消息發送到交換機中也不代表消費者一定能接收到消息,所以我們還需要設置 publisher-returns 為 true 來表示確認交換機中消息已經發送到隊列里。true 表示開啟失敗回調,開啟后當消息無法路由到指定隊列時會觸發 ReturnCallback 回調。UGT28資訊網——每日最新資訊28at.com

接著是 RabbitTemplateConfig 的代碼,這里面會定義前面提到的 confirmCallBackreturnCallBack 相關代碼,UGT28資訊網——每日最新資訊28at.com

@Slf4j@Componentpublic class RabbitTemplateConfig {    @Bean    public RabbitTemplate rabbitTemplate(CachingConnectionFactory connectionFactory) {        RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);        // 設置開啟Mandatory,才能觸發回調函數,無論消息推送結果怎么樣都強制調用回調函數        rabbitTemplate.setMandatory(true);        // 交換機收到消息回調        rabbitTemplate.setConfirmCallback((correlationData, ack, cause) -> log.info("消息發送成功:correlationData({}),ack({}),cause({})", correlationData, ack, cause));        // 隊列收到消息回調,如果失敗的話會進行 returnCallback 的回調處理,反之成功就不會回調。        rabbitTemplate.setReturnsCallback(returned -> {            log.info("returnCallback:     " + "消息:" + returned.getMessage());            log.info("returnCallback:     " + "回應碼:" + returned.getReplyCode());            log.info("returnCallback:     " + "回應信息:" + returned.getReplyText());            log.info("returnCallback:     " + "交換機:" + returned.getExchange());            log.info("returnCallback:     " + "路由鍵:" + returned.getRoutingKey());        });        return rabbitTemplate;    }}

在 RabbitTemplateConfig 類代碼里,我們可以設置 confirmCallBackreturnCallBack 回調函數后,監控生產者發送消息是否被交換機接收、以及交換機是否把消息發送到隊列中。UGT28資訊網——每日最新資訊28at.com

3. 使用 RabbitTemplate 發送消息

在 Spring Boot 項目中,集成了 spring-boot-starter-amqp 依賴后,就可以直接注入 RabbitTemplate 來發送消息。UGT28資訊網——每日最新資訊28at.com

這里用 waynboot-mall 項目中的異步下單流程舉例,代碼如下,UGT28資訊網——每日最新資訊28at.com

@Slf4j@Service@AllArgsConstructorpublic class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements IOrderService {    private RabbitTemplate rabbitTemplate;    @Override    public R asyncSubmit(OrderVO orderVO) {        OrderDTO orderDTO = new OrderDTO();        ...        // 開始異步下單        String uid = IdUtil.getUid();        // 1. 創建消息ID,確認機制發送消息時,需要給每個消息設置一個全局唯一 id,以區分不同消息,避免 ack 沖突        CorrelationData correlationData = new CorrelationData(uid);        // 2. 創建消息載體 Message ,AMQP 規范中定義的消息承載類,用來在生產者和消費者之前傳遞消息        Map<String, Object> map = new HashMap<>();        map.put("order", orderDTO);        map.put("notifyUrl", WaynConfig.getMobileUrl() + "/callback/order/submit");        try {            Message message = MessageBuilder                    .withBody(JSON.toJSONString(map).getBytes(Constants.UTF_ENCODING))                    .setContentType(MessageProperties.CONTENT_TYPE_TEXT_PLAIN)                    .setDeliveryMode(MessageDeliveryMode.PERSISTENT)                    .build();            // 3. 發送消息到 RabbitMQ 服務器,需要指定交換機、路由鍵、消息載體以及消息ID            rabbitTemplate.convertAndSend(MQConstants.ORDER_DIRECT_EXCHANGE, MQConstants.ORDER_DIRECT_ROUTING, message, correlationData);        } catch (UnsupportedEncodingException e) {            log.error(e.getMessage(), e);        }        return R.success().add("actualPrice", actualPrice).add("orderSn", orderSn);    }}

waynboot-mall 項目中在使用 rabbitTemplate 發送消息時,按照如下步驟,大家可以參考UGT28資訊網——每日最新資訊28at.com

  1. 創建消息 ID,確認機制發送消息時,需要給每個消息設置一個全局唯一 id,以區分不同消息,消費者消費時出現 ack 沖突。
  2. 創建消息載體 Message ,AMQP 規范中定義的消息承載類,用來在生產者和消費者之前傳遞消息。
  3. 發送消息到 RabbitMQ 服務器,需要指定交換機、路由鍵、消息載體以及消息 ID。

以上就是生產者發送消息時所有相關代碼了,接著我們看下消費者處理消息的相關代碼。UGT28資訊網——每日最新資訊28at.com

消費者處理消息

在 waynboot-mall 項目中,還是用訂單消息來舉例,消費者 yml 配置如下,UGT28資訊網——每日最新資訊28at.com

1. 消費者配置

在 RabbitMQ 的消息消費環節,需要注意的一點就是,如果需要確保消費者不出現漏消費,則需要開啟消費者的手動 ack 模式。UGT28資訊網——每日最新資訊28at.com

spring:  rabbitmq:    host: 127.0.0.1    port: 5672    username: guest    password: guest    ...    listener:      simple:        # 消息確認方式,其有三種配置方式,分別是none、manual(手動ack) 和auto(自動ack) 默認auto        acknowledge-mode: manual        # 一個消費者最多可處理的nack(未確認)消息數量,默認是250        prefetch: 250        # 設置消費者數量        concurrency: 1
acknowledge-mode 屬性

在 yml 文件的消費者配置中,acknowledge-mode 屬性用于指定消息確認模式,有三種模式:UGT28資訊網——每日最新資訊28at.com

  1. 手動確認 manual,在該模式下,消費者消費消息后需要根據消費情況給 Broker 返回一個回執,是確認 ack 使 Broker 刪除該條已消費的消息,還是失敗確認返回 nack,還是拒絕該消息。開啟手動確認后,如果消費者接收到消息后還沒有返回 ack 就宕機了,這種情況下消息也不會丟失,只有 RabbitMQ 接收到返回 ack 后,消息才會從隊列中被刪除。
  2. 自動確認 none,rabbitmq 默認消費者正確處理所有請求(不設置時的默認方式)。
  3. 根據請況確認 auto,主要分成以下幾種情況:

如果消費者在消費的過程中沒有拋出異常,則自動確認。UGT28資訊網——每日最新資訊28at.com

當消費者消費的過程中拋出 AmqpRejectAndDontRequeueException 異常的時候,則消息會被拒絕,且該消息不會重回隊列。UGT28資訊網——每日最新資訊28at.com

當拋出 ImmediateAcknowledgeAmqpException 異常,消息會被確認。UGT28資訊網——每日最新資訊28at.com

如果拋出其他的異常,則消息會被拒絕,但是與前兩個不同的是,該消息會重回隊列,如果此時只有一個消費者監聽該隊列,那么該消息重回隊列后又會推送給該消費者,會造成死循環的情況。UGT28資訊網——每日最新資訊28at.com

prefetch 屬性

消費者配置中,prefetch 屬性用于指定消費者每次從隊列獲取的消息數量。UGT28資訊網——每日最新資訊28at.com

每個 customer 會在 MQ 預取一些消息放入內存的 LinkedBlockingQueue 中進行消費,這個值越高,消息傳遞的越快,但非順序處理消息的風險更高。如果 ack 模式為 none,則忽略。UGT28資訊網——每日最新資訊28at.com

prefetch 默認值以前是 1,這可能會導致高效使用者的利用率不足。從 spring-amqp 2.0 版開始,默認的 prefetch 值是 250,這將使消費者在大多數常見場景中保持忙碌,從而提高吞吐量。UGT28資訊網——每日最新資訊28at.com

不過在有些情況下,尤其是處理速度比較慢的大消息,消息可能在內存中大量堆積,消耗大量內存;以及對于一些嚴格要求順序的消息,prefetch 的值應當設置為 1。UGT28資訊網——每日最新資訊28at.com

對于低容量消息和多個消費者的情況(也包括單 listener 容器的 concurrency 配置)希望在多個使用者之間實現更均勻的消息分布,建議在手動 ack 下并設置 prefetch=1。UGT28資訊網——每日最新資訊28at.com

如果要保證消息的可靠不丟失,當 prefetch 大于 1 時,可能會出現因為服務宕機引起的數據丟失,故建議將 prefetch=1。UGT28資訊網——每日最新資訊28at.com

concurrency 屬性

消費者配置中,concurrency 屬性設置的是對每個 listener 在初始化的時候設置的并發消費者的個數。在上面的 yml 配置中,cnotallow=1,即每個 Listener 容器將開啟一個線程去處理消息。在 2.0 以后的版本中,可以在注解中配置該參數,實例代碼如下,UGT28資訊網——每日最新資訊28at.com

@RabbitListener(queues = MQConstants.ORDER_DIRECT_QUEUE, concurrency = "2")public void process(Channel channel, Message message) throws IOException {    String body = new String(message.getBody());    log.info("OrderPayConsumer 消費者收到消息: {}", body);    ...}

2. 使用 RabbitListener 注解消費消息

在 waynboot-mall 項目中,消費者監聽隊列代碼如下,UGT28資訊網——每日最新資訊28at.com

@Slf4j@Componentpublic class OrderPayConsumer {    @Resource    private RedisCache redisCache;    @Resource    private MobileApi mobileApi;    @RabbitListener(queues = MQConstants.ORDER_DIRECT_QUEUE)    public void process(Channel channel, Message message) throws IOException {        // 1. 轉換訂單消息        String body = new String(message.getBody());        log.info("OrderPayConsumer 消費者收到消息: {}", body);        // 2. 獲取消息ID        String msgId = message.getMessageProperties().getHeader("spring_returned_message_correlation");        // 3. 獲取發送tag        long deliveryTag = message.getMessageProperties().getDeliveryTag();        // 4. 消費消息冪等性處理        if (redisCache.getCacheObject(ORDER_CONSUMER_MAP.getKey()) != null) {            // redis中包含該 key,說明該消息已經被消費過            log.error("msgId: {},消息已經被消費", msgId);            channel.basicAck(deliveryTag, false);// 確認消息已消費            return;        }        try {            // 5. 下單處理            mobileApi.submitOrder(body);            // 6. 手動ack,消息成功確認            channel.basicAck(deliveryTag, false);            // 7. 設置消息已被消費標識            redisCache.setCacheObject(ORDER_CONSUMER_MAP.getKey(), msgId, ORDER_CONSUMER_MAP.getExpireSecond());        } catch (Exception e) {            channel.basicNack(deliveryTag, false, false);            log.error(e.getMessage(), e);        }    }}

waynboot-mall 項目中在使用 RabbitListener 注解消費消息時,按照如下步驟,大家可以參考UGT28資訊網——每日最新資訊28at.com

  1. 將 message 參數轉換成訂單消息。
  2. 從 message 參數中獲取消息唯一 msgId。
  3. 從 message 參數中獲取消息發送 tag。
  4. 冪等性處理,根據第二步獲取的 msgId ,消費消息時需要先判斷 msgId 是否已經被處理。
  5. 調用 mobile-api 服務,進行下單邏輯處理,在 mobileApi.submitOrder(body) 方法中使用 Spring-Retry 的 @Retryable 注解,進行自動重試。
  6. 手動 ack,basicAck(long deliveryTag, boolean multiple)。basicAck 方法表示成功確認,使用此方法后,消息就會被 rabbitmq 服務器刪除。

其中參數 long deliveryTag 為消息的唯一序號也就是第三步獲取的發送 tag,第二個 boolean multiple 參數表示是否一次消費多條消息,false 表示只確認該序列號對應的消息,true 則表示確認該序列號對應的消息以及比該序列號小的所有消息,比如我先發送 2 條消息,他們的序列號分別為 2,3,并且他們都沒有被確認,還留在隊列中,那么如果當前消息序列號為 4,那么當 multiple 為 true,則序列號為 2、3 的消息也會被一同確認。UGT28資訊網——每日最新資訊28at.com

  1. 冪等性處理,消息已經被成功消費后,根據第二步獲取的 msgId 設置冪等標識。

總結一下

這篇文章給大家講解了在 Spring Boot 項目中如何集成消息隊列 RabbitMQ 用于業務邏輯解耦,有架構介紹、應用場景、坑點解析、代碼實戰 4 個部分,能帶領大家比較全面的了解一波 RabbitMQ。大家在自己的項目中如果需要引入 RabbitMQ 時,都可以參考本文的代碼實戰配置,幫助大家快速集成、避免踩坑。UGT28資訊網——每日最新資訊28at.com

本文鏈接:http://www.www897cc.com/showinfo-26-70467-0.htmlSpring Boot項目集成RabbitMQ實戰以及坑點講解

聲明:本網頁內容旨在傳播知識,若有侵權等問題請及時與本網聯系,我們將在第一時間刪除處理。郵件:2376512515@qq.com

上一篇: 利用Nacos實現Seata事務模式(XA與AT)的快速配置與靈活切換

下一篇: 字節碼增強技術,不止有 Java Proxy、 Cglib 和 Javassist 還有 Byte Buddy

標簽:
  • 熱門焦點
  • Find N3入網:最高支持16+1TB

    OPPO將于近期登場的Find N3折疊屏目前已經正式入網,型號為PHN110。本次Find N3在外觀方面相比前兩代有很大的變化,不再是小號的橫向折疊屏,而是跟別的廠商一樣采用了較為常見的
  • K60 Pro官方停產 第三方瞬間漲價

    雖然沒有官方宣布,但Redmi的一些高管也已經透露了,Redmi K60 Pro已經停產且不會補貨,這一切都是為了即將到來的K60 Ultra鋪路,屬于廠家的正常操作。但有意思的是該機在停產之后
  • K60至尊版狂暴引擎2.0加持:超177萬跑分斬獲性能第一

    Redmi的后性能時代戰略發布會今天下午如期舉辦,在本次發布會上,Redmi公布了多項關于和聯發科的深度合作,以及新機K60 Ultra在軟件和硬件方面的特性,例如:“K60 至尊版,雙芯旗艦
  • 線程通訊的三種方法!通俗易懂

    線程通信是指多個線程之間通過某種機制進行協調和交互,例如,線程等待和通知機制就是線程通訊的主要手段之一。 在 Java 中,線程等待和通知的實現手段有以下幾種方式:Object 類下
  • 如何正確使用:Has和:Nth-Last-Child

    我們可以用CSS檢查,以了解一組元素的數量是否小于或等于一個數字。例如,一個擁有三個或更多子項的grid。你可能會想,為什么需要這樣做呢?在某些情況下,一個組件或一個布局可能會
  • 使用LLM插件從命令行訪問Llama 2

    最近的一個大新聞是Meta AI推出了新的開源授權的大型語言模型Llama 2。這是一項非常重要的進展:Llama 2可免費用于研究和商業用途。(幾小時前,swyy發現它已從LLaMA 2更名為Lla
  • 自研Exynos回歸!三星Galaxy S24系列將提供Exynos和驍龍雙版本

    年初,全新的三星Galaxy S23系列發布,包含Galaxy S23、Galaxy S23+和Galaxy S23 Ultra三個版本,全系搭載超頻版驍龍8 Gen 2,雖同樣采用臺積電4nm工藝制
  • 三星Galaxy Z Fold/Flip 5國行售價曝光 :最低7499元/12999元起

    據官方此前宣布,三星將于7月26日也就是明天在韓國首爾舉辦Unpacked活動,屆時將帶來帶來包括Galaxy Buds 3、Galaxy Watch 6、Galaxy Tab S9、Galaxy
  • OPPO Reno10 Pro英雄聯盟定制禮盒公布:薩勒芬妮同款配色夢幻十足

    5月24日,OPPO推出了全新的OPPO Reno 10系列,包含OPPO Reno10、OPPO Reno10 Pro和OPPO Reno10 Pro+三款新機,全系標配了超光影長焦鏡頭,是迄今為止拍照
Top 主站蜘蛛池模板: 常州市| 武平县| 炉霍县| 朝阳区| 出国| 永康市| 青龙| 平昌县| 罗源县| 五原县| 富民县| 南江县| 浮山县| 搜索| 女性| 建瓯市| 阿图什市| 铅山县| 昭平县| 襄樊市| 商河县| 福州市| 广丰县| 曲靖市| 枝江市| 安国市| 双鸭山市| 迁安市| 郯城县| 石棉县| 阿拉善右旗| 彝良县| 子洲县| 奇台县| 北辰区| 新巴尔虎左旗| 迭部县| 昆明市| 德安县| 康平县| 都江堰市|