草庐IT

RocketMq-RocketMQMessageListener

全部标签

RocketMQ 学习

前言  RocketMQ是阿里巴巴旗下一款开源的MQ框架,经历过双十一考验、Java编程语言实现,有非常好完整生态系统。RocketMQ作为一款纯java、分布式、队列模型的开源消息中间件,支持事务消息、顺序消息、批量消息、定时消息、消息回溯等本篇文章第一部分属于一些核心概念和工作流程的讲解;第二部分就是纯手动搭建了一套环境;第三部分是基于环境进行测试和集成到SpringBoot核心概念NameServer:可以理解为是一个注册中心,主要是用来保存topic路由信息,管理Broker。在NameServer的集群中,NameServer与NameServer之间是没有任何通信的。Broker:

RocketMQ 学习

前言  RocketMQ是阿里巴巴旗下一款开源的MQ框架,经历过双十一考验、Java编程语言实现,有非常好完整生态系统。RocketMQ作为一款纯java、分布式、队列模型的开源消息中间件,支持事务消息、顺序消息、批量消息、定时消息、消息回溯等本篇文章第一部分属于一些核心概念和工作流程的讲解;第二部分就是纯手动搭建了一套环境;第三部分是基于环境进行测试和集成到SpringBoot核心概念NameServer:可以理解为是一个注册中心,主要是用来保存topic路由信息,管理Broker。在NameServer的集群中,NameServer与NameServer之间是没有任何通信的。Broker:

RocketMQ 学习

前言  RocketMQ是阿里巴巴旗下一款开源的MQ框架,经历过双十一考验、Java编程语言实现,有非常好完整生态系统。RocketMQ作为一款纯java、分布式、队列模型的开源消息中间件,支持事务消息、顺序消息、批量消息、定时消息、消息回溯等本篇文章第一部分属于一些核心概念和工作流程的讲解;第二部分就是纯手动搭建了一套环境;第三部分是基于环境进行测试和集成到SpringBoot核心概念NameServer:可以理解为是一个注册中心,主要是用来保存topic路由信息,管理Broker。在NameServer的集群中,NameServer与NameServer之间是没有任何通信的。Broker:

RocketMQ 学习

前言  RocketMQ是阿里巴巴旗下一款开源的MQ框架,经历过双十一考验、Java编程语言实现,有非常好完整生态系统。RocketMQ作为一款纯java、分布式、队列模型的开源消息中间件,支持事务消息、顺序消息、批量消息、定时消息、消息回溯等本篇文章第一部分属于一些核心概念和工作流程的讲解;第二部分就是纯手动搭建了一套环境;第三部分是基于环境进行测试和集成到SpringBoot核心概念NameServer:可以理解为是一个注册中心,主要是用来保存topic路由信息,管理Broker。在NameServer的集群中,NameServer与NameServer之间是没有任何通信的。Broker:

RocketMQ控制台消费者堆栈信息展示优化分析

背景介绍专有云企业版v_3_12,消息队列RocketMQ控制台->Group管理,查看GroupID下单个消费端堆栈信息,期望只展示与该GroupID相关的堆栈信息,在以下场景与期望不符。场景介绍在同一个程序中创建两个不同GroupID的消费端实例,在控制台中查看一个GroupID下单个消费端堆栈信息,堆栈信息中包含了两个GroupID消费端的堆栈信息,给排查问题造成了困扰。示例代码pomdependency>groupId>com.aliyun.openservicesgroupId>artifactId>ons-clientartifactId>version>1.8.8.3.Final

RocketMQ控制台消费者堆栈信息展示优化分析

背景介绍专有云企业版v_3_12,消息队列RocketMQ控制台->Group管理,查看GroupID下单个消费端堆栈信息,期望只展示与该GroupID相关的堆栈信息,在以下场景与期望不符。场景介绍在同一个程序中创建两个不同GroupID的消费端实例,在控制台中查看一个GroupID下单个消费端堆栈信息,堆栈信息中包含了两个GroupID消费端的堆栈信息,给排查问题造成了困扰。示例代码pomdependency>groupId>com.aliyun.openservicesgroupId>artifactId>ons-clientartifactId>version>1.8.8.3.Final

一文带你认知定时消息发布RocketMQ

摘要:DMS任意时间定时消息能力发布。本文分享自华为云社区《一文带你认知定时消息发布RocketMQ》,作者:华为云PaaS服务小智。DMS是华为云的分布式消息中间件服务。适用于解决分布式架构中的系统解耦、跨系统跨地域数据流通、分布式事务协调等难题,协助构建优雅的现代化应用架构,提供可兼容Kafka/RabbitMQ/RocketMQ开源系统的云服务。DMS是一个低延迟、弹性高可靠、高吞吐、动态扩展、便捷多样的消息中间件服务。近期,DMS服务正式上线任意时间定时消息特性,带来了灵活、精确、高性能的消息定时能力支持。DMSrocketMQ定时消息功能流程图为什么需要定时消息随着互联网技术的蓬勃发

一文带你认知定时消息发布RocketMQ

摘要:DMS任意时间定时消息能力发布。本文分享自华为云社区《一文带你认知定时消息发布RocketMQ》,作者:华为云PaaS服务小智。DMS是华为云的分布式消息中间件服务。适用于解决分布式架构中的系统解耦、跨系统跨地域数据流通、分布式事务协调等难题,协助构建优雅的现代化应用架构,提供可兼容Kafka/RabbitMQ/RocketMQ开源系统的云服务。DMS是一个低延迟、弹性高可靠、高吞吐、动态扩展、便捷多样的消息中间件服务。近期,DMS服务正式上线任意时间定时消息特性,带来了灵活、精确、高性能的消息定时能力支持。DMSrocketMQ定时消息功能流程图为什么需要定时消息随着互联网技术的蓬勃发

通过源码分析RocketMQ主从复制原理

作者:京东物流宫丙来一、主从复制概述RocketMQBroker的主从复制主要包括两部分内容:CommitLog的消息复制和Broker元数据的复制。CommitLog的消息复制是发生在消息写入时,当消息写完BrokerMaster时,会通过单独的线程,将消息写入到从服务器,在写入的时候支持同步写入、异步写入两种方式。Broker元数据的写入,则是Broker从服务器通过单独的线程每隔10s从主Broker上获取,然后更新从的配置,并持久化到相应的配置文件中。RocketMQ主从同步一个重要的特征:主从同步不具备主从切换功能,即当主节点宕机后,从不会接管消息发送,但可以提供消息读取。二、Com

通过源码分析RocketMQ主从复制原理

作者:京东物流宫丙来一、主从复制概述RocketMQBroker的主从复制主要包括两部分内容:CommitLog的消息复制和Broker元数据的复制。CommitLog的消息复制是发生在消息写入时,当消息写完BrokerMaster时,会通过单独的线程,将消息写入到从服务器,在写入的时候支持同步写入、异步写入两种方式。Broker元数据的写入,则是Broker从服务器通过单独的线程每隔10s从主Broker上获取,然后更新从的配置,并持久化到相应的配置文件中。RocketMQ主从同步一个重要的特征:主从同步不具备主从切换功能,即当主节点宕机后,从不会接管消息发送,但可以提供消息读取。二、Com