背景：近期项目需要，引入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

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