应用场景 主要作用解耦、滑峰填谷 异构系统的整合，这个问题比较容易理解，在原阿里SOA ESB比较火的年代，很多异构系统需要进行互联互通。 应用和应用之间的松耦合 ...

一、简介 官方简介： l RocketMQ是一款分布式、队列模型的消息中间件，具有以下特点： l 能够保证严格的消息顺序 l 提供丰富的消息拉取模式 l 高效的订阅者水平扩展能力 l 实时的消息订阅机制 l 亿级消息堆积能力 二、网络架构 三、特性 1. ...

说明： 我的阿里云是centos 6.9 jdk 1.8.0_192-b12（安装教程参照：https://www.cnblogs.com/kingsonfu/p/9801556.html） maven apache-maven-3.6.1（安装教程参照 ...

针对公司业务逻辑，向阿里云MQ发送指定数据，消费端根据数据来做具体的业务，分两个项目，一个生产端（Producer）、一个消费端(Consumer) 生产端通过定时任务执行sql向阿里云MQ发送数据，消费端消费指定Topic上的数据 1：定时任务列表： 2:生产端表结构 ...

//MsgDto<NotifyMsgRepsDto> result = JsonUtils.json2Object(new String(message.getBody()), ...

摘自：码友18年（www.mayou18.com） what is rocketMQ? RocketMQ作为一款分布式的消息中间件（阿里的说法是不遵循任何规范的，所以不能完全用JMS的那一套东西来看它），经历了Metaq1.x、Metaq2.x的发展和淘宝双十一的洗礼，在功能和性能上远超 ...

初始化消费者和生产者 生产者 设置rocketmq的accesskey 和secretkey 以及rocketmq的 binder server。 首先 编辑一个配置类，将关于配置rocketmq的东西写在配置类中 ` @Component @Getter @Setter ...

目的： 阿里云RocketMQ官方示例中，需要自己在定义consumer中指定订阅的listener，使用起来不太方便，因此想基于注解的方式，在MessageListener类上注解指定topic和tag，减少项目配置项，使使用更加方便。 使用效果： 步骤1：引入pom依赖 < ...