centos安装rocketmq
<svg xmlns="http://www.w3.org/2000/svg" style="display: none"><path stroke-linecap="round" d="M5,0 0,2.5 5,5z" id="raphael-marker-block" style="-webkit-tap-highlight-color: rgba(0, 0, 0, 0)"></path>
</svg>
<h1>1. RocketMQ快速入门</h1>
<p>RocketMQ是阿里巴巴2016年MQ中间件，使用Java语言开发，在阿里内部，RocketMQ承接了例如“双11”等高并发场景的消息流转，能够处理万亿级别的消息。</p>
<h2>1.1 准备工作</h2>
<h3>1.1.1 下载RocketMQ</h3>
<p>RocketMQ版本：4.4.0</p>
<p>下载地址</p>
<p><img src="https://img-blog.csdnimg.cn/20191116162628239.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NDkzNTU2,size_16,color_FFFFFF,t_70"></p>
<h3>1.1.2 环境要求</h3>
<ul>
<li>Linux64位系统</li>
<li>JDK1.8(64位)</li>
<li>源码安装需要安装Maven 3.2.x</li>
</ul>
<h3>1.1.3 常用插件安装命令</h3>
<pre><code class="prism language-xml"> 解压文件 yum install -y unzip zip
windows 需要向centos服务器上传文件 yum -y install lrzsz
</code></pre>
<h2>1.2 安装RocketMQ</h2>
<h3>1.2.1 安装步骤</h3>
<p>本教程以二进制包方式安装</p>
<h4>1.2.1.1 通过rz 把下载好的压缩文件上传到指定centos目录下面</h4>
<p><img src="https://img-blog.csdnimg.cn/20191116162608424.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NDkzNTU2,size_16,color_FFFFFF,t_70"></p>
<h4>1.2.1.2.解压rocket4.4压缩包</h4>
<pre><code>unzip -d /usr/software rocketmq-all-4.4.0-bin-release.zip
</code></pre>
<p><img src="https://img-blog.csdnimg.cn/20191116162922761.png"></p>
<h3>1.2.2 目录介绍</h3>
<p><img src="https://img-blog.csdnimg.cn/20191116164747479.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NDkzNTU2,size_16,color_FFFFFF,t_70"></p>
<ul>
<li>benchmark :rocketmq的一些代码示例</li>
<li>bin：启动脚本，包括shell脚本和CMD脚本</li>
<li>conf：实例配置文件 ，包括broker配置文件、logback配置文件等</li>
<li>lib：依赖jar包，包括Netty、commons-lang、FastJSON等</li>
</ul>
<h2>1.3 启动RocketMQ</h2>
<ol>
<li>启动NameServer</li>
</ol>
<pre><code># 1.启动NameServer
nohup sh bin/mqnamesrv &
# 2.查看启动日志
tail -f ~/logs/rocketmqlogs/namesrv.log
</code></pre>
<ol>
<li>启动Broker</li>
</ol>
<pre><code># 1.启动Broker
nohup sh bin/mqbroker -n localhost:9876 &
# 2.查看启动日志
tail -f ~/logs/rocketmqlogs/broker.log
</code></pre>
<ul>
<li>
<p>问题描述：</p>
<p>RocketMQ默认的虚拟机内存较大，启动Broker如果因为内存不足失败，需要编辑如下两个配置文件，修改JVM内存大小</p>
</li>
</ul>
<pre><code># 编辑runbroker.sh和runserver.sh修改默认JVM大小
vi runbroker.sh
vi runserver.sh
</code></pre>
<ul>
<li>参考设置：</li>
</ul>
<p><code>JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"</code></p>
<h2>1.4 测试RocketMQ</h2>
<h3>1.4.1 发送消息</h3>
<pre><code># 1.设置环境变量
export NAMESRV_ADDR=localhost:9876
# 2.使用安装包的Demo发送消息
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
</code></pre>
<h3>1.4.2 接收消息</h3>
<pre><code># 1.设置环境变量
export NAMESRV_ADDR=localhost:9876
# 2.接收消息
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
</code></pre>
<h2>1.5 关闭RocketMQ</h2>
<pre><code># 1.关闭NameServer
sh bin/mqshutdown namesrv
# 2.关闭Broker
sh bin/mqshutdown broker
</code></pre><br><br>
来源：https://www.cnblogs.com/ourlang/p/12230968.html
頁:
[1]