栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

RocketMQ入门(一)新手实战

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

RocketMQ入门(一)新手实战

学任何技术都是两步骤:

  1. 搭建环境

  2. helloworld

我也不例外,直接搞起来。

一、RocketMQ的安装 1、文档

官方网站

http://rocketmq.apache.org

GitHub

https://github.com/apache/rocketmq

2、下载
wget https://mirror.bit.edu.cn/apache/rocketmq/4.7.0/rocketmq-all-4.7.0-bin-release.zip

我们是基于Centos8来的,面向官方文档学习,所以下载地址自然也是官方的。

去官方网站找合适的版本进行下载,目前我这里最新的是4.7.0版本。

http://rocketmq.apache.org/dowloading/releases/

https://www.apache.org/dyn/closer.cgi?path=rocketmq/4.7.0/rocketmq-all-4.7.0-bin-release.zip

3、准备工作 3.1、解压
unzip rocketmq-all-4.7.0-bin-release.zip
3.2、安装jdk
sudo yum install java-1.8.0-openjdk-devel
4、启动 4.1、启动namesrv
cd rocketmq-all-4.7.0-bin-release/bin./mqnamesrv
4.2、启动broker
cd rocketmq-all-4.7.0-bin-release/bin./mqbroker -n localhost:9876

常见错误以及解决方案:

常见错误:启动broker失败 Cannot allocate memory

[root@node-113b bin]# ./mqbroker -n localhost:9876Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00000005c0000000, 8589934592, 0) failed; error='Cannot allocate memory' (errno=12)## There is insufficient memory for the Java Runtime Environment to continue.# Native memory allocation (mmap) failed to map 8589934592 bytes for committing reserved memory.# An error report file with more information is saved as:# /usr/local/rocketmq/bin/hs_err_pid1997.log

解决方案:

是由于默认内存分配的太大了,超出了本机内存,直接OOM了。

修改bin/目录下的如下两个脚本

runbroker.shrunserver.sh

在这两个脚本里都搜索-server -Xms,将其内存分配小点,自己玩的话512MB就足够了,够够的了!

4.3、启动成功标识

namesrv启动成功标识:

broker启动成功标识:

二、RocketMQ控制台的安装

控制台目前获取方式有如下两种:

  1. 第三方网站去下载现成的,比如csdn等。

  2. 官方源码包自己编译而成,官方没有现成的。

我们这里当然采取官方方式。

1、官方文档

github仓库

https://github.com/apache/rocketmq-externals

中文指南

https://github.com/apache/rocketmq-externals/blob/master/rocketmq-console/doc/1_0_0/UserGuide_CN.md

2、下载源码

https://codeload.github.com/apache/rocketmq-externals/zip/master

3、修改配置(可选)

我们下载完解压后的文件目录如下:

修改rocketmq-consolesrcmainresourcesapplication.properties文件的server.port就欧了。默认8080。

4、编译打包

进入rocketmq-console,然后用maven进行编译打包

mvn clean package -DskipTests

打包完会在target下生成我们spring boot的jar程序,直接java -jar启动完事。

5、启动控制台

将编译打包好的springboot程序扔到服务器上,执行如下命令进行启动

java -jar rocketmq-console-ng-1.0.1.jar --rocketmq.config.namesrvAddr=127.0.0.1:9876

如果想后台启动就nohup &

访问一下看看效果:

原文链接:https://mp.weixin.qq.com/s?__biz=MzI4Njc5NjM1NQ==&mid=2247493598&idx=1&sn=88bf0fcbfa5207f79399a7cb0b1b208f&chksm=ebd5d8f2dca251e4ca32dd910b9b3aaff641b40a6b1041df41881eea0a2526e1ea1ad1d9c765&scene=21#wechat_redirect
作者公众号:一起写程序
转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/237664.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号