نمط عمل Java RabbitMQ (مستهلكون متعددون)

وضع العمل في RabbitMQ يكون عن طريق تكوين عدة مستهلكين لاستهلاك الرسائل من طابور واحد، مما يمكن أن يحسن من سرعة معالجة الرسائل بشكل متزامن. يتم عرض العمارة كما هو موضح في الرسم البياني التالي.

ملاحظة: بغض النظر عن الوضع الذي يُستخدم في RabbitMQ، يدعم كل طابور عدة مستهلكين. بالنسبة لنفس الطابور، ستتم معالجة الرسالة من قبل مستهلك واحد فقط.

1. البرنامج التعليمي الأولي

يرجى قراءة الأقسام التالية أولاً لفهم المعرفة ذات الصلة.

• مفاهيم أساسية في RabbitMQ
• وضع العمل في RabbitMQ
• دليل بدء سريع لـ Java في RabbitMQ (إلزامي، حيث لن تكرر الأقسام التالية الشفرة بل ستعرض الشفرة المهمة فقط)

2. تكوين عدة مستهلكين

من خلال استخدام تعليق RabbitListener وتكوين معلمة concurrency، يمكنك بدء 10 مستهلكين لمعالجة الرسائل بشكل متزامن باستخدام الشفرة التالية.

package com.tizi365.rabbitmq.listener;

import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component
// قم بتعريف مستمع الرسالة وتحديد الطابور الذي يجب الاستماع إليه من خلال معلمة queues
// المعلمة المهمة: تعداد يمثل عدد المستهلكين الذي يجب بدؤهم لمستمع الحالي، ونوعها هو سلسلة نصية
@RabbitListener(queues = "hello", concurrency = "10")
public class HelloListener {
	// استخدام RabbitHandler لتحديد معالج الرسالة الذي يُستخدم لتنفيذ منطق معالجة الرسالة
    @RabbitHandler
    public void receive(String msg) {
        System.out.println("مستهلك - استقبل رسالة '" + msg + "'");
    }
}