rocketmq云消息队列 Kafka 版的相关内容

文章 2023-03-01 来自：开发者社区

阿里云消息队列 RocketMQ、Kafka 荣获金融级产品稳定性测评 “先进级” 认证

近日，由中国信通院和混沌工程实验室联合举办的混沌工程技术沙龙--金融行业精品专场顺利召开，并发布金融级产品稳定性测评成果。在分布式系统稳定性评估体系获奖名单中，阿里云分布式消息队列服务成为通过首批消息队列服务稳定性认证，荣获最高级别 “先进级” 认证的消息队列服务。根据混沌测试报告显示，阿里云分布式消息队列服务 RocketMQ版、Kafka 版已通过单项故障注入测试（服务器宕机、服务发现故障、....

文章 2023-01-16 来自：开发者社区

Rocketmq、Rabbitmq、Kafka、Mongo、Elasticsearch、Logstash、Kibana、Nacos、Skywalking、Seata、Spark、Zookeeper安装

文章目录前言一、docker-compose.yml配置二、安全组规则添加端口三、通过浏览器访问rabbitmq的管控页面四、提供其他项目依赖总结前言已经安装好了宝塔面板、并且可以在Docker栏目，选择docker安装，会把docker和docker-compose都安装好了一、docker-compose.yml配置在任意一个目录下创建并编辑vim docker-compose.yml配置粘....

文章 2023-01-15 来自：开发者社区

【Alibaba中间件技术系列】「RocketMQ技术专题」帮你梳理RocketMQ或Kafka的选择理由以及二者PK

前提背景大家都知道，市面上有许多开源的MQ，例如，RocketMQ、Kafka、RabbitMQ等等，现在Pulsar也开始发光，今天我们谈谈笔者最常用的RocketMQ和Kafka，想必大家早就知道二者之间的特点以及区别，但是在实际场景中，二者的选取有可能会范迷惑，那么今天笔者就带领大家分析一下二者之间的区别，以及选取标准吧！架构对比RocketMQ的架构RocketMQ由NameServer....

文章 2022-12-13 来自：开发者社区

消息中间件mq的比较：含RocketMQ、RabbitMQ、Kafka； rocketmq底层封装

消息中间件mq的比较：含RocketMQ、RabbitMQ、Kafka共同点都是消息队列，有mq的特性队列（先进先出原则）RocketMQ吞吐量经过了双十一的检验，比RabbitMQ好。阿里开发的，阿里系用的比较多些。RabbitMQRabbitMQ采用Erlang语言开发，是实现高级消息队列协议的开源消息中间件。它的官网有个兔子。Rabbit意味兔子。特点性能很好，延时低吞吐量到万级，相对低，....

文章 2022-09-07 来自：开发者社区

一篇文章把RabbitMQ、RocketMQ、Kafka三元归一(三）

MQ带来的一些问题、及解决方案如何保证顺序消费？RabbitMQ ：一个Queue对应一个Consumer即可解决。RocketMQhash (key)%队列数Kafka ：hash (key)%分区数如何实现延迟消费？RabbitMQ ：两种方案死信队列 + TTL引入RabbitMQ的延迟插件RocketMQ ：天生支持延时消息。Kafka ：步骤如下专门为要延迟的消息创建一个Topic新....

文章 2022-09-07 来自：开发者社区

一篇文章把RabbitMQ、RocketMQ、Kafka三元归一(二）

KafkaKafka是一个分布式、支持分区的、多副本的，基于ZooKeeper 协调的分布式消息系统。它最大的特性就是可以实时的处理大量数据以满足各种需求场景：比如基于Hadoop的批处理系统、低延迟的实时系统、Storm/Spark流式处理引擎，Web/Nginx日志、访问日志，消息服务等等，用 Scala语言编写。属于Apache基金会的顶级开源项目。先看一下Kafka的架构图：Kaf....

文章 2022-09-07 来自：开发者社区

一篇文章把RabbitMQ、RocketMQ、Kafka三元归一（一）

RabbitMQRabbitMQ各组件的功能Broker ：一个RabbitMQ实例就是一个BrokerVirtual Host ：虚拟主机。相当于MySQL的DataBase ，一个Broker上可以存在多个vhost，vhost之间相互隔离。每个vhost都拥有自己的队列、交换机、绑定和权限机制。vhost必须在连接时指定，默认的vhost是/。Exchange ：交换机，用来接收生产者发送....

文章 2022-05-11 来自：开发者社区

消息队列之事务消息，RocketMQ 和 Kafka 是如何做的？（下）

就是来了波狸猫换太子，其实延时消息也是这么实现的，最终将换了皮的消息入盘。Broker 处理提交或者回滚消息的处理方法是 EndTransactionProcessor#processRequest，我们来看一看它做了什么操作。可以看到，如果是提交事务就是把皮再换回来写入真正的topic所属的队列中，供消费者消费，如果是回滚则是将半消息记录到一个 half_op 主题下，到时候后台服务扫描半消息....

文章 2022-05-11 来自：开发者社区

消息队列之事务消息，RocketMQ 和 Kafka 是如何做的？（上）

每个时代，都不会亏待会学习的人。大家好，我是 yes。今天我们来谈一谈消息队列的事务消息，一说起事务相信大家都不陌生，脑海里蹦出来的就是 ACID。通常我们理解的事务就是为了一些更新操作要么都成功，要么都失败，不会有中间状态的产生，而 ACID 是一个严格的事务实现的定义，不过在单体系统时候一般都不会严格的遵循 ACID 的约束来实现事务，更别说分布式系统了。分布式系统往往只能妥协到最终一致性，....

文章 2022-05-11 来自：开发者社区

消息队列之推还是拉，RocketMQ 和 Kafka 是如何做的？（下）

Kafka 中的长轮询像 Kafka 在拉请求中有参数，可以使得消费者请求在 “长轮询” 中阻塞等待。简单的说就是消费者去 Broker 拉消息，定义了一个超时时间，也就是说消费者去请求消息，如果有的话马上返回消息，如果没有的话消费者等着直到超时，然后再次发起拉消息请求。并且 Broker 也得配合，如果消费者请求过来，有消息肯定马上返回，没有消息那就建立一个延迟操作，等条件满足了再返回。我们来....