Springboot实现MQTT通信

落日映苍穹つ 2023-10-02 09:15 30阅读 0赞

#### 目录 ####

*   *   *  一、MQTT简介
         *   *   *  1、MQTT协议
                 *  2、MQTT协议特点
         *  二、MQTT服务器搭建
         *  三、使用Springboot整合MQTT协议
         *   *  1、在父工程下创建一个Springboot项目作为消息的提供者
             *   *  1.1 导入依赖包
                 *  1.2 修改配置文件
                 *  1.3 消息发布者客户端配置
                 *  1.4 消息发布客户端回调
                 *  1.5 创建控制器测试发布信息
             *  2、在父工程下创建一个Springboot项目作为消息的接受者
             *   *  2.1 导入依赖包
                 *  2.2 修改配置文件
                 *  2.3 接收者客户端配置
                 *  2.4 消息接收者客户端回调
                 *  2.5 控制器控制手动建立和断开连接方法
             *  3、测试
             *   *  3.1 分别启动两个项目，可以在管理界面看到创建的两个客户端
                 *  3.2 调用发布消息接口
                 *  3.3 测试断开连接接口
                 *  3.4 测试建立连接接口

#### 一、MQTT简介 ####

###### 1、MQTT协议 ######

> MQTT（Message Queuing Telemetry Transport，消息队列遥测传输协议），是一种基于发布/订阅（publish/subscribe）模式的“轻量级”通讯协议，该协议构建于TCP/IP协议上，由IBM在1999年发布。  
> MQTT最大优点在于，用极少的代码和有限的带宽，为连接远程设备提供实时可靠的消息服务。  
> 作为一种低开销、低带宽占用的即时通讯协议，使其在物联网、小型设备、移动应用等方面有较广泛的应用。

###### 2、MQTT协议特点 ######

*  MQTT是一个基于客户端-服务器的消息发布/订阅传输协议。
 *  MQTT协议是轻量、简单、开放和易于实现的，这些特点使它适用范围非常广泛。在很多情况下，包括受限的环境中，如：机器与机器（M2M）通信和物联网（IoT）。

发布和订阅  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA54ix5omT576955CD55qE56CB54y_size_20_color_FFFFFF_t_70_g_se_x_16]  
QoS（Quality of Service levels）

*  ① QoS 0 至多一次  
    这一级别会发生消息丢失或重复，消息发布依赖于底层TCP/IP网络。即：<=1  
    ![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA54ix5omT576955CD55qE56CB54y_size_9_color_FFFFFF_t_70_g_se_x_16]
 *  ② QoS 1 最少一次  
    QoS 1 承诺消息将至少传送一次给订阅者。  
    ![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA54ix5omT576955CD55qE56CB54y_size_9_color_FFFFFF_t_70_g_se_x_16 1]
 *  ③ QoS 2 只有一次  
    使用 QoS 2，我们保证消息仅传送到目的地一次。为此，带有唯一消息 ID 的消息会存储两次，首先来自发送者，然后是接收者。QoS 级别 2 在网络中具有最高的开销，因为在发送方和接收方之间需要两个流。

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA54ix5omT576955CD55qE56CB54y_size_9_color_FFFFFF_t_70_g_se_x_16 2]

#### 二、MQTT服务器搭建 ####

这里可以参考我的另一篇博客: [MQTT服务器的搭建与MQTT客户端的使用][MQTT_MQTT].

#### 三、使用Springboot整合MQTT协议 ####

##### 1、在父工程下创建一个Springboot项目作为消息的提供者 #####

###### 1.1 导入依赖包 ######

<dependencies>
    		
    		<dependency>
    		<groupId>org.springframework.integration</groupId>
    		<artifactId>spring-integration-stream</artifactId>
    		</dependency>
    		<dependency>
    		<groupId>org.springframework.boot</groupId>
    		<artifactId>spring-boot-starter-integration</artifactId>
    		</dependency>
    		<dependency>
    		<groupId>org.springframework.integration</groupId>
    		<artifactId>spring-integration-mqtt</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter</artifactId>
    		</dependency>
    
    		<dependency>
        		<groupId>org.projectlombok</groupId>
       			<artifactId>lombok</artifactId>
        		<version>1.18.20</version>
    		</dependency>
    			<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-web</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-test</artifactId>
    			<scope>test</scope>
    		</dependency>
    	</dependencies>

