我的应用程序使用 SendMessageBatchRequest 将每个请求发布 10 条消息到 AWS-SQS。每条消息的大小小于250字节。该应用程序预计每天发布约一百万条记录。但要实现这一目标,消息发布的速度非常慢。
AmazonSQS sqs = null;
sqs = new AmazonSQSClient(new BasicAWSCredentials("accessKey", "SecretKey"));
//the below entries are added via a for loop picking the messages from a queue
//the typical queue size will be 20k messages
//AmazonSQSClient is created once and is used until the code comes out of the for loop
List<SendMessageBatchRequestEntry> entries = new ArrayList<SendMessageBatchRequestEntry>();
entries.add(new SendMessageBatchRequestEntry(messageBatchRequestId, "250kbJSONString"));
//Once the batch count reaches 10,the following code is called
CreateQueueRequest createQueueRequest = new CreateQueueRequest("CLIENT-TEST");
String myQueueUrl …Run Code Online (Sandbox Code Playgroud)