AWS SDK for Java 1.x telah memasuki mode pemeliharaan pada 31 Juli 2024, dan akan mencapai end-of-support
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 AmazonSqscreateQueue
metode, 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 Contoh
Antrean
Untuk membuat daftarAmazon SQSantrian untuk akun Anda, hubungi klien AmazonSqslistQueues
metode.
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); }
MenggunakanlistQueues
overload tanpa parameter kembaliAntrean. Anda dapat menyaring hasil yang dikembalikan dengan melewatkannyaListQueuesRequest
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); }
LihatLengkapi Contoh
Mendapatkan URL untuk Antrian
Hubungi klien AmazonSqsgetQueueUrl
metode.
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 Contoh
Menghapus Antrean
Berikan antreanURLke klien AmazonSqsdeleteQueue
metode.
Impor
import com.amazonaws.services.sqs.AmazonSQS; import com.amazonaws.services.sqs.AmazonSQSClientBuilder;
Kode
AmazonSQS sqs = AmazonSQSClientBuilder.defaultClient(); sqs.deleteQueue(queue_url);
LihatLengkapi Contoh
Info Selengkapnya
-
BagaimanaAmazon SQSAntreandiAmazon SQSPanduan Pengembang
-
CreateQueuediAmazon SQSReferensi API
-
GetQueueUrldiAmazon SQSReferensi API
-
ListQueuesdiAmazon SQSReferensi API
-
DeleteQueuesdiAmazon SQSReferensi API