RabbitMQ 配置檔案詳解（生產者和消費者）

2021-08-21 11:54:22 字數 2024 閱讀 1649

一、rabbitmq 配置檔案 在web 專案開發過程中，一般分為生產者配置檔案和消費者配置檔案。廢話少說，馬上教您整個流程的配置！

1、準備工作：安裝好rabbitmq,並在專案中增加配置檔案   rabbit.properties 內容如下：

rmq.ip=192.188.113.114   


rmq.port=5672


rmq.producer.num=20


rmq.manager.user=admin


rmq.manager.password=admin
二、生產者配置檔案：producer.xml

1、

2、spring amqp預設的是jackson 的乙個外掛程式,目的將生產者生產的資料轉換為json存入訊息佇列，由於fastjson的速度快於jackson,這裡替換為fastjson的乙個實現

3、 spring template   宣告， durable:是否持久化 ； exclusive: 僅建立者可以使用的私有佇列，斷開後自動刪除；auto_delete: 當所有消費客戶端連線斷開後，是否自動刪除佇列.

queue 佇列宣告 需要傳送訊息到哪些佇列 訊息系統監聽佇列

4、訊息失效後監聽佇列,6000 為 時間間隔資訊 60s   int或long型別，解決優先順序問題

60000
5、rabbitmq的三種模式：direct，fanout，topic 三種

direct 訊息轉換佇列 繫結key，意思就是訊息與乙個特定的路由鍵匹配，會**。rabbit:binding：設定訊息queue匹配的key。
fanout 模式:客戶端中只要是與該路由繫結在一起的佇列都會收到相關訊息，這類似廣播，傳送端不管佇列是誰，都由客戶端自己去繫結，誰需要資料誰去繫結自己的相應佇列。
topic 模式：傳送端不是按固定的routing key傳送訊息，而是按字串「匹配」傳送，接收端同樣如此。

6、生產者（傳送端）**：

@resource  


private rabbittemplate rabbittemplate;  


public void sendmessage(commonmessage msg) catch (exception e) 


}
三、消費者配置：同乙個專案中 consumer.xml

1、連線服務配置

2、spring amqp預設的是jackson 的乙個外掛程式,目的將生產者生產的資料轉換為json存入訊息佇列，由於fastjson的速度快於jackson,這裡替換為fastjson的乙個實現

3、自定義介面類

4、queue 佇列宣告 需要傳送訊息到哪些佇列 ，訊息系統監聽佇列

5、topic 模式 繫結。注意：此處僅寫一種模式；根據需求可以配多種模式。
6、用於訊息的監聽的**類messagelisteneradapter

//類名


//方法名
7、配置監聽  acknowledeg = "manual"   設定手動應答  當訊息處理失敗時:會一直重發  直到訊息處理成功，監聽容器

acknowledge="auto" concurrency="30"  設定傳送次數，最多傳送30次

8、消費端**：testhandler 類

public class testhandler  


}

rabbitMQ配置檔案

簡單的rabbitmq配置可無需配置檔案，只有需要定製複雜應用時，才需要用到配置檔案 rabbitmq env.conf配置 常用引數 quote rabbitmq node ip address ip位址，空串bind所有位址，指定位址bind指定網路介面 rabbitmq node port t...

rabbitMQ配置檔案

rabbitmq有三個配置檔案，分別為主配置檔案 rabbitmq.conf erlang術語格式配置檔案 advanced.config 環境變數配置檔案 rabbitmq env.conf 在linux使用二進位制安裝rabbitmq3.8版本，預設沒有配置檔案。需要自己建立檔案放上去。rabb...

RabbitMQ配置檔案

簡單的rabbitmq配置可無需配置檔案，只有需要定製複雜應用時，才需要用到配置檔案 rabbitmq env.conf配置 常用引數 rabbitmq node ip address ip位址，空串bind所有位址，指定位址bind指定網路介面 rabbitmq node port tcp埠號，預...