ApsaraMQ for RocketMQ:Abonelik tutarlılığı

Abonelik tutarlılığı nedir?

ApsaraMQ for RocketMQ ortamında bir tüketici grubu, birden fazla tüketici örneğinden oluşur. Çoğu dağıtık uygulamada, tek bir tüketici grubuna bağlı birden çok tüketici örneği bulunur.

ApsaraMQ for RocketMQ bağlamında abonelik; bir tüketici grubu ile belirli bir konu arasındaki ilişkiyi ifade eder. Bu ilişki, abone olunan konudaki mesajları filtrelemek için kullanılan koşulları da kapsar.

Aboneliklerin tutarlı olmasını sağlamak için, aynı grup kimliğiyle tanımlanan tüm tüketici örneklerinin aşağıdaki açılardan birebir eşleşmesi gerekir:

• Tüketici örneklerinin abone olduğu konular aynı olmalıdır.

  Örneğin, Tüketici 1 A Konusu ve B Konusu'na aboneyse, aynı gruptaki Tüketici 2 de hem A Konusu'na hem de B Konusu'na abone olmalıdır. Tüketici 2 yalnızca A veya B konusuna abone olamaz ya da A ve C konularına abone olamaz.

• Tüketici örneklerinin konulardaki abone oldukları etiketler; etiket sayısı ve sıralaması dahil olmak üzere tutarlı olmalıdır.

  Örneğin, Tüketici 1 B Konusu'ndaki Tag1||Tag2 etiketlerine aboneyse, aynı gruptaki Tüketici 2 de B Konusu'nda Tag1||Tag2 etiketlerine abone olmalıdır. Tüketici 2 yalnızca Tag1 veya Tag2 etiketine abone olamaz veya B Konusu'nda Tag2||Tag1 şeklinde farklı bir sırayla abone olamaz.

• Bir tüketici grubundaki örnekler birden fazla konuya aboneyse, bu konuların mesaj türleri aynı olmalıdır.

  Örneğin, Tüketici 1 ve Tüketici 2 hem A Konusu'na hem de B Konusu'na aboneyse, her iki konunun da normal mesaj veya sıralı mesaj gibi aynı mesaj türünde olması gerekir. ApsaraMQ for RocketMQ tarafından desteklenen mesaj türleri hakkında bilgi için bkz. Mesaj türleri.

Aşağıdaki görselde tutarlı abonelik ilişkisine bir örnek gösterilmektedir. Farklı kimliklere sahip gruplar farklı konulara abonedir. Her grup C1, C2 ve C3 adlı tüketici örneklerini içerir. Aynı gruptaki tüm tüketici örnekleri aynı konulara ve etiketlere abonedir.

Bir gruptaki tüketici örneklerinin aboneliklerinin tutarlı olup olmadığını nasıl kontrol ederim?

Bir gruptaki tüketici örneklerinin aboneliklerinin tutarlı olup olmadığını kontrol etmek için aşağıdaki adımları izleyin:

1. ApsaraMQ for RocketMQ konsolu üzerinde oturum açın. Instances sayfasında yönetmek istediğiniz örneği bulun ve örneğin adına tıklayarak Instance Details sayfasına gidin.

2. Sol gezinme bölmesinde Groups seçeneğine tıklayın. Açılan sayfada yönetmek istediğiniz tüketici grubunun adına tıklayın.

3. Group Details sayfasının Subscriptions bölümünde tüketici grubunun aboneliklerinin tutarlı olup olmadığını kontrol edin.

Tutarlı abonelik 1: Tek konuda tek etiket

Aşağıdaki görselde C1, C2 ve C3 tüketici örnekleri aynı gruba aittir. Bu örnekler A Konusu'ndaki Tag 1 etiketine abonedir. Bu senaryo abonelik tutarlılığı gereksinimlerini karşılar.

**Sample code of consistent subscription 1**

    Properties properties = new Properties();
    properties.put(PropertyKeyConst.GROUP_ID, "GID_test_1");
    Consumer consumer = ONSFactory.createConsumer(properties);
    consumer.subscribe("TopicA", "Tag1", new MessageListener() {
        public Action consume(Message message, ConsumeContext context) {
            System.out.println(message.getMsgID());
            return Action.CommitMessage;
        }
    });                    

Tutarlı abonelik 2: Tek konuda birden çok etiket

Aşağıdaki görselde C1, C2 ve C3 tüketici örnekleri aynı gruba aittir. Bu örnekler B Konusu'ndaki Tag1||Tag2 etiketlerine abonedir. Böylece tüm tüketici örnekleri B Konusu'ndaki Tag 1 veya Tag 2 etiketli mesajları aynı sırada tüketir. Bu senaryo abonelik tutarlılığı gereksinimlerini karşılar.

**Sample code of consistent subscription 2**

    Properties properties = new Properties();
    properties.put(PropertyKeyConst.GROUP_ID, "GID_test_2");
    Consumer consumer = ONSFactory.createConsumer(properties);
    consumer.subscribe("TopicB", "Tag1||Tag2", new MessageListener() {
        public Action consume(Message message, ConsumeContext context) {
            System.out.println(message.getMsgID());
            return Action.CommitMessage;
        }
    });                    

Tutarlı abonelik 3: Birden çok konuda birden çok etiket

Aşağıdaki görselde C1, C2 ve C3 tüketici örnekleri aynı gruba aittir. Bu örnekler hem A Konusu'na hem de B Konusu'na abonedir. A Konusu için herhangi bir etiket belirtilmemiştir, ancak B Konusu için Tag1||Tag2 etiketleri belirtilmiştir. Bu durumda tüketici örnekleri, A Konusu'ndaki tüm mesajları ve B Konusu'ndaki Tag 1 veya Tag 2 etiketli mesajları aynı sırada tüketir. Bu senaryo abonelik tutarlılığı gereksinimlerini karşılar.

**Sample code of consistent subscription 3**

    Properties properties = new Properties();
    properties.put(PropertyKeyConst.GROUP_ID, "GID_test_3");
    Consumer consumer = ONSFactory.createConsumer(properties);
    consumer.subscribe("TopicA", "*", new MessageListener() {
        public Action consume(Message message, ConsumeContext context) {
            System.out.println(message.getMsgID());
            return Action.CommitMessage;
        }
    });     
    consumer.subscribe("TopicB", "Tag1||Tag2", new MessageListener() {
        public Action consume(Message message, ConsumeContext context) {
            System.out.println(message.getMsgID());
            return Action.CommitMessage;
        }
    });                   

Tutarlı olmayan abonelikler

SSS

Bir tüketici grubu birden fazla konuya abone olabilir mi?

Evet, bir tüketici grubu birden fazla konuya abone olabilir. Tüketici grubu belirli bir konuya abone olduğunda bir abonelik oluşturulur. Tüketici grubundaki tüm tüketici örneklerinin söz konusu konuya abone olduğundan emin olun.

ApsaraMQ for RocketMQ konsolunda bir aboneliği silebilir miyim?

Hayır, ApsaraMQ for RocketMQ konsolunda doğrudan bir aboneliği silemezsiniz. Aboneliği silmek için istemci kodunuzdaki ilgili parametreyi yapılandırmanız gerekir.