###### 1.2 修改配置文件 ######

spring:
      application:
        name: provider
        #MQTT配置信息
      mqtt:
         #MQTT服务地址，端口号默认11883，如果有多个，用逗号隔开
        url: tcp://127.0.0.1:11883
         #用户名
        username: admin
         #密码
        password: 123456
         #客户端id(不能重复)
        client:
            id: provider-id
        #MQTT默认的消息推送主题，实际可在调用接口是指定
        default: 
            topic: topic
    server:
      port: 8080

###### 1.3 消息发布者客户端配置 ######

package com.lyp.mqttprovider.mqtt;
    
    import lombok.extern.slf4j.Slf4j;
    
    import javax.annotation.PostConstruct;
    
    import org.eclipse.paho.client.mqttv3.*;
    import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.context.annotation.Configuration;
    
    @Configuration
    @Slf4j
    public class MqttProviderConfig {
        
        @Value("${spring.mqtt.username}")
        private String username;
    
        @Value("${spring.mqtt.password}")
        private String password;
    
        @Value("${spring.mqtt.url}")
        private String hostUrl;
    
        @Value("${spring.mqtt.client.id}")
        private String clientId;
    
        @Value("${spring.mqtt.default.topic}")
        private String defaultTopic;
    
        /**
         * 客户端对象
         */
        private MqttClient client;
    
        /**
         * 在bean初始化后连接到服务器
         */
        @PostConstruct
        public void init(){
        
            connect();
        }
    
        /**
         * 客户端连接服务端
         */
        public void connect(){
        
            try{
        
            //创建MQTT客户端对象
            client = new MqttClient(hostUrl,clientId,new MemoryPersistence());
            //连接设置
            MqttConnectOptions options = new MqttConnectOptions();
            //是否清空session，设置false表示服务器会保留客户端的连接记录（订阅主题，qos）,客户端重连之后能获取到服务器在客户端断开连接期间推送的消息
            //设置为true表示每次连接服务器都是以新的身份
            options.setCleanSession(true);
            //设置连接用户名
            options.setUserName(username);
            //设置连接密码
            options.setPassword(password.toCharArray());
            //设置超时时间，单位为秒
            options.setConnectionTimeout(100);
            //设置心跳时间 单位为秒，表示服务器每隔 1.5*20秒的时间向客户端发送心跳判断客户端是否在线
            options.setKeepAliveInterval(20);
            //设置遗嘱消息的话题，若客户端和服务器之间的连接意外断开，服务器将发布客户端的遗嘱信息
            options.setWill("willTopic",(clientId + "与服务器断开连接").getBytes(),0,false);
            //设置回调
            client.setCallback(new MqttProviderCallBack());
            client.connect(options);
            } catch(MqttException e){
        
                e.printStackTrace();
            }
           
        }
        public void publish(int qos,boolean retained,String topic,String message){
        
            MqttMessage mqttMessage = new MqttMessage();
            mqttMessage.setQos(qos);
            mqttMessage.setRetained(retained);
            mqttMessage.setPayload(message.getBytes());
            //主题的目的地，用于发布/订阅信息
            MqttTopic mqttTopic = client.getTopic(topic);
            //提供一种机制来跟踪消息的传递进度
            //用于在以非阻塞方式（在后台运行）执行发布是跟踪消息的传递进度
            MqttDeliveryToken token;
            try {
        
                //将指定消息发布到主题，但不等待消息传递完成，返回的token可用于跟踪消息的传递状态
                //一旦此方法干净地返回，消息就已被客户端接受发布，当连接可用，将在后台完成消息传递。
                token = mqttTopic.publish(mqttMessage);
                token.waitForCompletion();
            } catch (MqttException e) {
        
                e.printStackTrace();
            }
        }
    
    }

###### 1.4 消息发布客户端回调 ######

