公司名称可以和网站域名不同吗,网站侧栏软件排行榜怎么做的,购买服务器,自己做发卡网站支付接口为什么采用宿主机而不采用 Docker 方式快速搭建
在搭建 RocketMQ 测试环境时#xff0c;我们可以选择在宿主机上直接安装和配置#xff0c;也可以使用 Docker 容器来快速搭建。然而#xff0c;为什么我们选择了在宿主机上安装而不是使用 Docker 方式呢#xff1f; 调整配置…为什么采用宿主机而不采用 Docker 方式快速搭建
在搭建 RocketMQ 测试环境时我们可以选择在宿主机上直接安装和配置也可以使用 Docker 容器来快速搭建。然而为什么我们选择了在宿主机上安装而不是使用 Docker 方式呢 调整配置的灵活性在 Docker 方式下虽然可以使用环境变量来设置配置项但是有时候需要对容器内部的配置文件进行修改默认RocketMQ broker 吃内存8个G电脑配置差docker更本起不来这可能不太方便。在宿主机上直接安装则可以直接编辑配置文件更加灵活地调整配置。 调试和排查问题的方便性在宿主机上安装的 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:MetaspaceSize128m -XX:MaxMetaspaceSize320m
改JAVA_OPT${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn512m -XX:MetaspaceSize128m -XX:MaxMetaspaceSize320mvim runbroker.sh
# 修改初始堆内存大小要不测试环境没那么多内存
原: JAVA_OPT${JAVA_OPT} -server -Xms8g -Xmx8g
改: JAVA_OPT${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m第三步启动RocketMQ单机
# 启动NameServerbin目录前台启动确定没报错再后台启动 【sh bin/mqnamesrv 】
[rootslavenode1 bin]# ./mqnamesrv
The Name Server boot success. serializeTypeJSON# 启动brokerbin目录前台启动确定没报错再后台启动
[rootmasternode1 bin]# ./mqbroker -n localhost:9876
The broker[masternode1, 192.168.1.160:10911] boot success. serializeTypeJSON and name server is localhost:9876# 查看进程
[rootmasternode1 ~]# jps
2214 Jps
2071 BrokerStartup
1947 NamesrvStartup
第四步发送消息测试
消费着启动 export NAMESRV_ADDRlocalhost:9876./tools.sh org.apache.rocketmq.example.quickstart.Consumer发送测试消息 export NAMESRV_ADDRlocalhost: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_ADDR0.0.0.0:9876 \apacherocketmq/rocketmq-dashboard:1.0.0
-v /apps/rocketmq-dashboard/data:/tmp/rocketmq-console/data 参数用于将主机的 /apps/rocketmq-dashboard/data 目录映射到容器的 /tmp/rocketmq-console/data 目录这样可以持久化保存 RocketMQ Dashboard 的数据。-e NAMESRV_ADDR0.0.0.0:9876 参数用于设置环境变量 NAMESRV_ADDR指定 RocketMQ 的 Namesrv 地址。
第六步rocketmq-client-go 测试延迟消息
延迟5秒代码测试示例
consumer.go
package mainimport (contextfmtgithub.com/apache/rocketmq-client-go/v2github.com/apache/rocketmq-client-go/v2/consumergithub.com/apache/rocketmq-client-go/v2/primitiveostime
)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_LEVELwarn
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 level1, 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())}
}
