1.首先查看阿里云的文档，把基本的配置和环境搭建完成。 https://help.aliyun.com/document_detail/114480.html?spm=a2c4g.11186623. ...

目录 前言 环境 具体实现 前言 RocketMQ是阿里巴巴在2012年开源的分布式消息中间件，记录下SpringBoot整合RocketMQ的方式，RocketMQ的安装可以查看：Windows下安装RocketMQ 环境 ...

简介 RocketMQ是阿里开源的消息中间件，目前已经捐献个Apache基金会，它是由Java语言开发的，具备高吞吐量、高可用性、适合大规模分布式系统应用等特点，经历过双11的洗礼，实力不容小觑。 官网：https://rocketmq.apache.org/ 快速入门 ...

最近在看消息队列框架 ，alibaba的RocketMQ单机支持1万以上的持久化队列，支持诸多特性， 目前RocketMQ在阿里集团被广泛应用在订单，交易，充值，流计算，消息推送，日志流式处理，binglog分发等场景 比kafka还是有过之无不及，其实kafka文档很丰富 ...

一、RocketMQ 特点 RocketMQ 是阿里巴巴在2012年开源的分布式消息中间件，有点什么的就不多说了，就直接将怎么用。 RocketMq大概就是真么一种结构，具体的使用流程就是，消息生产者（Producer）将消息发布到消息中心，消费者（Consumer）启动 ...

什么是消息队列？ 为什么要用消息队列？ 即，应用场景是什么，也就是用了有什么好处 解耦 ...

在工作中发现，有些时候消息因为某些原因在消费一次后，如果消息失败，这时候不ack，消息就回一直重回队列首部，造成消息拥堵。 如是有了如下思路： 消息进入队列前，header默认有参数 retry_num=0 表示尝试次数； 消费者在消费时候的，如果消息失败，就把消息插入另外一个队列（队列 ...

新的阅读体验：http://www.zhouhong.icu/post/157 一、业务需求 　　需要实现一个提前二十分钟通知用户去做某件事的一个业务，拿到这个业务首先想到的最简单得方法就是使用Redis监控Key值：在排计划时候计算当前时间与提前二十分钟这个时间差，然后使用一个唯一的业务 ...