中国和城乡建设部网站首页,做外贸要访问国外的网站怎么办,电商平台有哪些平台,关于手机网站设计的若干想法目录一、RockerMQ简介二、Linux中单节点部署1、准备工作2、下载和解压3、修改初始内存4、启动5、查看进程6、发送接收消息测试7、关闭三、控制台的安装与启动(可视化页面)1、修改配置#xff08;1#xff09;修改端口号#xff08;2#xff09;指定RocketMQ的name server地…
目录一、RockerMQ简介二、Linux中单节点部署1、准备工作2、下载和解压3、修改初始内存4、启动5、查看进程6、发送接收消息测试7、关闭三、控制台的安装与启动(可视化页面)1、修改配置1修改端口号2指定RocketMQ的name server地址3添加依赖2、打成jar包3、启动4、测试访问四、常见问题及解决方法1、rocketmq org.apache.rocketmq.remoting.exception.RemotingConnectException:connect to 10909 failed1问题原因2解决方案一、RockerMQ简介
MQMessage Queue是一种提供消息队列服务的中间件也称为消息中间件是一套提供了消息生产、存储、消费全过程API的软件系统。消息即数据。一般消息的体量不会很大。
可以用来在分布式系统中异步提速、解耦、削峰填谷和数据收集
二、Linux中单节点部署
1、准备工作
软硬件需求
系统要求是64位的JDK要求是1.8及其以上版本的。
下载RocketMQ安装包
版本选择https://archive.apache.org/dist/rocketmq/4.9.0/rocketmq-all-4.9.0-bin-release.zip
2、下载和解压
将下载的安装包上传到Linux上(也可以直接在Linux里用wget命令下载)
由于是zip文件所以需要有一个解压zip的工具
yum install -y unzip解压下载的压缩包
unzip rocketmq-all-4.9.0-bin-release.zip3、修改初始内存
修改 runserver.sh 文件 #使用vim命令打开 bin/runserver.sh 文件。现将这些值修改为如下
AVA_OPT${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn1g -XX:MetaspaceSize128m -XX:MaxMetaspaceSize320m
choose_gc_options修改 runbroker.sh 使用vim命令打开 bin/runbroker.sh 文件。现将这些值修改为如下
JAVA_OPT${JAVA_OPT} -server -Xms256M -Xmx256M -Xmn128M注意以上初始内存大小应该小于自己Linux的内存但也不能太小根据自己的实际情况而定
4、启动
启动start namesrv
### start namesrv
$ nohup sh bin/mqnamesrv ### verify namesrv
$ tail -f ~/logs/rocketmqlogs/namesrv.logThe Name Server boot success...启动 Broker
### start broker
$ nohup sh bin/mqbroker -n localhost:9876 ### verify broker
$ tail -f ~/logs/rocketmqlogs/broker_default.log The broker[broker-a,192.169.1.2:10911] boot success...5、查看进程
jps1860 BrokerStartup
1832 NamesrvStartup
2447 Jps6、发送接收消息测试
发送消息
$ export NAMESRV_ADDRlocalhost:9876
# 发送消息
$ sh bin/tools.sh org.apache.rocketmq.example.quickstart.ProducerSendResult [sendStatusSEND_OK, msgId ...接收消息
#接收消息
$ sh bin/tools.sh org.apache.rocketmq.example.quickstart.ConsumerConsumeMessageThread_%d Receive New Messages: [MessageExt...7、关闭
可以使用jps搜索进程,然后使用kill把进程杀死
kill -9 [进程号]第二种方法
### 关闭broker
$ sh bin/mqshutdown brokerThe mqbroker(36695) is running...
Send shutdown request to mqbroker(36695) OK### 关闭namesrv
$ sh bin/mqshutdown namesrvThe mqnamesrv(36664) is running...
Send shutdown request to mqnamesrv(36664) OK三、控制台的安装与启动(可视化页面)
RocketMQ有一个可视化的dashboard通过该控制台可以直观的查看到很多数据。
下载地址 官方地址https://github.com/apache/rocketmq-dashboard
1、修改配置
将下载的压缩包解压出来,进入文件修改其 src/main/resources 中的application.properties 配置文件.
1修改端口号
原来的端口号为8080修改为一个不常用的如7777
2指定RocketMQ的name server地址 3添加依赖
在解压目录rocketmq-console的pom.xml中添加如下JAXB依赖。 (JAXB*Java Architechture for Xml Binding用于XML绑定的Java技术是一个业界标准是一项可以根据XML Schema生成Java类的技术。)
dependencygroupIdjavax.xml.bind/groupIdartifactIdjaxb-api/artifactIdversion2.3.0/version
/dependency
dependencygroupIdcom.sun.xml.bind/groupIdartifactIdjaxb-impl/artifactIdversion2.3.0/version
/dependency
dependencygroupIdcom.sun.xml.bind/groupIdartifactIdjaxb-core/artifactIdversion2.3.0/version
/dependency
dependencygroupIdjavax.activation/groupIdartifactIdactivation/artifactIdversion1.1.1/version
/dependency2、打成jar包
在rocketmq-console目录下运行maven的打包命令。
mvn clean package -Dmaven.test.skiptrue也可以在idea里打jar包
3、启动
java -jar target/rocketmq-dashboard-1.0.1-SNAPSHOT.jar4、测试访问
访问http://localhost:7000/ 在这里可以搜索接收的消息,能够收到代表成功了。
四、常见问题及解决方法
1、rocketmq org.apache.rocketmq.remoting.exception.RemotingConnectException:connect to 10909 failed
1问题原因
由于跨域造成的
2解决方案
修改服务器中broker的配置添加服务器IP(公网)即可
vim conf/broker.conf在最后添加一行
brokerIP1xx.xx.xx.xx # 你的公网IP注意IP两个字母要大写。这个公网IP有的人用宿主机的IP有的人用的Linux的IP自己都试一下
杀死上面启动的进程后重启namesrv和broker
重启broker是要加入下面的选项 -c conf/broker.conf如果以上方法还不能解决你的问题尝试重启一下虚拟机会有意想不到的效果
