AWS IoT新手求助：基于Raspberry Pi的Greengrass设备通信实现指引

Hey there! 既然你已经走完了AWS Greengrass官方基础示例，接下来搞定双ESP设备通过树莓派Core通信的场景其实没那么复杂，我来给你一步步拆解关键步骤和实操细节：

Greengrass本地通信的本质是MQTT消息通过Core做本地路由，不需要绕云端。所以重点要搞定三个环节：设备与Core的合法连接、设备间的消息订阅权限、ESP端的代码适配。

1. 确认ESP设备的Greengrass注册状态 #

先检查ESP8266和ESP32是否已经：

• 作为Greengrass设备添加到你的组中
• 下载了对应的设备证书包（包含ca.pem、cert.pem、private.key）
• 在Greengrass组的「Devices」列表里状态显示为「Associated」

如果还没完成设备注册，直接用官方文档里的「Add Device」流程再走一遍就行，注意要选「Greengrass device」类型，不是普通IoT Thing。

2. 配置Greengrass组的订阅权限（最容易踩坑的环节） #

你需要给两个ESP设备配置互相发送消息的权限，步骤如下：

1. 进入你的Greengrass组，点击「Subscriptions」→「Add subscription」
2. 先添加ESP8266到主题的订阅：
   • 源：选择ESP8266对应的Thing名称
   • 目标：选择「Topic」，输入自定义主题（比如esp/local/comm，名字随便取，只要两个设备统一就行）
3. 再添加ESP32到同一主题的反向订阅，确保两个设备都能往这个主题发消息
4. 额外确认：Core需要有转发本地消息的权限，默认Greengrass组会开启本地路由策略，如果你没修改过就不用额外配置；如果之前改了，要确保Core的角色允许访问这个主题

提示：如果想用设备影子同步状态，主题格式是$aws/things/[ThingName]/shadow/update，但自定义主题更适合设备间直接的指令/数据通信。

3. ESP设备端代码适配 #

官方示例可能默认连云端MQTT，你需要改成连树莓派Core的本地IP，同时替换成Greengrass设备证书。这里给你一个Arduino环境下的ESP8266示例片段：

#include <ESP8266WiFi.h>
#include <PubSubClient.h>

// 替换成你的WiFi信息
const char* ssid = "你的WiFi名称";
const char* password = "WiFi密码";
// 替换成树莓派的局域网IP（比如192.168.3.10）
const char* mqttServer = "树莓派本地IP";
const int mqttPort = 8883;
// 替换成ESP8266对应的Greengrass Thing名称
const char* mqttClientId = "ESP8266_GG_Device";
// 和订阅配置里一致的主题
const char* topic = "esp/local/comm";

WiFiClientSecure espClient;
PubSubClient client(espClient);

void setup() {
  Serial.begin(115200);
  
  // 连接WiFi
  WiFi.begin(ssid, password);
  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print(".");
  }
  Serial.println("WiFi connected!");

  // 加载Greengrass设备证书（把证书内容直接粘贴到引号里）
  espClient.setCACert("-----BEGIN CERTIFICATE-----\n...（CA证书完整内容）\n-----END CERTIFICATE-----");
  espClient.setCertificate("-----BEGIN CERTIFICATE-----\n...（设备证书完整内容）\n-----END CERTIFICATE-----");
  espClient.setPrivateKey("-----BEGIN RSA PRIVATE KEY-----\n...（私钥完整内容）\n-----END RSA PRIVATE KEY-----");

  client.setServer(mqttServer, mqttPort);
  // 设置消息回调，接收ESP32发来的消息
  client.setCallback(callback);
}

void loop() {
  if (!client.connected()) {
    reconnect();
  }
  client.loop();

  // 每隔5秒发送一条测试消息
  static unsigned long lastPublish = 0;
  if (millis() - lastPublish > 5000) {
    lastPublish = millis();
    client.publish(topic, "Hello from ESP8266!");
    Serial.println("Message sent");
  }
}

// 消息回调函数，处理收到的消息
void callback(char* topic, byte* payload, unsigned int length) {
  Serial.print("Received message: ");
  for (int i = 0; i < length; i++) {
    Serial.print((char)payload[i]);
  }
  Serial.println();
}

// 重连MQTT函数
void reconnect() {
  while (!client.connected()) {
    Serial.print("Connecting to MQTT...");
    if (client.connect(mqttClientId)) {
      Serial.println("Connected!");
      // 订阅主题，接收其他设备的消息
      client.subscribe(topic);
    } else {
      Serial.print("Failed, rc=");
      Serial.print(client.state());
      Serial.println(" Retrying in 5s...");
      delay(5000);
    }
  }
}

ESP32的代码逻辑完全一致，只需要把mqttClientId换成它对应的Greengrass Thing名称，证书也换成自己的即可。

4. 验证通信是否正常 #

1. 先确认树莓派上的Greengrass Core服务在运行：执行sudo systemctl status greengrass，看到active(running)就没问题
2. 可以在树莓派上用mosquitto_sub工具监听主题，验证消息是否正常转发：

   mosquitto_sub -h localhost -p 8883 --cafile /greengrass/certs/root.ca.pem --cert /greengrass/certs/device.cert.pem --key /greengrass/certs/device.private.key -t "esp/local/comm"
   

3. 给两个ESP设备上电，打开串口监视器，应该能看到双方互相发送的消息。如果没收到，优先排查：WiFi是否连对、证书是否粘贴完整、Core的IP是否正确、订阅权限是否配置到位。

• 设备影子同步：如果需要同步设备在线状态/配置，可以用Greengrass设备影子，Core会缓存设备状态，即使设备离线也能读取最新数据
• 本地Lambda逻辑：如果需要复杂的设备联动（比如ESP8266触发ESP32执行特定动作），可以在Core上部署本地Lambda，监听主题消息后做处理再转发
• 日志排查：遇到问题时，查看Greengrass Core的日志：sudo tail -f /greengrass/ggc/var/log/system/runtime.log，或者ESP的串口日志，找具体报错信息

内容的提问来源于stack exchange，提问作者inayatu