脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → springboot 实现mqtt物联网

springboot 实现mqtt物联网的示例代码

 更新时间：2021年03月26日 08:34:43   作者：尽力漂亮  
这篇文章主要介绍了springboot 实现mqtt物联网,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下

Springboot整合mybatisPlus+mysql+druid+swaggerUI+ mqtt 整合mqtt整合druid整合mybatis-plus完整pom完整yml整合swaggerUi整合log4j MQTT 物联网系统基本架构本物联网系列
mqtt)

整合mqtt

 <!--mqtt依赖-->
  <dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-integration</artifactId>
  </dependency>
  <dependency>
   <groupId>org.springframework.integration</groupId>
   <artifactId>spring-integration-stream</artifactId>
  </dependency>
  <dependency>
   <groupId>org.springframework.integration</groupId>
   <artifactId>spring-integration-mqtt</artifactId>
  </dependency>

yml

iot:
 mqtt:
 clientId: ${random.value}
 defaultTopic: topic
 shbykjTopic: shbykj_topic
 url: tcp://127.0.0.1:1883
 username: admin
 password: admin
 completionTimeout: 3000
package com.shbykj.handle.mqtt;

import lombok.Getter;
import lombok.Setter;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.integration.annotation.IntegrationComponentScan;
import org.springframework.stereotype.Component;

/**
 * @Author: wxm
 * @Description: mqtt基础配置类
 */

@Getter
@Setter
@Component
@IntegrationComponentScan
@ConfigurationProperties(prefix = "iot.mqtt")
public class BykjMqttConfig {
 /*
 *
 * 服务地址
 */

 private String url;

 /**
 * 客户端id
 */


 private String clientId;
 /*
 *
 * 默认主题
 */

 private String defaultTopic;
 /*
 *
 * 用户名和密码*/


 private String username;

 private String password;

 /**
 * 超时时间
 */
 private int completionTimeout;
 /**
 * shbykj自定义主题
 */
 private String shbykjTopic;

}
package com.shbykj.handle.mqtt.producer;

import org.springframework.integration.annotation.MessagingGateway;
import org.springframework.integration.mqtt.support.MqttHeaders;
import org.springframework.messaging.handler.annotation.Header;

/**
 * @description rabbitmq mqtt协议网关接口
 * @date 2020/6/8 18:26
 */
@MessagingGateway(defaultRequestChannel = "iotMqttInputChannel")
public interface IotMqttGateway {

 void sendMessage2Mqtt(String data);

 void sendMessage2Mqtt(String data, @Header(MqttHeaders.TOPIC) String topic);

 void sendMessage2Mqtt(@Header(MqttHeaders.TOPIC) String topic, @Header(MqttHeaders.QOS) int qos, String payload);
}
package com.shbykj.handle.mqtt;

import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.integration.annotation.ServiceActivator;
import org.springframework.integration.channel.DirectChannel;
import org.springframework.integration.mqtt.core.DefaultMqttPahoClientFactory;
import org.springframework.integration.mqtt.core.MqttPahoClientFactory;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.MessageHandler;
import org.springframework.messaging.MessagingException;


@Configuration
public class IotMqttProducerConfig {
 public final Logger logger = LoggerFactory.getLogger(this.getClass());


 @Autowired
 private BykjMqttConfig mqttConfig;
 /*
 *
 * MQTT连接器选项
 * *
 */


 @Bean(value = "getMqttConnectOptions")
 public MqttConnectOptions getMqttConnectOptions1() {
 MqttConnectOptions mqttConnectOptions = new MqttConnectOptions();
 // 设置是否清空session,这里如果设置为false表示服务器会保留客户端的连接记录，这里设置为true表示每次连接到服务器都以新的身份连接
 mqttConnectOptions.setCleanSession(true);
 // 设置超时时间 单位为秒
 mqttConnectOptions.setConnectionTimeout(mqttConfig.getCompletionTimeout());
 mqttConnectOptions.setAutomaticReconnect(true);
 mqttConnectOptions.setUserName(mqttConfig.getUsername());
 mqttConnectOptions.setPassword(mqttConfig.getPassword().toCharArray());
 mqttConnectOptions.setServerURIs(new String[]{mqttConfig.getUrl()});
 // 设置会话心跳时间 单位为秒 服务器会每隔1.5*20秒的时间向客户端发送心跳判断客户端是否在线，但这个方法并没有重连的机制
 mqttConnectOptions.setKeepAliveInterval(10);
 // 设置“遗嘱”消息的话题，若客户端与服务器之间的连接意外中断，服务器将发布客户端的“遗嘱”消息。
 //mqttConnectOptions.setWill("willTopic", WILL_DATA, 2, false);
 return mqttConnectOptions;
 }

 /**
 * mqtt工厂
 *
 * @return
 */


 @Bean
 public MqttPahoClientFactory mqttClientFactory() {
 DefaultMqttPahoClientFactory factory = new DefaultMqttPahoClientFactory();
// factory.setServerURIs(mqttConfig.getServers());
 factory.setConnectionOptions(getMqttConnectOptions1());
 return factory;

 }

 @Bean
 public MessageChannel iotMqttInputChannel() {
 return new DirectChannel();
 }

