ApsaraMQ for RocketMQ:Istilah

• Topic

  • Topic adalah wadah tingkat teratas dalam ApsaraMQ for RocketMQ untuk transmisi dan penyimpanan pesan. Topic digunakan untuk mengidentifikasi pesan-pesan yang termasuk dalam kategori bisnis yang sama, dan diidentifikasi secara unik berdasarkan namanya. Untuk informasi selengkapnya, lihat Topics.

• Lite topic

  • Jika sebuah topic bertipe Lite, lite topics dapat dibuat di bawahnya. Wadah penyimpanan pesan diidentifikasi secara unik oleh kombinasi topic dan lite topic tersebut. Secara default, setiap wadah penyimpanan terdiri dari satu queue. Untuk informasi selengkapnya, lihat Lite topic model.

• Message type

  • Message type adalah klasifikasi pesan dalam ApsaraMQ for RocketMQ berdasarkan karakteristik transmisinya. Message types digunakan untuk manajemen tipe dan verifikasi keamanan. ApsaraMQ for RocketMQ mendukung normal messages, ordered messages, transactional messages, serta scheduled and delayed messages.

• Message queue

  • Message queue adalah wadah aktual untuk menyimpan dan mentransmisikan pesan dalam ApsaraMQ for RocketMQ, sekaligus merupakan unit penyimpanan pesan terkecil. Semua topic dalam ApsaraMQ for RocketMQ terdiri dari beberapa queue. Desain ini memungkinkan horizontal splitting queue dan penyimpanan streaming dalam setiap queue. Queue diidentifikasi secara unik berdasarkan QueueId-nya. Untuk informasi selengkapnya, lihat Message queues.

• Message

  • Message adalah unit terkecil dalam transmisi data di ApsaraMQ for RocketMQ. Seorang produsen mengemas muatan (payload) dan properti tambahan dari data bisnis ke dalam sebuah message lalu mengirimkannya ke server ApsaraMQ for RocketMQ. Server kemudian mengirimkan message tersebut ke konsumen untuk diproses berdasarkan semantik yang relevan. Untuk informasi selengkapnya, lihat Messages.

    ID pesan di ApsaraMQ for RocketMQ bersifat unik secara global dan tidak akan berulang di antara topic yang berbeda. Namun, dalam skenario seperti fluktuasi jaringan atau percobaan ulang akibat kegagalan konsumsi, sebuah pesan mungkin dikirimkan beberapa kali. Terapkan pemrosesan idempoten di sisi konsumen dengan menggunakan message key, bukan mengandalkan message ID untuk deduplikasi.

    ApsaraMQ for RocketMQ tidak mengubah konten pesan yang dikirim oleh produsen, termasuk kapitalisasi field, format, atau atribut lainnya. Data dalam isi pesan tetap dalam kondisi aslinya sebagaimana dikirim.

• Message view

  • Message view adalah antarmuka read-only yang disediakan oleh ApsaraMQ for RocketMQ dari perspektif developer. Message view memungkinkan Anda membaca berbagai properti dan muatan (payload) sebuah pesan, tetapi Anda tidak dapat mengubah pesan tersebut.

• Message tag

  • Message tag adalah properti untuk klasifikasi pesan detail halus dalam ApsaraMQ for RocketMQ. Message tag memungkinkan sub-kategorisasi pesan di bawah suatu topic. Konsumen dapat melakukan filtering detail halus dengan berlangganan tag tertentu. Untuk informasi selengkapnya, lihat Message filtering.

• Message offset

  • Pesan disimpan dalam queue suatu topic sesuai urutan kedatangannya di server ApsaraMQ for RocketMQ. Setiap pesan dalam sebuah queue memiliki koordinat unik bertipe Long yang disebut message offset. Untuk informasi selengkapnya, lihat Consumer progress management.

• Consumer offset

  • Pesan tidak langsung dihapus dari queue setelah dikonsumsi. Untuk setiap consumer group, ApsaraMQ for RocketMQ mencatat offset dari pesan terakhir yang telah dikonsumsi. Offset yang terekam ini disebut consumer offset. Untuk informasi selengkapnya, lihat Consumer progress management.

• Message key

  • Message key adalah properti indeks untuk pesan yang disediakan oleh ApsaraMQ for RocketMQ. Dengan menetapkan message key, Anda dapat dengan cepat menemukan konten pesan yang sesuai.

• Producer

  • Producer adalah entitas yang sedang berjalan dalam sistem ApsaraMQ for RocketMQ yang membangun dan mengirim pesan ke server. Producer biasanya diintegrasikan ke dalam sistem bisnis. Mereka mengemas data bisnis ke dalam pesan ApsaraMQ for RocketMQ lalu mengirimkannya ke server. Untuk informasi selengkapnya, lihat Producers.

• Transaction checker

  • Transaction checker adalah listener yang digunakan oleh produsen dalam ApsaraMQ for RocketMQ untuk melakukan pemeriksaan transaksi lokal dan memulihkan transaksi abnormal. Transaction checker harus memeriksa dan menentukan resolusi pesan transaksional berdasarkan status data bisnis. Untuk informasi selengkapnya, lihat Transactional messages.

• Transaction resolution

  • Transaction resolution adalah pengenal status commit dari pesan transaksional selama proses pengiriman di ApsaraMQ for RocketMQ. Server menggunakan transaction resolution untuk mengontrol apakah pesan transaksional tersebut di-commit dan dikirimkan. Transaction resolutions meliputi commit, rollback, dan pending. Untuk informasi selengkapnya, lihat Transactional messages.

