服务粉丝

我们一直在努力

rocketmq

  • RabbitMQ、RocketMQ、Kafka 三元归一

  • 作者：让我来搞这个bug来源：jianshu.com/p/2975d354fca5
    大家好，我是苏三。RabbitMQRabbitMQ各组件的功能Broker ：一个RabbitMQ实例就是一个BrokerVirtual Host ：虚拟主机。相当于

  • RocketMQ消息消费-客户端拉取消息前的准备工作

  • 本篇开始，我们将逐步介绍消息是如何被客户端消费的，在被消费的过程中，客户端以及Broker端都经历了哪些环节，各自付出了怎么样的努力，才保障消息能被顺利的消息，来最终完成一条消息

  • RocketMQ各种消息的生产与消费Demo

  • 这次我们对顺序消息，延时消息，批量消息，过滤消息进行一个demo,方便以后cv。顺序消息的生产与消费顺序消息是指当消息消费的时候，会按照消息发送的顺序进行消费。RocketMQ可以保

  • RocketMQ基础篇 Producer发送消息

  • 生产者发送消息的主要流程图如上图所示。具体的代码由于比较多，我就不在这边贴出来的。 主要讲一下我认为比较重要的点消息队列负载均衡Producer会每隔30s从Namesrv获取最新

  • RocketMQ—（总结）一篇就搞懂RocketMQ

  • 一、RocketMQ 是什么?

    是一个队列模型的消息中间件，具有高性能、高可靠、高实时、分布式特点；Producer、Consumer、队列都可以分布式；Producer向一些队列轮流发送消息，队列集合

  • 「RocketMQ」消息的消费

  • 消息消费当RocketMQ进行消息消费的时候，是通过ConsumeMessageConcurrentlyService的submitConsumeRequest方法，将消息提交到线程池中进行消费，具体的处理逻辑如下：如果本次消息

  • rocketmq之dledger模式配置

  • 概述：操作环境，3台机器，3broker + 2nameserver + 1adminconsle ，dledger模式，相当于1主两从。 保障高可用性。

    rcmq路径：/usr/local/rcmq/rcmq-48dledger/

    配置文件：
    conf/dledg

  • RocketMQ源码分析十四之心跳处理

  • 本章节，我们主要分析 RocketMQ Producer 心跳处理的原理！RocketMQ 心跳处理包括Client主动上报、Broker 扫描不活跃的 channel，达到节约网络端口，提升性能的效果。
    整体逻辑示意

  • rocketmq源码分析-负载均衡

  • 一、什么是负载均衡负载均衡（LB，Load Balance），是一种技术解决方案。用来在多个资源（一般是服务器）中分配负载，达到最优化资源使用，避免单台服务器过载。RocketMQ中的负载均衡，主要可

  • RocketMQ源码分析十之Name Server

  • 本章节，我们主要介绍 RokcetMQ 一个核心组件，它的职责是提供了 Topic 路由管理、Broker 服务注册与存活检测服务。它就是 Name Sever。维护了整个集群的元数据。让我们一起学

  • 「RocketMQ」消息的拉取

  • RocketMQ消息的消费以组为单位，有两种消费模式：广播模式：同一个消息队列可以分配给组内的每个消费者，每条消息可以被组内的消费者进行消费。集群模式：同一个消费组下，一个消息队列

  • RocketMQ源码分析七之创建ConsumerGroup

  • 在本章中，我们将分析 RocketMQ 是如何 创建订阅组的。看看 RocketMQ 是如何实现的。
    如何开启&关闭在部署 RocketMQ 的 Broker 的时候，我们通常都会把 autoCreateSubscription

  • RocketMQ源码分析四之获取Topic 信息

  • 上一章中。我们分析了 RocketMQ 创建 Topic 的命令过程。本章，我们开始分析 获取 Topic 路由信息的源码过程。继上一篇：RocketMQ源码分析三之删除Topic命令参数用法：sh mqadmin

  • RocketMQ 源码分析二之更新Topic命令

  • 本章开始分析 RocketMQ 创建 Topic 命令的整体流程。命令参数用法：
    sh mqadmin updateTopic -n 192.168.1.100:9876
    指令：
    updateTopic
    代码入口：org.apache.rocketmq.tools.

  • RocketMQ之消费者启动与消费流程

  • 一、简介1.1 RocketMQ 简介RocketMQ是由阿里巴巴开源的分布式消息中间件，支持顺序消息、定时消息、自定义过滤器、负载均衡、pull/push消息等功能。RocketMQ主要由 Producer

  • 原来RocketMQ高可用设计是这么玩的

  • 引言大家都知道对于一款消息中间件来说，它是否能够灵活的实现高可用是评价其稳定性能力的一个重要指标。RocketMQ作为阿里巴巴开源的消息中间件，在性能以及高可用等方面都有非

  • 「RocketMQ」MQ消息发送

  • 消息发送首先来看一个RcoketMQ发送消息的例子：@Service
    public class MQService {

    @Autowired
    DefaultMQProducer defaultMQProducer;

    public void sendMsg()

  • SpringBoot整合RocketMQ

  • 一、搭建步骤先说下技术大致架构SpringBoot2.1.6 + Maven3.5.4 + rocketmq4.3.0 + JDK1.8 +Lombok(插件)
    1、添加rocketmq包

    org.apache.rocketm

  • RocketMQ和RabbitMQ的特性及区别

  • 一、概述消息队列已经逐渐成为企业IT系统内部通信的核心手段，主要用来提升性能、系统解耦、流量消峰。 它具有低耦合、可靠投递、广播、流量控制、最终一致性等一系列功能，成

  • 「RocketMQ」消息的存储

  • Broker对消息的处理BrokerController初始化的过程中，调用registerProcessor方法注册了处理器，在注册处理器的代码中可以看到创建了处理消息发送的处理器对象SendMessageProces

  • RocketMQ与SpringBoot整合进行生产级二次封装

  • 前置掌握：SpringBoot基础使用、RocketMQ和SpringBoot的整合使用源码地址：gitee.com/tianxincode… 文章只会说明核心代码，其他的基础整合配置和多环境自动隔离参考源码即可一、

  • rocketmq-4：线上rocketmq slave节点的ECS宕机恢复实记

  • 原创；微信公众号：千里行走；受限图片大小限制，有些图片不是很清晰，可以到微信公众号查看；目录(1).问题发现与持续时间(2).恢复操作(3).恢复期间的数据1.slave节点恢复数据的TPS2.cp

热门文章

  • 青海公益电影放映 打通文化惠民“最后一公里”

  • 　　青海新闻网·大美青海客户端讯(记者 崔永焘 摄影报道) “有时候，电影放到一半，观众只剩下老人和孩子，但放映员依然要有耐心，哪怕只有一个观众，也要把这部电影分毫不差地放完，

  • 实力女神周海媚亮相《实力派》，谈人生聊表演

  • 当影视行业逐渐摆脱了流量控制，开启最本源的以内容为导向的竞争态势之后，那些在演艺圈努力打拼数十年的优秀演员，再度迎来了全新的春天。于是影视界“叔圈”“姐圈”频频破圈，成

聚合标签

中国 自己的 亿元 美国 企业 的人 都是 万元 疫情 的是 项目 华为 手机 三星 民警 工作 这款 车型 社区 乡村 日本 群众 小米 俄罗斯 孩子 公司 文化 居民 新能源 互联网 汽车 成都 荣耀 游戏 防控 北京 武汉 新疆 安全 城市 山东 核酸 销量 球员 街道