AWS SDK untuk Java 1.x telah memasuki mode pemeliharaan pada 31 Juli 2024, dan akan mencapai end-of-supportpada 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.

Bekerja dengan Amazon SQS Antrian Pesan

Antrian pesan adalah wadah logis yang digunakan untuk mengirim pesan dengan andal. Amazon SQS Ada dua jenis antrian: standar dan first-in, first-out (FIFO). Untuk mempelajari lebih lanjut tentang antrian dan perbedaan di antara jenis-jenis ini, lihat Panduan Amazon SQS Pengembang.

Topik ini menjelaskan cara membuat, membuat daftar, menghapus, dan mendapatkan URL Amazon SQS antrian dengan menggunakan. AWS SDK untuk Java

Buat Antrian

Gunakan createQueue metode klien AmazonSQS, menyediakan CreateQueueRequestobjek yang menjelaskan parameter antrian.

Impor

import com.amazonaws.services.sqs.AmazonSQS;
import com.amazonaws.services.sqs.AmazonSQSClientBuilder;
import com.amazonaws.services.sqs.model.AmazonSQSException;
import com.amazonaws.services.sqs.model.CreateQueueRequest;

Kode

AmazonSQS sqs = AmazonSQSClientBuilder.defaultClient();
CreateQueueRequest create_request = new CreateQueueRequest(QUEUE_NAME)
        .addAttributesEntry("DelaySeconds", "60")
        .addAttributesEntry("MessageRetentionPeriod", "86400");

try {
    sqs.createQueue(create_request);
} catch (AmazonSQSException e) {
    if (!e.getErrorCode().equals("QueueAlreadyExists")) {
        throw e;
    }
}

Anda dapat menggunakan bentuk yang disederhanakancreateQueue, yang hanya membutuhkan nama antrian, untuk membuat antrian standar.

sqs.createQueue("MyQueue" + new Date().getTime());

Lihat contoh lengkapnya di GitHub.

Daftar Antrian

Untuk membuat daftar Amazon SQS antrian untuk akun Anda, hubungi metode klien AmazonSQS. listQueues

Impor

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

Kode

AmazonSQS sqs = AmazonSQSClientBuilder.defaultClient();
ListQueuesResult lq_result = sqs.listQueues();
System.out.println("Your SQS Queue URLs:");
for (String url : lq_result.getQueueUrls()) {
    System.out.println(url);
}

Menggunakan listQueues kelebihan beban tanpa parameter apa pun mengembalikan semua antrian. Anda dapat memfilter hasil yang dikembalikan dengan meneruskannya ListQueuesRequest objek.

Impor

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

Kode

AmazonSQS sqs = AmazonSQSClientBuilder.defaultClient();
String name_prefix = "Queue";
lq_result = sqs.listQueues(new ListQueuesRequest(name_prefix));
System.out.println("Queue URLs with prefix: " + name_prefix);
for (String url : lq_result.getQueueUrls()) {
    System.out.println(url);
}

Lihat contoh lengkapnya di GitHub.

Dapatkan URL untuk Antrian

Panggil metode klien AmazonSQS. getQueueUrl

Impor

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

Kode

AmazonSQS sqs = AmazonSQSClientBuilder.defaultClient();
String queue_url = sqs.getQueueUrl(QUEUE_NAME).getQueueUrl();

Lihat contoh lengkapnya di GitHub.

Hapus Antrian

Berikan URL antrian ke metode klien AmazonSQS. deleteQueue

Impor

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

Kode

AmazonSQS sqs = AmazonSQSClientBuilder.defaultClient();
sqs.deleteQueue(queue_url);

Lihat contoh lengkapnya di GitHub.

Info Selengkapnya