Docker安装RocketMQ

文章目录

  • 前言
  • 一、rocketMQ安装教程
  • 二、rocketmq-console可视化界面

前言

本章节将介绍如何在docker环境下安装rocketmq以及rocketmq-console可视化界面

一、rocketMQ安装教程

在安装之前请保证您的服务器已经安装好docker环境并且安装好JDK
（1）拉取rocketMQ最新版本镜像

docker pull rocketmqinc/rocketmq

在这里插入图片描述

拉取镜像时间可能较久，等拉取完成后通过docker images查看镜像是否拉取成功，可以看到已经拉取rocketmq镜像
在这里插入图片描述
（2）创建nameserver数据存储目录
rocketMQ 分为nameserver和broker两部分，在启动时应该先启动nameserver，因此我们现在先创建nameserver的日志和数据存放目录。这个目录可由我们自己定义路径，这里我将其放到data路径下:

mkdir -p /data/namesrv/logs /data/namesrv/store

logs:是nameserver的日志目录，store:是nameserver的数据目录
在这里插入图片描述
（3）构建namesrv容器并启动
我们已经创建好了nameserver的日志和数据的存放路径，此时我们只需要挂在日志和数据路径，执行以下命令启动nameserver即可。

docker run -d  --restart=always --name rmqnamesrv -p 9876:9876  -v  /data/namesrv/logs:/root/logs  -v /data/namesrv/store:/root/store  -e "MAX_POSSIBLE_HEAP=100000000"  rocketmqinc/rocketmq sh mqnamesrv

执行完nameserver容器启动命名后，可以通过docker ps查看是否启动成功：
在这里插入图片描述
（4）创建broker数据存储路径
在操作这步之前，我们已经将nameserver启动成功，则接下来我们将要为broker创建数据挂载目录和配置文件，以确保broker能够成功启动。

mkdir -p /data/broker/logs  /data/broker/store /data/broker/conf

logs:是broker的日志目录，store:是broker的数据目录，conf是broker的配置信息目录

（5）创建broker配置文件
我们刚刚已经创建了broker配置目录(/data/broker/conf)，现在我们要在改配置目录下增加一个broker的配置文件，命名叫broker.conf

cd /data/broker/conf & vi broker.conf

请将一下信息复制到broker.conf文件中，请注意修改brokerIP1，改为您服务器的IP地址！！！！请注意修改brokerIP1，改为您服务器的IP地址！！！！ 

# 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 名字，注意此处不同的配置文件填写的不一样，如果在 broker-a.properties 使用: broker-a,
# 在 broker-b.properties 使用: broker-b
brokerName=broker-a
# 0 表示 Master，> 0 表示 Slave
brokerId=0
# nameServer地址，分号分割
namesrvAddr=rmqserver01:9876
# 启动IP,如果 docker 报 com.alibaba.rocketmq.remoting.exception.RemotingConnectException: connect to <192.168.0.120:10909> failed
# 解决方式1 加上一句 producer.setVipChannelEnabled(false);，解决方式2 brokerIP1 设置宿主机IP，不要使用docker 内部IP
#producer.setVipChannelEnabled=false
brokerIP1=192.168.101.220# 在发送消息时，自动创建服务器不存在的topic，默认创建的队列数
defaultTopicQueueNums=4
# 是否允许 Broker 自动创建 Topic，建议线下开启，线上关闭 ！！！这里仔细看是 false，false，false
autoCreateTopicEnable=true
# 是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭
autoCreateSubscriptionGroup=true
# Broker 对外服务的监听端口
listenPort=10911
# 删除文件时间点，默认凌晨4点
deleteWhen=04
# 文件保留时间，默认48小时
fileReservedTime=120
# commitLog 每个文件的大小默认1G
mapedFileSizeCommitLog=1073741824
# ConsumeQueue 每个文件默认存 30W 条，根据业务情况调整
mapedFileSizeConsumeQueue=300000
# destroyMapedFileIntervalForcibly=120000
# redeleteHangedFileInterval=120000
# 检测物理文件磁盘空间
diskMaxUsedSpaceRatio=88
# 存储路径
# storePathRootDir=/home/ztztdata/rocketmq-all-4.1.0-incubating/store
# commitLog 存储路径
# storePathCommitLog=/home/ztztdata/rocketmq-all-4.1.0-incubating/store/commitlog
# 消费队列存储
# storePathConsumeQueue=/home/ztztdata/rocketmq-all-4.1.0-incubating/store/consumequeue
# 消息索引存储路径
# storePathIndex=/home/ztztdata/rocketmq-all-4.1.0-incubating/store/index
# checkpoint 文件存储路径
# storeCheckpoint=/home/ztztdata/rocketmq-all-4.1.0-incubating/store/checkpoint
# abort 文件存储路径
# abortFile=/home/ztztdata/rocketmq-all-4.1.0-incubating/store/abort
# 限制的消息大小
maxMessageSize=65536
# flushCommitLogLeastPages=4
# flushConsumeQueueLeastPages=2
# flushCommitLogThoroughInterval=10000
# flushConsumeQueueThoroughInterval=60000
# Broker 的角色
# - ASYNC_MASTER 异步复制Master
# - SYNC_MASTER 同步双写Master
# - SLAVE
brokerRole=ASYNC_MASTER
# 刷盘方式
# - ASYNC_FLUSH 异步刷盘
# - SYNC_FLUSH 同步刷盘
flushDiskType=ASYNC_FLUSH
# 发消息线程池数量
# sendMessageThreadPoolNums=128
# 拉消息线程池数量
# pullMessageThreadPoolNums=128

