RabbitMQ Messaging & Async Systems · レッスン

クラスタリング向けFederationプラグイン

Federationプラグインを使って、複雑なネットワーク設定なしに複数のRabbitMQブローカーを論理クラスターとして接続する方法を学びます。データセンター間にまたがる分散メッセージングシステムを構築します。

レッスン 3/411 ステップ

「クラスタリング向けFederationプラグイン」はCoddyKit上の無料RabbitMQ Messaging & Async Systemsレッスンです。これはレッスン3/4です。下記で完全なレッスンを無料で読むことができます。その後、ブラウザ内の組み込みコードエディタと24時間対応のAIチューターでハンズオン演習できます。これはRabbitMQ Messaging & Async Systems学習パスの一部であり、ウェブとCoddyKitアプリ全体で進捗が同期されます。 RabbitMQ Messaging & Async Systemsコースには全4レッスンが含まれています。

このレッスンの一部はまだ翻訳されておらず、英語で表示されています。

What is RabbitMQ Federation?

Imagine you have RabbitMQ brokers in different data centers or cloud regions. How do they share messages without complex network setups?

The Federation plugin allows you to loosely connect these brokers. It enables messages to flow between them, creating a distributed messaging system across geographical boundaries.

Federation vs. Traditional Clustering

It's important to distinguish Federation from traditional RabbitMQ clustering:

Clustering: Tightly couples nodes, sharing state and data. Best for high availability within a single, low-latency network (e.g., a data center).
Federation: Loosely connects brokers by replicating messages. Ideal for spanning wide area networks (WANs) or connecting brokers managed by different teams. It doesn't share state like a cluster.

Key Components: Upstreams & Policies

Federation relies on two main concepts:

Upstreams: These define the source broker from which messages will be pulled. An upstream specifies the connection details (like URI) of the remote RabbitMQ instance.
Policies: These rules determine which exchanges or queues on your downstream broker should connect to which upstream broker. They use regular expressions to match names.

Enabling the Federation Plugin

Before you can use federation, you need to enable the plugin on all participating RabbitMQ brokers. This is done using the RabbitMQ command-line tool.

Run this command on each broker:

rabbitmq-plugins enable rabbitmq_federation rabbitmq_federation_management

Configuring an Upstream Link

An 'upstream' tells your local broker where to pull messages from. You define it using the rabbitmqctl set_parameter command.

This example sets up an upstream named 'my-upstream' pointing to a remote broker:

rabbitmqctl set_parameter federation-upstream my-upstream \
'{"uri":"amqp://guest:guest@remote-host:5672","expires":3600000}'

Creating a Federation Policy for Exchanges

Once an upstream is defined, you apply it to exchanges using a policy. This policy tells your local broker to federate messages for matching exchanges from the specified upstream.

This policy federates all exchanges starting with 'fed.' from 'my-upstream':

rabbitmqctl set_policy --apply-to exchanges \
fed-exchanges ".^fed\\..*" \
'{"federation-upstream":"my-upstream"}'

How Federated Exchanges Work

With a federated exchange:

A producer publishes messages to an exchange on the upstream broker.
The federation plugin on the downstream broker pulls these messages from the upstream exchange.
The messages then arrive at the corresponding federated exchange on the downstream broker, where local consumers can receive them.

The consumer only interacts with its local (downstream) broker.

Client Example: Consuming from Federated Exchange

Here's a Python consumer that connects to a downstream broker and receives messages from a federated exchange. It doesn't need to know the messages originated from an upstream broker.

To run this, ensure you have pika installed (pip install pika).

import pika
import sys
import os

def main():
    # Connect to the local (downstream) RabbitMQ broker
    connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
    channel = connection.channel()

    # Declare the exchange that is federated from an upstream broker
    # (e.g., using the policy created in previous steps for 'fed_logs')
    channel.exchange_declare(exchange='fed_logs', exchange_type='fanout', durable=True)

    result = channel.queue_declare(queue='', exclusive=True)
    queue_name = result.method.queue

    channel.queue_bind(exchange='fed_logs', queue=queue_name)

    print(' [*] Waiting for federated messages. To exit press CTRL+C')

    def callback(ch, method, properties, body):
        print(f" [x] Received: {body.decode()}")

    channel.basic_consume(queue=queue_name, on_message_callback=callback, auto_ack=True)
    channel.start_consuming()

