centos7 install rocketmq 宿主机快速搭建RocketMQ单机开发环境

为什么采用宿主机而不采用 Docker 方式快速搭建

在搭建 RocketMQ 测试环境时，我们可以选择在宿主机上直接安装和配置，也可以使用 Docker 容器来快速搭建。然而，为什么我们选择了在宿主机上安装而不是使用 Docker 方式呢？

  1. 调整配置的灵活性：在 Docker 方式下，虽然可以使用环境变量来设置配置项，但是有时候需要对容器内部的配置文件进行修改，（默认RocketMQ broker 吃内存8个G电脑配置差docker更本起不来）这可能不太方便。在宿主机上直接安装，则可以直接编辑配置文件，更加灵活地调整配置。

  2. 调试和排查问题的方便性：在宿主机上安装的 RocketMQ 实例，可以直接在宿主机上查看日志、调试程序，更容易排查问题。而在 Docker 容器中，需要通过 Docker logs 命令或者进入容器内部来查看日志，相对来说更加繁琐。

综上所述，虽然 Docker 提供了快速部署和便捷管理的优势，但在某些情况下，直接在宿主机上安装 RocketMQ 可能更加灵活、性能更好，并且更容易调试和排查问题。因此，在选择搭建测试环境时，我们根据实际情况选择了在宿主机上安装 RocketMQ。

第一步：源码下载和安装

wget https://archive.apache.org/dist/rocketmq/4.9.5/rocketmq-all-4.9.5-bin-release.zipunzip rocketmq-all-4.9.5-bin-release.zipmv rocketmq-all-4.9.5-bin-release /app/rocketmq

查看RocketMQ的更多版本链接

第二步：修改初始内存

# 修改初始内存【修改两个启动脚本的jvm】
cd /app/rocketmq/bin/
vim runserver.sh
# 修改初始堆内存大小，要不测试环境没那么多内存 
原：JAVA_OPT="${JAVA_OPT} -server -Xms4g -Xmx4g -Xmn2g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
改：JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn512m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"vim runbroker.sh
# 修改初始堆内存大小，要不测试环境没那么多内存 
原:  JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g"
改:  JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m"

第三步：启动RocketMQ单机

# 启动NameServer，bin目录前台启动，确定没报错再后台启动  【sh bin/mqnamesrv &】
[root@slavenode1 bin]# ./mqnamesrv
The Name Server boot success. serializeType=JSON# 启动broker，bin目录前台启动，确定没报错再后台启动
[root@masternode1 bin]# ./mqbroker -n localhost:9876
The broker[masternode1, 192.168.1.160:10911] boot success. serializeType=JSON and name server is localhost:9876# 查看进程
[root@masternode1 ~]# jps
2214 Jps
2071 BrokerStartup
1947 NamesrvStartup

第四步：发送消息测试

消费着启动

 export NAMESRV_ADDR=localhost:9876./tools.sh org.apache.rocketmq.example.quickstart.Consumer

发送测试消息

 export NAMESRV_ADDR=localhost:9876./tools.sh org.apache.rocketmq.example.quickstart.Producer

第五步：docker控制台搭建rocketmq-dashboard

docker run -d \--name rocketmq-dashboard \-p 8060:8080 \-v /apps/rocketmq-dashboard/data:/tmp/rocketmq-console/data \-e NAMESRV_ADDR=0.0.0.0:9876 \apacherocketmq/rocketmq-dashboard:1.0.0
  1. -v /apps/rocketmq-dashboard/data:/tmp/rocketmq-console/data 参数用于将主机的 /apps/rocketmq-dashboard/data 目录映射到容器的 /tmp/rocketmq-console/data
    目录，这样可以持久化保存 RocketMQ Dashboard 的数据。
  2. -e NAMESRV_ADDR=0.0.0.0:9876 参数用于设置环境变量 NAMESRV_ADDR，指定 RocketMQ 的 Namesrv 地址。
    在这里插入图片描述

第六步：rocketmq-client-go 测试延迟消息

延迟5秒代码测试示例
在这里插入图片描述

consumer.go