 // @Bean
// @ServiceActivator(inputChannel = "iotMqttInputChannel")
// public MessageHandler mqttOutbound() {
// MqttPahoMessageHandler messageHandler = new MqttPahoMessageHandler(mqttConfig.getClientId(), mqttClientFactory());
// messageHandler.setAsync(false);
// messageHandler.setDefaultQos(2);
// messageHandler.setDefaultTopic(mqttConfig.getDefaultTopic());
// return messageHandler;
// }
 @Bean
 @ServiceActivator(inputChannel = "iotMqttInputChannel")
 public MessageHandler handlerTest() {

 return message -> {
  try {
  String string = message.getPayload().toString();

  System.out.println(string);
  } catch (MessagingException ex) {
  ex.printStackTrace();
  logger.info(ex.getMessage());
  }
 };
 }
}
package com.shbykj.handle.mqtt;

import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.integration.annotation.ServiceActivator;
import org.springframework.integration.channel.DirectChannel;
import org.springframework.integration.core.MessageProducer;
import org.springframework.integration.mqtt.core.DefaultMqttPahoClientFactory;
import org.springframework.integration.mqtt.core.MqttPahoClientFactory;
import org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter;
import org.springframework.integration.mqtt.outbound.MqttPahoMessageHandler;
import org.springframework.integration.mqtt.support.DefaultPahoMessageConverter;
import org.springframework.messaging.Message;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.MessageHandler;
import org.springframework.messaging.MessagingException;

/**
 * @Author: xiaofu
 * @Description: 消息订阅配置
 * @date 2020/6/8 18:24
 */
@Configuration
public class IotMqttSubscriberConfig {
 public final Logger logger = LoggerFactory.getLogger(this.getClass());


 @Autowired
 private MqttReceiveHandle mqttReceiveHandle;
 @Autowired
 private BykjMqttConfig mqttConfig;
 /*
 *
 * MQTT连接器选项
 * *
 */


 @Bean(value = "getMqttConnectOptions")
 public MqttConnectOptions getMqttConnectOptions1() {
 MqttConnectOptions mqttConnectOptions = new MqttConnectOptions();
 // 设置是否清空session,这里如果设置为false表示服务器会保留客户端的连接记录，这里设置为true表示每次连接到服务器都以新的身份连接
 mqttConnectOptions.setCleanSession(true);
 // 设置超时时间 单位为秒
 mqttConnectOptions.setConnectionTimeout(10);
 mqttConnectOptions.setAutomaticReconnect(true);
// mqttConnectOptions.setUserName(mqttConfig.getUsername());
// mqttConnectOptions.setPassword(mqttConfig.getPassword().toCharArray());
 mqttConnectOptions.setServerURIs(new String[]{mqttConfig.getUrl()});
 // 设置会话心跳时间 单位为秒 服务器会每隔1.5*20秒的时间向客户端发送心跳判断客户端是否在线，但这个方法并没有重连的机制
 mqttConnectOptions.setKeepAliveInterval(10);
 // 设置“遗嘱”消息的话题，若客户端与服务器之间的连接意外中断，服务器将发布客户端的“遗嘱”消息。
 //mqttConnectOptions.setWill("willTopic", WILL_DATA, 2, false);
 return mqttConnectOptions;
 }
 /*
 *
 *MQTT信息通道（生产者）
 **
 */

 @Bean
 public MessageChannel iotMqttOutboundChannel() {
 return new DirectChannel();
 }
 /*

 *
 *MQTT消息处理器（生产者）
 **
 */

 @Bean
 @ServiceActivator(inputChannel = "iotMqttOutboundChannel")
 public MessageHandler mqttOutbound() {
 MqttPahoMessageHandler messageHandler = new MqttPahoMessageHandler(mqttConfig.getClientId(), mqttClientFactory());
 messageHandler.setAsync(true);
 messageHandler.setDefaultTopic(mqttConfig.getDefaultTopic());
 return messageHandler;
 }

 /*
 *
 *MQTT工厂
 **
 */
 @Bean
 public MqttPahoClientFactory mqttClientFactory() {
 DefaultMqttPahoClientFactory factory = new DefaultMqttPahoClientFactory();
// factory.setServerURIs(mqttConfig.getServers());
 factory.setConnectionOptions(getMqttConnectOptions1());
 return factory;
 }

 /*
 *
 *MQTT信息通道（消费者）
 **
 */
 @Bean
 public MessageChannel iotMqttInputChannel() {
 return new DirectChannel();
 }

 /**
 * 配置client,监听的topic
 * MQTT消息订阅绑定（消费者）
 ***/

 @Bean
 public MessageProducer inbound() {
 MqttPahoMessageDrivenChannelAdapter adapter = new MqttPahoMessageDrivenChannelAdapter(mqttConfig.getClientId(), mqttClientFactory(), mqttConfig.getDefaultTopic(), mqttConfig.getShbykjTopic());
 adapter.setCompletionTimeout(mqttConfig.getCompletionTimeout());
 adapter.setConverter(new DefaultPahoMessageConverter());
 adapter.setQos(2);
 adapter.setOutputChannel(iotMqttInputChannel());
 return adapter;
 }

 /**
 * @author wxm
 * @description 消息订阅
 * @date 2020/6/8 18:20
 */
 @Bean
 @ServiceActivator(inputChannel = "iotMqttInputChannel")

