Mengaktifkan buffering sisi klien dan meminta batching dengan Amazon SQS

AWS SDK for JavaTermasuk AmazonSQSBufferedAsyncClient yang mengakses Amazon SQS. Klien ini memungkinkan pengelompokan permintaan sederhana menggunakan buffering sisi klien—panggilan yang dilakukan dari klien pertama kali di-buffer dan kemudian dikirim sebagai permintaan batch ke Amazon SQS.

Buffering sisi klien memungkinkan hingga 10 permintaan untuk di-buffer dan dikirim sebagai permintaan batch, mengurangi biaya penggunaan Amazon SQS dan mengurangi jumlah permintaan yang dikirim. AmazonSQSBufferedAsyncClientbuffer panggilan sinkron dan asinkron. Permintaan batch dan dukungan untuk polling panjang juga dapat membantu meningkatkan throughput. Untuk informasi selengkapnya, lihat Meningkatkan throughput menggunakan penskalaan horizontal dan batching aksi dengan Amazon SQS.

Karena AmazonSQSBufferedAsyncClient mengimplementasikan antarmuka yang sama sepertiAmazonSQSAsyncClient, migrasi dari AmazonSQSAsyncClient ke AmazonSQSBufferedAsyncClient biasanya hanya memerlukan sedikit perubahan pada kode Anda yang ada.

catatan

Klien Asinkron Buffered Amazon SQS saat ini tidak mendukung antrian FIFO.

Menggunakan AmazonSQS BufferedAsyncClient

Sebelum memulai, selesaikan langkah-langkah di Menyiapkan Amazon SQS.

penting

Saat ini AWS SDK for Java 2.x tidak kompatibel denganAmazonSQSBufferedAsyncClient.

Anda dapat membuat yang baru AmazonSQSBufferedAsyncClient berdasarkanAmazonSQSAsyncClient, misalnya:

// Create the basic Amazon SQS async client
final AmazonSQSAsync sqsAsync = new AmazonSQSAsyncClient();
 
// Create the buffered client
final AmazonSQSAsync bufferedSqs = new AmazonSQSBufferedAsyncClient(sqsAsync);

Setelah Anda membuat yang baruAmazonSQSBufferedAsyncClient, Anda dapat menggunakannya untuk mengirim beberapa permintaan ke Amazon SQS (seperti yang Anda bisa denganAmazonSQSAsyncClient), misalnya:

final CreateQueueRequest createRequest = new CreateQueueRequest().withQueueName("MyQueue");
 
final CreateQueueResult res = bufferedSqs.createQueue(createRequest);
 
final SendMessageRequest request = new SendMessageRequest();
final String body = "Your message text" + System.currentTimeMillis();
request.setMessageBody( body );
request.setQueueUrl(res.getQueueUrl());
 
final Future<SendMessageResult> sendResult = bufferedSqs.sendMessageAsync(request);
 
final ReceiveMessageRequest receiveRq = new ReceiveMessageRequest()
    .withMaxNumberOfMessages(1)
    .withQueueUrl(queueUrl);
final ReceiveMessageResult rx = bufferedSqs.receiveMessage(receiveRq);

Mengkonfigurasi AmazonSQS BufferedAsyncClient

AmazonSQSBufferedAsyncClienttelah dikonfigurasi sebelumnya dengan pengaturan yang berfungsi untuk sebagian besar kasus penggunaan. Anda dapat mengkonfigurasi lebih lanjutAmazonSQSBufferedAsyncClient, misalnya:

1. Buat instance QueueBufferConfig kelas dengan parameter konfigurasi yang diperlukan.

2. Berikan instance ke AmazonSQSBufferedAsyncClient konstruktor.

// Create the basic Amazon SQS async client
final AmazonSQSAsync sqsAsync = new AmazonSQSAsyncClient();
 
final QueueBufferConfig config = new QueueBufferConfig()
    .withMaxInflightReceiveBatches(5)
    .withMaxDoneReceiveBatches(15);
 
