ApsaraMQ for RocketMQ：Penyaringan pesan

Skenario

ApsaraMQ for RocketMQ adalah layanan middleware berbasis model publikasi-langganan (pub/sub) yang digunakan untuk mengintegrasikan bisnis hulu dan hilir. Dalam skenario bisnis nyata, pesan dalam topik diproses oleh aplikasi hilir dengan logika konsumsi yang berbeda. Setiap aplikasi hanya perlu mengonsumsi pesan yang sesuai dengan logika konsumsinya.

Anda dapat menggunakan fitur penyaringan pesan yang disediakan oleh ApsaraMQ for RocketMQ untuk secara efisien menyaring pesan yang dibutuhkan oleh konsumen. Ini mencegah sejumlah besar pesan yang tidak relevan dikirimkan ke konsumen dan mengurangi beban kerja di sistem hilir.

Fitur penyaringan pesan dari ApsaraMQ for RocketMQ menyelesaikan masalah penyaringan pesan dalam topik dan digunakan dalam skenario di mana diperlukan pengkategorian rinci untuk jalur bisnis yang sama. Jika Anda ingin mengelola pesan untuk jalur bisnis yang berbeda, kami sarankan menggunakan topik yang berbeda.

Ikhtisar

Apa itu penyaringan pesan?

Fitur penyaringan pesan dari ApsaraMQ for RocketMQ menyaring pesan berdasarkan kondisi yang dikonfigurasi oleh konsumen dan mengirimkan pesan yang memenuhi kondisi tersebut kepada konsumen.

Setelah atribut pesan dan tag didefinisikan untuk produsen dan konsumen, pesan disaring dan dicocokkan berdasarkan kondisi penyaringan pada broker ApsaraMQ for RocketMQ. Hanya pesan yang memenuhi kondisi penyaringan yang dikirimkan kepada konsumen.

Bagaimana cara kerja penyaringan pesan?

Klasifikasi

Untuk informasi lebih lanjut, lihat Penyaringan Berbasis Tag dan Penyaringan Berbasis Atribut SQL.

Konsistensi langganan

Ekspresi penyaringan merupakan bagian dari langganan. Berdasarkan model domain ApsaraMQ for RocketMQ, ekspresi penyaringan langganan konsumen dalam grup konsumen yang sama harus sama. Jika tidak, pesan tertentu tidak dapat dikonsumsi. Untuk informasi lebih lanjut, lihat Langganan.

Penyaringan berbasis tag

Penyaringan berbasis tag adalah metode penyaringan dasar yang disediakan oleh ApsaraMQ for RocketMQ. Dalam metode ini, pesan dicocokkan berdasarkan tag yang ditentukan oleh produser. Konsumen menggunakan tag untuk menentukan pesan yang ingin mereka konsumsi.

Skenario contoh

Pengaturan tag

• Sebelum produser mengirim pesan, produser hanya dapat menambahkan satu tag ke setiap pesan.

• Setiap tag terdiri dari serangkaian karakter. Kami sarankan setiap tag tidak melebihi 128 karakter.

• Tag bersifat peka huruf besar/kecil. Misalnya, TAG A dan tag a adalah tag yang berbeda.

Aturan penyaringan

Kode contoh

• Tentukan tag sebelum pengiriman pesan

  Message message = messageBuilder.setTopic("topic")
                  // Kunci pesan. Anda dapat menggunakan kunci untuk mencari pesan.
                  .setKeys("messageKey")
                  // Tag pesan. Konsumen dapat menggunakan tag untuk menyaring pesan.
                  // Dalam contoh ini, tag pesan diatur ke TagA.
                  .setTag("TagA")
                  // Isi pesan.
                  .setBody("messageBody".getBytes())
                  .build();
                      

• Berlangganan pesan yang cocok dengan satu tag

  String topic = "Topik Anda";
  // Berlangganan pesan yang memiliki TagA.
  FilterExpression filterExpression = new FilterExpression("TagA", FilterExpressionType.TAG);
  pushConsumer.subscribe(topic, filterExpression);

• Berlangganan pesan yang cocok dengan beberapa tag

  String topic = "Topik Anda";
  // Berlangganan pesan yang memiliki TagA, TagB, atau TagC.
  FilterExpression filterExpression = new FilterExpression("TagA||TagB||TagC", FilterExpressionType.TAG);
  pushConsumer.subscribe(topic, filterExpression);