（6）构建broker容器并启动
刚刚我们已经创建了broker的挂载目录和配置文件，此时准备工作就已经完成，可以执行一下命令启动broker容器：

docker run -d --restart=always --name rmqbroker01  --link rmqnamesrv:namesrv -p 10911:10911 -p 10909:10909  -v /data/broker/logs:/root/logs -v /data/broker/store:/root/store  -v  /data/broker/conf/broker.conf:/opt/rocketmq-4.4.0/conf/broker.conf  -e "NAMESRV_ADDR=namesrv:9876"  -e "MAX_POSSIBLE_HEAP=200000000"  rocketmqinc/rocketmq sh mqbroker -c /opt/rocketmq-4.4.0/conf/broker.conf

通过docker ps可以看到nameserver和broker都已经启动成功，此时rocketmq已经安装完成。如果您需要一个可视化界面查看信息，可以再安装一个rocketmq-console。
在这里插入图片描述

二、rocketmq-console可视化界面

（1）拉取rocketmq-console镜像

docker pull pangliang/rocketmq-console-ng

（2）构建rocketmq-console容器并启动

docker run -d --restart=always --name rmqadmin -e "JAVA_OPTS=-Drocketmq.namesrv.addr=124.71.8.46:9876 -Dcom.rocketmqsendMessageWithVIPChannel=false"  -p 9999:8080  pangliang/rocketmq-console-ng

请将一下信息Drocketmq.namesrv.addr后面的IP地址改为您的nameserver IP地址！！！Drocketmq.namesrv.addr后面的IP地址改为您的nameserver IP地址！！！
（3）通过访问9999端口查看rocketmq-console是否启动成功
在这里插入图片描述
在这里插入图片描述

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.hqwc.cn/news/479126.html

如若内容造成侵权/违法违规/事实不符，请联系编程知识网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

什么软件可以保护公司办公终端 \ 电脑的文件数据、资料不被外泄？

什么软件可以保护公司办公终端 \ 电脑的文件数据、资料不被外泄？

天锐绿盾终端安全管理系统&#xff1a;这是一款综合性的安全软件&#xff0c;提供了文件加密、图纸加密、文档加密、源代码防泄密等多种智能透明加密功能&#xff0c;操作简单易用。 PC端&#xff1a;https://isite.baidu.com/site/wjz012xr/2eae091d-1b97-4276-90bc-6757c5dfe…
阅读更多...
Mysql事务原理与优化

Mysql事务原理与优化

概述 我们的数据库一般都会并发执行多个事务&#xff0c;多个事务可能会并发的对相同的一批数据进行增删改查操作&#xff0c;可能就会导致我们说的脏写、脏读、不可重复读、幻读这些问题。 这些问题的本质都是数据库的多事务并发问题&#xff0c;为了解决多事务并发问题&…
阅读更多...
C语言—指针(3)

C语言—指针(3)

嘿嘿嘿嘿&#xff0c;你看我像指针吗? 不会写&#xff0c;等我啥时候会写了再说吧&#xff0c;真的累了&#xff0c;倦了 1.面试题 1&#xff09;定义整形变量i&#xff1b; 2&#xff09;p为指向整形变量的指针变量&#xff1b; 3&#xff09;定…
阅读更多...
Atcoder ABC340 C - Divide and Divide

