[RocketMq：基于容器化]：快速部署安装

文章目录

  • 一：相关镜像准备：RocketNameServer
    • 1.1：查看相关镜像和版本
    • 1.2：拉取镜像
    • 1.3：配置和运行RocketNameServer容器
  • 二：相关镜像准备：RocketBroker
    • 2.1：创建配置目录和broker配置文件
    • 2.2：运行rocketBroker容器
  • 三：准备rocketmq控制台
    • 3.1：拉取镜像运行容器
    • 3.2：打开控制台

一：相关镜像准备：RocketNameServer

1.1：查看相关镜像和版本

[root@sv-slaver-one ~]# docker search apache/rocketmq
NAME                       DESCRIPTION                STARS     OFFICIAL
apache/rocketmq                                       115
apache/rocketmq-ci                                    0
apache/rocketmq-operator   Apache RocketMQ Operator   0
apache/rocketmq-exporter   Apache RocketMQ Exporter   0
[root@sv-slaver-one ~]# docker images apache/rocketmq
REPOSITORY   TAG       IMAGE ID   CREATED   SIZE
[root@sv-slaver-one ~]# docker search rocketmq
NAME                                 DESCRIPTION                                      STARS     OFFICIAL
apache/rocketmq                                                                       115
apache/rocketmq-ci                                                                    0
apache/rocketmq-operator             Apache RocketMQ Operator                         0
apache/rocketmq-exporter             Apache RocketMQ Exporter                         0
vulhub/rocketmq                                                                       0
rocketmqinc/rocketmq-broker          Customized RocketMQ Broker Image for RocketM…   14
rocketmqinc/rocketmq                 Image repository for Apache RocketMQ             58
rocketmqinc/rocketmq-namesrv         Customized RocketMQ Name Server Image for Ro…   9
xuchengen/rocketmq                   单机版Apache RocketMQ方便开发者一键部署开发…    58
apacherocketmq/rocketmq-broker       Apache RocketMQ docker image for broker.         12
foxiswho/rocketmq                    rocketmq                                         94
styletang/rocketmq-console-ng        rocketmq-console-ng                              45
apacherocketmq/rocketmq-operator     RocketMQ Operator is to manage RocketMQ serv…   3
rocketmqinc/rocketmq-operator        The Kubernetes operator for RocketMQ             0
apacherocketmq/rocketmq-nameserver   Apache RocketMQ docker image for name server.    6
apacherocketmq/rocketmq              Docker Image for Apache RocketMQ                 23
apacherocketmq/rocketmq-dashboard    Docker Image for Apache RocketMQ Dashboard       21
pureinsights/rocketmq-broker                                                          0
apacherocketmq/rocketmq-console      This repo has moved to rocketmq-dashboard, w…   10
king019/rocketmq                     rocketmq                                         10
pangliang/rocketmq-console-ng        Deprecated  use apacherocketmq/rocketmq-dash…   4
aaronai/rocketmq-proxy-it                                                             0
dyrnq/rocketmq                       This is a rocketmq docker image based AdoptO…   3
aiyowei/rocketmq-exporter                                                             0
slpcat/rocketmq-exporter             https://github.com/slpcat/docker-images/tree…   1

1.2：拉取镜像

[root@sv-slaver-one ~]# docker pull rocketmqinc/rocketmq
Using default tag: latest
latest: Pulling from rocketmqinc/rocketmq

1.3：配置和运行RocketNameServer容器

准备本地挂载目录配置：
mkdir -p /usr/local/docker/local/rocket/data/conf
mkdir -p /usr/local/docker/local/rocket/data/store
mkdir -p /usr/local/docker/local/rocket/data/logs
运行容器

docker run -d \
--name rmqnamesrv \
-p 9876:9876 \
-v /usr/local/docker/local/rocket/data/conf:/root/conf \
-v /usr/local/docker/local/rocket/data/store:/root/store \
-v /usr/local/docker/local/rocket/data/logs:/root/logs \
-e "MAX_POSSIBLE_HEAP=100000000" \
rocketmqinc/rocketmq \
sh mqnamesrv

-e 最大堆内存

[root@sv-slaver-one data]# docker run -d \
> --name rmqnamesrv \
> -p 9876:9876 \
> -v /usr/local/docker/local/rocket/data/conf:/root/conf \
> -v /usr/local/docker/local/rocket/data/store:/root/store \
> -v /usr/local/docker/local/rocket/data/logs:/root/logs \
> -e "MAX_POSSIBLE_HEAP=100000000" \
> rocketmqinc/rocketmq \
> sh mqnamesrv
e6723d36085821b81ce9718159c67560cc2744e92c9e153eb3dbb93d9d02ea08
[root@sv-slaver-one data]# docker ps |grep "rocket"
e6723d360858   rocketmqinc/rocketmq

