概述：1、当数据量过大时，将数据存放到es中，增加查询的效率，降低和数据库的交互。【一次性导入】2、使用mq同步es数据，避免DB中数据和Es中的不一致。【消息队列持续同步db中的数据】3、注意springboot和es的版本问题，不然项目一定起不来【elk6.几不支持springboot2.3点几的版本】我用的是：springboot-2.2.10.RELEASE；es-6.4版本关键导包!--集成es-->dependency>groupId>org.springframework.boot/groupId>artifactId>spring-boot-starter-data-elast
认识MQ-7模块与其工作原理 首先来认识MQ-7模块，MQ-7可以检测空气中的一氧化碳（CO）浓度。他采用半导体气敏元件来检测CO的气体浓度，其灵敏度高、反应速度快、响应时间短、成本低廉等特点使得它被广泛应用于智能家居、工业自动化、环保检测等领域。 MQ-7模块的工作原理基于半导体材料在气体作用下发生电学性质的变化，通过测量这种变化来检测气体浓度。具体来说，MQ-7烟雾传感器内部有一块小小的加热器，通过电流加热，使得传感器的工作环境温度升高，同时加速气体分子的运动。模块中的半导体气敏元件表面涂有一层特殊的金属氧化物，当在特定温度下，空气中的CO气体与金属氧化物接触时，会发生
认识MQ-7模块与其工作原理 首先来认识MQ-7模块，MQ-7可以检测空气中的一氧化碳（CO）浓度。他采用半导体气敏元件来检测CO的气体浓度，其灵敏度高、反应速度快、响应时间短、成本低廉等特点使得它被广泛应用于智能家居、工业自动化、环保检测等领域。 MQ-7模块的工作原理基于半导体材料在气体作用下发生电学性质的变化，通过测量这种变化来检测气体浓度。具体来说，MQ-7烟雾传感器内部有一块小小的加热器，通过电流加热，使得传感器的工作环境温度升高，同时加速气体分子的运动。模块中的半导体气敏元件表面涂有一层特殊的金属氧化物，当在特定温度下，空气中的CO气体与金属氧化物接触时，会发生
不喜欢用MQ。如果是同一个系统内的不同模块，可以用数据库表，来传递消息；如果是不同系统间数据接口，可以用webservice(同步，现在好像是gRPC有点热)、SFTP/FTP协议(异步)进行数据交换。看不出有任何使用MQ的需要。除非甲方指定，看在钱的面子上，勉为其难去用一下。MQ是异步通讯技术，与之相对的是SFTP/FTP。相比较而言，MQ毫无优势。速度、简易性、稳定性、标准化等各方面，MQ完败。SFTP/FTP也能轻松削峰与限流(MQ介绍文档常说的优点)。发送方快速发，接收方慢速处理、即时或滞后处理，都可以。使用接收方webservice，也可以收到数据后先保存在接口表中，后慢速处理。整体
不喜欢用MQ。如果是同一个系统内的不同模块，可以用数据库表，来传递消息；如果是不同系统间数据接口，可以用webservice(同步，现在好像是gRPC有点热)、SFTP/FTP协议(异步)进行数据交换。看不出有任何使用MQ的需要。除非甲方指定，看在钱的面子上，勉为其难去用一下。MQ是异步通讯技术，与之相对的是SFTP/FTP。相比较而言，MQ毫无优势。速度、简易性、稳定性、标准化等各方面，MQ完败。SFTP/FTP也能轻松削峰与限流(MQ介绍文档常说的优点)。发送方快速发，接收方慢速处理、即时或滞后处理，都可以。使用接收方webservice，也可以收到数据后先保存在接口表中，后慢速处理。整体
目录前言1.Sentinel的自动装配1.2依赖引入1.3SentinelWebAutoConfiguration配置类1.4CommonFilter过滤器1.5小结2.获取ProcessorSlot链2.1Sentinel源码包结构2.2获取ProcessorSlot链与操作Slot槽的入口CtSph.entryWithPriority()2.2.1构造ProcessorSlot链CtSph.lookProcessChain()2.2.2操作Slot槽的入口3.流控槽实施流控逻辑FlowSlot.entry()3.1获取流控规则FlowSlot.ruleProvider.apply()3.2
目录前言1.Sentinel的自动装配1.2依赖引入1.3SentinelWebAutoConfiguration配置类1.4CommonFilter过滤器1.5小结2.获取ProcessorSlot链2.1Sentinel源码包结构2.2获取ProcessorSlot链与操作Slot槽的入口CtSph.entryWithPriority()2.2.1构造ProcessorSlot链CtSph.lookProcessChain()2.2.2操作Slot槽的入口3.流控槽实施流控逻辑FlowSlot.entry()3.1获取流控规则FlowSlot.ruleProvider.apply()3.2
业务背景跟第三方系统做对接，双方通过ActiveMQ进行通信，消息之间是有内在关联的，也就是消息本来应该是有业务顺序的，但由于一些原因，现在收到消息是乱序的，这种情况下做业务处理就有一点小问题了方案一：自己重排序收到消息后，自己在内存排序，然后按顺序丢到队列中，自己控制消息的发送和接收保证收到按发送的顺序来收到消息。如果自己排序的话就要对每个消息标记一个顺序，同时还要指定预先定义好哪些消息属于一类并且相互之间有依赖顺序。具体实现的话，可以这样做：1、收到一条消息，封装一下加个序号，放到Redis中，用列表或者有序集合来存储，同时用字符串类型存一下这个业务单号的当前最小序号（默认是1）2、如果是
业务背景跟第三方系统做对接，双方通过ActiveMQ进行通信，消息之间是有内在关联的，也就是消息本来应该是有业务顺序的，但由于一些原因，现在收到消息是乱序的，这种情况下做业务处理就有一点小问题了方案一：自己重排序收到消息后，自己在内存排序，然后按顺序丢到队列中，自己控制消息的发送和接收保证收到按发送的顺序来收到消息。如果自己排序的话就要对每个消息标记一个顺序，同时还要指定预先定义好哪些消息属于一类并且相互之间有依赖顺序。具体实现的话，可以这样做：1、收到一条消息，封装一下加个序号，放到Redis中，用列表或者有序集合来存储，同时用字符串类型存一下这个业务单号的当前最小序号（默认是1）2、如果是
一、前言 消息队列（MessageQueue）是分布式系统必不可少的中间件，大部分消息队列产品（如RocketMQ/RabbitMQ/Kafka等）要求团队有比较强的技术实力，不适用于中小团队，并且对.NET技术的支持力度不够。而Redis实现的轻量级消息队列很简单，仅有Redis常规操作，几乎不需要开发团队掌握额外的知识！ 写这篇文档的目的，是因为在最近开发过程中，需要用到多端订阅的功能，之前设计的时候用的是rockemq，最近又重新整理了一遍项目架构，把orm替换成了二次封装的shinysqlsugar,redis也替换成了shiny.redis，正好看到newlife.redis已经实现
