本地RocketMQ的安装与调试

icattlecoder 发布于2019-08-19 11:36 / 2980人阅读

摘要：本地的安装与调试标签启动进入的源码项目。消息发送的高性能与低延迟。强大的消息堆积能力与消息处理能力。严格的顺序消息存储。保证消息至少被消费一次，但不承诺消息不会被消费者多次消费。其消息的幂等由消费者自己实现。

本地RocketMQ的安装与调试

标签：【RocketMQ】

1. 启动

进入RocketMQ-ALL的源码项目。

执行maven打包：

mvn -Prelease-all -DskipTests clean install -U

~~进入打包好的文件~~

cd /Users/rtw/IdeaProjects/RocketMQ/distribution/target/apache-rocketmq/bin

进入distribution/conf. 将其中的broker.conf 、 logback_broker.xml、logback_namesrv.xml复制到rocketmq_all/conf下。

修改broker.conf 的配置:

brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
namesrvAddr=127.0.0.1:9876
#存储路径
storePathRootDir=/Users/rtw/IdeaProjects/RocketMQ/store
#commitLog 存储路径
storePathCommitLog=/Users/rtw/IdeaProjects/RocketMQ/store/commitlog
#消费队列存储路径存储路径
storePathConsumeQueue=/Users/rtw/IdeaProjects/RocketMQ/store/consumequeue
#消息索引存储路径
storePathIndex=/Users/rtw/IdeaProjects/RocketMQ/store/index
#checkpoint 文件存储路径
storeCheckpoint=/Users/rtw/IdeaProjects/RocketMQ/store/checkpoint
#Broker 的角色
#- ASYNC_MASTER 异步复制Master
#- SYNC_MASTER 同步双写Master
#- SLAVE brokerRole=ASYNC_MASTER
#刷盘方式
#- ASYNC_FLUSH 异步刷盘
#- SYNC_FLUSH 同步刷盘 flushDiskType=ASYNC_FLUSH
#checkTransactionMessageEnable=false
#abort 文件存储路径
abortFile=/Users/rtw/IdeaProjects/RocketMQ/store/abort

运行org.apache.rocketmq.namesrv.NamesrvStartup，需要进行配置：

添加Environment variables: ROCKETMQ_HOME=/Users/rtw/IdeaProjects/RocketMQ

运行org.apache.rocketmq.broker.BrokerStartup，需要进行配置：

添加Environment variables: ROCKETMQ_HOME=/Users/rtw/IdeaProjects/RocketMQ

配置Program arguments,也就是项目的broker.conf的位置:

-c /Users/rtw/IdeaProjects/RocketMQ/conf/broker.conf

日志位置见RocketMQ/conf/logback_broker.xml.

运行org.apache.rocketmq.example.quickstart.Producer创建消息，注意需要添加producer.setNamesrvAddr("127.0.0.1:9876");

运行org.apache.rocketmq.example.quickstart.Consumer消费消息，注意添加consumer.setNamesrvAddr("127.0.0.1:9876");

2. RocketMQ

RocketMQ是一款高性能消息中间件，其核心的优势：

可靠的消息存储。

消息发送的高性能与低延迟。

强大的消息堆积能力与消息处理能力。

严格的顺序消息存储。

懂得取舍，消息中间件的理想状态是一条消息能且只被消费一次，但要做到这一点必然需要牺牲性能。RocketMQ保证消息至少被消费一次，但不承诺消息不会被消费者多次消费。其消息的幂等由消费者自己实现。

2.1 设计理念

使用NameServer，摒弃了业内常用的Zookeeper充当信息管理的“注册中心”。

因为Topic路由信息无须在集群之间保持强一致性，追求最终一致性，并且能容忍分钟级的不一致。

高效的IO存储机制。

容忍设计缺陷，RocketMQ保证消息至少被消费一次，但不承诺消息不会被消费者多次消费。其消息的幂等由消费者自己实现。

2.2 设计目标

RocketMQ作为一款消息中间件，需要解决如下问题：

架构模式：

RocketMQ与大部分消息中间件一样，采用发布订阅模式，基本的参与组件主要包括：消息发送者、消息服务器（消息存储）、消息消费、路由发现。

顺序消息：