package com.lyp.mqttprovider.mqtt;
    
    import org.eclipse.paho.client.mqttv3.IMqttAsyncClient;
    import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
    import org.eclipse.paho.client.mqttv3.MqttCallback;
    import org.eclipse.paho.client.mqttv3.MqttMessage;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.context.annotation.Configuration;
    
    @Configuration
    public class MqttProviderCallBack implements MqttCallback{
        
    
        @Value("${spring.mqtt.client.id}")
        private String clientId;
        /**
         * 与服务器断开的回调
         */
        @Override
        public void connectionLost(Throwable cause) {
        
            System.out.println(clientId+"与服务器断开连接");
        }
    
        /**
         * 消息到达的回调
         */
        @Override
        public void messageArrived(String topic, MqttMessage message) throws Exception {
        
            
            
        }
    
        /**
         * 消息发布成功的回调
         */
        @Override
        public void deliveryComplete(IMqttDeliveryToken token) {
        
            IMqttAsyncClient client = token.getClient();
            System.out.println(client.getClientId()+"发布消息成功！");
            
        }
        
    }

###### 1.5 创建控制器测试发布信息 ######

package com.lyp.mqttprovider.controller;
    
    import com.lyp.mqttprovider.mqtt.MqttProviderConfig;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Controller;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.ResponseBody;
    
    @Controller
    public class SendController {
        
        @Autowired
        private MqttProviderConfig providerClient;
    
        @RequestMapping("/sendMessage")
        @ResponseBody
        public String sendMessage(int qos,boolean retained,String topic,String message){
        
            try {
        
                providerClient.publish(qos, retained, topic, message);
                return "发送成功";
            } catch (Exception e) {
        
                e.printStackTrace();
                return "发送失败";
            }
        }
    }

##### 2、在父工程下创建一个Springboot项目作为消息的接受者 #####

###### 2.1 导入依赖包 ######

<dependencies>
    	
    		<dependency>
    		<groupId>org.springframework.integration</groupId>
    		<artifactId>spring-integration-stream</artifactId>
    		</dependency>
    		<dependency>
    		<groupId>org.springframework.boot</groupId>
    		<artifactId>spring-boot-starter-integration</artifactId>
    		</dependency>
    		<dependency>
    		<groupId>org.springframework.integration</groupId>
    		<artifactId>spring-integration-mqtt</artifactId>
    		</dependency>
    		
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-web</artifactId>
    		</dependency>
    
    		<dependency>
    			<groupId>org.projectlombok</groupId>
    			<artifactId>lombok</artifactId>
    			<optional>true</optional>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-test</artifactId>
    			<scope>test</scope>
    		</dependency>
    	</dependencies>

###### 2.2 修改配置文件 ######

spring:
      application:
        name: consumer
      #MQTT配置信息
      mqtt:
        #MQTT服务端地址，端口默认为11883，如果有多个，用逗号隔开
        url: tcp://127.0.0.1:11883
        #用户名
        username: admin
        #密码
        password: 123456
        #客户端id（不能重复）
        client:
          id: consumer-id
        #MQTT默认的消息推送主题，实际可在调用接口时指定
        default:
          topic: topic
    server:
      port: 8085

###### 2.3 接收者客户端配置 ######

