教程:将消息发送到 Amazon SQS 队列
在创建队列之后,可向其发送消息。以下示例说明如何向现有队列发送消息。
AWS 管理控制台
-
登录 Amazon SQS 控制台。
-
从队列列表中选择一个队列。
-
在队列操作中,选择发送消息。
将显示 Send a Message to
QueueName
对话框。以下示例显示了特定于 FIFO 队列(已禁用 content-based deduplication)的消息组 ID 和消息重复数据删除 ID 参数。
-
要将消息发送到 FIFO 队列,请键入 Message Body、Message Group ID
MyMessageGroupId1234567890
和 Message Deduplication IDMyMessageDeduplicationId1234567890
,然后选择 Send Message。有关更多信息,请参阅 FIFO 传送逻辑。注意
始终需要 message group ID。但是,如果启用 content-based deduplication,则 message deduplication ID 是可选的。
您的消息将会发送,并显示 Send a Message to
QueueName
对话框,其中将显示已发送消息的属性。以下示例显示了特定于 FIFO 队列的 Sequence Number 属性。
-
选择 Close。
AWS SDK for Java
在您开始处理示例代码之前,请指定 AWS 凭证。有关更多信息,请参阅 AWS SDK for Java Developer Guide 中的设置用于开发的 AWS 凭证和区域。
向 标准 队列发送消息
-
复制示例程序。
以下代码部分将向您的队列发送
This is my message text.
消息:// Send a message System.out.println("Sending a message to MyQueue.\n"); sqs.sendMessage(new SendMessageRequest(myQueueUrl, "This is my message text."));
-
编译并运行示例。
消息已发送到队列。此响应包含下列项目:
向 FIFO 队列发送消息
-
复制示例程序。
以下代码部分将向您的队列发送
This is my message text.
消息:// Send a message System.out.println("Sending a message to MyFifoQueue.fifo.\n"); final SendMessageRequest sendMessageRequest = new SendMessageRequest(myQueueUrl, "This is my message text."); // When you send messages to a FIFO queue, you must provide a non-empty MessageGroupId. sendMessageRequest.setMessageGroupId("messageGroup1"); // Uncomment the following to provide the MessageDeduplicationId //sendMessageRequest.setMessageDeduplicationId("1"); final SendMessageResult sendMessageResult = sqs.sendMessage(sendMessageRequest); final String sequenceNumber = sendMessageResult.getSequenceNumber(); final String messageId = sendMessageResult.getMessageId(); System.out.println("SendMessage succeed with messageId " + messageId + ", sequence number " + sequenceNumber + "\n");
-
编译并运行示例。
消息将会发送到您的队列。