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

现有项目都是分布式部署，一个项目模块也许需要多个实例运行。定时任务在项目中一般是不可缺少的，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

项目中获取类实例，我们一般使用@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