• Berlangganan semua pesan dalam topik

  String topic = "Topik Anda";
  // Berlangganan semua pesan.
  FilterExpression filterExpression = new FilterExpression("*", FilterExpressionType.TAG);
  pushConsumer.subscribe(topic, filterExpression);

Penyaringan SQL berbasis atribut

Penyaringan SQL berbasis atribut adalah metode penyaringan lanjutan yang disediakan oleh ApsaraMQ for RocketMQ. Dalam metode ini, pesan dicocokkan berdasarkan pasangan nilai-kunci yang ditentukan oleh produser. Saat produser mengirim pesan, produser dapat menentukan beberapa atribut untuk setiap pesan. Kemudian, konsumen dapat menentukan atribut dalam ekspresi SQL untuk menerima pesan tertentu.

Skenario contoh

Pengaturan atribut pesan

• Sebelum produser mengirim pesan, produser dapat menentukan atribut kustom untuk setiap pesan. Setiap atribut adalah pasangan nilai-kunci kustom.

  • Kunci atribut dapat berisi huruf, angka, dan garis bawah (_).

  • Kunci atribut harus dimulai dengan huruf atau garis bawah (_).

• Beberapa atribut dapat ditentukan untuk setiap pesan.

Aturan penyaringan

Anda harus mengikuti sintaksis SQL-92 saat menulis ekspresi filter. Tabel berikut menjelaskan sintaksis tersebut.

Kode contoh

• Tentukan tag dan atribut kustom sebelum pengiriman pesan

  Message message = messageBuilder.setTopic("topic")
                  // Kunci pesan. Anda dapat menggunakan kunci untuk mencari pesan.
                  .setKeys("messageKey")
                  // Tag pesan. Konsumen dapat menggunakan tag untuk menyaring pesan.
                  // Dalam contoh ini, tag pesan diatur ke messageTag.
                  .setTag("messageTag")
                  // Anda juga dapat menentukan atribut kustom untuk pesan, seperti lingkungan, wilayah, dan cabang logis.
                  // Dalam contoh ini, atribut kustom adalah region dan nilai atributnya adalah Hangzhou.
                  .addProperty("Region", "Hangzhou")
                  // Isi pesan.
                  .setBody("messageBody".getBytes())
                  .build();

• Berlangganan pesan yang cocok dengan satu atribut

  String topic = "topik";
  // Berlangganan hanya pesan yang nilai atribut wilayahnya adalah Hangzhou.
  FilterExpression filterExpression = new FilterExpression("Region IS NOT NULL AND Region='Hangzhou'", FilterExpressionType.SQL92);
  simpleConsumer.subscribe(topic, filterExpression);

• Berlangganan pesan yang cocok dengan beberapa atribut

  String topic = "topik";
  // Berlangganan pesan yang nilai atribut wilayahnya adalah Hangzhou dan nilai atribut harga lebih besar dari 30.
  FilterExpression filterExpression = new FilterExpression("Region IS NOT NULL AND price IS NOT NULL AND Region = 'Hangzhou' AND price > 30", FilterExpressionType.SQL92);
  simpleConsumer.subscribe(topic, filterExpression);

• Berlangganan semua pesan dalam topik

  String topic = "topik";
  // Berlangganan semua pesan.
  FilterExpression filterExpression = new FilterExpression("True", FilterExpressionType.SQL92);
  simpleConsumer.subscribe(topic, filterExpression);

Catatan penggunaan

Rencanakan topik dengan baik dan tentukan tag

FAQ

Mengapa pesan hilang saat beberapa konsumen berlangganan tag berbeda dalam satu topik?

Penyebab yang mungkin: Jika konsumen tersebut termasuk dalam grup konsumen yang sama, tag yang dilanggan oleh konsumen harus sama. Jika tidak, ketidaksesuaian langganan terjadi dan pesan tertentu hilang.

Bagaimana cara menghitung jumlah pesan yang dikonsumsi oleh konsumen saat kondisi penyaringan ditentukan?

Jumlah pesan yang dikonsumsi oleh konsumen dihitung setelah kondisi penyaringan ditentukan.

Mengapa pesan terakumulasi dalam grup meskipun konsumen online tidak mengonsumsi pesan?

Jika Anda menggunakan penyaringan SQL atau penyaringan berbasis tag untuk menyaring pesan, pesan yang tidak memenuhi kondisi penyaringan terakumulasi. Item berikut menjelaskan cara menghitung jumlah pesan terakumulasi dalam skenario tersebut:

Referensi

Untuk informasi tentang kode contoh lengkap untuk perpesanan, lihat Ikhtisar.