rabbitmq在安裝好之後就可以開始項目編碼啦。springboot項目整合rabbitmq的也是很簡單的。
1、前提安裝好rabbitmq。
2、pom.xml添加rabbitmq依賴。這個spring-boot-starter-amqp裡面的amqp指的是高級消息隊列協議,而rabbitmq就是amqp協議的一種實現中間件。
3、添加配置信息,這裡示例用的yml文件,springboot支持yml和properties這兩種格式文件。properties一般格式key=value,yml格式key:value;yml每一級之間用":"分隔,而且是逐級換行縮進。
這裡yml配置裡配置了rabbitmq的安裝地址、端口以及賬戶信息、發佈者確認等。
4、接下來寫的是一個最簡單的,單一生產者和單一消費者,生產者說白了就是消息製造,消費者就是消息接收。明確一點我們提到的消息指的是各個服務之間要傳遞的數據。
5、創建消費者類, 由@RabbitListener(queues = "hello-queue-test")來監聽"hello-queue-test"隊列的信息。消息有一個收一個。
6、創建生產者類。
7、定義配置類,創建消息隊列,Queue(隊列)是RabbitMQ的內部對象,專門用來存儲消息的,rabbitmq消息傳遞中的重要一環。
8、寫過controller來測試一下,
9、在postman上測試下接口,
10、後臺可以看到打印信息了。
11、rabbitmq的後臺可以看到新增的queue。
這個就是最簡單的消息傳送模式,結果也都搞出來了,接下來再學習其他模式。
閱讀更多 程序員球迷的日常 的文章
關鍵字: 換行 格式 properties