الرئيسية / Enterprise / حبّة المراسلة المدفوعة مقابل المراسلة التفاعلية
Enterprise متقدم

حبّة المراسلة المدفوعة مقابل المراسلة التفاعلية

استبدل حبّات JMS المدفوعة بالرسائل بـ MicroProfile Reactive Messaging لمعالجة أحداث أبسط.

مقارنة الكود
✕ Java EE 
@MessageDriven(activationConfig = {
    @ActivationConfigProperty(
        propertyName = "destinationType",
        propertyValue = "jakarta.jms.Queue"),
    @ActivationConfigProperty(
        propertyName = "destination",
        propertyValue = "java:/jms/OrderQueue")
})
public class OrderMDB implements MessageListener {
    @Override
    public void onMessage(Message message) {
        TextMessage txt = (TextMessage) message;
        processOrder(txt.getText());
    }
}
✓ MicroProfile 4+ 
@ApplicationScoped
public class OrderProcessor {
    @Incoming("orders")
    public void process(Order order) {
        // automatically deserialized from
        // the "orders" channel
        fulfillOrder(order);
    }
}
هل ترى مشكلة في هذا الكود؟ أخبرنا.
لماذا يتفوق الأسلوب الحديث
🪶

كود أدنى

دالة @Incoming واحدة تستبدل فئة MDB وواجهة MessageListener وتهيئة التنشيط.

🔌

مستقل عن الوسيط

بدّل موصلات Kafka أو AMQP أو JMS عبر التهيئة دون تغيير كود التطبيق.

☁️

ملائم للسحابة الأصلية

الضغط الخلفي للتدفقات التفاعلية وبيئة التشغيل الخفيفة يجعله مثالياً للنشر في حاويات.

الأسلوب القديم
Message-Driven Bean
الأسلوب الحديث
Reactive Messaging
منذ JDK
11
الصعوبة
متقدم
دعم JDK
حبّة المراسلة المدفوعة مقابل المراسلة التفاعلية
متاح

متاح منذ MicroProfile 4.0 / SmallRye Reactive Messaging

كيف يعمل

تتطلب حبّات Message-Driven تنفيذ MessageListener وتهيئة خصائص التنشيط وإلغاء تسلسل رسائل JMS يدوياً. تستخدم MicroProfile Reactive Messaging تعليقاً توضيحياً بسيطاً @Incoming على دالة تستقبل كائنات مكتوبة مباشرةً. تُخرَج تهيئة القناة مما يجعل الكود مستقلاً عن وسيط الرسائل وأسهل بكثير في الاختبار.

توثيق ذو صلة
MicroProfile Reactive Messaging Specification ↗ SmallRye Reactive Messaging Documentation ↗
أنماط ذات صلة
Enterprise متوسط

EJB versus CDI

Java EE
@Stateless
public class OrderEJB {
    @EJB
    private InventoryEJB inventory;

    public void placeOrder(Order order) {
        // container-managed transaction
        inventory.reserve(order.getItem());
    }
}
Jakarta EE 8+
@ApplicationScoped
public class OrderService {
    @Inject
    private InventoryService inventory;

    @Transactional
    public void placeOrder(Order order) {
        inventory.reserve(order.getItem());
    }
}
مرر للرؤية الحديث ←
JDK 11+ →
Concurrency متقدم

Structured concurrency

Java 8
ExecutorService exec =
    Executors.newFixedThreadPool(2);
Future<User> u = exec.submit(this::fetchUser);
Future<Order> o = exec.submit(this::fetchOrder);
try {
    return combine(u.get(), o.get());
} finally { exec.shutdown(); }
Java 25 (Preview)
try (var scope = new StructuredTaskScope
        .ShutdownOnFailure()) {
    var u = scope.fork(this::fetchUser);
    var o = scope.fork(this::fetchOrder);
    scope.join().throwIfFailed();
    return combine(u.get(), o.get());
}
مرر للرؤية الحديث ←
JDK 25+ →
Concurrency مبتدئ

Virtual threads

Java 8
Thread thread = new Thread(() -> {
    System.out.println("hello");
});
thread.start();
thread.join();
Java 21+
Thread.startVirtualThread(() -> {
    IO.println("hello");
}).join();
مرر للرؤية الحديث ←
JDK 21+ →
مشاركة 𝕏 🦋 in ⬡