So richten Sie hochverfügbare Messaging-Middleware unter Linux ein

So richten Sie hochverfügbare Nachrichten-Middleware unter Linux ein

Einführung:
Mit der weit verbreiteten Anwendung verteilter Architektur spielt Nachrichten-Middleware eine entscheidende Rolle beim Systemdesign. Die Aufrechterhaltung einer hohen Verfügbarkeit der Nachrichten-Middleware ist für den stabilen Betrieb des Systems von entscheidender Bedeutung. In diesem Artikel wird die Einrichtung hochverfügbarer Nachrichten-Middleware unter Linux vorgestellt und entsprechende Codebeispiele bereitgestellt.

1. Was ist Hochverfügbarkeits-Nachrichten-Middleware? Hochverfügbarkeit bedeutet normalerweise, dass ein System oder Dienst bei einem Ausfall weiterlaufen und so weit wie möglich in den normalen Betriebszustand zurückversetzt werden kann. Als wichtige verteilte Systemkomponente ist die Nachrichten-Middleware auf Hochverfügbarkeit ausgelegt, um sicherzustellen, dass die Nachrichten-Middleware unter allen Umständen verfügbar bleibt und eine zuverlässige Zustellung von Nachrichten gewährleistet ist.

Unter Linux stehen viele ausgereifte Nachrichten-Middleware zur Auswahl, z. B. RabbitMQ, Kafka, ActiveMQ usw. In diesem Artikel wird RabbitMQ als Beispiel verwendet, um die Einrichtung einer hochverfügbaren Nachrichten-Middleware unter Linux vorzustellen.

1. RabbitMQ installieren

   Zuerst müssen wir RabbitMQ unter Linux installieren. Am Beispiel von Ubuntu können Sie zur Installation den folgenden Befehl verwenden:
   

   sudo apt-get install rabbitmq-server

   Nach dem Login kopieren

RabbitMQ-Cluster konfigurieren
2. Um eine hohe Verfügbarkeit zu erreichen, müssen wir einen RabbitMQ-Cluster konfigurieren, der mehrere RabbitMQ-Knoten enthält. Auf jedem Knoten müssen wir Folgendes konfigurieren:
   

Verwenden Sie den folgenden Befehl, um die RabbitMQ-Konfigurationsdatei zu bearbeiten:

sudo nano /etc/rabbitmq/rabbitmq.conf

cluster_formation.peer_discovery_backend = rabbit_peer_discovery_aws
cluster_formation.aws.region = us-east-1
cluster_formation.aws.access_key_id = YOUR_ACCESS_KEY
cluster_formation.aws.secret_access_key = YOUR_SECRET_KEY
cluster_formation.aws.tag.Cluster = YOUR_CLUSTER_TAG
cluster_formation.aws.back_off_base = 2
cluster_formation.aws.back_off_multiplier = 1.2

Verwenden Sie den folgenden Befehl, um den RabbitMQ-Knoten zu starten:

sudo rabbitmq-server

Um weitere Knoten zum Cluster hinzuzufügen, verwenden Sie den folgenden Befehl:

sudo rabbitmqctl stop_app
sudo rabbitmqctl join_cluster rabbit@node1
sudo rabbitmqctl start_app

der Name des Knotens ist, der gestartet wurde. node1

Ermöglichen Sie die zuverlässige Zustellung von Nachrichten
3. Um eine zuverlässige Zustellung von Nachrichten sicherzustellen, können wir den von RabbitMQ bereitgestellten dauerhaften Nachrichten- und Freigabebestätigungsmechanismus verwenden.
   

Beim Senden einer Nachricht können Sie die Nachricht als persistent markieren, um sicherzustellen, dass die Nachricht nicht verloren geht, wenn der RabbitMQ-Knoten ausfällt. Ein Beispiel lautet wie folgt:

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

channel.queue_declare(queue='hello', durable=True)  # 声明队列为持久化的

channel.basic_publish(
    exchange='',
    routing_key='hello',
    body='Hello World!',
    properties=pika.BasicProperties(delivery_mode=2)  # 设置消息持久化
)

Durch die Aktivierung des Release-Bestätigungsmechanismus können Sie sicherstellen, dass die Nachricht erfolgreich von RabbitMQ empfangen wird. Ein Beispiel ist wie folgt:

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

channel.queue_declare(queue='hello')

channel.confirm_delivery()  # 启用发布确认机制

def on_delivery_confirmation(frame):
    if frame.method.NAME == 'Basic.Ack':
        print('Message successfully delivered to RabbitMQ')
    else:
        print('Message failed to be delivered to RabbitMQ')

channel.add_on_delivery_callback(on_delivery_confirmation)

channel.basic_publish(
    exchange='',
    routing_key='hello',
    body='Hello World!'
)

Dieser Artikel stellt vor, wie man hochverfügbare Nachrichten-Middleware unter Linux einrichtet und stellt Beispielcode für RabbitMQ bereit. In tatsächlichen Anwendungen sind weitere Konfigurationen und Optimierungen entsprechend den spezifischen Anforderungen erforderlich. Durch den rationellen Einsatz hochverfügbarer Nachrichten-Middleware können die Robustheit und Zuverlässigkeit des Systems verbessert und eine zuverlässige Zustellung von Nachrichten in einer verteilten Umgebung sichergestellt werden.

RabbitMQ-Dokumentation: https://www.rabbitmq.com/
1. Kafka-Dokumentation: https://kafka.apache.org/
2. ActiveMQ-Dokumentation: https://activemq.apache.org /

Das obige ist der detaillierte Inhalt vonSo richten Sie hochverfügbare Messaging-Middleware unter Linux ein. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!