1. 程式人生 > >RabbitMQ的學習(六):Spring整合RabbitMQ並進行兩個不同的系統間的呼叫

RabbitMQ的學習(六):Spring整合RabbitMQ並進行兩個不同的系統間的呼叫

上一篇文章已經講解了spring整合RabbitMQ的例子,目前所有的例子都是簡單明瞭,程式設計師需要有舉一反三的能力,所以若覺得例子太簡單,請手下留情。。
這篇文章將弄兩個系統,然後進行系統間的通訊,通過該例子,希望你能對分散式,叢集間的通訊有所瞭解。

  1. 新建一個能啟動的web專案(相關配置檔案和上篇文章的例子是一樣的)
    在這裡插入圖片描述

然後修改下MessageConsumer內容:


import org.apache.log4j.Logger;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessageListener;

public class MessageConsumer implements MessageListener {
     private Logger logger = Logger.getLogger(MessageConsumer.class);  
    @Override
    public void onMessage(Message message) {
         logger.info("只有消費者的專案————————consumer receive message------->:  "+message); 
    }
}

一個無比微小的demo就完成了。現在啟動兩個demo(該demo和上篇文章的demo)
效果如下:
在這裡插入圖片描述
我們發現,第二個系統接收到了第一個系統(demo)的資訊了,這說明兩個系統的通訊是實現了的!

demo下載地址:
https://download.csdn.net/download/shenhaiyushitiaoyu/10846160

spring整合rabbitmq的配置有點多,對於初學者不好理解,下一篇我們講解springboot和rabbitmq的整合。屆時將會有更清爽的程式碼實現rabbitmq的使用!_