RocketMQ入门手册
前言继我上一篇博客后分布式消息队列RocketMQ学习教程①上一篇博客最主要介绍了几种常用的MQ，所以本博客再简单介绍一下RocketMQ的原理和简单的例子，基于Java实现，希望可以帮助学习者RoketMQ搭建Linux版“工于利其事，必先利其器”，所以我们首先需要搭建好RocketMQ，考虑到学...
Kafka vs RocketMQ——多Topic对性能稳定性的影响
引言上期我们对比了RocketMQ和Kafka在多Topic场景下，收发消息的对比测试，RocketMQ表现稳定，而Kafka的TPS在64个Topic时可以保持13万，到了128个Topic就跌至0.85万，导致无法完成测试。我们不禁要问：为什么看不到Kafka性能暴跌的趋势呢？今天的测试，就来排...
RocketMQ集群部署配置
目标，使用2台机器部署RocketMQ多Master多Slave模式，异步复制集群模式。第一步，修改/etc/hosts文件192.168.116.115 rocketmq1192.168.116.116 rocketmq2集群机器配置完成之后，集群内进行ping一下，确保都通。编译得到环境git ...
RocketMQ入门案例
学习RocketMQ，先写一个Demo演示一下看看效果。一、服务端部署因为只是简单的为了演示效果，服务端仅部署单Master模式 —— 一个Name Server节点，一个Broker节点。主要有以下步骤。下载RocketMQ源码、编译（也可以网上下载编译好的文件），这里使用最新的4.4.0版本，下...
Alibaba-技术专区-RocketMQ 延迟消息实现原理和源码分析
痛点背景业务场景假设有这么一个需求，用户下单后如果30分钟未支付，则该订单需要被关闭。你会怎么做？之前方案最简单的做法，可以服务端启动个定时器，隔个几秒扫描数据库中待支付的订单，如果(当前时间-订单创建时间)>30分钟，则关闭订单。方案评估优点：是实现简单，缺点呢？缺点：定时扫描意味着隔个几秒...
rocketmq 启动和停止命令
A启动server: nohup sh mqnamesrv &A启动broken: nohup sh mqbroker -c /opt/rocketmq432/conf/2m-noslave/broker-a.properties autoCreateTopicEnable=true >...
Alibaba(阿里) RocketMQ入门实例
摘自：码友18年（www.mayou18.com）what is rocketMQ?RocketMQ作为一款分布式的消息中间件（阿里的说法是不遵循任何规范的，所以不能完全用JMS的那一套东西来看它），经历了Metaq1.x、Metaq2.x的发展和淘宝双十一的洗礼，在功能和性能上远超ActiveMQ...
RocketMQ消息队列安装
一、官方安装文档http://rocketmq.apache.org/docs/quick-start/下载地址https://github.com/apache/rocketmq/releases###环境需求jdk1.8以上maven二、安装wget https://github.com/apa...
Centos7安装RocketMQ及配置测试
环境Centos7RocketMQ 3.2.6安装位置 /usr/local/alibaba-rockermq外网ip 182.254.145.66内网ip 10.105.23.114安装wget https://github.com/alibaba/RocketMQ/releases/downlo...
RocketMQ集群搭建
1、RocketMQ介绍1.1. 简介RocketMQ 是一款分布式、队列模型的消息中间件，具有以下特点：能够保证严格的消息顺序 提供丰富的消息拉取模式 高效的订阅者水平扩展能力 实时的消息订阅机制 亿级消息堆积能力选用理由：强调集群无单点，可扩展，任意一点高可用，水平可扩展。海量消息堆积能力，消息...
49.RocketMQ 双主搭建（本文非EamonSec原创）
声明：本文非EamonSec原创，copy自网上下载的某个个文件1、RocketMQ介绍1.1. 简介RocketMQ 是一款分布式、队列模型的消息中间件，具有以下特点：能够保证严格的消息顺序提供丰富的消息拉取模式高效的订阅者水平扩展能力实时的消息订阅机制亿级消息堆积能力选用理由：l 强调集群无单点...
分布式消息中间件rocketmq的原理与实践
RocketMQ作为阿里开源的一款高性能、高吞吐量的消息中间件，它是怎样来解决这两个问题的？RocketMQ 有哪些关键特性？其实现原理是怎样的？关键特性以及其实现原理一、顺序消息消息有序指的是可以按照消息的发送顺序来消费。例如：一笔订单产生了 3 条消息，分别是订单创建、订单付款、订单完成。消费时...
RocketMQ学习笔记（4）----RocketMQ搭建双Master集群
前面已经学习了RockeMQ的四种集群方式，接下来就来搭建一个双Master(2m)的集群环境。1. 双Master服务器环境序号ip用户名密码角色模式(1)47.105.145.123rootnameServer1,brokerServer1 Master1(2)47.105.149.61root...
RocketMQ学习笔记（9）----RocketMQ的Producer 顺序消息
1. 顺序消息原理图2. 什么是顺序消息？消费消息的顺序要求同发送消息的顺序一致，在RocketMQ中，主要指的是局部顺序，即一类消息为满足顺序性，必须Producer单线程顺序发送，并且发送给到同一队列，这样Consumer就可以按照Producer发送的顺序去消费消息。2.1 普通顺序消息正常情...
rocketmq学习(二) rocketmq集群部署与图形化控制台安装
1.rocketmq图形化控制台安装虽然rocketmq为用户提供了使用命令行管理主题、消费组以及broker配置的功能，但对于不够熟练的非运维人员来说，命令行的管理界面还是较难使用的。为此，我们可以使用图形化的管理界面来简化管理操作。rocketmq官方推荐的图形化控制台目前还处在不成熟的孵化阶段...
RocketMQ(消息重发、重复消费、事务、消息模式)
分布式开放消息系统(RocketMQ)的原理与实践RocketMQ基础：https://github.com/apache/rocketmq/tree/rocketmq-all-4.5.1/docs/cn分布式消息系统作为实现分布式系统可扩展、可伸缩性的关键组件，需要具有高吞吐量、高可用等特点。而谈...
rocketmq总结(消息的顺序、重复、事务、消费模式)
rocketmq总结(消息的顺序、重复、事务、消费模式)参考：http://www.cnblogs.com/wxd0108/p/6038543.htmlhttps://www.cnblogs.com/520playboy/p/6750023.htmlhttps://blog.csdn.net/chu...
RocketMQ——角色与术语详解
原文地址：http://jaskey.github.io/blog/2016/12/15/rocketmq-concept/RocketMQ——角色与术语详解2016-12-15 THU 15:48RocketMQ中有很多概念，其中包括一些术语和角色。理清楚基本的概念能有效的帮助理解RocketMQ...
RocketMQ入门到入土（二）事务消息&顺序消息
接上一篇：RocketMQ入门到入土（一）新手也能看懂的原理和实战！一、事务消息的由来1、案例引用官方的购物案例：小明购买一个100元的东西，账户扣款100元的同时需要保证在下游的积分系统给小明这个账号增加100积分。账号系统和积分系统是两个独立是系统，一个要减少100元，一个要增加100积分。如下...
RocketMQ3.2.2生产者发送消息自动创建Topic队列数无法超过4个
问题现象RocketMQ3.2.2版本，测试时尝试发送消息时自动创建Topic，设置了队列数量为8：producer.setDefaultTopicQueueNums(8);同时设置broker服务器的配置文件broker.properties：defaultTopicQueueNums=16但实际...