AWS SDK untuk Java 1.x mencapai end-of-support pada 31 Desember 2025. Kami menyarankan Anda bermigrasi ke AWS SDK for Java 2.xuntuk terus menerima fitur baru, peningkatan ketersediaan, dan pembaruan keamanan.

Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

Mengirim, Menerima, dan Menghapus Pesan Amazon SQS

Topik ini menjelaskan cara mengirim, menerima, dan menghapus Amazon SQS pesan. Pesan selalu dikirimkan menggunakan SQS Queue.

Kirim Pesan

Tambahkan satu pesan ke Amazon SQS antrian dengan memanggil metode klien AmazonSQS. sendMessage Berikan SendMessageRequestobjek yang berisi URL antrian, isi pesan, dan nilai penundaan opsional (dalam hitungan detik).

Impor

import com.amazonaws.services.sqs.AmazonSQS;
import com.amazonaws.services.sqs.AmazonSQSClientBuilder;
import com.amazonaws.services.sqs.model.SendMessageRequest;

Kode

SendMessageRequest send_msg_request = new SendMessageRequest()
        .withQueueUrl(queueUrl)
        .withMessageBody("hello world")
        .withDelaySeconds(5);
sqs.sendMessage(send_msg_request);

Lihat contoh lengkapnya di GitHub.

Kirim Beberapa Pesan Sekaligus

Anda dapat mengirim lebih dari satu pesan dalam satu permintaan. Untuk mengirim beberapa pesan, gunakan sendMessageBatch metode klien AmazonSQS, yang mengambil SendMessageBatchRequestberisi URL antrian dan daftar pesan (masing-masing a SendMessageBatchRequestEntry) untuk dikirim. Anda juga dapat menetapkan nilai penundaan opsional per pesan.

Impor

import com.amazonaws.services.sqs.model.SendMessageBatchRequest;
import com.amazonaws.services.sqs.model.SendMessageBatchRequestEntry;

Kode

SendMessageBatchRequest send_batch_request = new SendMessageBatchRequest()
        .withQueueUrl(queueUrl)
        .withEntries(
                new SendMessageBatchRequestEntry(
                        "msg_1", "Hello from message 1"),
                new SendMessageBatchRequestEntry(
                        "msg_2", "Hello from message 2")
                        .withDelaySeconds(10));
sqs.sendMessageBatch(send_batch_request);

Lihat contoh lengkapnya di GitHub.

Menerima Pesan

Ambil pesan apa pun yang saat ini berada dalam antrian dengan memanggil receiveMessage metode klien AmazonSQS, meneruskannya URL antrian. Pesan dikembalikan sebagai daftar objek Pesan.

Impor

import com.amazonaws.services.sqs.AmazonSQSClientBuilder;
import com.amazonaws.services.sqs.model.AmazonSQSException;
import com.amazonaws.services.sqs.model.SendMessageBatchRequest;

Kode

List<Message> messages = sqs.receiveMessage(queueUrl).getMessages();

Hapus Pesan setelah Diterima

Setelah menerima pesan dan memproses isinya, hapus pesan dari antrian dengan mengirimkan alamat tanda terima pesan dan URL antrian ke metode klien AmazonSQS. deleteMessage

Kode

for (Message m : messages) {
    sqs.deleteMessage(queueUrl, m.getReceiptHandle());
}

Lihat contoh lengkapnya di GitHub.

Info Selengkapnya