没有使用链路跟踪时，页面报错都是要到日志里定位，在分布式部署的项目中，还是比较麻烦的。项目中链路跟踪本人选型了skywalking，为了方便定位页面问题，实现了web界面reponse中返回skywalking的traceId，不多说直接上代码实现。1、pom.xml引入<dependency><groupId>org.apache.skywalking</group

公司要求平台实现多租户，我实现方案是添加租户，动态创建数据库，然后把最新数据源publish到nacos，通知各实例模块数据源发生变化，各模块接收到通知，从nacos获取最新数据源更新已经初始化的数据源，通过shardingjdbc的分库达到不同租户访问自己数据源的效果，最终实现多租户且数据源完全隔离。整个方案实现细节比较多也有点小复杂，后续有时间写文章详细介绍，此文抠取nacos监听和发布进行分

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

一、背景：做物联网项目，需要用MQ做消息队列做缓冲，选择了使用kafka，部署在公网环境，部署kafka后没有设置登录验证，刚刚部署就被恶意扫描到，向kafka里面push超过1G的文件，直接导致kafka宕掉，虽然无法获取主机权限，但是比较膈应，因此设置了登录 验证，记录下安装、设置及项目程序代码实现整个过程二、部署环境：Linux+Ubuntu+kafka(2.8.0)+zookeeper(3

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

一、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

一、背景：做物联网项目，需要用MQ做消息队列做缓冲，选择了使用kafka，部署在公网环境，部署kafka后没有设置登录验证，刚刚部署就被恶意扫描到，向kafka里面push超过1G的文件，直接导致kafka宕掉，虽然无法获取主机权限，但是比较膈应，因此设置了登录 验证，记录下安装、设置及项目程序代码实现整个过程二、部署环境：Linux+Ubuntu+kafka(2.8.0)+zookeeper(3