www.91084.com

GVKun编程网logo

RocketMQ安装和测试（rocket mq安装）

21

以上就是给各位分享RocketMQ安装和测试，其中也会对rocketmq安装进行解释，同时本文还将给你拓展ApacheRocketMQRocketMQ是什么？消息中间件、CentOS7.4系统安装Ro

以上就是给各位分享RocketMQ安装和测试，其中也会对rocket mq安装进行解释，同时本文还将给你拓展Apache RocketMQ RocketMQ是什么？ 消息中间件、CentOS 7.4 系统安装RocketMQ、RocketMQ-Console、Golang RocketMq安装及简单应用（Mac环境）、linux 下rocketmq安装等相关知识，如果能碰巧解决你现在面临的问题，别忘了关注本站，现在开始吧！

本文目录一览：

RocketMQ安装和测试（rocket mq安装）

RocketMQ安装和测试（rocket mq安装）

一、RocketMQ

1.下载

RocketMQ官网：https://rocketmq.apache.org/
RocketMQ各个版本官网下载地址：https://rocketmq.apache.org/dowloading/releases/
我下载使用的4.3.0的版本：https://archive.apache.org/dist/rocketmq/4.3.0/rocketmq-all-4.3.0-bin-release.zip
下载完成后解压，配置环境变量
按照官网配置

2.配置环境

在这里插入图片描述

ROCKETMQ_HOME="D:\rocketmq"

NAMESRV_ADDR="localhost:9876"

在这里插入图片描述

在这里插入图片描述

3.测试

找到RocketMQ安装的bin目录下进入命令管理窗口（cmd）运行start mqnamesrv.cmd或者双击mqnamesrv.cmd文件，最下面会出现成功标志

在这里插入图片描述

在运行start mqbroker.cmd出现

在这里插入图片描述

二、安装可视化界面

github地址：https://github.com/apache/rocketmq-externals/tree/develop
主要是这个文件

在这里插入图片描述

修改application.properties文件，配置端口号和地址，然后启动项目，或打成jar

在这里插入图片描述

1.启动项目

在这里插入图片描述

2.打成jar

在这里插入图片描述


打开rocketmq-console目录，进入命令面板输入

//跳过测试打包
mvn clean package -Dmaven.test.skip=true
//或者不用调过直接输入下面的也行，有点慢
mvn clean package

然后会出现一个target文件，进入，启动jar

java -jar rocketmq-console-ng-1.0.0.jar

在这里插入图片描述


启动完成后访问：http://127.0.0.1:8080/

在这里插入图片描述

三、测试

两个最好并排放在一起，好看消息发送

bin目录下的命令
消费消息测试：

tools.cmd  org.apache.rocketmq.example.quickstart.Consumer

在这里插入图片描述

然后在打开新的命令面板输入
生产消息：

tools.cmd  org.apache.rocketmq.example.quickstart.Producer

在这里插入图片描述


可视化界面

在这里插入图片描述

总结

以上是小编为你收集整理的RocketMQ安装和测试全部内容。

如果觉得小编网站内容还不错，欢迎将小编网站推荐给好友。

原文地址：https://blog.csdn.net/weixin_45853881/article/details/122713156

Apache RocketMQ RocketMQ是什么？ 消息中间件

Apache RocketMQ RocketMQ是什么？ 消息中间件

Apache RocketMQ RocketMQ是什么？ 介绍

RocketMQ是什么？

RocketMQ
是一款开源的分布式消息系统，基于高可用分布式集群技术，提供低延时的、高可靠的消息发布与订阅服务。同时，广泛应用于多个领域，包括异步通信解耦、企业解决方案、金融支付、电信、电子商务、快递物流、广告营销、社交、即时通信、移动应用、手游、视频、物联网、车联网等。

具有以下特点：

  • 能够保证严格的消息顺序

  • 提供丰富的消息拉取模式

  • 高效的订阅者水平扩展能力

  • 实时的消息订阅机制

  • 亿级消息堆积能力

  • Metaq3.0 版本改名，产品名称改为RocketMQ

Apache RocketMQ RocketMQ是什么？ 官网

https://rocketmq.apache.org/

CentOS 7.4 系统安装RocketMQ、RocketMQ-Console

CentOS 7.4 系统安装RocketMQ、RocketMQ-Console

 

RocketMQ安装

一、使用源码安装
 
1、下载源码 git clone https://github.com/apache/incubator-rocketmq.git
    
2、移动文件至/usr/local/rocketmq
    
3、编译部署
    cd rocketmq
    mvn -Prelease-all -DskipTests clean install -U
        
二、环境变量配置
1、修改/etc/profile文件，使用命令：vim /etc/profile，将如下内容追加到文件末尾
    export ROCKETMQ_HOME=/usr/local/rocketmq/distribution/target/apache-rocketmq
    export PATH=$JAVA_HOME/bin:$ROCKETMQ_HOME/bin:$PATH
    