package com.lyp.mqttconsumer.mqtt;
    
    import javax.annotation.PostConstruct;
    
    import org.eclipse.paho.client.mqttv3.MqttClient;
    import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
    import org.eclipse.paho.client.mqttv3.MqttException;
    import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.context.annotation.Configuration;
    
    @Configuration
    public class MqttConsumerConfig {
        
        @Value("${spring.mqtt.username}")
        private String username;
    
        @Value("${spring.mqtt.password}")
        private String password;
    
        @Value("${spring.mqtt.url}")
        private String hostUrl;
    
        @Value("${spring.mqtt.client.id}")
        private String clientId;
    
        @Value("${spring.mqtt.default.topic}")
        private String defaultTopic;
    
        /**
         * 客户端对象
         */
        private MqttClient client;
    
        /**
         * 在bean初始化后连接到服务器
         */
        @PostConstruct
        public void init(){
        
            connect();
        }
    
        /**
         * 客户端连接服务端
         */
        public void connect(){
        
            try {
        
                //创建MQTT客户端对象
                client = new MqttClient(hostUrl,clientId,new MemoryPersistence());
                //连接设置
                MqttConnectOptions options = new MqttConnectOptions();
                //是否清空session，设置为false表示服务器会保留客户端的连接记录，客户端重连之后能获取到服务器在客户端断开连接期间推送的消息
                //设置为true表示每次连接到服务端都是以新的身份
                options.setCleanSession(true);
                //设置连接用户名
                options.setUserName(username);
                //设置连接密码
                options.setPassword(password.toCharArray());
                //设置超时时间，单位为秒
                options.setConnectionTimeout(100);
                //设置心跳时间 单位为秒，表示服务器每隔1.5*20秒的时间向客户端发送心跳判断客户端是否在线
                options.setKeepAliveInterval(20);
                //设置遗嘱消息的话题，若客户端和服务器之间的连接意外断开，服务器将发布客户端的遗嘱信息
                options.setWill("willTopic",(clientId + "与服务器断开连接").getBytes(),0,false);
                //设置回调
                client.setCallback(new MqttConsumerCallBack());
                client.connect(options);
                //订阅主题
                //消息等级，和主题数组一一对应，服务端将按照指定等级给订阅了主题的客户端推送消息
                int[] qos = {
        1,1};
                //主题
                String[] topics = {
        "topic1","topic2"};
              	//订阅主题
                client.subscribe(topics,qos);
            } catch (MqttException e) {
        
                e.printStackTrace();
            }
        }
    
        /**
         * 断开连接
         */
        public void disConnect(){
        
            try {
        
                client.disconnect();
            } catch (MqttException e) {
        
                e.printStackTrace();
            }
        }
    
    
        /**
         * 订阅主题
         */
        public void subscribe(String topic,int qos){
        
            try {
        
                client.subscribe(topic,qos);
            } catch (MqttException e) {
        
                e.printStackTrace();
            }
        }
    }

###### 2.4 消息接收者客户端回调 ######

package com.lyp.mqttconsumer.mqtt;
    
    import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
    import org.eclipse.paho.client.mqttv3.MqttCallback;
    import org.eclipse.paho.client.mqttv3.MqttMessage;
    
    public class MqttConsumerCallBack implements MqttCallback{
        
    
       /**
         * 客户端断开连接的回调
         */
        @Override
        public void connectionLost(Throwable throwable) {
        
            System.out.println("与服务器断开连接，可重连");
        }
    
        /**
         * 消息到达的回调
         */
        @Override
        public void messageArrived(String topic, MqttMessage message) throws Exception {
        
            System.out.println(String.format("接收消息主题 : %s",topic));
            System.out.println(String.format("接收消息Qos : %d",message.getQos()));
            System.out.println(String.format("接收消息内容 : %s",new String(message.getPayload())));
            System.out.println(String.format("接收消息retained : %b",message.isRetained()));
        }
    
        /**
         * 消息发布成功的回调
         */
        @Override
        public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {
        
    
        }
        
    }

###### 2.5 控制器控制手动建立和断开连接方法 ######

package com.lyp.mqttconsumer.controller;
    
    import com.lyp.mqttconsumer.mqtt.MqttConsumerConfig;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.stereotype.Controller;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.ResponseBody;
    
    
    @Controller
    public class TestController {
        
        @Autowired
        private MqttConsumerConfig client;
    
        @Value("${spring.mqtt.client.id}")
        private String clientId;
    
        @RequestMapping("/connect")
        @ResponseBody
        public String connect(){
        
            client.connect();
            return clientId + "连接到服务器";
        }
    
        @RequestMapping("/disConnect")
        @ResponseBody
        public String disConnect(){
        
            client.disConnect();
            return clientId + "与服务器断开连接";
        }
    }

##### 3、测试 #####

###### 3.1 分别启动两个项目，可以在管理界面看到创建的两个客户端 ######

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA54ix5omT576955CD55qE56CB54y_size_20_color_FFFFFF_t_70_g_se_x_16 1]