 public MessageHandler handler() {
 return new MessageHandler() {
  @Override
  public void handleMessage(Message<?> message) throws MessagingException {
  //处理接收消息
  try {
   mqttReceiveHandle.handle(message);
  } catch (Exception e) {
   logger.warn("消息处理异常"+e.getMessage());
   e.printStackTrace();

  }
  }
 };
 }
}
package com.shbykj.handle.mqtt;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.shbykj.handle.common.DataCheck;
import com.shbykj.handle.common.RedisKey;
import com.shbykj.handle.common.RedisUtils;
import com.shbykj.handle.common.constants.Constants;
import com.shbykj.handle.common.model.ShbyCSDeviceEntity;
import com.shbykj.handle.common.model.sys.SysInstrument;
import com.shbykj.handle.resolve.mapper.SysInstrumentMapper;
import com.shbykj.handle.resolve.util.DateUtils;
import com.shbykj.handle.resolve.util.ShbyCSDeviceUtils;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections.BidiMap;
import org.apache.commons.collections.bidimap.DualHashBidiMap;
import org.apache.commons.lang3.StringUtils;
import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttCallback;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.integration.mqtt.support.MqttHeaders;
import org.springframework.messaging.Message;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional;

import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;

/*
 *
 * mqtt客户端消息处理类
 * **/
@Component
@Slf4j
@Transactional
public class MqttReceiveHandle implements MqttCallback {
 private static final Logger logger = LoggerFactory.getLogger(MqttReceiveHandle.class);
 @Value("${shbykj.checkCrc}")
 private boolean checkcrc;
 @Autowired
 private SysInstrumentMapper sysInstrumentMapper;
 @Autowired
 private RedisUtils redisUtils;


 public static BidiMap bidiMap = new DualHashBidiMap();
 //记录bykj协议内容
 public static Map<String, Map<String, Object>> devMap = new HashMap();

 //记录上限数量
// public static Map<String, ChannelHandlerContext> ctxMap = new HashMap();
 public void handle(Message<?> message) {


 try {
  logger.info("{},客户端号：{},主题：{}，QOS:{}，消息接收到的数据：{}", new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()), message.getHeaders().get(MqttHeaders.ID), message.getHeaders().get(MqttHeaders.RECEIVED_TOPIC), message.getHeaders().get(MqttHeaders.RECEIVED_QOS), message.getPayload());
  //处理mqtt数据
  this.handle(message.getPayload().toString());
 } catch (Exception e) {
  e.printStackTrace();
  log.error("处理错误" + e.getMessage());
 }

 }

 private void handle(String str) throws Exception {

 boolean flag = this.dataCheck(str);
 if (flag) {

  ShbyCSDeviceEntity shbyCSDeviceEntity = ShbyCSDeviceUtils.convertToSysInstrumentEntity(str);
  String deviceNumber = shbyCSDeviceEntity.getPN();
  String smpId = shbyCSDeviceEntity.getSMP_ID();
  String smpName = shbyCSDeviceEntity.getSMP_NAME();
  String smpWt = shbyCSDeviceEntity.getSMP_WT();
  if (StringUtils.isEmpty(smpId) || StringUtils.isEmpty(smpName) || StringUtils.isEmpty(smpWt)) {
  log.error("过滤无实际作用报文信息", str);
  logger.error("过滤无实际作用报文信息", str);
  return;
  }
  //判断设备id是否存在数据库中，存在才进行数据部分处理
  //不存在就提醒需要添加设备：
  QueryWrapper<SysInstrument> wrapper = new QueryWrapper();

  wrapper.eq("number", deviceNumber);
  wrapper.eq("is_deleted", Constants.NO);
  SysInstrument sysInstrument = sysInstrumentMapper.selectOne(wrapper);
  if (null == sysInstrument) {
  log.error("碳氧仪不存在或已删除，设备号：{}", deviceNumber);
  logger.error("碳氧仪不存在或已删除，设备号：{}", deviceNumber);
  return;
  }

  try {
  //增加实时数据
  String instrumentId = sysInstrument.getId().toString();
  String realDataKey = RedisKey.CSdevice_DATA_KEY + instrumentId;

  this.redisUtils.set(realDataKey, shbyCSDeviceEntity);
  System.out.println(shbyCSDeviceEntity);
  //通讯时间
  String onlineTime = "shbykj_mqtt:onlines:" + instrumentId;
  this.redisUtils.set(onlineTime, shbyCSDeviceEntity.getDataTime(), (long) Constants.RedisTimeOut.REAL_TIME_OUT);
  log.info("实时数据已经更新：设备主键id" + instrumentId);
  logger.info("{} 实时数据已经更新：设备主键id:{}",new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()),instrumentId);

  } catch (Exception var1) {
  log.error("redis处理实时报文数据逻辑异常 ：" + var1.getMessage());
  logger.error("redis处理实时报文数据逻辑异常 ：" + var1.getMessage());

  }


 }
 }

 private boolean dataCheck(String message) {
 boolean flag = DataCheck.receiverCheck(message);
 if (!flag) {
  return false;
 } else {
  int i = message.indexOf("QN=");
  if (i < 0) {
  log.warn("数据包中没有QN号码: " + message);
  logger.warn("数据包中没有QN号码: " + message);
  return false;
  } else {
  i = message.indexOf("PN=");
  if (i < 0) {
   log.warn("数据包中没有PN号码: " + message);
   logger.warn("数据包中没有PN号码: " + message);
   return false;
  } else {
   if (this.checkcrc) {
   flag = DataCheck.checkCrc(message);
   if (!flag) {
    log.warn("crc校验失败: " + message);
    logger.warn("数据包中没有PN号码: " + message);
    return false;
   }
   }

   return true;
  }
  }
 }
 }


 /**
 * 连接丢失
 *
 * @param throwable
 */
 @Override
 public void connectionLost(Throwable throwable) {
 logger.warn("连接丢失-客户端:｛｝,原因：{}", throwable.getMessage());

 }

 /**
 * 消息已到达
 *
 * @param s
 * @param mqttMessage
 * @throws Exception
 */
 @Override
 public void messageArrived(String s, MqttMessage mqttMessage) throws Exception {

 }

 /**
 * 完成消息回调
 *
 * @param iMqttDeliveryToken
 */
 @Override
 public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {

 }
}