2、/etc/profile文件修改后，必须刷新才能有效使用，使用指令：
    source /etc/profile
三、修改服务器内存
由于RocketMQ默认配置要求很高，比如内存至少就要4个G，开发调试环境根本吃不消，所以开始启动前需要先修改这些参数。否则的话，会遇到内存分配或者不够的问题。
a)vim /usr/local/rocketmq/distribution/target/apache-rocketmq/bin/tools.sh
 
 
b)vim /usr/local/rocketmq/distribution/target/apache-rocketmq/bin/runbroker.sh
    
c)vim /usr/local/rocketmq/distribution/target/apache-rocketmq/bin/runserver.sh
 
 
四、启动NameServer、Broker
a)指定broker使用IP
  cd /usr/local/rocketmq/distribution/target/apache-rocketmq
 
b)编写配置文件
  echo "brokerIP1=自己的IP地址" > conf/broker.properties
c)启动mqnamesrc
  nohup sh bin/mqnamesrv &
d)启动mrbroker 启动时通过 -c 加载配置文件
  nohup sh bin/mqbroker -n IP地址:9876 -c conf/broker.properties &
e) jps 执行jps查看进程
f)查看日志
tail -f ~/logs/rocketmqlogs/namesrv.log
tail -f ~/logs/rocketmqlogs/broker.log
 
五、发送和接收消息
发送/接收消息之前,需要告诉客户端 NameServer 地址。为简单起见,我们使用环境变量 NAMESRV_ADDR。
export NAMESRV_ADDR=localhost:9876
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
 
六、关闭服务器
1、同样都是在 RocketMQ 安装目录下的  distribution/target/apache-rocketmq 目录下执行命令
2、与启动顺序相反进行关闭，先关闭 broker、在关闭 nameserv
src=

 

常用命令
除了上面几个命令之外，还有如下一些较常用的命令，ip请以实际为准：
查看集群情况： ./mqadmin clusterList -n 127.0.0.1:9876
查看 broker 状态： ./mqadmin brokerStatus -n 127.0.0.1:9876 -b 172.20.1.138:10911
查看 topic 列表： ./mqadmin topicList -n 127.0.0.1:9876
查看 topic 状态： ./mqadmin topicStatus -n 127.0.0.1:9876 -t MyTopic (换成想查询的 topic)
查看 topic 路由： ./mqadmin topicRoute -n 127.0.0.1:9876 -t MyTopic
 
七、RocketMQ-Console安装
1、使用git命令下载项目源码，由于我们仅需要rocketmq-console，故下载此项目对应分支即可。
    git clone -b release-rocketmq-console-1.0.0 https://github.com/apache/rocketmq-externals.git
2、进入项目文件夹并修改配置文件
    cd rocketmq-externals/rocketmq-console/
    vi src/main/resources/application.properties
    
#管理后台访问上下文路径，默认为空，如果填写，一定要前面加“/”，后面不要加，否则启动报错
server.contextPath=/rocketmq
#访问端口
server.port=8080
#spring.application.index=true
spring.application.name=rocketmq-console
spring.http.encoding.charset=UTF-8
spring.http.encoding.enabled=true
spring.http.encoding.force=true
#logback配置文件路径
logging.config=classpath:logback.xml
#if this value is empty,use env value rocketmq.config.namesrvAddr  NAMESRV_ADDR | now, you can set it in ops page.default localhost:9876
#Name Server地址，修改成你自己的服务地址
rocketmq.config.namesrvAddr=10.0.74.198:9876;10.0.74.199:9876
#if you use rocketmq version < 3.5.8, rocketmq.config.isVIPChannel should be false.default true
rocketmq.config.isVIPChannel=
#rocketmq-console''s data path:dashboard/monitor
rocketmq.config.dataPath=/tmp/rocketmq-console/data
#set it false if you don''t want use dashboard.default true
rocketmq.config.enableDashBoardCollect=true
 
3、将项目打成jar包，并运行jar文件。
$ mvn clean package -Dmaven.test.skip=true
 
$ java -jar target/rocketmq-console-ng-1.0.0.jar
 
#如果配置文件没有填写Name Server
$ java -jar target/rocketmq-console-ng-1.0.0.jar --rocketmq.config.namesrvAddr=''10.0.74.198:9876;10.0.74.199:9876''
 
4、启动成功后，访问地址http://localhost:8080/rocketmq, 即可进入管理后台操作。
 
 

Golang RocketMq安装及简单应用（Mac环境）

Golang RocketMq安装及简单应用（Mac环境）

一、下载安装RocketMq

地址：https://rocketmq.apache.org/dowloading/releases/

我选择的是这个二进制版本安装：
image.png