// Create the buffered client
final AmazonSQSAsync bufferedSqs = new AmazonSQSBufferedAsyncClient(sqsAsync, config);

QueueBufferConfig parameter konfigurasi
Parameter	Nilai default	Deskripsi
longPoll	true	Ketika longPoll diatur ketrue, AmazonSQSBufferedAsyncClient mencoba untuk menggunakan polling panjang ketika mengkonsumsi pesan.
longPollWaitTimeoutSeconds	20 s	Jumlah waktu maksimum (dalam detik) yang diblokir ReceiveMessage panggilan di server, menunggu pesan muncul dalam antrian sebelum kembali dengan hasil penerimaan kosong. catatan Ketika polling panjang dinonaktifkan, pengaturan ini tidak berpengaruh.
maxBatchOpenMs	200 ms	Jumlah waktu maksimum (dalam milidetik) panggilan keluar menunggu panggilan lain yang dengannya ia mengumpulkan pesan dari jenis yang sama. Semakin tinggi pengaturan, semakin sedikit batch yang diperlukan untuk melakukan jumlah pekerjaan yang sama (namun, panggilan pertama dalam batch harus menghabiskan waktu lebih lama menunggu). Saat Anda menyetel parameter ini0, permintaan yang dikirimkan tidak menunggu permintaan lain, yang secara efektif menonaktifkan batching.
maxBatchSize	10 permintaan per batch	Jumlah maksimum pesan yang dikumpulkan bersama dalam satu permintaan. Semakin tinggi pengaturan, semakin sedikit batch yang diperlukan untuk melakukan jumlah permintaan yang sama. catatan 10 permintaan per batch adalah nilai maksimum yang diizinkan untuk Amazon SQS.
maxBatchSizeBytes	256 KiB	Ukuran maksimum kumpulan pesan, dalam byte, yang coba dikirim klien ke Amazon SQS. catatan 256 KiB adalah nilai maksimum yang diizinkan untuk Amazon SQS.
maxDoneReceiveBatches	10 batch	Jumlah maksimum batch penerima yang AmazonSQSBufferedAsyncClient mengambil dan menyimpan sisi klien. Semakin tinggi pengaturan, semakin banyak permintaan penerimaan yang dapat dipenuhi tanpa harus melakukan panggilan ke Amazon SQS (namun, semakin banyak pesan yang diambil sebelumnya, semakin lama mereka tetap berada di buffer, menyebabkan batas waktu visibilitas mereka sendiri kedaluwarsa). catatan 0menunjukkan bahwa semua pra-pengambilan pesan dinonaktifkan dan pesan hanya dikonsumsi sesuai permintaan.
maxInflightOutboundBatches	5 batch	Jumlah maksimum batch keluar aktif yang dapat diproses secara bersamaan. Semakin tinggi pengaturan, batch keluar yang lebih cepat dapat dikirim (tunduk pada kuota seperti CPU atau bandwidth) dan semakin banyak thread yang dikonsumsi oleh. AmazonSQSBufferedAsyncClient
maxInflightReceiveBatches	10 batch	Jumlah maksimum batch penerima aktif yang dapat diproses pada saat yang bersamaan. Semakin tinggi pengaturan, semakin banyak pesan yang dapat diterima (tunduk pada kuota seperti CPU atau bandwidth), dan semakin banyak utas yang dikonsumsi olehAmazonSQSBufferedAsyncClient. catatan 0menunjukkan bahwa semua pra-pengambilan pesan dinonaktifkan dan pesan hanya dikonsumsi sesuai permintaan.
visibilityTimeoutSeconds	-1	Ketika parameter ini disetel ke nilai positif, bukan nol, batas waktu visibilitas yang ditetapkan di sini akan mengganti batas waktu visibilitas yang ditetapkan pada antrian dari mana pesan dikonsumsi. catatan -1menunjukkan bahwa pengaturan default dipilih untuk antrian. Anda tidak dapat mengatur batas waktu visibilitas ke. 0