需求场景：分布式项目中，每个子项目有各自的 user 数据库， 在综合管理系统中存放这所有用户信息， 为了保持综合管理系统用户的完整性，　　　　子系统添加用户后将用户信息以json格式保存至redis，然后发布到消息到消息通道，综合管理系统监控到子系统发布的消息前往redis 　　　　获取出用户信息保存到自己的数据库1）redis配置

一、前言延迟队列的使用场景：1.未按时支付的订单，30分钟过期之后取消订单；2.给活跃度比较低的用户间隔N天之后推送消息，提高活跃度；3.过1分钟给新注册会员的用户，发送注册邮件等。实现延迟队列的方式有两种：1.通过消息过期后进入死信交换器，再由交换器转发到延迟消费队列，实现延迟功能；2.使用rabbitmqdelayed

RabbitMQ集群安装配置HAproxyKeepalived高可用转自：https://www.linuxidc.com/Linux/201610/136492.htmrabbitmq集群消息队列RabbitMQ简介　　RabbitMQ(ht

配置参考然后不废话，直接贴最终的关键配置:想实现消息队列中保存2小时的消息，那么配置应该像这样:log.roll.hours1log.retention.hours2log.segment.delete.delay.ms0Kafka日志存储机制分析

1\.kafka介绍1.1. 主要功能根据官网的介绍，ApacheKafka®是_一个分布式流媒体平台_，它主要有3种功能：1：Itletsyoupublishandsubscribetostreamsofrecords.发布和订阅消息流，这个功能类似于消息队列，这也是kafka归类为消息队

1.ActiveMQ是什么ActiveMQ是一个消息队列应用服务器（推送服务器）。支持JMS规范。1.1JMS概述全称：JavaMessageService，即为Java消息服务，是一套java消息服务的API标准。（标准即接口）实现了JMS标准的系统，称之

Kafka简介_Kafka是分布式流平台。_一个流平台有3个主要特征：发布和订阅消息流，这一点与传统的消息队列相似。以容灾持久化方式的消息流存储。在消息流发生时处理消息流。Kafka通常使用在两大类应用中：在系统或应用之间，构建实时、可靠的消息流管道。构建实时流应用

架构、分布式、日志队列，标题自己都看着唬人，其实就是一个日志收集的功能，只不过中间加了一个Kafka做消息队列罢了。!(https://images2017.cnblogs.com/blog/109211/201802/109211201802061533201231622886397.png)kafka介绍Kafka是由

workqueues工作队列1、模型图：!(https://oscimg.oschina.net/oscnet/bf4b370589b4954af0314d5878d56952b20.png)为什么会出现workqueues?前提:使用simple队列的时候我们应用程序在是使用消息

        本书一切灵感均来自于<RabbitMQ实战 高效部署分布式消息队列这本书,书中知识会尽量复现验证,然我们一起学习,一起成长,当然有兴趣的同学还是拜读原著,收益颇丰.消息队列的成长史(是不是看不清,就算看清了也没啥用哈哈哈):!(https://static.oschina.net/uploads/space/2018/031