[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/
在这里插入图片描述

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

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

【HarmonyOS4学习笔记】《HarmonyOS4+NEXT星河版入门到企业级实战教程》课程学习笔记（一）

【HarmonyOS4学习笔记】《HarmonyOS4+NEXT星河版入门到企业级实战教程》课程学习笔记（一）

课程地址： 黑马程序员HarmonyOS4NEXT星河版入门到企业级实战教程，一套精通鸿蒙应用开发 （本篇笔记对应课程第 1 - 2节） P1《课程介绍》 开场白，HarmonyOS 的一个简介，话不多说，直接看图吧&…
阅读更多...
【算法一则】【贪心】数组中的数可以拼装成的最大数

【算法一则】【贪心】数组中的数可以拼装成的最大数

题目 给定一组非负整数 nums，重新排列每个数的顺序（每个数不可拆分）使之组成一个最大的整数。 注意：输出结果可能非常大，所以你需要返回一个字符串而不是整数。 示例 1： 输入：nums [10,2] …
阅读更多...
基于canal监听MySQL binlog实现数据增量同步

基于canal监听MySQL binlog实现数据增量同步

一、背景 业务反馈客服消息列表查询速度慢，有时候甚至要差不多20秒，急需优化提升速度。 二、方案 引入 首先，体验系统，发现查询慢的正是消息列表查询接口。 接着去看代码的设计，流程比较长，但从代码逻…
阅读更多...
应用监控(Prometheus + Grafana)

应用监控(Prometheus + Grafana)

可用于应用监控的系统有很多，有的需要埋点(切面)、有的需要配置Agent(字节码增强)。本节我教大家另外一个监控系统的使用 —— Grafana。 Grafana 监控面板 这套监控主要用到了 SpringBoot Actuator Prometheus Grafana 三个模块组合的起来使用的监控。非常轻量好…
阅读更多...
第一个大型汽车ITU-T车载语音通话质量实验室投入使用

第一个大型汽车ITU-T车载语音通话质量实验室投入使用

中国汽车行业蓬勃发展，尤其是新能源汽车风起云涌，无论是国内还是海外需求旺盛的趋势下，除乘用车等紧凑型车外，中型汽车如MPV、小巴、小型物流车，大型汽车如重卡、泥头车等亦加入了手机互联、智驾的科技行列&#xff0c…
阅读更多...
机器人-轨迹规划

机器人-轨迹规划

旋转矩阵 旋转矩阵--R--一个3*3的矩阵，其每列的值时B坐标系在A坐标系上的投影值。 代表B坐标系相对于A坐标系的姿态。 旋转矩阵的转置矩阵 其实A相对于B的旋转矩阵就相当于把B的列放到行上就行。 视频 （将矩阵的行列互换得到的新矩阵称为转置矩阵。&…
阅读更多...
基于__torch_dispatch__机制的dump方法

基于__torch_dispatch__机制的dump方法

基于__torch_dispatch__机制的dump方法 1.参考链接2.原理3.代码4.效果 之前拦截torch和torch.Tensor的办法,在处理backward时,不能看到aten算子的细节.以下基于__torch_dispatch__机制的方案更节约代码,且能看到调用栈 1.参考链接 [原理] (https://dev-discuss.pytorch.org/t…
阅读更多...
matlab学习005-利用matlab设计滤波器

matlab学习005-利用matlab设计滤波器

目录 一，含有多个频率成分的三角信号 1，以采样频率fs20KHz对信号采样， 画出信号的波形； 1）前期基础 2）波形图 3）代码 2，选取合适的采样点数，利用DFT分析信号的…
阅读更多...
FPGA 以太网通信UDP通信环回

FPGA 以太网通信UDP通信环回

1 实验任务 上位机通过网口调试助手发送数据给 FPGA ， FPGA 通过 PL 端以太网接口接收数据并将接收到的数据发送给上位机，完成以太网 UDP 数据的环回。 2 系统设计 系统时钟经过PLL时钟模块后，生成了两种不同频率和相位的时钟信号&#…
阅读更多...
基于SpringBoot+VueHome F家居系统的设计与实现

基于SpringBoot+VueHome F家居系统的设计与实现

系统介绍 该Home F家居系统采用B/S架构、前后端分离以及MVC模型进行设计，并采用Java语言以及SpringBoot框架进行开发。本系统主要设计并完成了用户注册、登录，购买家具过程、个人信息修改等，商家添加家具信息、对家具进行发货，管理…
阅读更多...
缓解程序员工作压力：从心理健康到社交网络

缓解程序员工作压力：从心理健康到社交网络

缓解程序员工作压力：从心理健康到社交网络 缓解程序员工作压力：从心理健康到社交网络摘要引言工作与休息的平衡制定有效的工作计划定时休息和放松 心理健康与自我关怀培养良好的生活习惯寻找心灵的慰藉 社交与网络建设加入专业社区和论坛建立良好的同事关…
阅读更多...
【静态分析】静态分析笔记09 - 污点分析

【静态分析】静态分析笔记09 - 污点分析

参考： 【课程笔记】南大软件分析课程—16课时完整版 - 知乎 ------------------------------------------------------------------------------- 1. 信息流安全 访问控制：关注信息访问。 信息流安全：关注信息传播。 信息流&#xff1a…
阅读更多...
自己搭建的大疆无人机RTMP流媒体服务延迟太大

自己搭建的大疆无人机RTMP流媒体服务延迟太大

流程：无人机摄像头->图传->遥控器->流媒体服务器->取流播放，延迟有10秒来的，大家有没有什么好的方案。
阅读更多...
【介绍下有那些常见的ssh功能】

【介绍下有那些常见的ssh功能】

🎥博主：程序员不想YY啊 💫CSDN优质创作者，CSDN实力新星，CSDN博客专家 🤗点赞🎈收藏⭐再看💫养成习惯 ✨希望本文对您有所裨益，如有不足之处，欢迎在评论区提出…
阅读更多...
python作业 切片逆转

python作业 切片逆转

题目： （反转显示一个整数）编写下面的函数，反向显示一个整数。 列如：reserse(3456)。编写一个测试程序，提示用户输入一个整数，然后显示它的反向数。 第一步定义一个函数： def rev…
阅读更多...
Linux进程概念（六）：进程控制

Linux进程概念（六）：进程控制

目录 进程创建 fork函数 进程终止 终止时干了什么 进程终止的三种情况 main函数的返回值 打印默认退出码 自定义退出码 总结 进程终止 exit函数 _exit函数 exit和_exit的区别 进程等待 什么是进程等待 为什么要有进程等待 wait函数 waitpid函数 阻塞等待与…
阅读更多...
【前端开发基础知识快速入门】

【前端开发基础知识快速入门】

前端开发基础知识&快速入门 一、VSCode 使用1.1 安装常用插件1.2 创建项目1.3 创建网页1.4 运行效果二、ES62.1 简介2.2 什么是 ECMAScript2.3 ES6 新特性2.3.1 let 声明变量2.3.2 const 声明常量（只读变量）2.3.3 解构表达式2.3.4 字符串扩展2.3.5 函数优化2.3.6 对象优化…
阅读更多...
开发日志（20240422）：一次以为是跨域但并不是跨域的问题排查记录

开发日志（20240422）：一次以为是跨域但并不是跨域的问题排查记录

1. 日志 在前后端联调的时候，遇到了报错，如下图所示（现在再看感觉非常简单了），发现前一个请求通过了，但是第二个请求报错，然后看到 strict-origin-when-cross-origin 条件反射的认为是跨域配置…
阅读更多...
流量网关与服务网关的区别：（面试题，掌握）

流量网关与服务网关的区别：（面试题，掌握）

流量网关：（如Nignx，OpenResty，Kong）是指提供全局性的、与后端业务应用无关的策略，例如 HTTPS证书认证、Web防火墙、全局流量监控，黑白名单等。 服务网关：（如Spring Clou…
阅读更多...
初步认识Java

初步认识Java

Java之父 Java 语言源于 1991 年 4 月，Sun 公司 James Gosling博士 领导的绿色计划(Green Project) 开始启动，此计划最初的目标是开发一种能够在各种消费性电子产品(如机顶盒、冰箱、收音机等)上运行的程序架构。这个就是Java的前身： Oak (得…
阅读更多...
最新文章

Copyright @ 2022~2023