

 適用於 JavaScript 的 AWS SDK v2 已end-of-support。我們建議您遷移至 [適用於 JavaScript 的 AWS SDK v3](https://docs.aws.amazon.com//sdk-for-javascript/v3/developer-guide/)。如需如何遷移的其他詳細資訊和資訊，請參閱此[公告](https://aws.amazon.com/blogs//developer/announcing-end-of-support-for-aws-sdk-for-javascript-v2/)。

本文為英文版的機器翻譯版本，如內容有任何歧義或不一致之處，概以英文版為準。

# 在 Amazon SQS 中傳送和接收訊息
<a name="sqs-examples-send-receive-messages"></a>

![\[JavaScript code example that applies to Node.js execution\]](http://docs.aws.amazon.com/zh_tw/sdk-for-javascript/v2/developer-guide/images/nodeicon.png)

**這個 Node.js 程式碼範例會說明：**
+ 如何在佇列中傳送訊息。
+ 如何在佇列中接收訊息。
+ 如何在佇列中刪除訊息。

## 使用案例
<a name="sqs-examples-send-receive-messages-scenario"></a>

在此範例中，您可以使用一系列的 Node.js 模組來傳送和接收訊息。Node.js 模組使用適用於 JavaScript 的 SDK，透過使用 `AWS.SQS`用戶端類別的這些方法來傳送和接收訊息：
+ [https://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/SQS.html#sendMessage-property](https://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/SQS.html#sendMessage-property)
+ [https://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/SQS.html#receiveMessage-property](https://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/SQS.html#receiveMessage-property)
+ [https://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/SQS.html#deleteMessage-property](https://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/SQS.html#deleteMessage-property)

如需 Amazon SQS 訊息的詳細資訊，請參閱《Amazon *Simple Queue Service *[開發人員指南》中的傳送訊息至 Amazon SQS 佇列](https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-send-message.html)以及[從 Amazon SQS 佇列接收和刪除訊息](https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-receive-delete-message.html)。

## 先決條件任務
<a name="sqs-examples-send-receive-messages-prerequisites"></a>

若要設定和執行此範例，您必須先完成這些任務：
+ 安裝 Node.js。如需安裝 Node.js 的詳細資訊，請參閱 [Node.js 網站](https://nodejs.org)。
+ 透過使用者登入資料建立共用組態檔。如需提供共用登入資料檔案的詳細資訊，請參閱 [從共用登入資料檔案中在 Node.js 中載入登入資料](loading-node-credentials-shared.md)。
+ 建立 Amazon SQS 佇列。如需建立佇列的範例，請參閱[在 Amazon SQS 中使用佇列](sqs-examples-using-queues.md)。

## 傳送訊息至佇列
<a name="sqs-examples-send-receive-messages-sending"></a>

以檔名 `sqs_sendmessage.js` 建立一個 Node.js 模組。請務必依前述的內容來設定軟體開發套件。若要存取 Amazon SQS，請建立 `AWS.SQS`服務物件。建立包含訊息所需參數的 JSON 物件，且其中應包括要傳送此訊息的目標佇列 URL。在此範例中，該訊息會提供暢銷小說排行榜中的書籍詳細資訊，包括書名、作者和上榜週數。

呼叫 `sendMessage` 方法。接著，回呼函數會傳回該訊息的唯一 ID。

```
// Load the AWS SDK for Node.js
var AWS = require("aws-sdk");
// Set the region
AWS.config.update({ region: "REGION" });

// Create an SQS service object
var sqs = new AWS.SQS({ apiVersion: "2012-11-05" });

var params = {
  // Remove DelaySeconds parameter and value for FIFO queues
  DelaySeconds: 10,
  MessageAttributes: {
    Title: {
      DataType: "String",
      StringValue: "The Whistler",
    },
    Author: {
      DataType: "String",
      StringValue: "John Grisham",
    },
    WeeksOn: {
      DataType: "Number",
      StringValue: "6",
    },
  },
  MessageBody:
    "Information about current NY Times fiction bestseller for week of 12/11/2016.",
  // MessageDeduplicationId: "TheWhistler",  // Required for FIFO queues
  // MessageGroupId: "Group1",  // Required for FIFO queues
  QueueUrl: "SQS_QUEUE_URL",
};

sqs.sendMessage(params, function (err, data) {
  if (err) {
    console.log("Error", err);
  } else {
    console.log("Success", data.MessageId);
  }
});
```

若要執行範例，請在命令列中輸入以下內容。

```
node sqs_sendmessage.js
```

您可以在 [GitHub 上](https://github.com/awsdocs/aws-doc-sdk-examples/tree/master/javascript/example_code/sqs/sqs_sendmessage.js)找到這個範本程式碼。

## 從佇列接收並刪除訊息
<a name="sqs-examples-send-receive-messages-receiving"></a>

以檔名 `sqs_receivemessage.js` 建立一個 Node.js 模組。請務必依前述的內容來設定軟體開發套件。若要存取 Amazon SQS，請建立 `AWS.SQS`服務物件。建立包含訊息所需參數的 JSON 物件，且應包括要從中接收訊息的佇列 URL。在此範例中，該參數會指定接收所有訊息屬性，並將接收的訊息數量上限設定為 10 則。

呼叫 `receiveMessage` 方法。接著，回呼函數會傳回 `Message` 物件陣列，您能夠從中擷取每個訊息的 `ReceiptHandle`，稍後再使用此屬性刪除該訊息。建立另一個 JSON 物件，其中包含刪除訊息所需的參數，意即佇列 URL 和 `ReceiptHandle` 值。接著，呼叫 `deleteMessage` 方法以刪除收到的訊息。

```
// Load the AWS SDK for Node.js
var AWS = require("aws-sdk");
// Set the region
AWS.config.update({ region: "REGION" });

// Create an SQS service object
var sqs = new AWS.SQS({ apiVersion: "2012-11-05" });

var queueURL = "SQS_QUEUE_URL";

var params = {
  AttributeNames: ["SentTimestamp"],
  MaxNumberOfMessages: 10,
  MessageAttributeNames: ["All"],
  QueueUrl: queueURL,
  VisibilityTimeout: 20,
  WaitTimeSeconds: 0,
};

sqs.receiveMessage(params, function (err, data) {
  if (err) {
    console.log("Receive Error", err);
  } else if (data.Messages) {
    var deleteParams = {
      QueueUrl: queueURL,
      ReceiptHandle: data.Messages[0].ReceiptHandle,
    };
    sqs.deleteMessage(deleteParams, function (err, data) {
      if (err) {
        console.log("Delete Error", err);
      } else {
        console.log("Message Deleted", data);
      }
    });
  }
});
```

若要執行範例，請在命令列中輸入以下內容。

```
node sqs_receivemessage.js
```

您可以在 [GitHub 上](https://github.com/awsdocs/aws-doc-sdk-examples/tree/master/javascript/example_code/sqs/sqs_receivemessage.js)找到這個範本程式碼。