-
Linux下RocketMQ单机安装
2019-02-26 18:21:26Linux下RocketMQ单机安装 1、优化 主机名、防火墙关闭、tcp优化等 2、jdk安装(1.8) wget ftp://10.249.100.249/pub/jdk/jdk8/* 3、Maven 3.0.5 打包过程省了,开发给我打包好 4、下载rocketmq wget ...Linux下RocketMQ单机安装
1、优化
主机名、防火墙关闭、tcp优化等2、jdk安装(1.8)
wget ftp://10.249.100.249/pub/jdk/jdk8/*3、Maven 3.0.5
打包过程省了,开发给我打包好4、下载rocketmq
wget https://github.com/apache/rocketmq/archive/rocketmq-all-4.2.0.tar.gz5、环境变量
vi /etc/profile
export rocketmq=/usr/local/rocketmq-4-3-0
export PATH=$PATH:$rocketmq/bin
source /etc/profile6、启动mqnameserver
配置内存
/usr/local/rocketmq-4-3-0/bin
runserver.sh
runbroker.sh
测试环境给1g即可/usr/local/rocketmq-4-3-0/usr/local/rocketmq-4-3-0/bin目录下
cd /var/log/
touch rocketmq.lognohup sh mqnamesrv > /var/log/rocketmq.log 2>&1 &
nohup: ignoring input
Java HotSpot(TM) 64-Bit Server VM warning: Using the DefNew young collector with the CMS collector is deprecated and will likely be removed in a future release
Java HotSpot(TM) 64-Bit Server VM warning: UseCMSCompactAtFullCollection is deprecated and will likely be removed in a future release.
The Name Server boot success. serializeType=JSON7、启动mqbroker
启动mqbroker(/usr/local/rocketmq-4-3-0/bin目录下)nohup sh mqbroker -n localhost:9876 autoCreateTopicEnable=true > /var/log/rocketmq-broker.log 2>&1 &
注意:localhost可以换成你刚才启动mqnamesrv的ip
[root@ip-10-101-200-47 bin]# jps
25105 BrokerStartup
25045 NamesrvStartup
25158 Jps
8、维护
关闭服务器与启动服务的顺序是相反的
停止broker
sh mqshutdown broker
停止namerserver
sh mqshutdown namesrv[root@ip-10-101-200-47 bin]# sh mqshutdown broker
The mqbroker(25105) is running...
Send shutdown request to mqbroker(25105) OK
[root@ip-10-101-200-47 bin]# sh mqshutdown namesrv
The mqnamesrv(25045) is running...
Send shutdown request to mqnamesrv(25045) OK
[2]+ Exit 143 nohup sh mqbroker -n localhost:9876 autoCreateTopicEnable=true > /var/log/rocketmq-broker.log 2>&19、图形界面上传启动
nohup java -jar rocketmq-console-ng-1.0.0.jar > /var/log/rocketmq-console-ng 2>&1 &
http://10.101.200.47:8080/#/10、监控上传启动
nohup java -jar zipkin.jar > /var/log/zipkin.log 2>&1 &
http://10.101.200.47:9411/zipkin/
================================
常用命令参考文档https://blog.csdn.net/varyall/article/details/79630037
首先进入 RocketMQ 工程,进入/RocketMQ/bin 在该目录下有个 mqadmin 脚本 .
查看帮助: 在 mqadmin 下可以查看有哪些命令
查看具体命令的使用
sh mqadmin命令名称
sh mqadmin help查看 updateTopic 的使用
sh mqadmin help updateTopic关闭nameserver和所有的broker:
进入到bin下:
sh mqshutdown namesrv
sh mqshutdown broker
查看所有消费组group:
sh mqadmin consumerProgress -n 10.101.200.47:9876
查看指定消费组下的所有topic数据堆积情况:
sh mqadmin consumerProgress -n 10.101.200.47:9876 -g warning-group
查看所有topic :
sh mqadmin topicList -n 10.101.200.47:9876
查看topic信息列表详情统计
sh mqadmin topicstatus -n 10.101.200.47:9876 -t topicWarning
新增topic
sh mqadmin updateTopic –n 10.101.200.47:9876 –c DefaultCluster –t topicWarning
删除topic
sh mqadmin deleteTopic –n 10.101.200.47:9876 –c DefaultCluster –t topicWarning
查询集群消息
sh mqadmin clusterList -n 10.101.200.47:9876
==================================== -
linux-windowns启动关闭RocketMQ
2019-09-18 16:23:041、进入bin目录:双击启动mqnamesrv.cmd,保持mqnamesrv.exe运行,不要关闭这个终端。 2、另外起一个cmd窗口进入bin目录输入:mqbroker -n 127.0.0.1:9876 linux 安装 解压即可,jdk1.8以上。 启动 1、nohup sh ...windows
启动1、进入bin目录:双击启动mqnamesrv.cmd,保持mqnamesrv.exe运行,不要关闭这个终端。
2、另外起一个cmd窗口进入bin目录输入:mqbroker -n 127.0.0.1:9876linux
安装
解压即可,jdk1.8以上。启动
1、nohup sh mqnamesrv > /dev/null 2>&1 &
2、nohup sh mqbroker -n 10.10.103.67:9876 > /dev/null 2>&1 &
关闭
1、sh bin/mqshutdown broker
2、sh bin/mqshutdown namesrv -
Linux上安装RocketMQ
2020-11-05 18:06:07关闭RocketMQ 1. 准备工作 1.1 下载RocketMQ 点我下载,下载的时候下载二进制版本。 2. 环境要求 Linux64位系统 JDK1.8(64位) 3. 安装步骤 本教程以二进制包方式安装 解压安装包 进入安装目录 4. 目单靠脑袋是记不住的鸭~
文章学习总结于视频:B站学习视频
视频中有一些错误,已经在文章中修改过来了这篇文章主要学习RocketMQ的下载、安装、启动、关闭这些基础的流程。
文章目录
1. 准备工作
1.1 下载RocketMQ
点我下载,下载的时候下载二进制版本。
2. 环境要求
- Linux64位系统
- JDK1.8(64位)
3. 安装步骤
本教程以二进制包方式安装
- 解压安装包
- 进入安装目录
- 我喜欢将文件夹名字修改得简单点,并且移动到 /usr/local/ 目录下。
/usr/local/rocketmq
4. 目录介绍
- bin:启动脚本,包括shell脚本和CMD脚本
- conf:实例配置文件 ,包括broker配置文件、logback配置文件等
- lib:依赖jar包,包括Netty、commons-lang、FastJSON等
5. 启动RocketMQ
- 启动NameServer
# 1.启动NameServer nohup sh bin/mqnamesrv & # 2.查看启动日志 tail -f ~/logs/rocketmqlogs/namesrv.log
- 启动Broker
# 1.启动Broker nohup sh bin/mqbroker -n localhost:9876 & # 2.查看启动日志 tail -f ~/logs/rocketmqlogs/broker.log
-
问题描述:
RocketMQ默认的虚拟机内存较大,启动Broker如果因为内存不足失败,需要编辑如下两个配置文件,修改JVM内存大小,它们在 bin 目录下:
# 编辑runbroker.sh和runserver.sh修改默认JVM大小 vi runbroker.sh vi runserver.sh
- 参考设置:
JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m -Xmn256m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
6. 测试RocketMQ
6.1 发送消息
# 1.设置环境变量 export NAMESRV_ADDR=localhost:9876 # 2.使用安装包的Demo发送消息 sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
6.2 接收消息
# 1.设置环境变量 export NAMESRV_ADDR=localhost:9876 # 2.接收消息 sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
7. 关闭RocketMQ
# 1.关闭NameServer sh bin/mqshutdown namesrv # 2.关闭Broker sh bin/mqshutdown broker
技 术 无 他, 唯 有 熟 尔。
知 其 然, 也 知 其 所 以 然。
踏 实 一 些, 不 要 着 急, 你 想 要 的 岁 月 都 会 给 你。
-
Linux下安装RocketMQ
2020-12-17 00:09:23Linux下安装RocketMQ 准备工作 安装 第一步、上传文件,解压 第二步、配置环境变量,启动rocketmq 第三步、关闭服务 测试 第一步、打开相应端口 第二步、修改broker.conf配置文件 第三步、编写代码进行测试...目录
Linux下安装RocketMQ
准备工作
RocketMQ下载地址:http://rocketmq.apache.org/release_notes/ 选择对应的版本号进行下载,我下载的是4.7.1
带bin的是二进制文件,带source的是源码
中文官方文档:https://github.com/apache/rocketmq/tree/master/docs/cn
官方推荐配置:
- 64bit OS, Linux/Unix/Mac is recommended;(Windows user see guide below)
- 64bit JDK 1.8+;
- Maven 3.2.x;
- Git;
- 4g+ free disk for Broker server
我的linux版本:CentOS 7
安装rocketmq前需要先安装jdk1.8,因为rocketmq是Java语言写的
JDK1.8安装教程:https://blog.csdn.net/Me_xuan/article/details/111306026
安装
第一步、上传文件,解压
将我们下载的zip的包上传至服务器,新建文件夹,将zip包复制到我们新建的文件夹下面,然后进行解压,我的目录是/app/rocketmq
解压完后重命名,也可以不重命名,因为之前的名字太长,建议还是重命名一下比较好
第二步、配置环境变量,启动rocketmq
配置环境变量
vi /etc/profile
# rocketmq
export ROCKETMQ_HOME=/app/rocketmq/rocketmq
export PATH=$PATH:${ROCKETMQ_HOME}/bin
ROCKETMQ_HOME就是我们刚安装的racketmq的地址
配置完环境变量,我们启动一下NameServer
nohup sh mqnamesrv &
如果没有配置环境变量。则得在mq的bin目录下执行 sh mqnamesrv
如果此时启动不起来,看一下rockermq设置的jvm参数,可以把-Xms -Xmx -Xmn 这三个参数根据自己的服务器配置进行相应的调整
启动成功后查看rocketmq的进程
也可以看打印的日志 tail -f ~/logs/rocketmqlogs/namesrv.log
启动borker
先根据自己的服务器配置修改JVM参数
vi runbroker.sh
启动
nohup sh mqbroker -n localhost:9876 &
-n参数后面接要连接到的NameServer的ip和端口 , ip:port;ip:port 多个用分号隔开。
日志打印
至此,我们的rocketmq服务端就已经启动成功了。
第三步、关闭服务
NameServer和broker关闭
# 关闭NameServer
sh mqshutdown namesrv
# 关闭broker
sh mqshutdown broker
测试
第一步、打开相应端口
开放9876、10911端口
查看防火墙状态:[root@localhost ~]# systemctl status firewalld
查看开放端口:[root@localhost ~]# firewall-cmd --list-all
开放端口:
firewall-cmd --zone=public --add-port=9876/tcp --permanent
firewall-cmd --zone=public --add-port=10911/tcp --permanent
刷新防火墙:firewall-cmd --reload
注意,这里有个坑
之前我天真的以为打开这个端口9876就可以了,结果还是不行,然后得再打开10911这个端口
如果不打开10911这个端口,生产者服务会报超时异常,然后一直打印[NettyClientSelector_1] INFO RocketmqRemoting - closeChannel: close the connection to remote address[] result: true
如:
RocketMQLog:WARN No appenders could be found for logger (io.netty.util.internal.InternalThreadLocalMap).
RocketMQLog:WARN Please initialize the logger system properly.
Exception in thread "main" org.apache.rocketmq.remoting.exception.RemotingTooMuchRequestException: sendDefaultImpl call timeout
at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:667)
at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1343)
at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1289)
at org.apache.rocketmq.client.producer.DefaultMQProducer.send(DefaultMQProducer.java:325)
at com.example.demo.rocketmq.producer.SyncProducer.main(SyncProducer.java:30)
23:18:22.026 [NettyClientSelector_1] INFO RocketmqRemoting - closeChannel: close the connection to remote address[] result: true
23:18:52.508 [NettyClientSelector_1] INFO RocketmqRemoting - closeChannel: close the connection to remote address[] result: true
23:19:22.510 [NettyClientSelector_1] INFO RocketmqRemoting - closeChannel: close the connection to remote address[] result: true通过日志可以看到,broker使用了10911这个端口
因为代理服务器(Broker Server)在RocketMQ系统中负责接收从生产者发送来的消息并存储、同时为消费者的拉取请求作准备,所以broker的端口也得打开
然后再启动生产者代码,会正常打印相关日志,address中会有我们的两个服务地址,如下
00:01:14.782 [NettyClientSelector_1] INFO RocketmqRemoting - closeChannel: close the connection to remote address[192.168.75.100:10911] result: true
00:01:14.785 [NettyClientSelector_1] INFO RocketmqRemoting - closeChannel: close the connection to remote address[192.168.75.100:9876] result: true第二步、修改broker.conf配置文件
需要配置broker.conf 这个配置文件,不然的话自己的java项目是无法连接至服务端的
[root@localhost bin]# vi ../conf/broker.conf
增加两个配置项:
# 当前服务器ip:port
namesrvAddr=192.168.75.100:9876
# 当前服务器ip
brokerIP1=192.168.75.100
然后重新启动NameServer和broker
nohup sh mqnamesrv -n 192.168.75.100:9876 &
nohup sh mqbroker -n 192.168.75.100:9876 -c ../conf/broker.conf autoCreateTopicEnable=true &
autoCreateTopicEnable=true 的作用是自动创建topic
第三步、编写代码进行测试
代码示例:
官方文档中有简单案例:
https://github.com/apache/rocketmq/blob/master/docs/cn/RocketMQ_Example.md
我这就是直接拷的官方demo
我这个是springboot的项目
1.引入maven相关依赖
<dependency> <groupId>org.apache.rocketmq</groupId> <artifactId>rocketmq-client</artifactId> <version>4.7.1</version> </dependency>
2.编写生产者代码
package com.example.demo.rocketmq.producer; import org.apache.rocketmq.client.producer.DefaultMQProducer; import org.apache.rocketmq.client.producer.SendResult; import org.apache.rocketmq.common.message.Message; import org.apache.rocketmq.remoting.common.RemotingHelper; /** * @ClassName SyncProducer * @Author chenxuan * @Date 2020/12/15 23:11 * @Version 1.0 */ public class SyncProducer { public static void main(String[] args) throws Exception { // 实例化消息生产者Producer DefaultMQProducer producer = new DefaultMQProducer("please_rename_unique_group_name"); // 设置NameServer的地址 producer.setNamesrvAddr("192.168.75.100:9876"); // 启动Producer实例 producer.start(); for (int i = 0; i < 10; i++) { // 创建消息,并指定Topic,Tag和消息体 Message msg = new Message("TopicTest" /* Topic */, "TagA" /* Tag */, ("Hello RocketMQ " + i).getBytes(RemotingHelper.DEFAULT_CHARSET) /* Message body */ ); // 发送消息到一个Broker SendResult sendResult = producer.send(msg); // 通过sendResult返回消息是否成功送达 System.out.printf("%s%n", sendResult); } // 如果不再发送消息,关闭Producer实例。 producer.shutdown(); } }
3.编写消费者代码
package com.example.demo.rocketmq.consumer; import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer; import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext; import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus; import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently; import org.apache.rocketmq.client.exception.MQClientException; import org.apache.rocketmq.common.message.MessageExt; import java.util.List; /** * @ClassName Consumer * @Author chenxuan * @Date 2020/12/15 23:11 * @Version 1.0 */ public class Consumer { public static void main(String[] args) throws InterruptedException, MQClientException { // 实例化消费者 DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("please_rename_unique_group_name"); // 设置NameServer的地址 consumer.setNamesrvAddr("192.168.75.100:9876"); // 订阅一个或者多个Topic,以及Tag来过滤需要消费的消息 consumer.subscribe("TopicTest", "*"); // 注册回调实现类来处理从broker拉取回来的消息 consumer.registerMessageListener(new MessageListenerConcurrently() { @Override public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext context) { System.out.printf("%s Receive New Messages: %s %n", Thread.currentThread().getName(), msgs); msgs.stream().forEach(msg -> System.out.println("msg:"+new String(msg.getBody())) ); // 标记该消息已经被成功消费 return ConsumeConcurrentlyStatus.CONSUME_SUCCESS; } }); // 启动消费者实例 consumer.start(); System.out.printf("Consumer Started.%n"); } }
4.启动代码,成功运行
生产者日志:
RocketMQLog:WARN Please initialize the logger system properly.
SendResult [sendStatus=SEND_OK, msgId=C0A8016931CC00B4AAC25266E3E80000, offsetMsgId=C0A84B6400002A9F000000000000178E, messageQueue=MessageQueue [topic=TopicTest, brokerName=broker-a, queueId=1], queueOffset=9]
SendResult [sendStatus=SEND_OK, msgId=C0A8016931CC00B4AAC25266E3FB0001, offsetMsgId=C0A84B6400002A9F0000000000001857, messageQueue=MessageQueue [topic=TopicTest, brokerName=broker-a, queueId=2], queueOffset=7]
SendResult [sendStatus=SEND_OK, msgId=C0A8016931CC00B4AAC25266E3FF0002, offsetMsgId=C0A84B6400002A9F0000000000001920, messageQueue=MessageQueue [topic=TopicTest, brokerName=broker-a, queueId=3], queueOffset=6]
SendResult [sendStatus=SEND_OK, msgId=C0A8016931CC00B4AAC25266E4010003, offsetMsgId=C0A84B6400002A9F00000000000019E9, messageQueue=MessageQueue [topic=TopicTest, brokerName=broker-a, queueId=0], queueOffset=8]
SendResult [sendStatus=SEND_OK, msgId=C0A8016931CC00B4AAC25266E4050004, offsetMsgId=C0A84B6400002A9F0000000000001AB2, messageQueue=MessageQueue [topic=TopicTest, brokerName=broker-a, queueId=1], queueOffset=10]
SendResult [sendStatus=SEND_OK, msgId=C0A8016931CC00B4AAC25266E4090005, offsetMsgId=C0A84B6400002A9F0000000000001B7B, messageQueue=MessageQueue [topic=TopicTest, brokerName=broker-a, queueId=2], queueOffset=8]
SendResult [sendStatus=SEND_OK, msgId=C0A8016931CC00B4AAC25266E40C0006, offsetMsgId=C0A84B6400002A9F0000000000001C44, messageQueue=MessageQueue [topic=TopicTest, brokerName=broker-a, queueId=3], queueOffset=7]
SendResult [sendStatus=SEND_OK, msgId=C0A8016931CC00B4AAC25266E4100007, offsetMsgId=C0A84B6400002A9F0000000000001D0D, messageQueue=MessageQueue [topic=TopicTest, brokerName=broker-a, queueId=0], queueOffset=9]
SendResult [sendStatus=SEND_OK, msgId=C0A8016931CC00B4AAC25266E4120008, offsetMsgId=C0A84B6400002A9F0000000000001DD6, messageQueue=MessageQueue [topic=TopicTest, brokerName=broker-a, queueId=1], queueOffset=11]
SendResult [sendStatus=SEND_OK, msgId=C0A8016931CC00B4AAC25266E4140009, offsetMsgId=C0A84B6400002A9F0000000000001E9F, messageQueue=MessageQueue [topic=TopicTest, brokerName=broker-a, queueId=2], queueOffset=9]
00:01:14.782 [NettyClientSelector_1] INFO RocketmqRemoting - closeChannel: close the connection to remote address[192.168.75.100:10911] result: true
00:01:14.785 [NettyClientSelector_1] INFO RocketmqRemoting - closeChannel: close the connection to remote address[192.168.75.100:9876] result: trueProcess finished with exit code 0
消费者日志(只打印了消息内容,不然日志太多):
Consumer Started.
msg:Hello RocketMQ 0
msg:Hello RocketMQ 1
msg:Hello RocketMQ 2
msg:Hello RocketMQ 3
msg:Hello RocketMQ 4
msg:Hello RocketMQ 5
msg:Hello RocketMQ 6
msg:Hello RocketMQ 7
msg:Hello RocketMQ 8
msg:Hello RocketMQ 9至此我们的rocketmq安装成功,第一个rocketmq的demo也成功运行,后面就可以开始rocketmq之旅了。
-
Tomcat关闭RocketMQ消费者资源未释放,导致内存不足 SSH架构 解决方案
2019-12-02 13:54:20在linux的tomcat部署的ssh项目集成了阿里rocketmq,每次重启tomcat发现阿里的控制台就会多一个mq消费者在线,这样一来除了广播模式,发布消息到消息消费都会受到影响,系统开辟的进程多了起来,还会导致tomcat无法... -
Linux RocketMQ搭建、及常用命令
2020-12-11 11:04:30首先进入进入/RocketMQ/bin 在该目录下有个 mqadmin 脚本 . 查看帮助: 在 mqadmin 下可以查看有哪些命令 a:查看具体命令的使用 :sh mqadmin b: sh mqadmin help 命令名称 例如,查看 updateTopic 的使用 ... -
Linux下搭建RocketMQ4.5.2集群并设置开机自启
2019-10-10 14:05:27防火墙关闭;虚拟机地址:192.168.0.40,192.168.0.41,192.168.0.42,192.168.0.75; 因为之前该虚拟机上搭建了其他的东西,因此这次就指定别名了,直接通过ip和端口访问; 二、软件说明 RocketMQ本是阿里自己的... -
RocketMQ学习1-1:Linux环境搭建单机版本RocketMQ
2019-12-29 23:52:01关闭防火墙:systemctl stop firewalld.service 上传rocketmq-all-4.6.0-bin-release.zip 到 usr 目录下 解压未找到命令 安装zip命令: yum install -y unzip zip 一直等待安装完成 再次解压 解压... -
RocketMQ入门
2020-09-15 22:44:32接下来记录在linux平台下安装一个RocketMQ的服务。 目录 1 下载RocketMQ ...5 关闭RocketMQ 1 下载RocketMQ 下载地址:http://rocketmq.apache.org/release_notes/release-notes-4.7.1/ 环境要求 Linux64 -
Apache RocketMQ在linux上的常用命令
2018-11-21 21:28:00Apache RocketMQ在linux上的常用命令 进入maven安装后的rocketmq的bin目录 1、启动Name Server 2、启动Broker 3、关闭Name Server 4、关闭Broker 5、查看Name Server日志 6、查看Broker日志 ... -
rocketMQ学习笔记一:RocketMQ安装部署
2019-05-12 18:50:28文章目录一、环境要求二、下载、构建三、 启动NameServer四、启动Broker五、发送和接收消息六、启动rocketmq-console控制台七、mqadmin使用八、关闭服务 官网链接:rocketmq-apache-org 一、环境要求 推荐64bit OS,... -
消息队列——rocketmq——搭建集群(linux)
2020-03-31 13:04:20目录 1、集群方案: (1)多master模式: ...5、关闭防火墙: 6、JDK环境安装: 7、软件下载: 8、软件安装: 9、配置环境变量: 10、修改日志存储位置: 11、修改配置文件: (1)创建namesrv.... -
RocketMQ安装和基本使用
2020-06-22 16:19:23RocketMQ安装和基本使用环境要求安装RocketMQ启动RocketMQ测试RocketMQ关闭RocketMQRocketMQ控制台安装Java整合rocketMQ 环境要求 Linux 64位操作系统 64bit JDK 1.8+ 安装RocketMQ 下载地址 上传文件到linux... -
RocketMq控制台部署
2020-02-19 23:29:09下载 编译 ... 执行jar ...在linux上创建文件夹 /usr/soft 把在编译好的jar上传 执行 java -jar jar包名称 检查 关闭防火墙 1.使用命令:systemctl status firewalld.service查看防火墙状态 2.执行... -
rocketmq windows安装_在开发环境下,基于Springboot的RocketMQ示例(含安装步骤、错误分析)...
2021-01-15 04:20:43RocketMQ服务器启动linux环境下载编译源码启动 Name Server启动 Broker关闭服务器windows环境RocketMQ发送消息和消费消息RocketMQ发送消息和消费消息,先启动消费者,然后再启动生产者添加依赖发送消息发送消息--... -
Docker一键安装RocketMQ(All in one Docker)
2019-12-16 19:07:17CentOS Linux release 7.7.1908 (Core) Docker version 19.03.4, build 9013bf583a 安装: 本镜像于2019-12-16基于rocketmq-all-4.6.0制作的; 镜像包含mqnamesrv、mqbroker以及console; 安装前请关闭防火墙... -
rocketmq-简单入门例子
2018-05-23 16:50:55本章节主要详细介绍如何在本地计算机上设置RocketMQ消息系统以发送和接收消息. 在本章节 前置条件 下载发行版本并构建 启动NAME SERVER服务 启动BROKE服务 发送并接收消息 关闭服务 前置条件 假定安装了... -
搭建 Apache RocketMQ 单机环境
2016-04-26 11:14:58环境需求:64位操作系统,建议使用Linux / Unix /CentOs7.364bit JDK 1.8+Maven 3.2.x一、安装Maven安装过程请查看:https://blog.51cto.com/qiangsh/1771831二、安装RocketMQ1、关闭防火墙systemctlstopfirewalld.... -
RocketMQ -- 如何安装,启动 & Web Console 安装
2020-07-15 22:02:25RocketMQ 运行需要 Java 环境,首先确保 Linux 系统中有 Java 环境 1、解压 alibaba-rocketmq.tar.gz 2、进入目录 alibaba-rocketmq/bin/ 授予文件执行权限 运行 ./startmq.sh 关闭 ./stopmq.sh 3、拷贝 console ... -
RocketMQ第02讲:下载及安装
2020-09-11 09:19:27RocketMQ第02讲:下载及安装1. 环境准备2. 下载1.1 Apache官网1.2 GitHub3. 安装3.1 源码安装3.2 二进制安装5. 启动5.1 NameServer5.2 Broker6. 发送/接收消息6.1 发送消息6.2 接收消息7. 关闭服务 首先,部分资料... -
RocketMQ官方教程(翻译加扩充)——快速开始
2019-05-04 21:37:32文章目录先决条件下载并构建开启name server开启broker发送和接收消息关闭服务生产者和消费者 本翻译教程来自RocketMQ官方网站,中间会加上自己的理解,有错误或者不妥之处请及时指正。另外,本文所基于的版本是... -
centos下RocketMQ集群(两主两从)环境搭建
2020-02-24 10:46:49本人使用的环境是CentOS-6.4-x86_64-bin-DVD1.rar,alibaba-rocketmq-3.2.6.tar.gz,jdk-7u67-linux-x64.tar.gz,apache-tomcat-7.0.29.tar.gz。两台主节点ip:192.168.1.125,192.168.1.126。两台从节点ip:192.168.1.... -
java常出现的错误案例_在开发环境下,Springboot集成RocketMQ(含安装步骤、错误分析)...
2021-01-30 02:46:47RocketMQ服务器启动linux环境下载编译源码 启动 Name Server启动 Broker关闭服务器windows环境RocketMQ发送消息和消费消息RocketMQ发送消息和消费消息,先启动消费者,然后再启动生产者添加依赖发送消息发送消息--... -
Rocketmq 学习搭建集群出现的 问题,求帮忙解答
2021-01-07 17:48:201.一共两台linux环境,centos 7 系统64位;129是第一台,就是启动的这台 2.尝试修改过系统名称 /etc/hosts 无效 3.防火墙都已关闭,且ip地址两台能互相ping通 4 主节点启动正常,使用sync 方式 ,另外一台也已启动... -
idea 错误: 找不到或无法加载主类_在开发环境下,Springboot集成RocketMQ(含安装步骤、错误分析)...
2020-11-24 13:11:05RocketMQ服务器启动linux环境下载编译源码 启动 Name Server启动 Broker关闭服务器windows环境RocketMQ发送消息和消费消息RocketMQ发送消息和消费消息,先启动消费者,然后再启动生产者添加依赖发送消息发送消息--... -
idea 错误: 找不到或无法加载主类_在开发环境下,基于Springboot的RocketMQ示例(含安装步骤、错误分析).....
2020-11-24 13:11:38RocketMQ服务器启动linux环境下载编译源码启动 Name Server启动 Broker关闭服务器windows环境RocketMQ发送消息和消费消息RocketMQ发送消息和消费消息,先启动消费者,然后再启动生产者添加依赖发送消息发送消息--... -
1.4 RabbitMQ-常用的linux命令
2019-04-23 13:57:30本文基于慕课网-阿神老师的课程-RocketMQ核心技术精讲与高并发抗压实战,仅作为个人的学习 记录 1.RabbitMQ基本操作 1.关闭应用 rabbitmqctl stop_app 2.启动应用 rabbitmqctl start_app 3.查看节点状态 ... -
阿里云RemotingTooMuchRequestException: sendDefaultImpl call timeout
2021-01-17 13:09:10一、问题 Exception in thread "main" org.apache.rocketmq.remoting.exception.RemotingTooMuchRequestException:...1.linux防火墙端口有没有关闭 systemctl status firewalld systemctl stop firewalld 2.是否是 -
No provider available from registry ip for service ...
2019-11-20 10:28:09浏览器访问就报错了 看zk日志有说是HelloServiceApi这个类的节点已经存在 但是我觉得跟这个问题不大 因为运行一次就会创建一个节点 多次的话肯定报节点存在的错 我的linux是虚拟机 并且已经关闭了防火墙 不存在端口...
-
简单增删查改新闻管理系统
-
FyreString:FyreString是PHP的免费开源字符串实用程序库-源码
-
《让心灵洒满阳光》读后感
-
全局绝热搜索算法的电路模型
-
龙芯生态应用开发基础:C语言精要
-
详解敏捷测试
-
Go-SpeedTest-Bot:帮助您使用手机管理所有节点的机器人-源码
-
如何快速有效学习CS知识
-
c语言实现去除字符串首尾空格
-
解决java.lang.ClassNotFoundException: com.mysql.cj.jdbc.Driver异常
-
工程制图 AutoCAD 2012 从二维到三维
-
物联网之mqtt实现(emqx+springboot+mqtt附源码)
-
2012年下半年 信息系统监理师 上午试卷 综合知识 软考真题【含答案和答案解析】
-
DHCP 动态主机配置服务(在Linux环境下,配置单网段或跨网段提)
-
MySQL你该了解的那些事【服务端篇】
-
Python启蒙到架构师的核心技术精讲课程
-
使用 Linux 平台充当 Router 路由器
-
Golang零基础-->高级编程
-
Galera 高可用 MySQL 集群(PXC v5.7+Hapro)
-
2016年上半年 信息系统监理师 上午试卷 综合知识 软考真题【含答案和答案解析】