Young Kbt blog Young Kbt blog
首页
  • java基础

    • Java基础
    • Java集合
    • Java反射
    • JavaJUC
    • JavaJVM
  • Java容器

    • JavaWeb
  • Java版本新特性

    • Java新特性
  • SQL 数据库

    • MySQL
    • Oracle
  • NoSQL 数据库

    • Redis
    • ElasticSearch
  • 数据库

    • MyBatis
    • MyBatis-Plus
  • 消息中间件

    • ActiveMQ
    • RabbitMQ
    • RocketMQ
    • Kafka
  • 进阶服务

    • Nginx
  • Spring
  • Spring Boot
  • Spring Security
  • 设计模式
  • 算法
  • 知识
  • 管理

    • Maven
    • Git
  • 部署

    • Linux
    • Docker
    • Jenkins
    • Kubernetes
  • 进阶

    • TypeScript
  • 框架

    • React
    • Vue2
    • Vue3
  • 轮子工具
  • 项目工程
  • 友情链接
  • 本站

    • 分类
    • 标签
    • 归档
  • 我的

    • 收藏
    • 关于
    • Vue2-Admin (opens new window)
    • Vue3-Admin(完善) (opens new window)
GitHub (opens new window)

Shp Liu

朝圣的使徒,正在走向编程的至高殿堂!
首页
  • java基础

    • Java基础
    • Java集合
    • Java反射
    • JavaJUC
    • JavaJVM
  • Java容器

    • JavaWeb
  • Java版本新特性

    • Java新特性
  • SQL 数据库

    • MySQL
    • Oracle
  • NoSQL 数据库

    • Redis
    • ElasticSearch
  • 数据库

    • MyBatis
    • MyBatis-Plus
  • 消息中间件

    • ActiveMQ
    • RabbitMQ
    • RocketMQ
    • Kafka
  • 进阶服务

    • Nginx
  • Spring
  • Spring Boot
  • Spring Security
  • 设计模式
  • 算法
  • 知识
  • 管理

    • Maven
    • Git
  • 部署

    • Linux
    • Docker
    • Jenkins
    • Kubernetes
  • 进阶

    • TypeScript
  • 框架

    • React
    • Vue2
    • Vue3
  • 轮子工具
  • 项目工程
  • 友情链接
  • 本站

    • 分类
    • 标签
    • 归档
  • 我的

    • 收藏
    • 关于
    • Vue2-Admin (opens new window)
    • Vue3-Admin(完善) (opens new window)
GitHub (opens new window)
  • MyBatis

  • MyBatis-Plus

  • 中间件 - ActiveMQ

  • 中间件 - RabbitMQ

  • 中间件 - RocketMQ

    • RocketMQ - 介绍
    • RocketMQ - 安装
      • Docker 安装
        • 安装 NameServer
        • 安装 Broker
        • 安装可视化控制台
    • RocketMQ - 消息示例
    • RocketMQ - SpringBoot
    • RocketMQ - 核心概念
    • RocketMQ - 消息存储机制
    • RocketMQ - 集群核心概念
  • 中间件 - Kafka

  • 高性能服务器 - Nginx

  • 响应式框架 - Reactor

  • 框架
  • 中间件 - RocketMQ
Young Kbt
2023-10-14
目录

RocketMQ - 安装

  • Docker 安装
    • 安装 NameServer
    • 安装 Broker
    • 安装可视化控制台

# Docker 安装

# 安装 NameServer

mkdir /docker/rocketmq/nameserver/logs
mkdir /docker/rocketmq/nameserver/store

docker pull rocketmqinc/rocketmq:latest

docker run -d -p 9876:9876 \
--restart=always \
--name rmqnamesrv \
-v /docker/rocketmq/nameserver/logs:/root/logs \
-v /docker/rocketmq/nameserver/store:/root/store \
-e "MAX_POSSIBLE_HEAP=100000000" \
rocketmqinc/rocketmq:latest \
sh mqnamesrv
1
2
3
4
5
6
7
8
9
10
11
12
13

# 安装 Broker

创建 broker.conf 文件:

# broker集群名称
brokerClusterNam = DefaultCluster
# broker节点名称
brokerName = broker-a
# broker节点id
brokerId = 0
# 删除条件?这个还不清楚用途,后续研究下
deleteWhen = 04
# 文件保留时间(单位小时),默认为3天
fileReservedTime = 48
# broker角色
brokerRole = ASYNC_MASTER
# 磁盘同步方式:同步,异步
flushDiskType = ASYNC_FLUSH
# 当前broker监听的IP(主)
brokerIP1 = 192.168.199.32
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
# 创建数据卷
mkdir /docker/rocketmq/broker/logs
mkdir /docker/rocketmq/broker/store
mkdir /docker/rocketmq/broker/conf/

vi /docker/rocketmq/broker/conf/broker.conf

# -- 文件内容 开始 --
# broker集群名称
brokerClusterNam = DefaultCluster
# broker节点名称
brokerName = broker-a
# broker节点id
brokerId = 0
# 删除条件?这个还不清楚用途,后续研究下
deleteWhen = 04
# 文件保留时间(单位小时),默认为3天
fileReservedTime = 48
# broker角色
brokerRole = ASYNC_MASTER
# 磁盘同步方式:同步,异步
flushDiskType = ASYNC_FLUSH
# 当前broker监听的IP(主)
brokerIP1 = 192.168.199.32
# -- 文件内容 结束 --


docker pull rocketmqinc/rocketmq:latest

# 启动项目
docker run -d --name rmqbroker \
--restart=always \
-p 10911:10911 -p 10909:10909 \
--link rmqnamesrv:namesrv \
-e "NAMESRV_ADDR=namesrv:9876" \
-v /docker/rocketmq/broker/logs:/root/logs \
-v /docker/rocketmq/broker/store:/root/store \
-v /docker/rocketmq/broker/conf/broker.conf:/opt/rocketmq/conf/broker.conf \
-e "MAX_POSSIBLE_HEAP=200000000" \
rocketmqinc/rocketmq:latest \
sh mqbroker -c /opt/rocketmq/conf/broker.conf
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41

# 安装可视化控制台

docker pull docker pull rocketmqinc/rocketmq:latest


docker run  -d --name rocketmq-console \
--restart=always \
-p 8000:8080 \
-e "JAVA_OPTS=-Drocketmq.config.namesrvAddr=192.168.199.32:9876 -Drocketmq.config.isVIPChannel=false" \
-t styletang/rocketmq-console-ng
1
2
3
4
5
6
7
8

其中 -Drocketmq.config.namesrvAddr 指定为自己服务器的 IP + RocketMQ 端口(部署 RocketMQ 的服务器 IP + RocketMQ 端口)

最后访问可视化控制台:http://192.168.199.32:9876。

编辑此页 (opens new window)
#RocketMQ
更新时间: 2023/10/23, 10:58:52
RocketMQ - 介绍
RocketMQ - 消息示例

← RocketMQ - 介绍 RocketMQ - 消息示例→

最近更新
01
技术随笔 - Element Plus 修改包名 原创
11-02
02
Reactor - 扩展性
11-02
03
Reactor - 最佳实践
11-02
更多文章>
Theme by Vdoing | Copyright © 2021-2024 Young Kbt | blog
桂ICP备2021009994号
  • 跟随系统
  • 浅色模式
  • 深色模式
  • 阅读模式