• 1. SpringBoot整合RocketMQ实现消息发送和接收

  三步走：导包-->写配置-->编码及测试1、引入依赖在SpringBoot工程中直接引入对应的starter就好了rocketmq-spring-boot-starter用法简介当开发中需要快速集成RocketMQ时可以考虑使用rocketmq-spring-boot-starter搭建RocketMQ的集成环境，但该框架并不完全具备RocketMQ所有的配置简化，如需批量消费消...

  http://www.easyblog.top:80/article/details/297 - 2020-12-11 - RocketMQ

• 2. RocketMQ Linux 安装配置

  Linux安装1、准备工作下载RocketMQ截止教程发布日期，RocketMQ最新版本：4.7.1下载地址可以直接点击上面下载地址下载到本地然后上传到Liunx上，或者也可以直接使用wget命令在Linux上下载环境要求Linux64位系统JDK1.8(64位)源码安装需要安装Maven3.2.x2、安装RocketMQ安装步骤本教程以二进制包方式安装解压安装包进入安装目录目录介绍进入到安...

  http://www.easyblog.top:80/article/details/291 - 2020-11-29 - RocketMQ

• 3. RocketMQ Java 客户端搭建及简单消息生产和消费案例

  RocketMQ是阿里开源的一款分布式消息中间件，主要分为以下几个部分1、生产者Producer，消费者(Consumer），NameServer，Broker2、生产者主要用来发送消息，，消费者用来接收消息3、nameServer就像一个邮局，Broker相当于快递小哥，nameServer用来管理Broker。4、发送消息有三种方式，分别是同步，异步，单向，异步发送会返回一个回调函数，同...

  http://www.easyblog.top:80/article/details/293 - 2020-12-01 - RocketMQ

• 4. RocketMQ 顺序消息、延时消息、批量消息、过滤消息和事物消息之发送和消费案例

  1、顺序消息消息有序指的是可以按照消息的发送顺序来消费(FIFO)。RocketMQ可以严格的保证消息有序，可以分为分区有序或者全局有序。顺序消费的原理解析，在默认的情况下消息发送会采取轮询方式把消息发送到不同的queue(分区队列)；而消费消息的时候从多个queue上拉取消息，这种情况发送和消费是不能保证顺序。如图：而消费端消费的时候，是会分配到多个queue的，多个queue是同时拉取提...

  http://www.easyblog.top:80/article/details/294 - 2020-12-02 - RocketMQ

• 5. RocketMQ 消息存储

  分布式队列因为有高可靠性的要求，所以数据要进行持久化存储。消息生成者发送消息MQ收到消息，将消息进行持久化，在存储中新增一条记录返回ACK给生产者MQpush消息给对应的消费者，然后等待消费者返回ACK如果消息消费者在指定时间内成功返回ack，那么MQ认为消息消费成功，在存储中删除消息，即执行第6步；如果MQ在指定时间内没有收到ACK，则认为消息消费失败，会尝试重新push消息,重复执行4、...

  http://www.easyblog.top:80/article/details/296 - 2020-12-07 - RocketMQ

• 6. RocketMQ教程

  RocektMQ是阿里巴巴在2012年开源的一个纯java、分布式、队列模型的第三代消息中间件，不仅在传统高频交易链路有着低延迟的出色表现，在实时计算等大数据领域也有着不错的吞吐。2016年11月11号，双十一大促见证了RocketMQ低延迟存储架构的成功试水，99.996%的延迟落在了10ms以内，极个别由于GC引发的停顿在50ms以内，其高性能、低延时和高可靠的特性承载了近年来双十一17...

  http://www.easyblog.top:80/article/details/290 - 2020-11-29 - RocketMQ