二：相关镜像准备：RocketBroker

2.1：创建配置目录和broker配置文件

准备broket本地挂载目录和配置
mkdir -p /usr/local/docker/local/rocketbroker/conf
vi /usr/local/docker/local/rocketbroker/conf/broker.conf
mkdir -p /usr/local/docker/local/rocketbroker/logs
mkdir -p /usr/local/docker/local/rocketbroker/store
配置文件broker.conf内容
brokerClusterName = DefaultCluster
brokerName = rocket-broker-master-one

brokerClusterName = DefaultCluster
brokerName = rocket-broker-master-one
# Master=0，slave > 0
brokerId = 0
# 表示几点做消息删除动作，默认是凌晨4点
deleteWhen = 04
# 在磁盘上保留消息的时长，单位是小时
fileReservedTime = 48
# 有三个值：SYNC_MASTER，ASYNC_MASTER，SLAVE；同步和异步表示Master和Slave之间同步数据的机制；
brokerRole = ASYNC_MASTER
# 刷盘策略，取值为：ASYNC_FLUSH，SYNC_FLUSH表示同步刷盘和异步刷盘；SYNC_FLUSH消息写入磁盘后才返回成功状态，ASYNC_FLUSH不需要；
flushDiskType = ASYNC_FLUSH
# 设置broker节点所在服务器的ip地址
brokerIP1 = 192.168.56.8

在这里插入图片描述

2.2：运行rocketBroker容器

docker run -d  \
--name rocketbroker \
--link rmqnamesrv:namesrv \
-p 10911:10911 \
-p 10909:10909 \
-v /usr/local/docker/local/rocketbroker/logs:/root/logs \
-v /usr/local/docker/local/rocketbroker/store:/root/store \
-v /usr/local/docker/local/rocketbroker/conf/broker.conf:/opt/rocketmq/conf/broker.conf \
-e "NAMESRV_ADDR=namesrv:9876" \
-e "MAX_POSSIBLE_HEAP=200000000" \
rocketmqinc/rocketmq \
sh mqbroker -c /opt/rocketmq/conf/broker.conf

[root@sv-slaver-one conf]# docker run -d  --name rocketbroker --link rmqnamesrv:namesrv -p 10911:10911 -p 10909:10909 -v /usr/local/docker/local/rocketbroker/logs:/root/logs -v /usr/local/docker/local/rocketbroker/store:/root/store -v /usr/local/docker/local/rocketbroker/conf/broker.conf:/opt/rocketmq/conf/broker.conf -e "NAMESRV_ADDR=namesrv:9876" -e "MAX_POSSIBLE_HEAP=200000000" rocketmqinc/rocketmq sh mqbroker -c /opt/rocketmq/conf/broker.conf
722e6b6fc41682c4fd0bd4cc7cb273011cc6cda3fece9fa5219d8d19328c1e11
[root@sv-slaver-one conf]# docker ps -a |grep "rocket"
722e6b6fc416   rocketmqinc/rocketmq                                "sh mqbroker -c /opt…"   5 seconds ago    Up 4 seconds               0.0.0.0:10909->10909/tcp, :::10909->10909/tcp, 9876/tcp, 0.0.0.0:10911->10911/tcp, :::10911->10911/tcp   rocketbroker
e6723d360858   rocketmqinc/rocketmq                                "sh mqnamesrv"            56 minutes ago   Up 56 minutes              10909/tcp, 0.0.0.0:9876->9876/tcp, :::9876->9876/tcp, 10911/tcp                                          rmqnamesrv
[root@sv-slaver-one conf]# docker ps -a |grep "rocket"

三：准备rocketmq控制台

3.1：拉取镜像运行容器

docker pull pangliang/rocketmq-console-ng

[root@sv-slaver-one conf]# docker pull pangliang/rocketmq-console-ng
Using default tag: latest
latest: Pulling from pangliang/rocketmq-console-ng

docker run -d
–name rmqadmin
-e “JAVA_OPTS=-Drocketmq.namesrv.addr=192.168.56.8:9876
-Dcom.rocketmq.sendMessageWithVIPChannel=false”
-p 9999:8080
pangliang/rocketmq-console-ng

-> 宿主机端口9999映射到容器内8080端口