消息消费者按照消息达到消息存储服务器的顺序消费。

消息过滤：

RocketMQ消息过滤支持在 ==服务端== 与 ==消费端==的消息过滤机制。

消息在Broker端过滤。Broker可以只将消息消费者感兴趣的消息发送给消息过滤机制。

消息在消费端过滤，消息过滤方式完全由消息消费者自定义，但缺点是有很多无效消息会从Broker传输到消费者。

消息存储：

消息的堆积能力和消息存储性能。RocketMQ追求消息存储的高性能，引入内存映射机制，所有有主题的消息顺存储在同一个文件中。

消息高可用性：

消息到达（消费）低延迟：

确保消息必须被消费一次：

RocketMQ通过消息消费确认机制（ACK）来确保消息至少被消费一次，但由于ACK消息有可能丢失等其他原因，==RocketMQ无法做到消息只被消费一次，有重复消费的可能。==

3. 启动参数

brokerRole=？；SYNC_MASTER、ASYNC_MASTER、SLAVE。SYNC和ASYNC表示Master和Slave同步消息设置，SYNC的意思是当Slave和Master消息同步完成后，再返回发送成功的状态。

服务器托管专线服务服务器的调试与安装本地调试私有云与本地部署的区别公有云与本地服务器的区别

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/77523.html

SpringBoot RocketMQ 整合使用和监控

摘要：前提通过前面两篇文章可以简单的了解和安装，今天就将和整合起来使用。然后我运行之前的整合项目，查看监控信息如下总结整篇文章讲述了与整合和监控平台的搭建。 showImg(https://segmentfault.com/img/remote/1460000013232432?w=1920&h=1277); 前提通过前面两篇文章可以简单的了解 RocketMQ 和安装 RocketMQ...

Jacendfeng 2019-08-16 11:03 评论0 收藏0
paascloud开源项目学习(2) -- centos7下安装SpringCloud+Vue环境

摘要：依次执行下面命令本地安装从官方安装包下载。管理界面提供多种管理方式命令行和界面等提供一个开源的扩展项目里面包含一个子项目配置下打个包就可以用了。前言 github 开源项目--paascloud-master：https://github.com/paascloud/... paascloud-master 官方环境搭建：http://blog.paascloud.net/20...

jsdt 2019-08-16 14:44 评论0 收藏0
深度解析RocketMQ Topic的创建机制

摘要：当接收到消息后，会在方法中调用方法，将的信息塞进缓存中，并且会定时发送心跳将发送给进行注册。这也说明了当用集群模式去创建时，集群里面每个的的数量相同，当用单个模式去创建时，每个的数量可以不一致。微信公众号「后端进阶」，专注后端技术分享：Java、Golang、WEB框架、分布式中间件、服务治理等等。老司机倾囊相授，带你一路进阶，来不及解释了快上车！我还记得第一次使用rocket...

gself 2019-08-16 16:17 评论0 收藏0
让你看懂的RocketMQ事务消息源码分析(干货)

摘要：但是服务器又确实是收到了这条消息的，只是给客户端的响应丢失了，所以导致的结果就是扣款失败，成功发货。所有的半消息都会写在为的半消息队列里，并且每条半消息，在整个链路里会被写多次，如果并发很大且大部分消息都是事务消息的话，可靠性会存在问题。前言得益于MQ削峰填谷，系统解耦，操作异步等功能特性，在互联网行业，可以说有分布式服务的地方，MQ都往往不会缺席。由阿里自研的RocketMQ更是...

zsirfs 2019-08-16 18:34 评论0 收藏0
一定能看懂的RocketMQ事务消息源码分析(干货)

摘要：但是服务器又确实是收到了这条消息的，只是给客户端的响应丢失了，所以导致的结果就是扣款失败，成功发货。既然消息的发送不能和本地事务写在一起，那如何来保证其整体具有原子性的需求呢答案就是今天我们介绍的主角事务消息。前言得益于MQ削峰填谷，系统解耦，操作异步等功能特性，在互联网行业，可以说有分布式服务的地方，MQ都往往不会缺席。由阿里自研的RocketMQ更是经历了多年的双十一高并发挑战...

myshell 2019-08-16 18:33 评论0 收藏0