在使用SpringBoot中,筆者使用到了RabbitMQ,其中踩了不少地雷,經過些許的刻版終於把它調通了,

筆者主要說的是從生產者生產資料併發送給消費者到後者接收並處理資料這麼一個全過程,我這裡的資料指的是實體物件.生產者和消費者是處在兩個不同的專案中的.

首先說明下整個過程.

在 Spring-AMQP 中比較重要的類就是 Message ，因為要傳送的訊息必須要構造成一個 Message 物件來進行傳輸。Message 物件包括兩部分 Body 和 Properties
訊息生產者構造好 Message 之後，就會將 Message 傳送到指定的 Exchange (交換機)，再根據 Exchange 的型別及 routing-key 將訊息路由到相應的 queue 中，最後被監聽該 queue 的消費者消費.

tips:

1,當處理的資料是實體類的時候,需要特別注意,它是需要轉換的,否則會拋錯的.筆者指的是使用

1,生產者負責傳送如右邊:RabbitTemplate rabbitTemplate.convertAndSend("testDirectExchange","key1", new Teacher("whc_teacher"));

2,消費者這邊有監聽器,繫結好佇列,交換機和路由.如下,在消費者類頭配置.

@RabbitListener(
        containerFactory = "simpleRabbitListenerContainerFactory",
        bindings = @QueueBinding(
                value = @Queue(value = "testDirectQueue1",durable = "true"),
                exchange = @Exchange(value = "testDirectExchange",type = ExchangeTypes.DIRECT),
                key = "key1")
)

3,最核心的我覺得是它的配置檔案了,因為我們傳輸的是是實體物件.所以牽涉到資料的轉換了.

資料轉化我用的是Jackson2JsonMessageConverter,比較友好.

認證: @Qualifier(value = "classMapper") ClassMapper classMapper


傳輸:Jackson2JsonMessageConverter messageConverter = new Jackson2JsonMessageConverter();


需要把認證set進去,messageConverter.setClassMapper(classMapper);

其中,classMapper 這個bean裡面使用的是DefaultClassMapper,它裡面有放著一個map.

特別需要注意的是:Jackson2JsonMessageConverter,JsonMessageConverter 等都是比較常用的轉化器,但是他們也是有侷限性的,

不過使用 它們時有一個小問題，在不對它進行任何改造的前提下 ，傳送訊息的類和接受訊息的類必須是一樣的，不僅是要裡面的欄位一樣，類名一樣，連類的包路徑都要一樣。

4,

交換機：_Exchange 用於轉發訊息，但是它不會做儲存_ ，如果沒有 Queue bind 到 Exchange 的話，它會直接丟棄掉 Producer 傳送過來的訊息。常用交換機又分為3種類型：Direct Exchange，Topic Exchange，Fanout Exchange。

繫結：也就是交換機需要和佇列相繫結，這其中如上圖所示，是多對多的關係.

虛擬主機：一個虛擬主機持有一組交換機、佇列和繫結。為什麼需要多個虛擬主機呢？很簡單，_RabbitMQ當中，使用者只能在虛擬主機的粒度進行許可權控制