RabbitMQ的學習(六):Spring整合RabbitMQ並進行兩個不同的系統間的呼叫
阿新 • • 發佈:2018-12-18
上一篇文章已經講解了spring整合RabbitMQ的例子,目前所有的例子都是簡單明瞭,程式設計師需要有舉一反三的能力,所以若覺得例子太簡單,請手下留情。。
這篇文章將弄兩個系統,然後進行系統間的通訊,通過該例子,希望你能對分散式,叢集間的通訊有所瞭解。
- 新建一個能啟動的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的使用!_