awsIot客户端集成springboot

àì夳堔傛蜴生んèń 2022-09-15 00:59 185阅读 0赞

之前写了一篇awsIot服务端创建物品的文章，经过一番研究awsIot客户端也有小成。  
代码如下

首先连接初并始化客户端

@PostMapping("/initClient")
        private String initClient(@RequestBody InitClientRequestDTO initClientRequestDTO) {
            SampleUtil.KeyStorePasswordPair pair = SampleUtil.getKeyStorePasswordPair(initClientRequestDTO.getCertificateFile(), initClientRequestDTO.getPrivateKeyFile());
            AWSIotMqttClient awsIotClient = new AWSIotMqttClient(clientEndpoint, initClientRequestDTO.getThingName(), pair.keyStore, pair.keyPassword);
            if (awsIotClient == null) {
                throw new IllegalArgumentException("Failed to construct client due to missing certificate or credentials.");
            }
            try {
                awsIotClient.connect();
            } catch (AWSIotException e) {
                e.printStackTrace();
            }
            concurrentHashMap.put(initClientRequestDTO.getThingName(), awsIotClient);
            return "OK";
        }

订阅主题

@RequestMapping("/subscribe")
        private String subscribe(String thingName, String topic) {
            AWSIotMqttClient awsIotClient = concurrentHashMap.get(thingName);
            AWSIotTopic awsIotTopic = new TopicListener(topic, TestTopicQos);
            try {
                awsIotClient.subscribe(awsIotTopic, true);
    
            } catch (AWSIotException e) {
                e.printStackTrace();
            }
            return "OK";
        }

发送主题

@RequestMapping("/NonBlockingPublisher")
        private String NonBlockingPublisher(String thingName, String topic,String payload) {
            AWSIotMessage message = new NonBlockingPublishListener(topic, TestTopicQos, payload);
            try {
                AWSIotMqttClient awsIotClient = concurrentHashMap.get(thingName);
                awsIotClient.publish(message);
            } catch (AWSIotException e) {
                System.out.println(System.currentTimeMillis() + ": publish failed for " + payload);
            }
            return "OK";
        }

订阅主题后接收消息的回调

package com.example.awsmqttclient.client;
    
    import com.amazonaws.services.iot.client.AWSIotMessage;
    import com.amazonaws.services.iot.client.AWSIotQos;
    import com.amazonaws.services.iot.client.AWSIotTopic;
    
    /**
     * This class extends {@link AWSIotTopic} to receive messages from a subscribed
     * topic.
     */
    public class TopicListener extends AWSIotTopic {
    
        public TopicListener(String topic, AWSIotQos qos) {
            super(topic, qos);
        }
    
        @Override
        public void onMessage(AWSIotMessage message) {
            System.out.println(message.getTopic());
            System.out.println("回调"+ message.getStringPayload());
        }
    
    }

测试流程  
其中用postman模拟物品，aws自带的客户端模拟app

首先初始化物品  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5oiR5piv55yf55qE6I-cKOOEkm_jhJIp_size_20_color_FFFFFF_t_70_g_se_x_16]  
然后订阅主题  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5oiR5piv55yf55qE6I-cKOOEkm_jhJIp_size_20_color_FFFFFF_t_70_g_se_x_16 1]  
模拟app发送命令  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5oiR5piv55yf55qE6I-cKOOEkm_jhJIp_size_20_color_FFFFFF_t_70_g_se_x_16 2]  
物品得到感应  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5oiR5piv55yf55qE6I-cKOOEkm_jhJIp_size_20_color_FFFFFF_t_70_g_se_x_16 3]  
模拟app向物品发送指令的流程，鄙人才接触一个礼拜对物联网也不太熟悉，如理解有错误尽管指出。

[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5oiR5piv55yf55qE6I-cKOOEkm_jhJIp_size_20_color_FFFFFF_t_70_g_se_x_16]: /images/20220828/2cb79eaed70f445f88bc51c17ba1783d.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5oiR5piv55yf55qE6I-cKOOEkm_jhJIp_size_20_color_FFFFFF_t_70_g_se_x_16 1]: /images/20220828/04d26ff72669440fbb6bc0e8052adb85.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5oiR5piv55yf55qE6I-cKOOEkm_jhJIp_size_20_color_FFFFFF_t_70_g_se_x_16 2]: /images/20220828/399c5ba16dca47ef9114841de9b417fe.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5oiR5piv55yf55qE6I-cKOOEkm_jhJIp_size_20_color_FFFFFF_t_70_g_se_x_16 3]: /images/20220828/4185428e27524652bb20d77893fad506.png