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

Bekerja dengan Amazon Simple Queue Service antrian pesan

Antrian pesan adalah wadah logis yang digunakan untuk mengirim pesan dengan andal Amazon Simple Queue Service. Ada dua jenis antrian: standar dan first- in, first-out (FIFO). Untuk mempelajari selengkapnya tentang antrian dan perbedaan antara jenis ini, lihat Panduan Peng Amazon Simple Queue Service embang.

Topik ini menjelaskan cara membuat, membuat daftar, menghapus, dan mendapatkan URL an Amazon Simple Queue Service trian dengan menggunakan AWS SDK untuk Java.

sqsClientVariabel yang digunakan dalam contoh berikut dapat dibuat dari cuplikan berikut.

SqsClient sqsClient = SqsClient.create();

Saat Anda membuat SqsClient dengan menggunakan create() metode statis, SDK mengonfigurasi Wilayah dengan menggunakan rantai penyedia wilayah default dan kredenSIAL dengan menggunakan rantai penyedia kredenSIAL default.

Membuat antrean

Gunakan SqsClient’s createQueue metode, dan berikan CreateQueueRequest objek yang menjelaskan parameter antrian seperti yang ditunjukkan dalam cuplikan kode berikut.

Impor

import software.amazon.awssdk.regions.Region;
import software.amazon.awssdk.services.sqs.SqsClient;
import software.amazon.awssdk.services.sqs.model.*;
import java.util.List;

Kode

            CreateQueueRequest createQueueRequest = CreateQueueRequest.builder()
                .queueName(queueName)
                .build();

            sqsClient.createQueue(createQueueRequest);

Lihat sampel lengkapnya di GitHub.

Daftar antrian

Untuk membuat daftar Amazon Simple Queue Service antrian untuk akun Anda, panggil SqsClient’s listQueues metode dengan ListQueuesRequest objek.

Bila Anda menggunakan bentuk listQueues metode yang tidak menggunakan parameter, layanan mengembalikan semua antrian —hingga 1.000 antrian.

Anda dapat memberikan awalan nama antrian ke ListQueuesRequest objek untuk membatasi hasil ke antrian yang cocok dengan awalan tersebut seperti yang ditunjukkan dalam kode berikut.

Impor

import software.amazon.awssdk.regions.Region;
import software.amazon.awssdk.services.sqs.SqsClient;
import software.amazon.awssdk.services.sqs.model.*;
import java.util.List;

Kode

        String prefix = "que";

        try {
            ListQueuesRequest listQueuesRequest = ListQueuesRequest.builder().queueNamePrefix(prefix).build();
            ListQueuesResponse listQueuesResponse = sqsClient.listQueues(listQueuesRequest);

            for (String url : listQueuesResponse.queueUrls()) {
                System.out.println(url);
            }

        } catch (SqsException e) {
            System.err.println(e.awsErrorDetails().errorMessage());
            System.exit(1);
        }

Lihat sampel lengkapnya di GitHub.

Dapatkan URL untuk antrian

Kode berikut menunjukkan cara mendapatkan URL untuk antrian dengan memanggil SqsClient’s getQueueUrl metode dengan GetQueueUrlRequest objek.

Impor

import software.amazon.awssdk.regions.Region;
import software.amazon.awssdk.services.sqs.SqsClient;
import software.amazon.awssdk.services.sqs.model.*;
import java.util.List;

Kode

            GetQueueUrlResponse getQueueUrlResponse =
                sqsClient.getQueueUrl(GetQueueUrlRequest.builder().queueName(queueName).build());
            String queueUrl = getQueueUrlResponse.queueUrl();
            return queueUrl;

Lihat sampel lengkapnya di GitHub.

Menghapus antrian

Berikan URL antrian ke DeleteQueueRequest objek. Kemudian panggil SqsClient’s deleteQueue metode untuk menghapus antrian seperti yang ditunjukkan dalam kode berikut.

Impor

import software.amazon.awssdk.regions.Region;
import software.amazon.awssdk.services.sqs.SqsClient;
import software.amazon.awssdk.services.sqs.model.*;
import java.util.List;

Kode

    public static void deleteSQSQueue(SqsClient sqsClient, String queueName) {

        try {

            GetQueueUrlRequest getQueueRequest = GetQueueUrlRequest.builder()
                    .queueName(queueName)
                    .build();

            String queueUrl = sqsClient.getQueueUrl(getQueueRequest).queueUrl();

            DeleteQueueRequest deleteQueueRequest = DeleteQueueRequest.builder()
                    .queueUrl(queueUrl)
                    .build();

            sqsClient.deleteQueue(deleteQueueRequest);

        } catch (SqsException e) {
            System.err.println(e.awsErrorDetails().errorMessage());
            System.exit(1);
        }
    }

Lihat sampel lengkapnya di GitHub.

Informasi selengkapnya