Atcoder ABC340 C - Divide and Divide

Divide and Divide&#xff08;分而治之&#xff09; 时间限制&#xff1a;2s 内存限制&#xff1a;1024MB 【原题地址】 所有图片源自Atcoder&#xff0c;题目译文源自脚本Atcoder Better! 点击此处跳转至原题 【问题描述】 【输入格式】 【输出格式】 【样例1】 【样例…
阅读更多...
微信小程序-绑定数据并在后台获取它

微信小程序-绑定数据并在后台获取它

如图 遍历列表的过程中需要绑定数据&#xff0c;点击时候需要绑定数据 这里是源代码 <block wx:for"{{productList}}" wx:key"productId"><view class"product-item" bindtap"handleProductClick" data-product-id"{{i…
阅读更多...
Uniapp-开发小程序

Uniapp-开发小程序

文章目录 前言一、npm run xxx —— cross-env: Permission denied解决方法&#xff08;亲测有效&#xff09;其他解决方法&#xff1a; 二、macOS 微信开发者工具选择uniapp 用 vscode 开发 总结 前言 macOS下 uniapp 开发小程序。 一、npm run xxx —— cross-env: Permissi…
阅读更多...
ACE的MPC编译

ACE的MPC编译

如下需要下载已经生成好的工程&#xff0c;链接如下: Releases DOCGroup/ACE_TAO GitHub 步骤1 下载ACE:ACE 下载MPC:MPC 下载perl并安装&#xff1a;perl 注意&#xff1a;perl安装中勾选将perl路径添加到path环境变更中&#xff0c;安装完后重启 解压ACE后路径如下:…
阅读更多...
突破百度地图Web API的配额限制，实现接口调用自由！

突破百度地图Web API的配额限制，实现接口调用自由！

声明 本文章中所有内容仅供学习交流，抓包内容、敏感网址、数据接口均已做脱敏处理，严禁用于商业用途和非法用途，否则由此产生的一切后果均与作者无关，若有侵权，请联系我立即删除！ 引言 好久没用百度地图开放平台，最近发现平台调整了接口调用的策略，增加了实名认证，…
阅读更多...
JAVA高并发——人手一支笔:ThreadLocal

JAVA高并发——人手一支笔:ThreadLocal

文章目录 1、ThreadLocal的简单使用2、ThreadLocal的实现原理3、对性能有何帮助4、线程私有的随机数发生器ThreadLocalRandom4.1、反射的高效替代方案4.2、随机数种子4.3、探针Probe的作用 除了控制资源的访问&#xff0c;我们还可以通过增加资源来保证所有对象的线程安全。比如…
阅读更多...
从低像素到高清晰，批量提升TIFF图片像素，高效管理图片库

从低像素到高清晰，批量提升TIFF图片像素，高效管理图片库

你是否曾经因为手中持有的TIFF图片像素过低&#xff0c;而无法展现出其应有的魅力而苦恼&#xff1f;在数字化时代&#xff0c;像素就是图像的生命力&#xff0c;而一张低像素的TIFF图片往往无法满足我们日益增长的视觉需求。 第一步&#xff0c;首先我们要进入首助剪辑高手主页…
阅读更多...
基于SSM的在线教学质量评价系统（有报告）。Javaee项目。ssm项目。

基于SSM的在线教学质量评价系统（有报告）。Javaee项目。ssm项目。

演示视频&#xff1a; 基于SSM的在线教学质量评价系统&#xff08;有报告&#xff09;。Javaee项目。ssm项目。 项目介绍&#xff1a; 采用M&#xff08;model&#xff09;V&#xff08;view&#xff09;C&#xff08;controller&#xff09;三层体系结构&#xff0c;通过Spri…
阅读更多...
04 Aras Innovator二次开发-客户端方法

04 Aras Innovator二次开发-客户端方法

客户端方法为JS方法。 系统提供了很多触发点&#xff0c;可以嵌入客户端方法&#xff0c;如下&#xff1a; 1 对象类的客户端事件页签&#xff1a; 2 窗体的Form Event和Filed Event 3.关系类的网格事件&#xff1a; 4 属性事件&#xff1a; 5.可自定义Action,触发客户端事件…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023