《rocketmq》专题
-
1.1.1 为什么使用消息队列？消息队列有什么优点和缺点？Kafka、ActiveMQ、RabbitMQ、RocketMQ 都有什么优点和缺点？
面试题 为什么使用消息队列？ 消息队列有什么优点和缺点？ Kafka、ActiveMQ、RabbitMQ、RocketMQ 都有什么区别，以及适合哪些场景？ 面试官心理分析 其实面试官主要是想看看： 第一，你知不知道你们系统里为什么要用消息队列这个东西？ 不少候选人，说自己项目里用了 Redis、MQ，但是其实他并不知道自己为什么要用这个东西。其实说白了，就是为了用而用，或者是别人设计的架构，他从
-
RocketMq事务消息发送代码流程详解
本文向大家介绍RocketMq事务消息发送代码流程详解，包括了RocketMq事务消息发送代码流程详解的使用技巧和注意事项，需要的朋友参考一下 一、RocketMq事务消息流程： 1、首先会向broker发送一个预请求消息，消费者不可见 2、回调执行本地事务（比如操作数据库） 3、事务执行成功后，再次发送消息给broker，告诉broker事务执行成功这个消息要提交，让消费者可见。如果本地事务执行
-
springBoot整合RocketMQ及坑的示例代码本文向大家介绍springBoot整合RocketMQ及坑的示例代码，包括了springBoot整合RocketMQ及坑的示例代码的使用技巧和注意事项，需要的朋友参考一下 版本： JDK:1.8 springBoot:1.5.10 rocketMQ：4.2.0 pom 配置： application.properties 配置: java代码： 生产者 消费者： 掉坑总结： 1.roc
-
Docker中RocketMQ的安装与使用详解本文向大家介绍Docker中RocketMQ的安装与使用详解，包括了Docker中RocketMQ的安装与使用详解的使用技巧和注意事项，需要的朋友参考一下 搜索RocketMQ的镜像，可以通过docker的hub.docker.com上进行搜索，也可以在Linux下通过docker的search命令进行搜索，不过最近防火墙升级后，导致国外的网站打开都很慢，通过命令搜索反而会更加方便，操作Docke
-
RocketMQ消息中间件用起来真的可靠吗？主要内容：一、前情提示,二、ack机制回顾,三、ack机制实现原理：delivery tag,四、RabbitMQ如何感知到仓储服务实例宕机,五、仓储服务处理失败时的消息重发,六、阶段总结一、前情提示 上一篇文章《MQ保证读写消息不丢失，这个你都不会就等着被开除吧...》我们初步介绍了之前制定的那些消息中间件数据不丢失的技术方案遗留的问题。 一个最大的问题，就是生产者投递出去的消息，可能会丢失。 丢失的原因有很多，比如消息在网络传输到一半的时候因为网络故障就丢了，或者是消息投递到MQ的内存时，M
-
Canal Kafka RocketMQ QuickStart
基本说明 canal 1.1.1版本之后, 默认支持将canal server接收到的binlog数据直接投递到MQ, 目前默认支持的MQ系统有: kafka: https://github.com/apache/kafka RocketMQ : https://github.com/apache/rocketmq 环境版本 操作系统：CentOS release 6.6 (Final) java
-
RocketMQ每秒要写入几十万并发，是怎么实现的？主要内容：1、页缓存技术 + 磁盘顺序写,2、零拷贝技术,3、最后的总结这篇文章来聊一下Kafka的一些架构设计原理，这也是互联网公司面试时非常高频的技术考点。 Kafka是高吞吐低延迟的高并发、高性能的消息中间件，在大数据领域有极为广泛的运用。配置良好的Kafka集群甚至可以做到每秒几十万、上百万的超高并发写入。 那么Kafka到底是如何做到这么高的吞吐量和性能的呢？这篇文章我们来一点一点说一下。 1、页缓存技术 + 磁盘顺序写 首先Kafka每次接收到数据都会往磁
-
RocketMQ面试题【35道】主要内容：1.RocketMQ由哪些角色组成，每个角色作用和特点是什么,2.RocketMQ中的Topic和JMS的queue有什么区别,3.RocketMQ Broker中的消息被消费后会立即删除吗,4.RocketMQ消费模式有几种,5.RocketMQ消息是push还是pull,6.为什么要主动拉取消息而不使用事件监听方式,7.Broker如何处理拉取请求的,8.RocketMQ如何做负载均衡,,,,,,,,,,,,,,,,,,,,,,,,,,,1.RocketMQ由哪些角色组成，每个角色
-
RocketMQ 不丢失消息的方式主要内容：1.RocketMq架构,2.消息不丢失1.RocketMq架构 Producer,Consumer,Brocker,Name Server 2.消息不丢失 1.Producer发送消息 2.Brocker保存消息 3.Consumer 消费消息 4.Brocker主从切换 2.1 同步发送 同步发送会返回状态码 1.SEND_OK：消息发送成功。需要注意的是，消息发送到 broker 后，还有两个操作：消息刷盘和消息同步到 slave
-
RocketMQ和Kafka的差异对比
主要内容：1.Broker差异,2.Producer差异,3.Consumer差异1.Broker差异 主从差异: kafka的master/slave是基于partition维度的，而rocketmq是基于broker维度的；kafka的master/slave是可以切换的，而rocketmq不行，当rocketmq的master宕机时，读能被路由到slave上，但写会被路由到此topic的其他broker上。 刷盘： rocketmq支持同步刷盘，也就是每次消息都等刷入磁盘
-
Kafka 和 RocketMq 的对比
主要内容：数据可靠性,性能对比,单机支持的队列数,消息投递实时性,消费失败重试,严格的消息顺序,定时消息,分布式事务消息,消息查询,消息回溯,消费并行度,消息轨迹,开发语言友好性,Broker端消息过滤,消息堆积能力,开源社区活跃度,商业支持,成熟度数据可靠性 RocketMQ支持异步实时刷盘，同步刷盘，同步Replication，异步Replication Kafka使用异步刷盘方式，异步Replication 总结：RocketMQ的同步刷盘在单机可靠性上比Kafka更高，不会因为操作系统C
-
RocketMQ调试环境准备主要内容：1 下载源码包,2 配置目录,3 启动namesrv,4 启动broker,5 启动管理后台,6 快速案例详细介绍了RocketMQ 4.9.3 分支的源码调试环境搭建等一系列准备工作。 RocketMQ的源码这么多，我们肯定不会全部看完的，我们的源码分析主要会涉及到namesrv、broker、client、remoting、store等模块，也就是生产者、消费者、nameServr、Broker这几个角色的核心功能点。 在看RocketMQ源码之前，一定一定一定要先学会如何使用Ro
-
Apache RocketMQ-Spring
为了帮助开发者在 Spring Boot 中快速集成 RocketMQ 并支持 Spring Message 规范，使开发者从其它 MQ 快速切换到 RocketMQ，Apache RocketMQ 社区推出了 RocketMQ SpringBoot 项目。 前提条件 JDK 1.8 and above Maven 3.0 and above 功能特性 同步发送 同步顺序发送 异步发送 异
-
Apache RocketMQ
RocketMQ是什么？ RocketMQ 是一款开源的分布式消息系统，基于高可用分布式集群技术，提供低延时的、高可靠的消息发布与订阅服务。同时，广泛应用于多个领域，包括异步通信解耦、企业解决方案、金融支付、电信、电子商务、快递物流、广告营销、社交、即时通信、移动应用、手游、视频、物联网、车联网等。 具有以下特点： 能够保证严格的消息顺序 提供丰富的消息拉取模式 高效的订阅者水平扩展能力 实时的消
-
rocketmq_completion
rocketmq 命令行自动补全工具。大多数软件工程师都比较喜欢命令行交互，mqadmin作为rocketmq的管理端，为我们提供了众多功能，因其命令众多，不同命令参数也很多，通过这个命令行自动补全工具，让我们使用起来特别友善！