整合druid

pom

 <dependency>
  <groupId>com.alibaba</groupId>
  <artifactId>druid-spring-boot-starter</artifactId>
  <version>1.1.10</version>
 </dependency>

druid-bean.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
 xmlns:aop="http://www.springframework.org/schema/aop" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 xsi:schemaLocation="
 http://www.springframework.org/schema/beans
 http://www.springframework.org/schema/beans/spring-beans.xsd
 http://www.springframework.org/schema/aop
 http://www.springframework.org/schema/aop/spring-aop.xsd">

 <!-- 配置_Druid和Spring关联监控配置 -->
 <bean id="druid-stat-interceptor"
  class="com.alibaba.druid.support.spring.stat.DruidStatInterceptor"></bean>

 <!-- 方法名正则匹配拦截配置 -->
 <bean id="druid-stat-pointcut" class="org.springframework.aop.support.JdkRegexpMethodPointcut"
  scope="prototype">
 <property name="patterns">
  <list>
  <value>com.shbykj.*.service.*.impl.*</value>
  </list>
 </property>
 </bean>

 <aop:config proxy-target-class="true">
 <aop:advisor advice-ref="druid-stat-interceptor"
   pointcut-ref="druid-stat-pointcut" />
 </aop:config>

</beans>

yml

#spring
spring:
 main:
 allow-bean-definition-overriding: true
 # mysql DATABASE CONFIG
 datasource:
 druid:
 filters: stat,wall,log4j2
 continueOnError: true
 type: com.alibaba.druid.pool.DruidDataSource
 url: jdbc:mysql://localhost:3306/mqttdb?useSSL=false&useUnicode=true&characterEncoding=utf-8&serverTimezone=UTC&allowPublicKeyRetrieval=true
 username: root
 password: 123456
 driver-class-name: com.mysql.jdbc.Driver
 # see https://github.com/alibaba/druid
 initialSize: 15
 minIdle: 10
 maxActive: 200
 maxWait: 60000
 timeBetweenEvictionRunsMillis: 60000
 validationQuery: SELECT 1
 testWhileIdle: true
 testOnBorrow: false
 testOnReturn: false
 poolPreparedStatements: true
 keepAlive: true
 maxPoolPreparedStatementPerConnectionSize: 50
 connectionProperties:
 druid.stat.mergeSql: true
 druid.stat.slowSqlMillis: 5000

启动类加上注解@ImportResource( locations = {"classpath:druid-bean.xml"} )

在这里插入图片描述

整合mybatis-plus

pom

<!--mybatis-plus-->
 <dependency>
  <groupId>com.baomidou</groupId>
  <artifactId>spring-wind</artifactId>
  <version>1.1.5</version>
  <exclusions>
  <exclusion>
   <groupId>com.baomidou</groupId>
   <artifactId>mybatis-plus</artifactId>
  </exclusion>
  </exclusions>
 </dependency>

 <dependency>
  <groupId>com.baomidou</groupId>
  <version>3.1.2</version>
  <artifactId>mybatis-plus-boot-starter</artifactId>
 </dependency>
 <dependency>
  <groupId>mysql</groupId>
  <artifactId>mysql-connector-java</artifactId>
  <version>5.1.44</version>
 </dependency>
  <!--PageHelper分页插件-->
 <dependency>
  <groupId>com.github.pagehelper</groupId>
  <artifactId>pagehelper-spring-boot-starter</artifactId>
  <version>1.2.12</version>
 </dependency>

yml