###### 3.2 调用发布消息接口 ######

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA54ix5omT576955CD55qE56CB54y_size_20_color_FFFFFF_t_70_g_se_x_16 2]  
数据一致，测试成功  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA54ix5omT576955CD55qE56CB54y_size_20_color_FFFFFF_t_70_g_se_x_16 3]

###### 3.3 测试断开连接接口 ######

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA54ix5omT576955CD55qE56CB54y_size_20_color_FFFFFF_t_70_g_se_x_16 4]  
查看客户端，确实已经断开连接  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA54ix5omT576955CD55qE56CB54y_size_20_color_FFFFFF_t_70_g_se_x_16 5]

###### 3.4 测试建立连接接口 ######

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA54ix5omT576955CD55qE56CB54y_size_20_color_FFFFFF_t_70_g_se_x_16 6]  
客户端显示已经重新连接上，测试成功  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA54ix5omT576955CD55qE56CB54y_size_20_color_FFFFFF_t_70_g_se_x_16 7]

[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA54ix5omT576955CD55qE56CB54y_size_20_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/be1596f914bd4b9483c0d8726c36e849.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA54ix5omT576955CD55qE56CB54y_,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA54ix5omT576955CD55qE56CB54y_size_9_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/d720f19fad5f45929f0e644f50a56cf4.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA54ix5omT576955CD55qE56CB54y_,size_9,color_FFFFFF,t_70,g_se,x_16
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA54ix5omT576955CD55qE56CB54y_size_9_color_FFFFFF_t_70_g_se_x_16 1]: https://img-blog.csdnimg.cn/fae9faf2dc19482ab51b209dd5d92943.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA54ix5omT576955CD55qE56CB54y_,size_9,color_FFFFFF,t_70,g_se,x_16
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA54ix5omT576955CD55qE56CB54y_size_9_color_FFFFFF_t_70_g_se_x_16 2]: https://img-blog.csdnimg.cn/d83bbc9a896f4755a583bdd0bda2b2c7.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA54ix5omT576955CD55qE56CB54y_,size_9,color_FFFFFF,t_70,g_se,x_16
[MQTT_MQTT]: https://blog.csdn.net/weixin_46822367/article/details/120154306?spm=1001.2014.3001.5501
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA54ix5omT576955CD55qE56CB54y_size_20_color_FFFFFF_t_70_g_se_x_16 1]: https://img-blog.csdnimg.cn/e00b5ffe71bf4f53b0fa1c4048e99896.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA54ix5omT576955CD55qE56CB54y_,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA54ix5omT576955CD55qE56CB54y_size_20_color_FFFFFF_t_70_g_se_x_16 2]: https://img-blog.csdnimg.cn/86666e1aba9b47e1adeb73caaf50b92b.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA54ix5omT576955CD55qE56CB54y_,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA54ix5omT576955CD55qE56CB54y_size_20_color_FFFFFF_t_70_g_se_x_16 3]: https://img-blog.csdnimg.cn/09dcac00b759464ea8d8be7c712877f8.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA54ix5omT576955CD55qE56CB54y_,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA54ix5omT576955CD55qE56CB54y_size_20_color_FFFFFF_t_70_g_se_x_16 4]: https://img-blog.csdnimg.cn/1856ca5a925847ac8c32b3ecf441b6bd.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA54ix5omT576955CD55qE56CB54y_,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA54ix5omT576955CD55qE56CB54y_size_20_color_FFFFFF_t_70_g_se_x_16 5]: https://img-blog.csdnimg.cn/be74a3a1cd7445aa885a903947587242.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA54ix5omT576955CD55qE56CB54y_,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA54ix5omT576955CD55qE56CB54y_size_20_color_FFFFFF_t_70_g_se_x_16 6]: https://img-blog.csdnimg.cn/53558827dc114ac8acb7b12bbf9ae7b3.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA54ix5omT576955CD55qE56CB54y_,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA54ix5omT576955CD55qE56CB54y_size_20_color_FFFFFF_t_70_g_se_x_16 7]: https://img-blog.csdnimg.cn/d9ed0092beff41fc8ca741a924e8bd9e.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA54ix5omT576955CD55qE56CB54y_,size_20,color_FFFFFF,t_70,g_se,x_16