@RestController
public class IotController {

    @PostMapping("/data")
    public void receiveData(@RequestBody String data) {
        // 使用 Amazon IoT SDK 将数据发布到 IoT 规则引擎
        AmazonIotClient iotClient = new AmazonIotClient();
        PublishMessageRequest request = new PublishMessageRequest();
        request.setTopic("my-topic");
        request.setMessage(data);
        iotClient.publishMessage(request);
    }
}

public class IotVerticle extends AbstractVerticle {

    @Override
    public void start() {
        // 创建 MQTT 客户端
        MqttClientOptions options = new MqttClientOptions();
        options.setUsername(username);
        options.setPassword(password);
        MqttClient client = MqttClient.create(options);

        // 遥测订阅设备
        client.subscribe("devices/#", 1);

        // 设置消息侦听器
        client.messageHandler(message -> {
            // 发送遥测数据 EventBus
            EventBusHelper.send(eventBus, "telemetry", message.payload());
        });
    }
}