#mybatis
mybatis-plus:
 mapper-locations: classpath:/mapper/*.xml
 typeAliasesPackage: org.spring.springboot.entity
 global-config:
 #主键类型 0:"数据库ID自增", 1:"用户输入ID",2:"全局唯一ID (数字类型唯一ID)", 3:"全局唯一ID UUID";
 id-type: 3
 #字段策略 0:"忽略判断",1:"非 NULL 判断"),2:"非空判断"
 field-strategy: 2
 #驼峰下划线转换
 db-column-underline: true
 #刷新mapper 调试神器
 refresh-mapper: true
 configuration:
 map-underscore-to-camel-case: true
 cache-enabled: false

启动类注解@MapperScan({"com.shbykj.handle.resolve.mapper"})

完整pom

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
 <modelVersion>4.0.0</modelVersion>
 <parent>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-parent</artifactId>
 <version>2.4.1</version>
 <relativePath/> <!-- lookup parent from repository -->
 </parent>
 <groupId>com.shbykj</groupId>
 <artifactId>handle</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 <name>handle</name>
 <description>Demo project for Spring Boot</description>

 <properties>
 <java.version>1.8</java.version>
 </properties>

 <dependencies>
 <!--注意： <scope>compile</scope> 这里是正式环境，解决启动报错-->
 <!--idea springboot启动报SLF4J:Failed to load class “org.slf4j.impl.StaticLoggerBinder-->
 <!--参考：https://blog.csdn.net/u010696630/article/details/84991116-->
 <dependency>
  <groupId>org.slf4j</groupId>
  <artifactId>slf4j-simple</artifactId>
  <version>1.7.25</version>
  <scope>compile</scope>
 </dependency>
 <!-- Log4j2 -->
 <dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-log4j2</artifactId>
 </dependency>

 <!--开启日志注解-->
 <dependency>
  <groupId>org.projectlombok</groupId>
  <artifactId>lombok</artifactId>
 </dependency>
 <!-- 排除 Spring-boot-starter 默认的日志配置 -->
 <dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter</artifactId>
  <exclusions>
  <exclusion>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-logging</artifactId>
  </exclusion>
  </exclusions>
 </dependency>
 <!--swagger api接口生成-->
 <dependency>
  <groupId>io.springfox</groupId>
  <artifactId>springfox-swagger-ui</artifactId>
  <version>2.9.2</version>
 </dependency>

 <!-- 代码生成器的依赖 -->
 <dependency>
  <groupId>io.springfox</groupId>
  <artifactId>springfox-swagger2</artifactId>
  <version>2.9.2</version>
  <exclusions>
  <exclusion>
   <groupId>com.google.guava</groupId>
   <artifactId>guava</artifactId>
  </exclusion>
  </exclusions>
 </dependency>
 <!--mybatis-plus-->
 <dependency>
  <groupId>com.baomidou</groupId>
  <artifactId>spring-wind</artifactId>
  <version>1.1.5</version>
  <exclusions>
  <exclusion>
   <groupId>com.baomidou</groupId>
   <artifactId>mybatis-plus</artifactId>
  </exclusion>
  </exclusions>
 </dependency>

 <dependency>
  <groupId>com.baomidou</groupId>
  <version>3.1.2</version>
  <artifactId>mybatis-plus-boot-starter</artifactId>
 </dependency>
 <dependency>
  <groupId>mysql</groupId>
  <artifactId>mysql-connector-java</artifactId>
  <version>5.1.44</version>
 </dependency>
 <dependency>
  <groupId>com.alibaba</groupId>
  <artifactId>druid-spring-boot-starter</artifactId>
  <version>1.1.10</version>
 </dependency>
 <!--PageHelper分页插件-->
 <dependency>
  <groupId>com.github.pagehelper</groupId>
  <artifactId>pagehelper-spring-boot-starter</artifactId>
  <version>1.2.12</version>
 </dependency>
 <!--devtools热部署-->
 <dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-devtools</artifactId>
  <optional>true</optional>
  <scope>runtime</scope>
 </dependency>
 <!--json转换工具-->
 <dependency>
  <groupId>com.google.code.gson</groupId>
  <artifactId>gson</artifactId>
 </dependency>
 <!-- redis -->
 <dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-data-redis</artifactId>
 </dependency>
 <!--工具类-->
 <dependency>
  <groupId>org.apache.commons</groupId>
  <artifactId>commons-lang3</artifactId>
  <version>3.8.1</version>
 </dependency>
 <!--google-->
 <!-- https://mvnrepository.com/artifact/com.google.guava/guava -->
 <dependency>
  <groupId>com.google.guava</groupId>
  <artifactId>guava</artifactId>
  <version>30.0-jre</version>
 </dependency>
 <!-- 工具类库 -->
 <dependency>
  <groupId>cn.hutool</groupId>
  <artifactId>hutool-core</artifactId>
  <version>5.5.0</version>
 </dependency>

 <!--lombok-->
 <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>

 <build>
 <plugins>
  <plugin>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-maven-plugin</artifactId>
  </plugin>
 </plugins>
 </build>

</project>

完整yml

server:
 port: 8082
#spring
spring:
 devtools:
 restart:
 enabled: true
 main:
 allow-bean-definition-overriding: true
 # mysql DATABASE CONFIG
 datasource:
 druid:
 filters: stat,wall,log4j2
 continueOnError: true
 type: com.alibaba.druid.pool.DruidDataSource
 url: jdbc:mysql://localhost:3306/mqttdb?useSSL=false&useUnicode=true&characterEncoding=utf-8&serverTimezone=UTC&allowPublicKeyRetrieval=true
 username: root
 password: 123456
 driver-class-name: com.mysql.jdbc.Driver
 # see https://github.com/alibaba/druid
 initialSize: 15
 minIdle: 10
 maxActive: 200
 maxWait: 60000
 timeBetweenEvictionRunsMillis: 60000
 validationQuery: SELECT 1
 testWhileIdle: true
 testOnBorrow: false
 testOnReturn: false
 poolPreparedStatements: true
 keepAlive: true
 maxPoolPreparedStatementPerConnectionSize: 50
 connectionProperties:
 druid.stat.mergeSql: true
 druid.stat.slowSqlMillis: 5000
shbykj:
 checkCrc: false
#mybatis
mybatis-plus:
 mapper-locations: classpath:/mapper/*.xml
 typeAliasesPackage: org.spring.springboot.entity
 global-config:
 #主键类型 0:"数据库ID自增", 1:"用户输入ID",2:"全局唯一ID (数字类型唯一ID)", 3:"全局唯一ID UUID";
 id-type: 3
 #字段策略 0:"忽略判断",1:"非 NULL 判断"),2:"非空判断"
 field-strategy: 2
 #驼峰下划线转换
 db-column-underline: true
 #刷新mapper 调试神器
 refresh-mapper: true
 configuration:
 map-underscore-to-camel-case: true
 cache-enabled: false
#logging
logging:
 config: classpath:log4j2-demo.xml

整合swaggerUi

pom

<!--swagger api接口生成-->
  <dependency>
  <groupId>io.springfox</groupId>
  <artifactId>springfox-swagger-ui</artifactId>
  <version>2.9.2</version>
  </dependency>
  <!--解决报错：swagger:Illegal DefaultValue null for parameter type integer. java.lang.NumberFormatException: For input string: "".-->
  <!--1.5.21的AbstractSerializableParameter.getExample()方法增加了对空字符串的判断-->
  <dependency>
  <groupId>io.swagger</groupId>
  <artifactId>swagger-models</artifactId>
  <version>1.5.21</version>
  </dependency>
  <!-- 代码生成器的依赖 -->
  <dependency>
  <groupId>io.springfox</groupId>
  <artifactId>springfox-swagger2</artifactId>
  <version>2.9.2</version>
  <exclusions>
   <exclusion>
   <groupId>com.google.guava</groupId>
   <artifactId>guava</artifactId>
   </exclusion>
  </exclusions>
  </dependency>

使用

package com.shbykj.handle.web.wx;

import com.baomidou.mybatisplus.core.metadata.IPage;
import com.shbykj.handle.common.RetMsgData;
import com.shbykj.handle.common.State;
import com.shbykj.handle.common.model.sys.SysInstrument;
import com.shbykj.handle.h.service.ISysInstrumentService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

/**
 * 监测点接口
 *
 * @author
 * @date 2021-01-15 16:49
 */
