官网地址：http://rocketmq.apache.org/docs/quick-start/

快速启动

下载源码包，解压并构建

unzip rocketmq-all-4.4.0-source-release.zip
cd rocketmq-all-4.4.0/
mvn -Prelease-all -DskipTests clean install -U
cd distribution/target/apache-rocketmq/bin

修改runbroker.sh 和 runserver.sh的参数
目录distribution/target/apache-rocketmq/bin下放置的相关的脚本

JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn256m"
JAVA_OPT="${JAVA_OPT} -XX:MaxDirectMemorySize=512m"

在distribution下创建日志目录/logs
启动服务

//启动nameserver
nohup sh target/apache-rocketmq/bin/mqnamesrv > ./logs/namesrv.log 2>&1 &//启动broker
nohup sh target/apache-rocketmq/bin/mqbroker -n localhost:9876 > ./logs/broker.log 2>&1 &//使用jps命令查看是否启动成功
[root@4c33afef76b9 distribution]# jps
16963 NamesrvStartup
17019 BrokerStartup
18686 Jps

测试

//发送消息
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

关闭服务

//distribution/target/apache-rocketmq/bin目录下执行
sh bin/mqshutdown broker
sh bin/mqshutdown namesrv

可视化平台

在GitHub 中搜索 rocketmq-externals，其中 rocketmq-console 就是 RocketMQ 可视化控制台。
https://github.com/apache/rocketmq-externals
修改配置文件

find -name application.properties
文件路径./rocketmq-console/src/main/resources/application.propertiesvim application.properties
rocketmq.config.namesrvAddr=192.168.143.128:9876

编译打包启动

mvn clean package -Dmaven.test.skip=truePID=`ps aux | grep "rocketmq-console"| grep -v grep | awk '{print $2}'`
echo "kill process is ${PID}"
kill -9 ${PID}nohup java -jar target/rocketmq-console-ng-1.0.1.jar >>/rocketmq_console.log 2>&1 &

查看 http://10.96.114.151:8080

RocketMQ初识相关推荐

《RocketMQ技术内幕：RocketMQ架构设计与实现原理》一导读...
内容介绍本书由RocketMQ社区早期的布道者和技术专家撰写,Apache RocketMQ创始人/Linux OpenMessaging创始人兼主席/Alibaba Messaging开源技术负责 ...
【初识Netty使用Netty实现简单的客户端与服务端的通信操作Netty框架中一些重要的类以及方法的解析】
一.Netty是什么? Netty 由 Trustin Lee(韩国,Line 公司)2004 年开发本质:网络应用程序框架实现:异步.事件驱动特性:高性能.可维护.快速开发用途:开发服务器和 ...
初识RabbitMQ与 SpringAMQP
初识MQ 同步和异步通讯微服务间通讯有同步和异步两种方式: 同步通讯:就像打电话,需要实时响应. 异步通讯:就像发邮件,不需要马上回复. 两种方式各有优劣,打电话可以立即得到响应,但是你却不能跟多个 ...
RocketMQ 中Topic、Tag、GroupName基本概念介绍
本文主要介绍RocketMQ中Topic.Tag.GroupName的概念.设计初衷以及使用方法. 一.Topic 首先看看官方的定义: Topic是生产者在发送消息和消费者在拉取消息的类别.Topi ...
RabbitMQ 服务异步通信 -- 初识MQ（同步通信和异步通信、MQ、几种常见MQ的对比）、RabbitMQ安装和介绍
文章目录 1. 初识MQ 1.1 同步通信和异步通信 1.1.1 同步通信存在的问题 1.1.2 同步调用小结 1.1.3 异步通讯 1.1.4 异步调用方案 1.1.5 异步调用小结 1.2 什么是 ...
day3----编码-集合-深浅copy-文件操作-函数初识
day3----编码-集合-深浅copy-文件操作-函数初识本文档主要内容: 一编码二集合三深浅copy 四文件操作五函数初识首先,我们来看看两个字符串的比较打开cmd,进入do ...
⑥python模块初识、pyc和PyCodeObject
一.模块初识(一) 模块,也叫库.库有标准库第三方库. 注意事项:文件名不能和导入的模块名相同 1. sys模块 import sys print(sys.path) #打印环境变量 print(sy ...
初识Redis，看这一篇就够了
Redis (全称: Remote Dictionary Server 远程字典服务)是一个开源的使用 ANSI C语言编写.支持网络.可基于内存亦可持久化的日志型. Key-Value数据库 . ...
初识java类的接口实现
初识java类的接口实现如果两个类之间不存在继承关系,且两个类都想实现同一个接口,两个类都必须实现接口中全部方法,否则报语法错误如果两个类之间存在继承关系也想实现同一个接口,父类如果实现了某个接口 ...

RocketMQ初识

快速启动

可视化平台

RocketMQ初识相关推荐

最新文章

热门文章