如何在我的 Amazon MQ 代理程式上設定 RabbitMQ 聯合身分外掛程式？

2 分的閱讀內容

我想使用 RabbitMQ 聯合身分外掛程式將訊息從內部部署代理程式分發到 Amazon MQ for RabbitMQ 代理程式。如何設定我的 Amazon MQ for RabbitMQ 代理程式以使用 RabbitMQ 聯合身分外掛程式？

簡短描述

若要在 Amazon MQ for RabbitMQ 代理程式上設定 RabbitMQ 聯合身分外掛程式，您必須在下遊代理程式上設定以下內容：

一個或多個 federation-upstream 參數，用於定義指向遠端佇列或交換的聯合身分連線。
一個 RabbitMQ 政策，可讓特定的遠端佇列或交換成為聯合狀態。
帶有新佇列的交換，綁定到此佇列以接收訊息。

解決方案

注意：以下程序需要兩個代理程式：上遊代理程式 (內部部署或基於雲端) 和下遊代理程式 (Amazon MQ for RabbitMQ 代理程式)。

建立一個或多個 federation-upstream 參數，用於定義指向遠端佇列或交換的聯合身分連線

1. 開啟 Amazon MQ 主控台。

2. 在左側導覽窗格中，選擇代理程式。

3. 在名稱欄中，選擇下遊代理程式的名稱。

4. 在連線窗格中，選擇 RabbitMQ Web 主控台下列出的 URL。下遊代理程式的 RabbitMQ Web 主控台登入頁面開啟。

5. 輸入代理程式的使用者名稱和密碼。然後，選擇登入以登入 RabbitMQ Web 主控台。

6. 在 RabbitMQ Web 主控台中，選擇管理索引標籤。然後，在右側導覽窗格中，選擇聯合身分上游。

7. 選擇新增上游。

8. 在名稱中，輸入上遊參數的名稱。

9. 對於 URI，刪除預設的 amqp:// 文字，然後按以下格式輸入上遊代理程式的 URI：

amqps://$UPSTREAM_BROKER_USER:$UPSTREAM_BROKER_PASSWORD@$UPSTREAM_BROKER_ENDPOINT:5671

10. 選擇新增上遊。

建立 RabbitMQ 政策，讓特定的遠端佇列或交換成為聯合狀態

1. 開啟下遊代理程式的 RabbitMQ Web 主控台。有關説明，請參閲本文的使用 RabbitMQ Web 主控台建立聯合身分上遊參數部分的步驟 1-5。

2. 選擇管理員索引標籤。然後，在右側導覽窗格中，選擇政策。

3. 選擇新增/更新政策。

4. 對於名稱，輸入您的政策的名稱。

5. 對於模式，輸入一個正則表達式，該正則表達式與要允許成為聯合狀態的佇列或交換名稱相符。

6. 對於適用於，從下拉式清單中選擇交換。

注意：將該政策適用於交換可讓政策僅適用於下遊代理程式中的交換。

7. 對於優先順序，輸入數字 1。

注意：如果多個政策具有相同的名稱，則優先順序設定用於確定應適用於交換或佇列的政策。將優先順序設定指定為 1 可防止任何具有相同名稱的預設 Amazon MQ 政策覆寫此政策。

8. 對於定義，在第一個文字方塊中，於 = 符號之前輸入 federation-upstream-set 作為索引鍵。然後，在 = 符號右側的第二個文字方塊中輸入 all 作為值。

9. 選擇新增/更新政策。

建立帶有新佇列的交換，綁定到此佇列以接收訊息

1. 開啟下遊代理程式的 RabbitMQ Web 主控台。有關説明，請參閲本文的使用 RabbitMQ Web 主控台建立聯合身分上遊參數部分的步驟 1-5。

2. 選擇佇列索引標籤。

3. 在新增佇列下的名稱中，輸入正在接收訊息的新佇列的名稱。

4. 選擇新增佇列。

5. 選擇交換索引標籤。

6. 在新增交換下的名稱中，輸入與建立 RabbitMQ 政策時使用的交換名稱相符的正則表達式。

7. 選擇新增交換。

**注意：**RabbitMQ 還會自動在具有相同名稱的上遊代理程式上建立交換。

8. 選擇交換索引標籤。

9. 在所有交換下，選擇建立的新交換的名稱。

10. 在繫結下，對於從此交換新增繫結，從下拉式清單中選擇至佇列。然後，輸入建立的佇列的名稱。

11. 對於路由索引鍵，輸入選擇的值。使用此值傳送到上遊代理程式中交換的訊息也會傳送至與此交換繫結的佇列。

12. 選擇繫結。

測試設定

向上遊代理程式的來源交換傳送測試訊息

1. 開啟上遊代理程式的 RabbitMQ Web 主控台。

**注意：**有關如何存取 RabbitMQ Web 主控台的詳細資訊，請參閲 RabbitMQ 文件中的管理外掛程式。

2. 選擇交換索引標籤。然後，選擇來源交換的名稱。

3. 在左側導覽窗格中，選擇發佈訊息。此時將開啟發佈訊息部分。

4. 在路由索引鍵文字方塊中，輸入您建立的路由索引鍵值。

5. 在承載文字方塊中，輸入測試訊息。

注意：可以將標題和屬性文字方塊留空。

6. 選擇發佈訊息按鈕。測試訊息將傳送到來源交換。如果您的聯合身分參數設定正確，則訊息也會傳送至下遊代理程式的目的地佇列。

驗證下遊代理程式的目的地佇列是否收到測試訊息

1. 開啟下遊代理程式的 RabbitMQ Web 主控台。

2. 選擇佇列索引標籤。然後，選擇目的地佇列的名稱。

3. 在左側導覽窗格中，選擇取得訊息。這將開啟取得訊息部分。

4. 選擇取得訊息按鈕。如果聯合身分參數設定正確，則傳送至來源交換的測試訊息將顯示為承載值。