• Consumer group

  • Consumer group adalah grup load balancing dalam sistem ApsaraMQ for RocketMQ yang berisi beberapa konsumen dengan perilaku konsumsi identik. Berbeda dengan konsumen, consumer group adalah resource logis, bukan entitas yang berjalan. Di ApsaraMQ for RocketMQ, inisialisasi beberapa konsumen dalam satu consumer group mencapai skalabilitas horizontal untuk performa konsumsi dan pemulihan bencana berdaya tinggi. Untuk informasi selengkapnya, lihat Consumer groups.

• Consumer

  • Consumer adalah entitas yang berjalan dalam ApsaraMQ for RocketMQ yang menerima dan memproses pesan. Consumer biasanya diintegrasikan ke dalam sistem bisnis. Mereka mengambil pesan dari server ApsaraMQ for RocketMQ dan mengubahnya menjadi informasi yang dapat dipahami oleh logika bisnis untuk diproses. Untuk informasi selengkapnya, lihat Consumers.

    Metode dorong (push) pesan bergantung pada mode konsumsi. Dalam mode clustering consumption, pesan didistribusikan berdasarkan queue. Pesan dalam queue yang sama dikirimkan secara serial, sedangkan pesan di queue berbeda dapat didorong secara konkuren. Dalam mode broadcasting consumption, setiap pesan didorong ke semua konsumen. Untuk ordered messages, pesan dikirimkan secara berurutan dalam queue yang sama, dan pesan berikutnya tidak dikirimkan hingga pesan sebelumnya selesai diproses sepenuhnya.

• Consumption result

  • Consumption result dikembalikan oleh listener PushConsumer di ApsaraMQ for RocketMQ setelah selesai memproses sebuah pesan. Consumption result menunjukkan apakah pesan tersebut diproses dengan benar. Hasil konsumsi meliputi success dan failure.

• Subscription

  • Subscription adalah aturan dan konfigurasi status tentang cara konsumen mengambil dan memproses pesan dalam sistem ApsaraMQ for RocketMQ. Subscription didaftarkan secara dinamis oleh consumer group ke server. Selama transmisi pesan berikutnya, aturan filtering yang didefinisikan dalam subscription digunakan untuk pencocokan pesan dan pemeliharaan progres konsumen. Untuk informasi selengkapnya, lihat Subscriptions.

• Message filtering

  • Konsumen dapat memfilter pesan dengan berlangganan tag pesan (Tags) tertentu untuk memastikan hanya menerima kumpulan pesan yang telah difilter. Perhitungan dan pencocokan aturan filtering dilakukan di server ApsaraMQ for RocketMQ. Untuk informasi selengkapnya, lihat Message filtering.

• Consumer offset resetting

  • Fitur ini mengatur ulang progres konsumsi consumer group untuk topik yang dilangganan ke titik waktu tertentu. Setelah pengaturan ulang, konsumen menerima pesan yang dikirim oleh produsen ke server ApsaraMQ for RocketMQ setelah titik waktu yang ditentukan. Untuk informasi selengkapnya, lihat Reset consumer offsets.

• Message trace

  • Message trace menyediakan informasi lengkap mengenai jejak sebuah pesan. Informasi ini dikumpulkan dari data seperti waktu dan lokasi dari setiap node terkait saat pesan berpindah dari produsen ke konsumen. Message trace memungkinkan Anda melihat dengan jelas seluruh jalur pesan mulai dari produsen, melalui server ApsaraMQ for RocketMQ, hingga ke konsumen. Hal ini membantu dalam troubleshooting dan diagnosis masalah.

• Message accumulation

  • Message accumulation terjadi ketika produsen mengirim pesan ke server ApsaraMQ for RocketMQ lebih cepat daripada kecepatan konsumen memprosesnya. Pesan yang belum dikonsumsi disimpan di server ApsaraMQ for RocketMQ.

• Transactional message

  • Transactional message adalah tipe pesan lanjutan yang disediakan oleh ApsaraMQ for RocketMQ. Tipe ini menjamin konsistensi akhir antara produksi pesan dan transaksi lokal dalam skenario terdistribusi.

• Scheduled and delayed message

  • Scheduled and delayed message adalah tipe pesan lanjutan yang disediakan oleh ApsaraMQ for RocketMQ. Setelah pesan dikirim ke server, pesan tersebut baru dapat dikonsumsi oleh konsumen setelah waktu tertentu. Dengan menetapkan waktu tunda tertentu, Anda dapat mencapai efek penjadwalan dan pemicuan tertunda dalam skenario terdistribusi.

• Ordered message

  • Ordered message adalah tipe pesan lanjutan yang disediakan oleh ApsaraMQ for RocketMQ. Tipe ini menjamin bahwa konsumen menerima pesan dalam urutan yang sama dengan saat dikirim. Hal ini memungkinkan pemrosesan berurutan dalam skenario bisnis.

• Lite message

  • Lite message adalah tipe pesan lanjutan yang disediakan oleh ApsaraMQ for RocketMQ. Tipe ini mendukung pembuatan dinamis jutaan lite topics dan menyediakan fitur seperti manajemen siklus hidup otomatis serta langganan berkinerja-tinggi. Untuk informasi selengkapnya, lihat Lite topic model.

FAQ