SpringBoot 整合 RabbitMQ demo
本文只做Demo案例的分享，具体只是需自行百度。
Flink 归约聚合（reduce）
其实，reduce 的语义是针对列表进行规约操作，运算规则由 ReduceFunction 中的 reduce方法来定义，而在 ReduceFunction 内部会维护一个初始值为空的累加器，注意累加器的类型。将合并的结果看作一个数据、再跟后面的数据合并，最终会将它“简化”成唯一的一个数据，这也就是
Hyperf使用RabbitMQ消息队列
Hyperf连接使用RabbitMQ消息中间件。
kafka-2.12使用记录
kafka-ui-lite是一个开源的kafka监控项目，可以在gitee下载.提供了对kafka 、zookeeper 、redis的监控和管理功能，支持在线浏览和管理kafka的 topic主题/kafka集群/group分组支持在线发送kafka消息。
springboot集成rabbitmq
RabbitMQ 是实现 AMQP（高级消息队列协议）的消息中间件的一种，最初起源于金融系统，用于在分布式系统中存储转发消息，在易用性、扩展性、高可用性等方面表现不俗。RabbitMQ 主要是为了实现系统之间的双向解耦而实现的。当生产者大量产生数据时，消费者无法快速消费，那么需要一个中间层。保存这个
Kafka：什么是kafka？ ①
kafka是一种分布式的，基于发布/订阅的消息系统。它可以处理消费者在网站中的所有动作流数据。这种动作(网页浏览，搜索和其他用户的行动)是在现代网络上的许多社会功能的一个关键因素。这些数据通常是由于吞吐量的要求而通过处理日志和日志聚合来解决。
kafka常用命令
bin/kafka-consumer-groups.sh --bootstrap-server $nodes --group $groupname --reset-offsets --all-topics --to-earliest --execute # 重设消费者组位移(待验证)bin/kafk
kafka实现消息接受和发送
kafka实现消息接受和发送
RabbitMQ高阶使用延时任务
目录1 从打车开始说起1.1 需要解决的问题1.1.1 打车超时2 延时任务2.1 什么是延时任务2.1.1 和定时任务区别2.2 延时队列使用场景2.3 常见方案2.3.1 数据库轮询2.3.1 JDK的延迟队列2.3.3 netty时间轮算法2.3.4 使用消息队列2.4 延时队列2.4.1 T
RabbitMQ死信队列
DLX，全称为Dead-Letter-Exchange , 可以称之为死信交换机，也有人称之为死信邮箱。当消息在一个队列中变成死信(dead message)之后，它能被重新发送到另一个交换机中，这个交换机就是DLX ，绑定DLX的队列就称之为死信队列。消息被拒绝消息过期队列达到最大长度DLX也是一
深入理解Flink IntervalJoin源码
接着会经历嵌套for循环，判断哪些StreamRecord是满足Join条件的：以当前StreamRecord的Timestamp和指定的上、下界组成时间过滤条件，对当前StreamRecord的“对方MapState”内的每个Timestamp（作为Key）进行比对。接着将当前StreamReco
ZooKeeper实现分布式锁
ZooKeeper实现分布式锁
Grafana制作图表-自定义Flink监控图表
Grafana制作图表-自定义Flink监控图表
Kafka系列之：延时队列
Kafka系列之：延时队列
Spark的dropDuplicates或distinct 对数据去重
消除重复的数据可以通过使用 distinct 和 dropDuplicates 两个方法。
配置Hadoop_0
Hadoop配置
kafka 安装快速入门
1、service.properties (添加)进入到config文件夹里面，找到zookeeper.properties文件，进行编辑，找到。kafka 集成了 zookeeper 的软件包，不需要安装，配置就好。直接上干货，我们公司最近要进行消息推送指定软件kafka,直接走起。完成启动就可以
Springboot集成RabbitMq@RabbitListener不自动生成队列
大意如下，如果定义了RabbitAdmin的Bean，就会自动创建队列。如下配置消费队列，期望会自动创建注解中的queue和exchange。修改rabbit配置，增加RabbitAdmin定义，如下。查看RabbitListener定义。但是启动报错，日志如下。再次启动，成功创建。
分布式 - 消息队列Kafka：Kafka 消费者消息消费与参数配置
01. 创建消费者在读取消息之前，需要先创建一个KafkaConsumer对象。创建KafkaConsumer对象与创建KafkaProducer对象非常相似——把想要传给消费者的属性放在Properties对象里。为简单起见，这里只提供4个必要的属性：bootstrap.servers、key.d
windows环境下安装zookeeper
解压后将prunmgr.exe(监控服务配置及运行的程序)和prunsrv.exe(做服务的执行程序)两个可执行文件复制到zookeeper的bin目录下。在bin目录下双击zkCli.cmd，打开客户端(此时的服务端zkServer的dos窗口不要关闭)，出现“欢迎”字样，说明安装成功。复制zoo