选择一个目录解压，一般情况路径是:/usr/local/bin，下面是我自己的路径是：

image.png

由于RocketMq是纯java编写，确认自己是否有jdk环境，执行如下命令：

cd rocketmq-all-5.0.0-ALPHA-bin-release/bin
./mqnamesrv -n 127.0.0.1:9876
./bin/mqbroker -n 127.0.0.1:9876 -c conf/broker.conf 
autoCreateTopicEnable=true

上述命令尽量按照顺序来执行！

分别打开两个窗口，启动之后分别可以看到如下：
image.png

image.png

二、根据个人需要可以安装RocketMq可视化工具界面：下载链接如下：

https://github.com/apache/rocketmq-dashboard/tree/release-1.0.0

执行如下命令：(确认已安装mvn!)

cd rocketmq-externals-rocketmq-console-1.0.0/rocketmq-console
mvn clean package -Dmaven.test.skip=true

上述命令执行成功后会在rocketmq-externals-rocketmq-console-1.0.0/rocketmq-console下产生一个target文件夹，执行如下命令：

cd target
java -jar rocketmq-console-ng-1.0.0.jar --server.port=8080 --rocketmq.config.namesrvAddr=127.0.0.1:9876

成功界面：
image.png

输入地址：127.0.0.1:8080，显示如下效果：

image.png

三、golang介入
执行如下命令：

go get github.com/apache/rocketmq-client-go/v2
go get github.com/apache/rocketmq-client-go/v2/primitive
go get github.com/apache/rocketmq-client-go/v2/producer

创建main.go文件，下面的例子是同步生产消息机制

package main

import (
    "context"
    "fmt"
    "os"
    "strconv"

    "github.com/apache/rocketmq-client-go/v2"
    "github.com/apache/rocketmq-client-go/v2/primitive"
    "github.com/apache/rocketmq-client-go/v2/producer"
)

func main() {

    p, _ := rocketmq.NewProducer(
        producer.WithNsResolver(primitive.NewPassthroughResolver([]string{"127.0.0.1:9876"})),
        producer.WithRetry(2),
    )
    err := p.Start()
    if err != nil {
        fmt.Printf("start producer error: %s", err.Error())
        os.Exit(1)
    }
    topic := "testmq"

    for i := 0; i < 10; i++ {
        msg := &primitive.Message{
            Topic: topic,
            Body:  []byte("Hello RocketMQ Go Client! " + strconv.Itoa(i)),
        }
        res, err := p.SendSync(context.Background(), msg)

        if err != nil {
            fmt.Printf("send message error: %s\n", err)
        } else {
            fmt.Printf("send message success: result=%s\n", res.String())
        }
    }
    err = p.Shutdown()
    if err != nil {
        fmt.Printf("shutdown producer error: %s", err.Error())
    }
}

执行go run main.go 出现如下的结果：
image.png
查看可视化界面：
image.png

linux 下rocketmq安装

linux 下rocketmq安装

一、解压mq（/data下）
tar -zxvf Rocketmq-3.5.8.tar.gz

二、修改配置文件
vi /etc/profile
export rocketmq=/data/alibaba-rocketmq
export PATH=$PATH:$rocketmq/bin

三、执行配置文件，使之生效
source /etc/profile


四、创建日志目录
cd /data/alibaba-rocketmq

五、修改内存（安装目录下/data/alibaba-rocketmq/bin下）

找到runserver.sh和runbroker.sh并修改参数：

JAVA_OPT=”${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn125m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m

六、启动mqnameserver(安装目录下/data/alibaba-rocketmq)执行

  nohup sh bin/mqnamesrv &

    可通过 tail -f ~/logs/rocketmqlogs/namesrv.log 来查看是否启动成功

七、启动mqbroker(安装目录bin下/data/alibaba-rocketmq)

  nohup sh bin/mqbroker -n localhost:9876 &

    可通过 tail -f ~/logs/rocketmqlogs/broker.log 来查看是否启动成功

注意：localhost可以换成你刚才启动mqnamesrv的ip

八、关闭服务(安装目录下/data/alibaba-rocketmq)执行
关闭namesrv服务：sh bin/mqshutdown namesrv
关闭broker服务 ：sh bin/mqshutdown broker

 

今天的关于RocketMQ安装和测试和rocket mq安装的分享已经结束，谢谢您的关注，如果想了解更多关于Apache RocketMQ RocketMQ是什么？ 消息中间件、CentOS 7.4 系统安装RocketMQ、RocketMQ-Console、Golang RocketMq安装及简单应用（Mac环境）、linux 下rocketmq安装的相关知识，请在本站进行查询。

本文标签：

上一篇分享你的见解与经验｜RocketMQ Summit 2022 议题征集中！（rocketmq选举）

下一篇RocketMQ（rocketmq工作原理）

相关文章