Bekerja denganAmazon SQSAntrean pesan - AWS SDK for Java 1.x

AWS SDK for 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 denganAmazon SQSAntrean pesan

SEBUAHAntrean pesanadalah wadah logis yang digunakan untuk mengirim pesan andalAmazon SQS. Ada dua tipe antrian:standardanpertama-dalam, pertama-keluar(FIFO). Untuk mempelajari lebih lanjut tentang antrian dan perbedaan antara jenis ini, lihatAmazon SQSPanduan Pengembang.

Topik ini menjelaskan cara membuat, membuat daftar, menghapus, dan mendapatkan URLAmazon SQSantrian dengan menggunakanAWS SDK for Java.

Membuat Antrean

Gunakan klien AmazonSqscreateQueuemetode, menyediakanCreateQueueRequestobjek yang menggambarkan 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 sederhanacreateQueue, yang hanya membutuhkan nama antrian, untuk membuat antrian standar.

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

LihatLengkapi Contohdi GitHub.

Antrean

Untuk membuat daftarAmazon SQSantrian untuk akun Anda, hubungi klien AmazonSqslistQueuesmetode.

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); }

MenggunakanlistQueuesoverload tanpa parameter kembaliAntrean. Anda dapat menyaring hasil yang dikembalikan dengan melewatkannyaListQueuesRequestobjek.

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); }

LihatLengkapi Contohdi GitHub.

Mendapatkan URL untuk Antrian

Hubungi klien AmazonSqsgetQueueUrlmetode.

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();

LihatLengkapi Contohdi GitHub.

Menghapus Antrean

Berikan antreanURLke klien AmazonSqsdeleteQueuemetode.

Impor

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

Kode

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

LihatLengkapi Contohdi GitHub.

Info Selengkapnya