首页 > 其他分享 >ROCKETMQ

ROCKETMQ

时间:2023-05-30 17:45:36浏览次数:45  
标签:JAVA License ROCKETMQ cmd broker RocketMQ store

配置环境变量(ROCKETMQ_HOME

修改runserver.cmd

1、进入bin目录下找到runserver.cmd文件,用编辑器打开,因为RocketMQ默认需要2g运行内存,做为测试用,就只要最低配置就好了,注释原有的NameServer 的配置,在其前面加上rem 注释掉,

rem set "JAVA_OPT=%JAVA_OPT% -server -Xms2g -Xmx2g -Xmn1g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m" 

在后面加上

set "JAVA_OPT=%JAVA_OPT% -server -Xms256m -Xmx512m" 

2、双击 mqnamesrv.cmd 文件 NameServer 的默认端口是9876

3、配置broker排位置文件

a.用编辑器打开runbroker.cmd文件

注释默认配置,在其前面加上

rem set "JAVA_OPT=%JAVA_OPT% -server -Xms2g -Xmx2g -Xmn1g" 

并在后面配置

set "JAVA_OPT=%JAVA_OPT% -server -Xms256m -Xmx512m"

b.配置NameServer地址

rem 指定NameServer的地址

set "NAMESRV_ADDR=localhost:9876"

rem 添加NameServer的地址

call "%ROCKETMQ_HOME%\bin\runbroker.cmd" org.apache.rocketmq.broker.BrokerStartup %*

查看 是否有集群注册

.\mqadmin.cmd clusterList -n localhost:9876

  • 修改 conf 文件夹中的 broker.conf 文件

# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements.  See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License.  You may obtain a copy of the License at
#
#     http://www.apache.org/licenses/LICENSE-2.0
#
#  Unless required by applicable law or agreed to in writing, software
#  distributed under the License is distributed on an "AS IS" BASIS,
#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
#  See the License for the specific language governing permissions and
#  limitations under the License.

# 集群名字
brokerClusterName = DefaultCluster
# 使用的broker-a.properties配置,名字和配置文件一致
brokerName = broker-a
# 0表示master,大于0表示slave
brokerId = 0
# 删除文件时间,默认为凌晨4点
deleteWhen = 04
# 文件保留时间,默认为48小时
fileReservedTime = 48
# broker角色:ASYNC_MASTER异步复制Master  SYNC_MASTER同步双写Master
brokerRole = ASYNC_MASTER
# 刷盘方式:ASYNC_FLUSH异步刷盘  SYNC_FLUSH同步刷盘
flushDiskType = ASYNC_FLUSH

# 允许自动创建topic
autoCreateTopicEnable=true
# 允许自动创建订阅组
autoCreateSubscriptionGroup=true
# 对外服务的监听端口
listenPort=10911
# 检测磁盘空间,低于该值就会导致消息接收失败
diskMaxUsedSpaceRatio=99
# store存储路径
storePathRootDir=D:\RocketMQ\log\store
# commitlog存储路径
storePathCommitLog=D:\RocketMQ\log\store\commitlog
# 消费队列存储路径
storePathConsumeQueue=D:\RocketMQ\log\store\consumequeue
# 消息索引存储路径
storePathIndex=D:\RocketMQ\log\store\index
# checkpoint文件存储路径
storeCheckpoint=D:\RocketMQ\log\store\checkpoint
# abort文件存储路径
abortFile=D:\RocketMQ\log\store\abort


图形化界面:

idea运行就行

https://github.com/apache/rocketmq-dashboard

标签:JAVA,License,ROCKETMQ,cmd,broker,RocketMQ,store
From: https://www.cnblogs.com/firsthelloworld/p/17443910.html

相关文章

  • RocketMQ使用实例
    下面是一个使用Java实现的RocketMQ示例代码,用于发送和消费消息:首先,您需要下载并安装RocketMQ,并启动NameServer和Broker。接下来,您可以使用以下示例代码来发送和消费消息:Producer.java文件:importorg.apache.rocketmq.client.producer.DefaultMQProducer;importorg.apache.ro......
  • 详解RocketMQ 顺序消费机制
    摘要:顺序消息是指对于一个指定的Topic,消息严格按照先进先出(FIFO)的原则进行消息发布和消费,即先发布的消息先消费,后发布的消息后消费。本文分享自华为云社区《RocketMQ顺序消费机制》,作者:勇哥java实战分享。顺序消息是指对于一个指定的Topic,消息严格按照先进先出(FIFO)的原则......
  • SpringBoot集成RocketMQ,rocketmq_client.log日志文件配置
    SpringBoot项目集成rocketmq-client<dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-client</artifactId><version>4.7.0</version></dependency>项目启动时会在${user.home}/logs目录下创建一个roc......
  • RocketMQ4.9.5集群部署
    RocketMQ集群部署背景:生产环境单机的MQ不具有高可用,所以我们应该部署成集群模式,这里给大家部署一个双主双从异步复制的Broker集群一、单机部署、部署前提参考https://www.cnblogs.com/hsyw/p/17428530.htmlhttps://www.cnblogs.com/hsyw/p/17429834.html二、集群部署......
  • RocketMQ 顺序消费机制
    顺序消息是指对于一个指定的Topic,消息严格按照先进先出(FIFO)的原则进行消息发布和消费,即先发布的消息先消费,后发布的消息后消费。顺序消息分为分区顺序消息和全局顺序消息。1、分区顺序消息对于指定的一个Topic,所有消息根据ShardingKey进行区块分区,同一个分区内的消息按......
  • 【❧消息队列】解析 RocketMQ 业务消息——“事务消息”
    在分布式系统调用场景中存在这样一个通用问题,即在执行一个核心业务逻辑的同时,还需要调用多个下游做业务处理,而且要求多个下游业务和当前核心业务必须同时成功或者同时失败,进而避免部分成功和失败的不一致情况出现。简单来说,消息队列中的“事务”,主要解决的是消息生产者和消费者的......
  • 【RocketMQ】NameServer总结
    NameServer是一个注册中心,提供服务注册和服务发现的功能。NameServer可以集群部署,集群中每个节点都是对等的关系(没有像ZooKeeper那样在集群中选举出一个Master节点),节点之间互不通信。服务注册Broker启动的时候会向所有的NameServer节点进行注册,注意这里是向集群中所有的NameServ......
  • cloud alibaba 学习 之 rocketmq
    rocketmq有三种消息发送模式:1.同步发送需要等待broker回应/***同步消息发送*/@TestpublicvoidtestSyncSend(){//param1:topic;若添加tag:topic:tag//param2:消息内容SendResultsendResult=rocketMQTemplate......
  • RocketMQ 在小米的多场景灾备实践案例
    作者:邓志文、王帆01为什么要容灾?在小米内部,我们使用RocketMQ来为各种在线业务提供消息队列服务,比如商城订单、短信通知甚至用来收集IoT设备的上报数据,可以说RocketMQ的可用性就是这些在线服务的生命线。作为软件开发者,我们通常希望服务可以按照理想状态去运行:在没有Bug的......
  • RocketMQ事务消息原理
    一、RocketMQ事务消息原理:        RocketMQ在4.3版本之后实现了完整的事务消息,基于MQ的分布式事务方案,本质上是对本地消息表的一个封装,整体流程与本地消息表一致,唯一不同的就是将本地消息表存在了MQ内部,而不是业务数据库,事务消息解决的是生产端的消息发送与本地事务执行......