MQ - 闲聊MQ一二事儿 (Kafka、RocketMQ 、Pulsar )
ookeeper 是 cp 强一致架构的一种,其内部使用 zab 算法,进行信息同步和容灾,在信息量较小的情况下,性能较好,当信息交互变多,因为同步带来的性能损耗加大,性能和吞吐量降低。kafka 的整体性能收到了 topic 数量的限制,这和底层的存储有密不可分的关系,我们上面讲过,当消息来的时候
RocketMQ在Linux中的安装教程
修改目录 /usr/local/rocketmq/rocketmq-all-4.7.1-bin-release/bin 下的 3 个配置文件: runserver.sh、runbroker.sh 、tools.sh不然会报insufficient memory。进入 RocketMQ 安装目录下的
RocketMQ与Kafka对比(18项差异)
为了方便大家选型,整理一份RocketMQ与Kafka的对比文档。
RocketMQ集群的特点以及各种集群模式的介绍
同步模式下的多Master多Slave模式比异步模式效率略低,并且性能也比异步模式消耗要高,因为同步模式Broker收到一条消息,首先会落盘然后同步给Slave,最后再反馈给发送者,而异步模式下,Broker在收到消息的一瞬间就会反馈给发送者消息已收到。同步模式下可以保证消息的可靠性,会保证每一条消
消息队列黄金三剑客:RabbitMQ、RocketMQ和Kafka全面对决,谁是最佳选择?
RocketMQ Console:RocketMQ官方提供了一个Web控制台,称为RocketMQ Console。它提供了一个可视化界面,用于管理和监控RocketMQ集群的各个方面,包括Topic、消费者组、消息查询、性能统计等。RabbitMQ Web管理界面:RabbitMQ自带一个Web管
Flink RocketMQ Connector实现
Public可以看到,自定义的Source,只需要实现SourceFunction。创建FlinkRocketMQConsumer,实现SourceFunction,重写run()和cancel()方法@Override@Override这样,在FlinkRocketMQConsumer类加载的时候
rocketmq消息注解基于springboot的简单应用及默认详细配置
rocketmq消息组件在springboot框架中的应用,使用rocketmq的整合包进行编码实现。
RocketMq-RocketMQMessageListener标签解析
rocketmq结合springboot使用起来十分方便,只要我们将实现类添加注解RocketMQMessageListener,并且实现接口RocketMQListener,就可以轻松实现某topic的消费侧消费消息的功能。
消息队列总结(4)- RabbitMQ & Kafka & RocketMQ高性能方案
描述RabbitMQ、Kafka、RocketMQ针对高性能做的设计。
RocketMQ源码分析
RocketMQ源码分析
springboot整合rocketmq:一个消费者组怎么订阅多个topic
一个消费组(消费者)订阅多个topic的代码
中间件大全---凤凰篇
中间件大全(RabbitMQ、RocketMQ、Redis、Nginx、Elastic Stack、ShardingJDBC、MongoDB、Elasticsearch、MyCat、FastDFS)
【面试需了解之消息队列】RocketMQ、kafka、RabbitMQ概述
消息队列说明:RocketMQ、kafka、RabbitMQ概述及关键概念
SpringBoot整合RocketMQ,老鸟们都是这么玩的!
今天我们来讨论如何在项目开发中优雅地使用RocketMQ。本文分为三部分,第一部分实现SpringBoot与RocketMQ的整合,第二部分解决在使用RocketMQ过程中可能遇到的一些问题并解决他们,第三部分介绍如何封装RocketMQ以便更好地使用。1. SpringBoot整合RocketMQ
RocketMQ (六) 主题-Topic
RocketMQ(主题)
RocketMQ 5.0 本地源码启动Cluster模式指南
这里是weihubeats,觉得文章不错可以关注公众号,文章首发。拒绝营销号,拒绝标题党。
docker部署RocketMQ
docker部署RocketMQ服务
RocketMQ的下载及安装以及历史和发展
2015年,阿里基于RocketMQ开发了阿里云上的Aliware MQ,Aliware MQ(Message Queue)是RocketMQ的商业版本,是阿里云商用的专业消息中间件,是企业级互联网架构的核心产品,基于高可用分布式集群技术,搭建了包括发布订阅、消息轨迹、资源统计、定时(延时)、监控报
RocketMQ安装
这是我安装RocketMQ的全部过程,中间页踩了好多坑,尤其是maven环境变量的配置,刚开始安装时没有配置找了好久,才发现是要配置,希望发的这个能帮助到大家
RocketMQ如何实现消息轨迹:消息何时发送的?耗时多久?谁消费的?存在哪个broker了?
RocketMQ中使用消息轨迹功能;源码剖析RocketMQ如何实现消息轨迹功能;AsyncTraceDispatcher、ConsumeMessageHook、SendMessageHook、TraceContext、TraceBean详解