PricingLoginStart free
RabbitMQ Messaging & Async Systems · Pelajaran

Pesan dan Antrean Persisten

Pahami cara membuat pesan dan antrean tetap persisten agar dapat bertahan saat broker dimulai ulang. Pastikan data penting Anda tidak pernah hilang, bahkan dalam lingkungan yang tidak stabil.

Pelajaran 1 dari 411 langkah

Pesan dan Antrean Persisten adalah pelajaran RabbitMQ Messaging & Async Systems gratis di CoddyKit. Ini adalah pelajaran 1 dari 4. Kamu bisa membaca pelajaran lengkapnya di bawah secara gratis — lalu praktikkan langsung di browser dengan editor kode bawaan dan tutor AI 24/7. Ini adalah bagian dari jalur belajar RabbitMQ Messaging & Async Systems, dan progresmu tersinkronisasi di web dan aplikasi CoddyKit. Kursus RabbitMQ Messaging & Async Systems mencakup 4 pelajaran total.

Bagian dari pelajaran ini belum diterjemahkan dan ditampilkan dalam bahasa Inggris.

Why Persistence Matters

Imagine your RabbitMQ broker suddenly restarts. What happens to the messages and queues you've set up?

By default, many things are temporary. If your broker crashes or restarts, non-persistent messages and non-durable queues might be lost forever. This is where persistence comes in.

Persistence ensures that critical data—your queues and messages—survive broker restarts, making your messaging system robust and reliable.

Making Queues Durable

The first step to reliability is making your queues durable. A durable queue will survive a RabbitMQ broker restart.

When you declare a queue, you pass a durable parameter. Setting this to true tells RabbitMQ to save the queue's definition to disk.

  • Durable: Queue definition saved; survives restarts.
  • Non-durable: Queue definition lost on restart.

Remember, once a queue is declared durable (or not), you can't change its durability later without deleting and re-creating it.

Code: Declaring a Durable Queue

Here's how you declare a durable queue in Java. Notice the true for the second parameter in queueDeclare.

Try running this! Even if you stop and restart RabbitMQ, this queue named 'my_durable_queue' will still be there.

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

public class DeclareDurableQueue {
  private final static String QUEUE_NAME = "my_durable_queue";

  public static void main(String[] argv) throws Exception {
    ConnectionFactory factory = new ConnectionFactory();
    factory.setHost("localhost");
    try (Connection connection = factory.newConnection();
         Channel channel = connection.createChannel()) {
      
      // Declare a durable queue
      channel.queueDeclare(QUEUE_NAME, true, false, false, null);
      System.out.println("Queue '" + QUEUE_NAME + "' declared as durable.");
    }
  }
}

Understanding Message Persistence

Even if a queue is durable, messages sent to it are not automatically saved to disk. For messages to survive a broker restart, they must also be marked as persistent.

When a message is persistent, RabbitMQ writes it to disk as soon as it's received by the broker, before delivering it to consumers.

This ensures that if the broker goes down, the message can be recovered from disk when the broker restarts.

Code: Sending a Persistent Message

To send a persistent message, you need to set the deliveryMode to 2 (which means persistent) or use MessageProperties.PERSISTENT_TEXT_PLAIN for convenience.

Run this producer, then try to restart your RabbitMQ broker. After restarting, if you run a consumer, you should still receive this message!

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.MessageProperties;

public class SendPersistentMessage {
  private final static String QUEUE_NAME = "my_durable_queue";

  public static void main(String[] argv) throws Exception {
    ConnectionFactory factory = new ConnectionFactory();
    factory.setHost("localhost");
    try (Connection connection = factory.newConnection();
         Channel channel = connection.createChannel()) {
      
      // Ensure the queue is durable first
      channel.queueDeclare(QUEUE_NAME, true, false, false, null);

      String message = "Hello, persistent world!";
      // Mark message as persistent
      channel.basicPublish("", QUEUE_NAME, 
                           MessageProperties.PERSISTENT_TEXT_PLAIN, 
                           message.getBytes("UTF-8"));
      System.out.println(" [x] Sent '" + message + "'");
    }
  }
}

The Persistence 'Gotcha'

It's crucial to understand a subtlety: even with durable queues and persistent messages, a message can still be lost.

This happens if the message is in transit from the producer to the broker, or if it has arrived at the broker but hasn't yet been flushed to disk, and the broker crashes at that exact moment.

For true reliability, where you know the broker has definitely received and saved your message, you need Publisher Confirms. We'll cover this in a future lesson!

When to Use Persistence

