公司中项目大多是物联网项目，需要跟设备进行交互，用到的协议比较多，如NB/MQTT/LWM2M/COAP等，项目中不可避免用到了MQTT协议，本文介绍springboot项目MQTT客户端实现，不多说直接上可执行代码。一、EMQ官网java sdk demo，如果只需要用到一个客户端，可以参照下官网demo，修改下应用用项目1、pom.xml依赖引用<dependency><gr

现有项目都是分布式部署，一个项目模块也许需要多个实例运行。定时任务在项目中一般是不可缺少的，springboot自带的@Scheduled注解单节点运行是没有问题的，但是多实例运行会导致同一个定时任务运行多次，结果不是预期的，虽然可以通过分布式锁，让多实例上只一个节点运行。在定位任务选型中，本人选型使用xxl-job，优点不多说，直接上代码。1、pom.xml<dependency>&

几乎每个web项目都会用到http请求，空闲时间封装了一个工具类，分享出来，用到的时候可以直接拷贝使用import org.apache.http.HttpEntity;import org.apache.http.HttpResponse;import org.apache.http.NameValuePair;import org.apache.http.client.config.Reque

背景：近期项目需要，引入flink，研究了下flink，步步踩坑终于可以单独运行，也可发布到集群运行，记录下踩坑点。开发环境：idea+springboot(2.3.5.RELEASSE)+kafka(2.8.1)+mysql(8.0.26)。废话不多说，直接上可执行代码。以下代码实现了某个时间间隔，设备不上传数据，判断为离线的逻辑一、项目application创建/*** flink任务提交ap

项目中获取类实例，我们一般使用@Autowired或者@Resource直接注入使用。但在某些场景下，我们实现类@Service或者@Componet注解，私有变量无法自动注入，这时我们就需要自己在new的时候初始化。常见于线程里面有需要注入的service类，这时候我们在new线程时候，无法自动注入，需要自己手动获取bean，本文介绍springboot项目通过bean的name和type获取类

公司规划了一个AIOT平台项目，希望将来可以提供SAAS服务，可设备接入、算法训练及算法接口发布。写此博文时，本人已经实现了IOT部分（已测试完毕发布），多租户不同设备接入以及设备数据转发。本文着重介绍项目中多租户实现。主流的租户实现一般有两种方式，一种是所有表字段冗余租户ID字段，在增删改查时拦截sql语句进行拼接租户ID字段，达到不同租户展示不同数据的目录；另一种方式每个租户对应一个业务逻辑库

现在项目一般都是多实例，分布式部署，一个请求也许会需要多个项目模块响应，链路比较长。前端页面请求出现问题了，定位需要多个项目挨个查看日志，在生产环境日志量比较大，刷新的也比较快，会给问题定位带来很大的难度，所以链路跟踪是非常必要的。在工作中使用过zipkin和skywalking，也使用过arths，在最近项目选型链路跟踪软件果断选择了skywalking了，好处不多说，直接上从0开始部署方法。一

当系统规模比较大，模块非常多时，或者一些重要日志需要归档时，就需要有个日志统一管理平台。本人所在公司有个需求，边缘端的日志需要统一上传管理，方便后续问题定位。方案是边缘端定时打包日志上传到fastdfs，然后把url推送到业务端，业务根据url从fastdfs上获取到日志，解压缩到指定目录，filebeat获取到日志发生变化，然后解析发送到kafka，logstash监听kafka把日志存储到es

背景：近期项目需要，引入flink，研究了下flink，步步踩坑终于可以单独运行，也可发布到集群运行，记录下踩坑点。开发环境：idea+springboot(2.3.5.RELEASSE)+kafka(2.8.1)+mysql(8.0.26)。废话不多说，直接上可执行代码。以下代码实现了某个时间间隔，设备不上传数据，判断为离线的逻辑一、项目application创建/*** flink任务提交ap

一、ES查询示例1、查看es信息GET /2、创建索引PUT demo_person3、删除索引DELETE demo_person说明：DELETE /index_one,index_two --删除两个索引DELETE /index_* --删除index_k开头的索引DELETE /_all --删除全部索引DELETE /* --删除全部索引4、创建索引包含setting和mappingP