[root@sv-slaver-one conf]# docker run -d \
> --name rmqadmin \
> -e "JAVA_OPTS=-Drocketmq.namesrv.addr=192.168.56.8:9876 \
> -Dcom.rocketmq.sendMessageWithVIPChannel=false" \
> -p 9999:8080 \
> pangliang/rocketmq-console-ng
446c1f4b273745cf50d8e9802c81b260a73051a4dd732f5d00fe15a91c086650

3.2：打开控制台

http://192.168.56.8:9999/
在这里插入图片描述

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

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

相关文章

使用docker创建rocketMQ主从结构，使用

使用docker创建rocketMQ主从结构，使用

1、 创建目录 mkdir -p /docker/rocketmq/logs/nameserver-a mkdir -p /docker/rocketmq/logs/nameserver-b mkdir -p /docker/rocketmq/logs/broker-a mkdir -p /docker/rocketmq/logs/broker-b mkdir -p /docker/rocketmq/store/broker-a mkdir -p /docker/rocketmq/store/b…
阅读更多...
计算机网络 -- 多人聊天室

计算机网络 -- 多人聊天室

一 程序介绍和核心功能 这是基于 UDP 协议实现的一个网络程序，主要功能是 构建一个多人聊天室，当某个用户发送消息时，其他用户可以立即收到，形成一个群聊。 这个程序由一台服务器和n个客户端组成，服务器扮演了一个接受…
阅读更多...
vue 实现项目进度甘特图

vue 实现项目进度甘特图

项目需求： 实现以1天、7天、30天为周期（周期根据筛选条件选择），展示每个项目不同里程碑任务进度。 项目在Vue-Gantt-chart: 使用Vue做数据控制的Gantt图表基础上进行了改造。 有需要的小伙伴也可以直接引入插件，自己…
阅读更多...
装饰器模式、代理模式、适配器模式对比

装饰器模式、代理模式、适配器模式对比

装饰器模式、代理模式和适配器模式都是结构型设计模式，它们的主要目标都是将将类或对象按某种布局组成更大的结构，使得程序结构更加清晰。这里将装饰器模式、代理模式和适配器模式进行比较，主要是因为三个设计模式的类图结构相似度较高、且功…
阅读更多...
4-1 STM32C8T6控制OLED显示

4-1 STM32C8T6控制OLED显示

实物接线： #include "stm32f10x.h" // Device header #include "delay.h" #include "LED.h" #include "Key.h" #include "Buzzer.h" #include "Oled.h"int main(void) {OLED_Init()…
阅读更多...
基于SpringBoot实现各省距离Excel导出实战

基于SpringBoot实现各省距离Excel导出实战

目录 前言 一、列表及图表信息展示 1、数据过滤调整 2、信息列表及图表展示 3、Excel写入 二、界面可视化 1、Echarts图表和列表展示 2、城市详情和下载功能设计 三、成果展示 1、图表展示 2、部分城市数据分析 总结 前言 今天是五一黄金周假期第二天，不知…
阅读更多...
搜索引擎的设计与实现参考论文（论文 + 源码）

搜索引擎的设计与实现参考论文（论文 + 源码）

【免费】搜索引擎的设计与实现.zip资源-CSDN文库https://download.csdn.net/download/JW_559/89249705?spm1001.2014.3001.5501 搜索引擎的设计与实现 摘要： 我们处在一个大数据的时代，伴随着网络信息资源的庞大，人们越来越多地注重怎样才能…
阅读更多...
光模块基础概念

光模块基础概念

一:什么是光模块？ 光模块作为光通信中的重要组成部分，是实现光信号传输过程中光电互相转换的光电子器件。 光模块通常由光发射组件、光接收组件、激光器芯片、探测器芯片等部件组成。光模块结构示意图（SFP封装）此图来源于光模块…
阅读更多...
Tensorflow2.0笔记 - ResNet实践

Tensorflow2.0笔记 - ResNet实践

本笔记记录使用ResNet18网络结构，进行CIFAR100数据集的训练和验证。由于参数较多，训练时间会比较长，因此只跑了10个epoch，准确率还没有提升上去。 import os import time import tensorflow as tf from tensorflow import keras …
阅读更多...
自适应医疗决策框架 MDAgents：问题复杂度评估 + 医疗决策 + 多智能体协作

自适应医疗决策框架 MDAgents：问题复杂度评估 + 医疗决策 + 多智能体协作

自适应医疗决策框架 MDAgents：问题复杂度评估 医疗决策 多智能体协作 提出背景MDAgents 拆解解法：MDAgents框架处理医疗问题3.1 查询复杂性评估例子：糖尿病患者的医疗查询 3.2 专家招募3.3 医疗协作与改良3.4 决策制定 分阶段决策1. 问题复…
阅读更多...
【实时数仓架构】方法论

