閱讀66 返回首頁    go 財經資訊


運行 Demo__MQ Demo 工程_消息隊列 MQ-阿裏雲

以 Main 方式啟動收發消息

  1. 運行 SimpleMQProducer 類發送消息。
  2. 登錄 MQ 控製台,在左側菜單欄選擇消息查詢>Topic 查詢,選擇 Topic 名稱進行查詢。可以看見消息已經發送至 Topic。

    Topic查詢

  3. 運行 SimpleMQConsumer 類接收消息。可以看到消息被接收打印的日誌。因為有初始化,所以需等待幾秒,在生產環境中不會經常初始化。

    打印消費端日誌

    訂閱管理>消費者狀態中可以看到,啟動的消費端已經在線,並且訂閱關係一致。

    消費者狀態

以 Spring 方式啟動收發消息

  1. 運行 MQProducer4Spring 類發送消息。
  2. 運行 MQConsumer4Spring 類接收消息。

查看結果跟上麵過程類似。

發送事務消息

運行 SimpleTransactionProducer 類發送消息。

說明:LocalTransactionCheckerImpl 類為本地事務 check 接口類。用於校驗事務。詳情請參考發送分布式事務消息

發送定時(延時)消息

運行 MQTimerProducer 類發送消息。延時3秒後投遞。

說明:MQ 也可以指定一個精確的投遞時間,最長定時時間為40天。具體請參考發送定時消息

HTTP、MQTT 物聯接入

  1. HTTP 接入請參考 MQ HTTP 接入
  2. MQTT 接入請參考 MQTT 接入

最後更新:2016-11-23 16:04:19

  上一篇:go Demo 工程配置__MQ Demo 工程_消息隊列 MQ-阿裏雲
  下一篇:go 消息過濾__特色功能_消息隊列 MQ-阿裏雲