步骤 3：演示使用 Amazon IoTDevice Client 订阅消息

在执行此过程时，确保终端窗口和窗口都有 MQTT 测试客户端可见。此外，请确保 MQTT 测试客户端仍订阅为#主题筛选条件。如果没有订阅，请再次订阅#筛选条件主题。

在终端窗口中，输入这些命令以使用在 Amazon IoT中创建的配置文件运行 创建配置文件Device Client。

cd ~/aws-iot-device-client/build
./aws-iot-device-client --config-file ~/dc-configs/dc-pubsub-custom-config.json

在终端窗口中，Amazon IoT Device Client 显示信息消息以及运行时发生的任何错误。

如果终端窗口中未显示错误，请在 Amazon IoT控制台继续。

在 Amazon IoT控制台中的 MQTT 测试客户端中，选择发布到主题选项卡。

在 主题名称中，输入 test/dc/subtopic。

在消息负载中，查看消息内容。

选择 Publish（发布）发布 MQTT 消息。

在终端窗口中，注意 Amazon IoTDevice Client 的接收消息条目。

2021-11-10T16:02:20.890Z [DEBUG] {samples/PubSubFeature.cpp}: Message received on subscribe topic, size: 45 bytes

看见显示已收到消息接收消息的条目之后，输入^C(Ctrl-C) 可停止 Amazon IoTDevice Client。

输入此命令可查看消息日志文件的末尾并查看您从 MQTT 测试客户端发布的信息

tail ~/.aws-iot-device-client/log/pubsub_rx_msgs.log

在连接到 Raspberry Pi 的本地主机上的终端窗口中，打开 ~/dc-configs/dc-pubsub-custom-config.json进行编辑并定位 samples对象。

