使用Amazon SQS消息队列 - AWS SDK for Java1.x

本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。

使用Amazon SQS消息队列

消息队列 是用于在 Amazon SQS 中可靠地发送消息的逻辑容器。有两种类型的队列:标准先进先出 (FIFO)。要了解有关队列以及这些类型之间的差异的更多信息,请参阅Amazon SQS开发人员指南.

本主题介绍如何使用 AWS SDK for Java 来创建、列出、删除和获取 Amazon SQS 队列的 URL。

创建队列

使用 AmazonSQS 客户端createQueue方法,提供CreateQueueRequest对象,它描述队列参数。

导入

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;

代码

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

您可以使用 createQueue 的简化形式,这只需要队列名称即可创建标准队列。

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

请参阅 GitHub 上的完整示例

列出队列

要列出Amazon SQS调用您的账户的队列,可调用 AmazonSQS 客户端的listQueues方法。

导入

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

代码

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

使用 listQueues 重载 (不带任何参数) 将返回所有队列。您可以通过向其传递一个 ListQueuesRequest 对象来筛选返回的结果。

导入

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

代码

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

请参阅 GitHub 上的完整示例

获取队列的 URL

调用 AmazonSQS 客户端getQueueUrl方法。

导入

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

代码

AmazonSQS sqs = AmazonSQSClientBuilder.defaultClient(); String queue_url = sqs.getQueueUrl(QUEUE_NAME).getQueueUrl();

请参阅 GitHub 上的完整示例

删除队列

提供队列的URL向 AmazonSQS 客户的deleteQueue方法。

导入

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

代码

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

请参阅 GitHub 上的完整示例

更多信息