Persistence isn't free; it adds overhead because RabbitMQ has to write data to disk. So, when should you use it?

  • Critical Tasks: Orders, financial transactions, user sign-ups.
  • Long-running Processes: Image processing, video encoding.
  • System Integration: Ensuring data transfer between services is reliable.

If message loss is acceptable (e.g., real-time monitoring data that's quickly outdated), you can skip persistence for better performance.

Performance Impact

Writing data to disk takes more time than keeping it in memory. Therefore, enabling persistence for queues and messages will reduce your message throughput (messages per second).

  • Durable Queues: Minor impact, as it's just the queue definition.
  • Persistent Messages: More significant impact, as each message is written.

It's a trade-off: higher reliability versus higher performance. Always choose persistence for messages that you absolutely cannot afford to lose.

Recap: Persistence in Action

Let's briefly review the steps for a fully persistent setup:

  1. Declare your queue as durable (durable=true).
  2. Send your messages with a persistent delivery mode (MessageProperties.PERSISTENT_TEXT_PLAIN).
  3. For ultimate reliability (knowing the broker received it), combine with Publisher Confirms (covered later).

Quick Check: Durable Queues

You want to ensure that a queue and its messages survive if the RabbitMQ broker restarts. Which of the following is absolutely necessary for the queue itself to survive a restart?

Jawab di pelajaran interaktif

Recap & Next Steps

Great job! You've learned how to make your RabbitMQ queues and messages persistent, a crucial step towards building reliable messaging systems.

We covered:

  • The importance of persistence.
  • How to declare durable queues.
  • How to send persistent messages.
  • The performance trade-offs and the 'gotcha' with in-flight messages.

In the next lesson, we'll dive into Publisher Confirms, which provide an even higher level of reliability by ensuring the broker has truly received and processed your messages.

Gratis untuk memulai

Belajar RabbitMQ Messaging & Async Systems dengan tutor AI — gratis

Tulis dan jalankan kode asli di browser kamu, dapatkan bantuan instan dari tutor AI 24/7, dan lanjutkan di mana kamu tinggalkan di web atau aplikasi.

Kursus
11
Pelajaran
44
Mulai belajar gratisLihat kursus lengkapnya

Pertanyaan yang Sering Diajukan

Apakah pelajaran “Pesan dan Antrean Persisten” gratis?

Ya — teks lengkap “Pesan dan Antrean Persisten” gratis dibaca di sini di web. Untuk praktiknya secara interaktif (editor kode bawaan dan tutor AI 24/7) dan buka sisa kursus RabbitMQ Messaging & Async Systems, upgrade ke CoddyKit PRO. Kursus RabbitMQ Messaging & Async Systems mencakup 4 pelajaran total.

Apa yang akan aku pelajari di “Pesan dan Antrean Persisten”?

Pahami cara membuat pesan dan antrean tetap persisten agar dapat bertahan saat broker dimulai ulang. Pastikan data penting Anda tidak pernah hilang, bahkan dalam lingkungan yang tidak stabil. Kamu berlatih RabbitMQ Messaging & Async Systems dengan kode praktik yang langsung kamu jalankan di browser, dan tutor AI 24/7 menjawab pertanyaanmu saat kamu mengerjakan pelajaran ini.

Apakah aku perlu pengalaman untuk memulai RabbitMQ Messaging & Async Systems?

Tidak diperlukan pengalaman sebelumnya. RabbitMQ Messaging & Async Systems di CoddyKit dirancang untuk pemula hingga pelajar tingkat lanjut, jadi kamu bisa memulai di sini atau dari awal dan belajar sesuai kecepatan kamu sendiri. Ini adalah pelajaran 1 dari 4.

Berapa lama pelajaran “Pesan dan Antrean Persisten” memakan waktu?

Sebagian besar pelajaran CoddyKit memakan waktu sekitar 5–10 menit. Setiap pelajaran ringkas dan interaktif, jadi kamu membuat kemajuan stabil dan melanjutkan dari tempat kamu tinggalkan di web dan aplikasi.

Bisakah aku menulis dan menjalankan kode dalam pelajaran RabbitMQ Messaging & Async Systems ini?

Ya. Setiap pelajaran RabbitMQ Messaging & Async Systems menyertakan editor kode bawaan, jadi kamu menulis dan menjalankan kode nyata langsung di browser dan mendapatkan umpan balik AI instan — tidak diperlukan penyiapan lokal.

Semua pelajaran dalam kursus ini

  1. Pesan dan Antrean Persisten
  2. Konfirmasi Publisher untuk Keandalan
  3. Acknowledge Consumer & Antrean Ulang
  4. Transaksi vs Konfirmasi Penerbit
← Kembali ke RabbitMQ Messaging & Async Systems