【实时数仓架构】方法论

笔者不是专业的实时数仓架构，这是笔者从其他人经验和网上资料整理而来，仅供参考。写此文章意义，加深对实时数仓理解。 一、实时数仓架构技术演进 1.1 四种架构演进 1）离线大数据架构 一种批处理离线数据分析架构，…
阅读更多...
目标检测算法YOLOv3简介

目标检测算法YOLOv3简介

YOLOv3由Joseph Redmon等人于2018年提出，论文名为：《YOLOv3: An Incremental Improvement》，论文见：https://arxiv.org/pdf/1804.02767.pdf ，项目网页：https://pjreddie.com/darknet/yolo/ 。YOLOv3是对YOL…
阅读更多...
leetcode870.优势洗牌

leetcode870.优势洗牌

题目描述： 给定两个长度相等的数组 nums1 和 nums2，nums1 相对于 nums2 的优势可以用满足 nums1[i] > nums2[i] 的索引 i 的数目来描述。 返回 nums1 的任意排列，使其相对于 nums2 的优势最大化。 示例一： 输入&#xff…
阅读更多...
BIO、NIO与AIO

BIO、NIO与AIO

文章目录 一 BIO同步阻塞案例BIO模式消息多发多收实现 二 NIONIO核心组件Buffer(缓冲区)Buffer常见方法缓冲区的数据操作直接内存与非直接内存 Channel(通道)channel常用操作 Selector(选择器)selector选择器处理流程NIO非阻塞式网络通信原理分析 NIO网络编程实现群聊系统服务端…
阅读更多...
Acrobat Pro DC 2023：专业PDF编辑软件，引领高效办公新时代

Acrobat Pro DC 2023：专业PDF编辑软件，引领高效办公新时代

Acrobat Pro DC 2023是一款专为Mac和Windows用户设计的专业PDF编辑软件，凭借其强大的功能和卓越的性能，成为现代职场人士不可或缺的得力助手。 这款软件拥有出色的PDF编辑能力。用户不仅可以轻松地对PDF文档中的文字、图片和布局进行编辑和调整&#xf…
阅读更多...
【C++】哈希的应用---位图

【C++】哈希的应用---位图

目录 1、引入 2、位图的概念 3、位图的实现 ①框架的搭建 ②设置存在 ③设置不存在 ④检查存在 ​4、位图计算出现的次数 5、完整代码 1、引入 我们可以看一道面试题 给40亿个不重复的无符号整数，没排过序。给一个无符号整数，如何快速判断一个数…
阅读更多...
菜鸡学习netty源码（一）——ServerBootStrap启动

菜鸡学习netty源码（一）——ServerBootStrap启动

1.概述 对于初学者而然，写一个netty本地进行测试的Server端和Client端，我们最先接触到的类就是ServerBootstrap和Bootstrap。这两个类都有一个公共的父类就是AbstractBootstrap. 那既然 ServerBootstrap和Bootstrap都有一个公共的分类，那就证明它们两个肯定有很多公共的职…
阅读更多...
树莓派4B安装安卓系统LineageOS 21（Android14）

树莓派4B安装安卓系统LineageOS 21（Android14）

1：系统下载 2：下载好镜像后，准备写入SD卡，我这边使用的是 balenaetcher 3：插入树莓派，按照指示一步一步进行配置，可以配置时区，语言。 注意点 1》:想返回的时候按F2 2》:进入系统…
阅读更多...
基于springboot实现中药实验管理系统设计项目【项目源码+论文说明】计算机毕业设计

基于springboot实现中药实验管理系统设计项目【项目源码+论文说明】计算机毕业设计

基于springboot实现中药实验管理系统设计演示 摘要 随着信息技术在管理上越来越深入而广泛的应用，管理信息系统的实施在技术上已逐步成熟。本文介绍了中药实验管理系统的开发全过程。通过分析中药实验管理系统管理的不足，创建了一个计算机管理中药实验管…
阅读更多...
AI视频教程下载：用ChatGPT提示词开发AI应用和GPTs

AI视频教程下载：用ChatGPT提示词开发AI应用和GPTs

在这个课程中，你将深入ChatGPT的迷人世界，学习如何利用其能力构建创新和有影响力的工具。你将发现如何创建不仅吸引而且保持用户参与度的应用程序，将流量驱动到你的网站，并开辟新的货币化途径。 **课程的主要特点：** …
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023