@RestController
@RequestMapping({"/api/wxapoint"})
@Api(
 tags = {"小程序 监测点接口"}
)
public class CSDevicesController extends BaseController {
 @Autowired
 private ISysInstrumentService sysInstrumentService;

 public CSDevicesController() {
 }

 @ApiOperation(
  value = "分页查询",
  notes = "分页查询站点信息"
 )
 @ApiImplicitParams({@ApiImplicitParam(
  name = "number",
  value = "设备编号",
  paramType = "query",
  dataType = "String"
 ), @ApiImplicitParam(
  name = "page",
  value = "页码 从1开始",
  required = false,
  dataType = "long",
  paramType = "query"
 ), @ApiImplicitParam(
  name = "size",
  value = "页数",
  required = false,
  dataType = "long",
  paramType = "query"
 )})
 @GetMapping({"/pageByNumber"})
 public RetMsgData<IPage<SysInstrument>> pageByNumber(@RequestParam(required = false) String number) {
 RetMsgData msg = new RetMsgData();

 try {
  IPage<SysInstrument> page1 = this.getPage();
  page1 = sysInstrumentService.pageByNumber(number, page1);

  msg.setData(page1);
 } catch (Exception var5) {
  msg.setState(State.RET_STATE_SYSTEM_ERROR);
  this.logger.error(var5.getMessage());
 }

 return msg;
 }
}
package com.shbykj.handle.common.model.sys;

import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import java.io.Serializable;
import java.util.Date;

@TableName("instrument")
@ApiModel("仪器配置表字段信息")
public class SysInstrument implements Serializable {
 private static final long serialVersionUID = 1L;
 @TableId(
 value = "id",
 type = IdType.AUTO
 )
 @ApiModelProperty(
 value = "id",
 name = "id",
 required = true
 )
 private Long id;
 @TableField("name")
 @ApiModelProperty(
 value = "名称 仪器名称",
 name = "name"
 )
 private String name;
 @TableField("number")
 @ApiModelProperty(
 value = "编号 仪器编号(PN)",
 name = "number"
 )
 private String number;
 @TableField("manufacturer")
 @ApiModelProperty(
 value = "生产厂商 生产厂商",
 name = "manufacturer"
 )
 private String manufacturer;
 @TableField("gmt_create")
 @ApiModelProperty(
 value = "创建时间",
 name = "gmt_create"
 )
 private Date gmtCreate;
 @TableField("gmt_modified")
 @ApiModelProperty(
 value = "更新时间",
 name = "gmt_modified"
 )
 private Date gmtModified;
 @TableField("is_deleted")
 @ApiModelProperty(
 value = "表示删除，0 表示未删除 默认0",
 name = "is_deleted"
 )
 private Integer isDeleted;
 @TableField("device_type")
 @ApiModelProperty(
 value = "设备类型(PT)",
 name = "device_type"
 )
 private String deviceType;

 public SysInstrument() {
 }

 public Long getId() {
 return this.id;
 }

 public String getName() {
 return this.name;
 }


 public String getNumber() {
 return this.number;
 }

 public String getManufacturer() {
 return this.manufacturer;
 }

 public Date getGmtCreate() {
 return this.gmtCreate;
 }

 public Date getGmtModified() {
 return this.gmtModified;
 }

 public Integer getIsDeleted() {
 return this.isDeleted;
 }

 public String getDeviceType() {
 return this.deviceType;
 }

 public void setId(final Long id) {
 this.id = id;
 }

 public void setName(final String name) {
 this.name = name;
 }


 public void setNumber(final String number) {
 this.number = number;
 }

 public void setManufacturer(final String manufacturer) {
 this.manufacturer = manufacturer;
 }

 public void setGmtCreate(final Date gmtCreate) {
 this.gmtCreate = gmtCreate;
 }

 public void setGmtModified(final Date gmtModified) {
 this.gmtModified = gmtModified;
 }

 public void setIsDeleted(final Integer isDeleted) {
 this.isDeleted = isDeleted;
 }

 public void setDeviceType(final String deviceType) {
 this.deviceType = deviceType;
 }

 

 public String toString() {
 return "SysInstrument(id=" + this.getId() + ", name=" + this.getName() + ", number=" + this.getNumber() + ", manufacturer=" + this.getManufacturer() + ", gmtCreate=" + this.getGmtCreate() + ", gmtModified=" + this.getGmtModified() + ", isDeleted=" + this.getIsDeleted() + ", deviceType=" + this.getDeviceType() + ")";
 }
}

