RabbitMQ是目前被廣泛使用的訊息佇列。那麼RabbitMQ如何進行訊息的生產和消費是很多開發者普遍關心的問題。本文旨在講述如何實現RabbitMQ的Topics方式訊息訂閱。
工具/原料
Eclipse開發工具
安裝有RabbitMQ軟體的Linux虛擬機器
方法/步驟
建立maven工程,匯入RabbitMQ客戶端開發所使用的jar包。
編寫訊息傳送端程式。此程式碼的功能為連線RabbitMQ伺服器,以"anonymous.info"為繫結鍵繫結訊息佇列Q1向伺服器傳送訊息。
編寫訊息接收端程式。此程式碼的功能為連線RabbitMQ伺服器,通過繫結鍵接收指定佇列中的訊息。
啟動接收端程式,制定繫結鍵為“anonymous.info”,檢視能否接收程式。
啟動傳送端程式,傳送資訊,檢視能否接收到傳送的資訊。
修改接收端程式的繫結鍵,檢視能否接收到資訊。執行程式可知,雖然訊息已經發送,但接收端並未接收到訊息。此因為繫結鍵不匹配。
如上所述,訊息傳送者可以通過指定不同的繫結鍵繫結訊息佇列傳送訊息,接收端可以根據需要選擇性的接收訊息,實現真正的訂閱功能。
注意事項
測試程式的執行依賴於RabbitMQ已經正常啟動。
確保連線RabbitMQ使用的使用者已經建立,並可正常使用。RabbitMQ預設使用使用者名稱和密碼為“guest”、“guest”。