spring-boot - 带有 Apache camel-mqtt 的 AWS IoT MQTT 客户端

Question

我正在研究使用 Apache Camel（使用 camel-mqtt）+ Spring Boot 构建 AWS IoT Java 客户端。这听起来很适合我，但找不到任何例子。有什么我看不到的缺点吗？有兴趣看到任何指针。

Answer 1

我让它与以下配置一起工作。sslContext bean 持有证书/安全性：

    @Bean
    RouteBuilder awsIoTRoute() {

        return new RouteBuilder() {

            @Override
            public void configure() throws Exception {

                from("timer://foo?repeatCount=0&delay=5000&fixedRate=true&period=17s")
                    .setBody(simple("TEST MESSAGE"))
                    .to("mqtt:awsIoTPublisher?host=ssl://{{aws.iot.host}}:8883&publishTopicName={{aws.iot.pub.topic}}&clientId={{aws.iot.pub.clientId}}&sslContext=#sslContext")
                    .log("Sent :"+body().convertToString().toString());

                from("mqtt:awsIoTReciever?host=ssl://{{aws.iot.host}}:8883&subscribeTopicName={{aws.iot.sub.topic}}&clientId={{aws.iot.sub.clientId}}&sslContext=#sslContext").log("Recieved : "+body().convertToString());


            }
        };
    }