48.rocketMQ

一、简介

　　RocketMQ是阿里旗下的一款产品，分为开源版本和非开源版本。相比于ActiveMQ，RocketMQ支持顺序消费、事务机制、失败重试机制、消息可查询、消息订阅、较强的水平扩展能力、亿级堆积能力以及友好的消息拉取模式。RocketMQ的开源社区比较活跃，经受过双十二的考验。（架构师杨正坤：oceanBase）

　　在这里，我们用nameServer来替代zookeeper，nameServer不遵循JMS，有一些ActiveMQ中没有涉及到的专业术语需要了解一下：

  • push consumer
  • pull consumer
  • producer group 一类producter的集合
  • consumer group 一类consumer名称
  • broker：消息中转
  • 广播消息
  • 发布订阅模式：RocketMQ中只有这一种模式，只是有基于一个还是多个之说
  • 集群消息
  • message Filter：java代码上传
  • message persistence：仅支持kafka和RocketMQ这两种持久化
  • RocketMQ是无界的
  • 带有消息过滤

二、搭建

2.1 几种模式

  1. 单master（基本不用）
  2. 多master多slave（不常用）
  3. 多master模式（常用，大部分场景可以满足）
  4. 异步复制：向master发送成功就返回给应用表名成功
  5. 同步双写：数据和服务都无单点，可靠性很高，向master和slave都发送成功才告诉应用成功

2.2 步骤

  1. host配置
  2. 上传解压rocketmq压缩包
  3. 创建两台机器的存储路径
    ../store
    ../store/comitlog
    ../store/consumequeue
    ../sotre/index
  4. 修改 broker-a.properties <-- master1
           broker-b.properties <-- master2
    可清掉默认配置
    brokerClusterName都一样
    brokerName=broker-a
    brokerId=0表示master
  5. 修改日志文件
  6. 修改启动参数（JVM调优）
    runbroker.sh 最小堆是1g
    runserver.sh
时间： 2024-08-25 17:21:49

48.rocketMQ的相关文章

RocketMQ——角色与术语详解

原文地址:http://jaskey.github.io/blog/2016/12/15/rocketmq-concept/ RocketMQ--角色与术语详解 2016-12-15 THU 15:48 RocketMQ中有很多概念,其中包括一些术语和角色. 理清楚基本的概念能有效的帮助理解RocketMQ的原理以及排查问题. 角色: Producer 生产者.发送消息的客户端角色.发送消息的时候需要指定Topic. Consumer 消费者.消费消息的客户端角色.通常是后台处理异步消费的系统.

rocketmq 命令示例

http://www.360doc.com/content/16/0111/17/1073512_527143896.shtml http://www.cnblogs.com/marcotan/p/4256857.html RocketMQ常用命令 二.根据msgId查询消息 1.文档: 指令 queryMsgById 类路径 com.alibaba.rocketmq.tools.command.message.QueryMsgByIdSubCommand 参数 是否必填 说明 -i 是 msg

消息中间件 RocketMQ源码解析：事务消息

关注微信公众号:[芋艿的后端小屋]有福利: RocketMQ / MyCAT / Sharding-JDBC 所有源码分析文章列表 RocketMQ / MyCAT / Sharding-JDBC 中文注释源码 GitHub 地址 您对于源码的疑问每条留言都将得到认真回复.甚至不知道如何读源码也可以请教噢. 新的源码解析文章实时收到通知.每周更新一篇左右. 1. 概述 2. 事务消息发送 2.1 Producer 发送事务消息 2.2 Broker 处理结束事务请求 2.3 Broker 生成

rocketMQ的运行示例代码

rocketMQ的示例代码 1 import com.alibaba.rocketmq.client.exception.MQBrokerException; 2 import com.alibaba.rocketmq.client.exception.MQClientException; 3 import com.alibaba.rocketmq.client.producer.DefaultMQProducer; 4 import com.alibaba.rocketmq.client.pr

双RocketMq集群的搭建

一.双Master RocketMq集群的搭建 1.服务器环境: 序号 IP 用户名 角色 模式 1 192.168.211.128 root nameServer1,brokerServer1 Master1 2 192.168.211.129 root nameServer2,brokerServer2 Master1 2.添加hosts信息 vim /etc/hosts IP NAME 192.168.211.128 rocketmq-nameserver1 192.168.211.128

51.RocketMQ 顺序消费

3种不同模式的Producer NormalProducer(普通) OrderProducer(顺序) TransactionProducer(事务) 生产者 1 /** 2 * Copyright (C) 2010-2013 Alibaba Group Holding Limited 3 * 4 * Licensed under the Apache License, Version 2.0 (the "License"); 5 * you may not use this fil

49.RocketMQ 双主搭建（本文非EamonSec原创）

声明:本文非EamonSec原创,copy自网上下载的某个个文件 1.RocketMQ介绍 1.1. 简介 RocketMQ 是一款分布式.队列模型的消息中间件,具有以下特点: 能够保证严格的消息顺序 提供丰富的消息拉取模式 高效的订阅者水平扩展能力 实时的消息订阅机制 亿级消息堆积能力 选用理由: l 强调集群无单点,可扩展,任意一点高可用,水平可扩展. l 海量消息堆积能力,消息堆积后,写入低延迟. l 支持上万个队列 l 消息失败重试机制 l 消息可查询 l 开源社区活跃 l 成熟度(经过

阿里 RocketMQ 安装与简介

一.简介 官方简介: l  RocketMQ是一款分布式.队列模型的消息中间件,具有以下特点: l  能够保证严格的消息顺序 l  提供丰富的消息拉取模式 l  高效的订阅者水平扩展能力 l  实时的消息订阅机制 l  亿级消息堆积能力 二.网络架构 三.特性 1.      nameserver 相对来说,nameserver的稳定性非常高.原因有二: 1 .nameserver互相独立,彼此没有通信关系,单台nameserver挂掉,不影响其他nameserver,即使全部挂掉,也不影响业务

Rocketmq分布式消息队列的部署与监控

-------------------------------------------------------------------------------------------- 一.Rocketmq简介: -------------------------------------------------------------------------------------------- RocketMQ是一款分布式.队列模型的消息中间件,具有以下特点:1.支持严格的消息顺序:2.支持T