package mainimport ("context""fmt""github.com/apache/rocketmq-client-go/v2""github.com/apache/rocketmq-client-go/v2/consumer""github.com/apache/rocketmq-client-go/v2/primitive""os""time"
)func main() {// 设置推送消费者c, _ := rocketmq.NewPushConsumer(//消费组consumer.WithGroupName("testGroup"),// namesrv地址consumer.WithNameServer([]string{"127.0.0.1:9876"}),)// 必须先在 开始前err := c.Subscribe("Topic-test", consumer.MessageSelector{}, func(ctx context.Context, ext ...*primitive.MessageExt) (consumer.ConsumeResult, error) {for i := range ext {// 获取消息正文body := ext[i].Bodyfmt.Printf("获取到值:%s \n", body)}return consumer.ConsumeSuccess, nil})if err != nil {fmt.Println(err.Error())}err = c.Start()if err != nil {fmt.Println(err.Error())os.Exit(-1)}time.Sleep(time.Hour)err = c.Shutdown()if err != nil {fmt.Printf("shutdown Consumer error:%s", err.Error())}
}
export ROCKETMQ_GO_LOG_LEVEL=warn
go run   consumer.go

producer_delay.go


func main() {p, _ := rocketmq.NewProducer(// 设置 nameSrvAddr// nameSrvAddr 是 Topic 路由注册中心producer.WithNameServer([]string{"0.0.0.0:9876"}),// 指定发送失败时的重试时间producer.WithRetry(3),// 设置 Groupproducer.WithGroupName("testGroup"),)// 开始连接err := p.Start()if err != nil {fmt.Printf("start producer error: %s", err.Error())os.Exit(2)}// 设置节点名称topic := "Topic-test"// 循环发送信息 (同步发送)for i := 0; i < 10; i++ {msg := &primitive.Message{Topic: topic,Body:  []byte("RocketMQ Go producer_delay.go [" + strconv.Itoa(i) + "] " + time.Now().Format("2006-01-02 15:04:05")),}time.Sleep(time.Second)// WithDelayTimeLevel set message delay time to consume.// reference delay level definition: 1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h// delay level starts from 1. for example, if we set param level=1, then the delay time is 1s.// 设置消息的延时级别为 2，对应 RocketMQ 配置中的延时时间 5smsg.WithDelayTimeLevel(2)// 发送信息res, err := p.SendSync(context.Background(), msg)if err != nil {fmt.Printf("发送失败！:%s\n", err)} else {fmt.Printf("发送成功 : result=%s\n", res.String())}}// 关闭生产者err = p.Shutdown()if err != nil {fmt.Printf("shutdown producer error:%s", err.Error())}
}

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

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

相关文章

Android14之报错：error:add its name to the whitelist(一百九十四)

Android14之报错：error:add its name to the whitelist(一百九十四)

简介&#xff1a; CSDN博客专家&#xff0c;专注Android/Linux系统&#xff0c;分享多mic语音方案、音视频、编解码等技术&#xff0c;与大家一起成长&#xff01; 优质专栏&#xff1a;Audio工程师进阶系列【原创干货持续更新中……】&#x1f680; 优质专栏&#xff1a;多媒…
阅读更多...
Vue手写模拟步骤条

Vue手写模拟步骤条

效果图&#xff1a; 如果要使用element的步骤条就需要强行修改样式&#xff0c;参考之前的那篇步骤条。这里我采用手写div 代码&#xff1a; 思路是给最外层的div一个左边框&#xff0c;给里面的step-item设置左边框为图片&#xff0c;通过定位来移动。 <div class"m…
阅读更多...
代码训练LeetCode(11)删除有序数组中的重复项II

代码训练LeetCode(11)删除有序数组中的重复项II

代码训练(11)LeetCode之删除有序数组中的重复项II Author: Once Day Date: 2024年3月14日 漫漫长路&#xff0c;才刚刚开始… 全系列文章可参考专栏: 十年代码训练_Once-Day的博客-CSDN博客 参考文章: 80. 删除有序数组中的重复项 II - 力扣&#xff08;LeetCode&#xff…
阅读更多...
【深度学习】diffusers 学习过程记录，StableDiffusion扩散原理

【深度学习】diffusers 学习过程记录，StableDiffusion扩散原理

教程地址&#xff1a;https://huggingface.co/docs/diffusers/quicktour 文章目录 环境扩散模型噪声残差的作用原理&#xff0c;文字编码如何给入Unetschedulerguidance_scalescheduler.init_noise_sigma训练时候的反向传播 环境 python3.10安装环境&#xff1a; pip install…
阅读更多...
CMAKE_CUDA_ARCHITECTURES set to ‘native’多版本与版本号矛盾问题，报错

CMAKE_CUDA_ARCHITECTURES set to ‘native’多版本与版本号矛盾问题，报错

CMAKE_CUDA_ARCHITECTURES set to ‘native’多版本与版本号矛盾问题&#xff0c;报错 1. 报错提醒如下图2. 原因本地安装多个cuda版本导致native寻找到多个版本&#xff0c;导致报错3. 具体配置需要根据你的显卡型号来确认 1. 报错提醒如下图 2. 原因本地安装多个cuda版本导致…
阅读更多...
C++——类和对象（1）

C++——类和对象（1）

1. 面向对象和面向过程对比 当涉及到编程范式时&#xff0c;两个主要的方法是面向对象编程&#xff08;Object-Oriented Programming&#xff0c;OOP&#xff09;和面向过程编程&#xff08;Procedural Programming&#xff09;。这两种编程范式在解决问题和组织代码时有着不同…
阅读更多...
每周一算法：迭代加深搜索

每周一算法：迭代加深搜索

题目链接 加成序列 题目描述 满足如下条件的序列 X X X&#xff08;序列中元素被标号为 1 、 2 、 3 … m 1、2、3…m 1、2、3…m&#xff09;被称为加成序列&#xff1a; X [ 1 ] 1 X[1]1 X[1]1 X [ m ] n X[m]n X[m]n X [ 1 ] < X [ 2 ] < … < X [ m − 1 ]…
阅读更多...
Redis：持久化、线程模型、大 key

Redis：持久化、线程模型、大 key

Redis持久化方式有什么方式&#xff1f; Redis 的读写操作都是在内存中&#xff0c;所以 Redis 性能才会高&#xff0c;但是当 Redis 重启后&#xff0c;内存中的数据就会丢失&#xff0c;那为了保证内存中的数据不会丢失&#xff0c;Redis 实现了数据持久化的机制&#xff0c…
阅读更多...
YOLOV5 部署：QT的可视化界面推理（创建UI，并编译成py文件）

YOLOV5 部署：QT的可视化界面推理（创建UI，并编译成py文件）

1、前言 之前用YOLOV5 做了一个猫和老鼠的实战检测项目，本章将根据之前训练好的权重进行部署，搭建一个基于QT的可视化推理界面，可以检测图片和视频 本章使用的数据集和权重参照：YOLOV5 初体验：简单猫和老鼠数据集模型训练-CSDN博客 可视化界面如下： 2、安装Pyside6 本…
阅读更多...
使用helm部署clickhouse

使用helm部署clickhouse

&#xff08;作者&#xff1a;陈玓玏&#xff09; 前置条件 已安装 Kubernetes 集群&#xff1b; 已安装 Helm 包管理工具。 部署 1 添加 RadonDB ClickHouse 的 Helm 仓库 helm repo add ck https://radondb.github.io/radondb-clickhouse-kubernetes/ helm repo upd…
阅读更多...
Figure与OpenAI 联手推出新机器人；荣耀首款「AI PC」即将发布

Figure与OpenAI 联手推出新机器人；荣耀首款「AI PC」即将发布

▶ Figure 与 OpenAI 联手推出新机器人 AI 机器人公司 Figure 发布了他们与 OpenAI 的合作成果&#xff0c;将 OpenAI 的大模型运用在其机器人 Figure 01 上。 据介绍&#xff0c;OpenAI 大模型加持的 Figure 01 机器人现在可以与人全面对话。 OpenAI 模型为机器人提供了高级…
阅读更多...
git基础命令(一)

git基础命令(一)

目录 基础概念git statusgit addgit diffgit loggit commit文件可以处于以下三种状态之一远程存储库与本地存储库参考 用于知识记录。后续有新的的内容&#xff0c;例子&#xff0c;将持续更新本文档。 基础概念 工作树&#xff1a;git add 之前&#xff0c;变动内容的文件列表…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023