在文本编辑器中，定位 samples对象并更新 subscribe-topic值如下所示。

  "samples": {
    "pub-sub": {
      "enabled": true,
      "publish-topic": "test/dc/pubtopic",
      "publish-file": "~/messages/sample-ws-message.json",
      "subscribe-topic": "test/dc/#",
      "subscribe-file": "~/.aws-iot-device-client/log/pubsub_rx_msgs.log"

新 subscribe-topic值是 MQTT主题筛选条件，其末尾带有 MQTT 通配符。这描述了以 test/dc/开始的所有 MQTT 主题的订阅。Amazon IoT Device Client 将从该订阅接收的消息有效负载写入名为subscribe-file 的文件。

将修改后的配置文件另存为~/dc-configs/dc-pubsub-wild-config.json，然后退出编辑器。

在连接到 Raspberry Pi 的本地主机上的终端窗口中，在您最喜欢的文本编辑器中打开 ~/policies/pubsub_test_thing_policy.json进行编辑，然后定位 iot::Subscribe和 iot::Receive文件中的策略语句。

在iot::Subscribe策略语句中更新 Resource 对象中的字符串用 *替换 subtopic，如下所示。

    {
      "Effect": "Allow",
      "Action": [
        "iot:Subscribe"
      ],
      "Resource": [
        "arn:aws:iot:us-west-2:57EXAMPLE833:topicfilter/test/dc/*"
      ]
    }

在 iot::Receive策略语句中更新 Resource 对象中的字符串用 subtopic替换 *，如下所示。

    {
      "Effect": "Allow",
      "Action": [
        "iot:Receive"
      ],
      "Resource": [
        "arn:aws:iot:us-west-2:57EXAMPLE833:topic/test/dc/*"
      ]
    }

将更新后的策略文档另存为 ~/policies/pubsub_wild_test_thing_policy.json，然后退出编辑器。

输入此命令可更新本教程的策略使用新的资源定义。

aws iot create-policy-version \
--set-as-default \
--policy-name "PubSubTestThingPolicy" \
--policy-document "file://~/policies/pubsub_wild_test_thing_policy.json"

如果命令成功，将返回类似于此类的响应。请注意，policyVersionId 现在是 2，表示这是此策略的第二个版本。

如果成功更新策略，可以继续下一个过程。

{
    "policyArn": "arn:aws:iot:us-west-2:57EXAMPLE833:policy/PubSubTestThingPolicy",
    "policyDocument": "{\n  \"Version\": \"2012-10-17\",\n  \"Statement\": [\n    {\n      \"Effect\": \"Allow\",\n      \"Action\": [\n        \"iot:Connect\"\n      ],\n      \"Resource\": [\n        \"arn:aws:iot:us-west-2:57EXAMPLE833:client/PubSubTestThing\"\n      ]\n    },\n    {\n      \"Effect\": \"Allow\",\n      \"Action\": [\n        \"iot:Publish\"\n      ],\n      \"Resource\": [\n        \"arn:aws:iot:us-west-2:57EXAMPLE833:topic/test/dc/pubtopic\"\n      ]\n    },\n    {\n      \"Effect\": \"Allow\",\n      \"Action\": [\n        \"iot:Subscribe\"\n      ],\n      \"Resource\": [\n        \"arn:aws:iot:us-west-2:57EXAMPLE833:topicfilter/test/dc/*\"\n      ]\n    },\n    {\n      \"Effect\": \"Allow\",\n      \"Action\": [\n        \"iot:Receive\"\n      ],\n      \"Resource\": [\n        \"arn:aws:iot:us-west-2:57EXAMPLE833:topic/test/dc/*\"\n      ]\n    }\n  ]\n}\n",
    "policyVersionId": "2",
    "isDefaultVersion": true
}

如果您收到有太多策略版本无法保存新版本的错误，请输入此命令列出策略的当前版本。查看此命令返回的列表查找可以删除的策略版本。

aws iot list-policy-versions --policy-name "PubSubTestThingPolicy"

输入此命令删除不再需要的版本。请注意，您无法删除原定设置策略版本。原定设置策略版本为具有 true的 isDefaultVersion值。

aws iot delete-policy-version \
--policy-name "PubSubTestThingPolicy" \
--policy-version-id policyId

删除策略版本后，请重试此步骤。

在 MQTT 测试客户端，检查订阅。如果已在 #主题筛选条件中订阅了 MQTT 测试客户端，请继续执行下一步。如果没有订阅，进入 MQTT test client（MQTT 测试客户端）的 Subscribe to a topic（订阅主题）选项卡，在 Topic filter（主题筛选条件）中输入 #（井号），然后选择 Subscribe（订阅）进行订阅。

在连接到 Raspberry Pi 的本地主机上的终端窗口中，输入这些命令启动 Amazon IoTDevice Client。

cd ~/aws-iot-device-client/build
./aws-iot-device-client --config-file ~/dc-configs/dc-pubsub-wild-config.json

在观看在本地主机上终端窗口中的 Amazon IoTDevice Client 输出，返回 MQTT 测试客户端。在发布主题选项卡中，主题名称，输入 test/dc/subtopic，然后选择发布。

在终端窗口中，通过查找以下消息确认已收到消息，例如：

2021-11-10T16:34:20.101Z [DEBUG] {samples/PubSubFeature.cpp}: Message received on subscribe topic, size: 76 bytes

在观看在本地主机的终端窗口中Amazon IoT Device Client 输出，返回 MQTT 测试客户端。在发布主题选项卡中，主题名称，输入 test/dc/subtopic2，然后选择发布。

在终端窗口中，通过查找以下消息确认已收到消息，例如：

2021-11-10T16:34:32.078Z [DEBUG] {samples/PubSubFeature.cpp}: Message received on subscribe topic, size: 77 bytes

看到确认收到两条消息的消息后，请输入 ^C(Ctrl-C) 可停止 Amazon IoTDevice Client。

输入此命令可查看消息日志文件的末尾并查看您从 MQTT 测试客户端发布的信息

tail -n 20 ~/.aws-iot-device-client/log/pubsub_rx_msgs.log