IBM MQ ve Sıralı Teslim — Gerçekleşme, Emirden Önce Nasıl İşlendi?

Bir aile bankaya üç fişle geliyor: hesap aç, para yatır, para çek. Fişler doğru sırada. Ama üç gişe fişleri aynı anda alırsa, hesap açılmadan para çekilmeye çalışılabilir.

Kuyruk sırayla verir

IBM MQ gibi bir mesaj kuyruğu, aynı öncelikteki mesajları geldikleri sırayla verir. Java’da bu kuyruklarla çoğu zaman JMS?Terimin tanımını açJMSJakarta Messaging (eski adıyla Java Message Service): Java'da IBM MQ gibi mesaj kuyruklarıyla konuşmak için standart arayüz.Sözlükte gör → arayüzü üzerinden konuşulur.

Tek bir tüketici mesajları teker teker alıp işlerse, işlenme sırası da kuyruktaki sıradır. Emir önce açılır, sonra gerçekleşir, sonra kapanır.

Üç tüketici, bozulan sıra

Sıra, kuyruğun bir özelliğidir; işlemenin değil. Paralel tüketiciler kuyruğu hızlı boşaltır ama sırayı bir anahtara bağlamadıkça korumaz.

Anahtara göre böl

Her mesajın sırası önemli değildir; yalnızca aynı emre ait mesajların sırası önemlidir. Bu yüzden mesajları emir numarasına göre gruplara?Terimin tanımını açmesaj grubuSırası önemli olan mesajları bir anahtarla (örneğin emir numarası) bir araya toplamak. Aynı gruptaki mesajlar tek tüketicide, sırayla işlenir.Sözlükte gör → bölmek yeter.

Gönderen taraf emir numarasından bir kuyruk seçer: aynı emir hep aynı kuyruğa gider. Her kuyruğu tek bir tüketici okur. Emir içinde sıra korunur, farklı emirler yan yana işlenir.

Kendin gör

1. Varsayılanla oynat. Üç tüketici iki turda bitirdi, ama A’nın gerçekleşmesi emir yokken işlendi.
2. “Tek tüketici”yi seç. Sıra doğru, ama altı tur sürdü: A’nın mesajı B’yi de bekletti.
3. “Emre göre grup”u seç. Sıra doğru ve üç turda bitti: A ve B yan yana işlendi.

Tuzaklar

Sırayı tıkayan mesaj. İşlenemeyen bir poison pill?Terimin tanımını açpoison pillKaç kez denenirse denensin işlenemeyecek bir mesaj: bozuk format, geçersiz veri. Yeniden denemek yalnızca arkasındaki mesajları bekletir.Sözlükte gör → geri alınıp yeniden denenir ve arkasındaki her şeyi bekletir. IBM MQ’da kuyruğun backout eşiği ve backout kuyruğu tanımlanır; eşik aşılınca mesaj oraya taşınır ve bir insan bakar.

İşlemeden önce onaylamak. Mesajı alır almaz onaylayıp sonra işlemede hata alırsan mesaj kaybolur. Transacted bir oturum kullan: işlem başarılıysa onayla, değilse geri al.

Kuyruk sayısını değiştirmek. Kuyruk sayısı değişince aynı emir başka bir kuyruğa düşebilir. Yoldaki mesajlar bitmeden sayıyı değiştirme.

Aşağıda emir mesajlarını emir numarasına göre kuyruklara dağıtan bir yönlendirici ve her kuyruğu tek tüketiciyle okuyan Spring JMS dinleyicileri var.

1
package com.bank.oms.mq;
2

3
import org.springframework.jms.core.JmsTemplate;
4
import org.springframework.stereotype.Component;
5

6
@Component
7
public class OrderEventRouter {
8

9
    static final int PARTITIONS = 4;
10

11
    private final JmsTemplate jms;
12

13
    public OrderEventRouter(JmsTemplate jms) {
14
        this.jms = jms;
15
    }
16

17
    public void publish(OrderEvent event) {
18
        // Same order, same queue: its events keep their order.
19
        int partition = Math.floorMod(event.orderId().hashCode(), PARTITIONS);
20
        jms.convertAndSend("OMS.ORDER.EVENTS." + partition, event);
21
    }
22
}

1
package com.bank.oms.mq;
2

3
import org.springframework.jms.annotation.JmsListener;
4
import org.springframework.stereotype.Component;
5

6
@Component
7
public class OrderEventListener {
8

9
    private final OrderBook orders;
10

11
    public OrderEventListener(OrderBook orders) {
12
        this.orders = orders;
13
    }
14

15
    // One consumer per queue. An exception rolls the session back and MQ
16
    // redelivers; past the backout threshold MQ moves the message aside.
17
    @JmsListener(destination = "OMS.ORDER.EVENTS.0", concurrency = "1")
18
    @JmsListener(destination = "OMS.ORDER.EVENTS.1", concurrency = "1")
19
    @JmsListener(destination = "OMS.ORDER.EVENTS.2", concurrency = "1")
20
    @JmsListener(destination = "OMS.ORDER.EVENTS.3", concurrency = "1")
21
    public void on(OrderEvent event) {
22
        orders.apply(event);
23
    }
24
}

1
ibm:
2
  mq:
3
    queue-manager: QM_OMS
4
    channel: OMS.SVRCONN
5
    conn-name: mq.internal(1414)
6
spring:
7
  jms:
8
    listener:
9
      session:
10
        transacted: true   # acknowledge only after apply() succeeds
11
# On the queue manager, per queue: BOTHRESH(3) BOQNAME('OMS.ORDER.EVENTS.BACKOUT')

Kendini sına