整合log4j

https://www.jb51.net/article/152599.htm

MQTT 物联网系统基本架构

pom

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
 <modelVersion>4.0.0</modelVersion>
 <parent>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-parent</artifactId>
 <version>2.4.2</version>
 <relativePath/> <!-- lookup parent from repository -->
 </parent>
 <groupId>com.shbykj</groupId>
 <artifactId>handle_mqtt</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 <name>handle_mqtt</name>
 <description>Demo project for Spring Boot</description>
 <properties>
 <java.version>1.8</java.version>
 <skipTests>true</skipTests>
 </properties>
 <dependencies>
  <!--mqtt依赖-->
  <dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-integration</artifactId>
  </dependency>
  <dependency>
   <groupId>org.springframework.integration</groupId>
   <artifactId>spring-integration-stream</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>
  <exclusions>
  <exclusion>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-logging</artifactId>
  </exclusion>
  </exclusions>
 </dependency>
 <!--注意： <scope>compile</scope> 这里是正式环境，解决启动报错-->
 <!--idea springboot启动报SLF4J:Failed to load class “org.slf4j.impl.StaticLoggerBinder-->
 <!--参考：https://blog.csdn.net/u010696630/article/details/84991116-->
 <dependency>
  <groupId>org.slf4j</groupId>
  <artifactId>slf4j-simple</artifactId>
  <version>1.7.25</version>
  <scope>compile</scope>
 </dependency>
 <!-- Log4j2 -->
 <dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-log4j2</artifactId>
 </dependency>

 <!-- 排除 Spring-boot-starter 默认的日志配置 -->
 <dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter</artifactId>
  <exclusions>
  <exclusion>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-logging</artifactId>
  </exclusion>
  </exclusions>
 </dependency>
 <!--swagger api接口生成-->
  <dependency>
  <groupId>io.springfox</groupId>
  <artifactId>springfox-swagger-ui</artifactId>
  <version>2.9.2</version>
  </dependency>
  <!--解决报错：swagger:Illegal DefaultValue null for parameter type integer. java.lang.NumberFormatException: For input string: "".-->
  <!--1.5.21的AbstractSerializableParameter.getExample()方法增加了对空字符串的判断-->
  <dependency>
  <groupId>io.swagger</groupId>
  <artifactId>swagger-models</artifactId>
  <version>1.5.21</version>
  </dependency>
  <!-- 代码生成器的依赖 -->
  <dependency>
  <groupId>io.springfox</groupId>
  <artifactId>springfox-swagger2</artifactId>
  <version>2.9.2</version>
  <exclusions>
   <exclusion>
   <groupId>com.google.guava</groupId>
   <artifactId>guava</artifactId>
   </exclusion>
  </exclusions>
  </dependency>

 <!--其他工具-->
 <!--devtools热部署-->
 <dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-devtools</artifactId>
  <optional>true</optional>
  <scope>runtime</scope>
 </dependency>
 <!--json转换工具-->
 <dependency>
  <groupId>com.google.code.gson</groupId>
  <artifactId>gson</artifactId>
 </dependency>
 <!-- redis -->
 <dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-data-redis</artifactId>
 </dependency>
 <!--工具类-->
 <dependency>
  <groupId>org.apache.commons</groupId>
  <artifactId>commons-lang3</artifactId>
  <version>3.8.1</version>
 </dependency>
 <!--google-->
 <!-- https://mvnrepository.com/artifact/com.google.guava/guava -->
 <dependency>
  <groupId>com.google.guava</groupId>
  <artifactId>guava</artifactId>
  <version>30.0-jre</version>
 </dependency>
 <!-- 工具类库 -->
 <dependency>
  <groupId>cn.hutool</groupId>
  <artifactId>hutool-core</artifactId>
  <version>5.5.0</version>
 </dependency>

 <!--lombok-->
 <dependency>
  <groupId>org.projectlombok</groupId>
  <artifactId>lombok</artifactId>
  <optional>true</optional>
 </dependency>
 <!--工具类-->
 <dependency>
  <groupId>commons-collections</groupId>
  <artifactId>commons-collections</artifactId>
  <version>3.2</version>
 </dependency>
 <dependency>
  <groupId>com.baomidou</groupId>
  <artifactId>spring-wind</artifactId>
  <version>1.1.5</version>
  <exclusions>
  <exclusion>
   <groupId>com.baomidou</groupId>
   <artifactId>mybatis-plus</artifactId>
  </exclusion>
  </exclusions>
 </dependency>

 <dependency>
  <groupId>com.baomidou</groupId>
  <version>3.1.2</version>
  <artifactId>mybatis-plus-boot-starter</artifactId>
 </dependency>
 <dependency>
  <groupId>mysql</groupId>
  <artifactId>mysql-connector-java</artifactId>
  <version>5.1.44</version>
 </dependency>
 <dependency>
  <groupId>com.alibaba</groupId>
  <artifactId>druid-spring-boot-starter</artifactId>
  <version>1.1.10</version>
 </dependency>
 <!--PageHelper分页插件-->
 <dependency>
  <groupId>com.github.pagehelper</groupId>
  <artifactId>pagehelper-spring-boot-starter</artifactId>
  <version>1.2.12</version>
 </dependency>
 <dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-test</artifactId>
  <scope>test</scope>
 </dependency>

 </dependencies>

 <build>
 <plugins>
  <plugin>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-maven-plugin</artifactId>
  <executions>
   <execution>
   <goals>
    <goal>repackage</goal>
   </goals>
   </execution>
  </executions>
  </plugin>
 </plugins>

 </build>

