JBoss Fuse - Apache AMQ

在本章中，我們將瞭解 ActiveMQ 以及它如何充當訊息代理，允許應用程式相互通訊。

什麼是 AMQ？

ActiveMQ 是一個用 Java 編寫的開源訊息代理。它完全符合 JMS 1.1 標準。

JMS 是一種允許開發基於訊息的系統的規範。ActiveMQ 充當訊息代理，位於應用程式之間，並允許它們以非同步和可靠的方式進行通訊。

訊息型別

為了更好地理解，下面解釋了兩種訊息傳遞選項。

點對點

在這種型別的通訊中，代理僅將訊息傳送給一個消費者，而其他消費者將等待直到他們從代理獲取訊息。沒有消費者會收到相同的訊息。

如果沒有消費者，代理將儲存訊息，直到它獲得一個消費者。這種型別的通訊也稱為**基於佇列的通訊**，其中生產者將訊息傳送到佇列，並且只有一個消費者從佇列獲取一條訊息。如果有多個消費者，他們可能會獲取下一條訊息，但他們不會獲取與其他消費者相同的訊息。

釋出/訂閱

在這種型別的通訊中，代理將相同的訊息副本傳送給所有活動的消費者。這種型別的通訊也稱為**基於主題的通訊**，其中代理將相同的訊息傳送給已訂閱特定主題的所有活動消費者。此模型支援單向通訊，其中不期望對傳輸的訊息進行驗證。

建立佇列和主題

Fuse 與 ActiveMQ 捆綁在一起。我們可以使用 FMC 控制檯（基於瀏覽器的 AMQ 工作介面）訪問 ActiveMQ。

使用**localhost:8181**登入 FMC 並選擇**ActiveMQ**選項卡。

• 點選+建立
• 輸入佇列/主題名稱
• 從單選按鈕中選擇佇列/主題
• 點選建立佇列/建立主題

現在您應該能夠在根 → 佇列 → 下看到已建立的**TestQ**。

要檢查建立的主題，請按照根 → 主題操作。

瀏覽/刪除佇列內容

• 使用**localhost:8181**登入 FMC

• 選擇 ActiveMQ 選項卡

• 根 → 佇列 → TestQ <選擇要瀏覽的佇列> → 瀏覽

• 要檢查此訊息的內容，請點選該特定訊息。

• 您可以透過點選右上角顯示的刪除按鈕來刪除特定訊息