if __name__ == '__main__':
    try:
        main()
    except KeyboardInterrupt:
        print(' Interrupted')
        try:
            sys.exit(0)
        except SystemExit:
            os._exit(0)

Federating Queues

You can also federate queues. When a queue is federated, messages published to that queue on the upstream broker will be pulled and added to the corresponding queue on the downstream broker.

The policy setup is very similar, just specify --apply-to queues:

rabbitmqctl set_policy --apply-to queues \
fed-queues ".^fed\\..*" \
'{"federation-upstream":"my-upstream"}'

Quick Check on Federation

Which of the following best describes the primary use case for RabbitMQ Federation?

対話的なレッスンで答える

Recap: Federation for Distributed Messaging

In this lesson, you learned about the RabbitMQ Federation plugin:

It allows you to connect RabbitMQ brokers across different locations.
It uses upstreams to define source brokers and policies to apply federation rules.
Federation differs from clustering by offering loose coupling, suitable for WANs.
You can federate both exchanges and queues, enabling flexible message distribution in a distributed system.

This powerful plugin helps you build robust, geographically distributed messaging architectures.

無料で開始

AI チューターと学ぶ RabbitMQ Messaging & Async Systems — 無料

ブラウザでリアルコードを書いて実行し、24/7 の AI チューターから瞬時にサポートを受け、ウェブまたはアプリで続きから学習できます。

コース: 11
レッスン: 44

無料で学習を始めるコース全体を表示

よくある質問

「クラスタリング向けFederationプラグイン」レッスンは無料ですか？

はい。「クラスタリング向けFederationプラグイン」の完全なテキストはこのウェブで無料で読めます。インタラクティブに演習し（組み込みコードエディタと24時間対応のAIチューター）、RabbitMQ Messaging & Async Systemsコースの残りをアンロックするには、CoddyKit PROにアップグレードしてください。 RabbitMQ Messaging & Async Systemsコースには全4レッスンが含まれています。

「クラスタリング向けFederationプラグイン」で何を学びますか？

Federationプラグインを使って、複雑なネットワーク設定なしに複数のRabbitMQブローカーを論理クラスターとして接続する方法を学びます。データセンター間にまたがる分散メッセージングシステムを構築します。ブラウザで直接実行するハンズオンコードでRabbitMQ Messaging & Async Systemsを演習し、24時間対応のAIチューターがレッスンを進める中での質問に答えます。

RabbitMQ Messaging & Async Systemsを始めるのに経験は必要ですか？

事前経験は必要ありません。CoddyKitのRabbitMQ Messaging & Async Systemsは初級者から上級者向けに構成されているため、ここから始めるか最初から始めて、自分のペースで進むことができます。これはレッスン3/4です。

「クラスタリング向けFederationプラグイン」レッスンにはどのくらい時間がかかりますか？

ほとんどのCoddyKitレッスンは約5～10分かかります。各レッスンはコンパクトでインタラクティブなので、着実に進歩し、ウェブとアプリ全体で正確に前回の場所から再開できます。

このRabbitMQ Messaging & Async Systemsレッスンでコードを書いて実行できますか？

はい。すべてのRabbitMQ Messaging & Async Systemsレッスンに組み込みコードエディタが含まれているため、ブラウザでリアルコードを書いて実行し、即座のAIフィードバックを取得できます。ローカル設定は不要です。

このコースのすべてのレッスン

Delayed Messagesプラグイン
フェデレーション向けShovelプラグイン
クラスタリング向けFederationプラグイン
メッセージの重複排除とConsistent Hash Exchangeプラグイン

← RabbitMQ Messaging & Async Systemsに戻る