</project>

yml

server:
 port: 8082
iot:
 mqtt:
 clientId: ${random.value}
 defaultTopic: topic
 shbykjTopic: shbykj_topic
 url: tcp://127.0.0.1:1883
 username: admin
 password: admin
 completionTimeout: 3000
#微信小程序相关参数
shbykjWeixinAppid: wxae343ca8948f97c4
shbykjSecret: 9e168c92702efc06cb12fa22680f049a

#spring
spring:
 devtools:
 restart:
 enabled: true
 main:
 allow-bean-definition-overriding: true
 # mysql DATABASE CONFIG
 datasource:
 druid:
 filters: stat,wall,log4j2
 continueOnError: true
 type: com.alibaba.druid.pool.DruidDataSource
 url: jdbc:mysql://localhost:3306/mqttdb?useSSL=false&useUnicode=true&characterEncoding=utf-8&serverTimezone=UTC&allowPublicKeyRetrieval=true
 username: root
 password: 123456
 driver-class-name: com.mysql.jdbc.Driver
 # see https://github.com/alibaba/druid
 initialSize: 15
 minIdle: 10
 maxActive: 200
 maxWait: 60000
 timeBetweenEvictionRunsMillis: 60000
 validationQuery: SELECT 1
 testWhileIdle: true
 testOnBorrow: false
 testOnReturn: false
 poolPreparedStatements: true
 keepAlive: true
 maxPoolPreparedStatementPerConnectionSize: 50
 connectionProperties:
 druid.stat.mergeSql: true
 druid.stat.slowSqlMillis: 5000

shbykj:
 checkCrc: false
#mybatis
mybatis-plus:
 mapper-locations: classpath:/mapper/*.xml
 typeAliasesPackage: org.spring.springboot.entity
 global-config:
 #主键类型 0:"数据库ID自增", 1:"用户输入ID",2:"全局唯一ID (数字类型唯一ID)", 3:"全局唯一ID UUID";
 id-type: 3
 #字段策略 0:"忽略判断",1:"非 NULL 判断"),2:"非空判断"
 field-strategy: 2
 #驼峰下划线转换
 db-column-underline: true
 #刷新mapper 调试神器
 refresh-mapper: true
 configuration:
 map-underscore-to-camel-case: true
 cache-enabled: false
 #log4j打印sql日志
 log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
#logging
logging:
 config: classpath:log4j2-demo.xml

到此这篇关于springboot 实现mqtt物联网的文章就介绍到这了,更多相关springboot 实现mqtt物联网内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

相关文章

  • Spring Boot利用Thymeleaf发送Email的方法教程

    Spring Boot利用Thymeleaf发送Email的方法教程

    spring Boot默认就是使用thymeleaf模板引擎的，下面这篇文章主要给大家介绍了关于在Spring Boot中利用Thymeleaf发送Email的方法教程，文中通过示例代码介绍的非常详细，对大家具有一定的参考学习价值，需要的朋友们下面来一起看看吧。
    2017-08-08
  • Java 字符串转float运算 float转字符串的方法

    Java 字符串转float运算 float转字符串的方法

    今天小编就为大家分享一篇Java 字符串转float运算 float转字符串的方法，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
    2018-07-07
  • Java连接Redis全过程讲解

    Java连接Redis全过程讲解

    这篇文章主要介绍了Java连接Redis全过程讲解，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
    2022-06-06
  • SpringCloud与Consul集成实现负载均衡功能

    SpringCloud与Consul集成实现负载均衡功能

    负载均衡基本概念有：实服务、实服务组、虚服务、调度算法、持续性等，其常用应用场景主要是服务器负载均衡，链路负载均衡。这篇文章主要介绍了SpringCloud与Consul集成实现负载均衡 ,需要的朋友可以参考下
    2018-09-09
  • java 操作gis geometry类型数据方式

    java 操作gis geometry类型数据方式

    这篇文章主要介绍了java 操作gis geometry类型数据方式，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
    2022-03-03
  • java 中sendredirect()和forward()方法的区别

    java 中sendredirect()和forward()方法的区别

    这篇文章主要介绍了java 中sendredirect()和forward()方法的区别,需要的朋友可以参考下
    2017-08-08
  • Spring Data Jpa返回自定义对象的3种方法实例

    Spring Data Jpa返回自定义对象的3种方法实例

    在使用Spring Data Jpa框架时,根据业务需求我们通常需要进行复杂的数据库查询,下面这篇文章主要给大家介绍了关于Spring Data Jpa返回自定义对象的3种方法,文中通过实例代码介绍的非常详细,需要的朋友可以参考下
    2022-08-08
  • springboot多租户设计过程图解

    springboot多租户设计过程图解

    这篇文章主要介绍了springboot多租户设计过程图解,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2019-12-12
  • Java 超详细讲解hashCode方法

    Java 超详细讲解hashCode方法

    在 Java 应用程序执行期间，在同一对象上多次调用 hashCode 方法时，必须一致地返回相同的整数，前提是对象上 equals 比较中所用的信息没有被修改。从某一应用程序的一次执行到同一应用程序的另一次执行，该整数无需保持一致
    2022-04-04
  • Java实现在线聊天室(层层递进）

    Java实现在线聊天室(层层递进）

    这篇文章主要为大家详细介绍了Java实现在线聊天室，层层递进，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
    2022-09-09

最新评论