zhouguofeng
- 浏览: 86417 次
-
文章分类
- 全部博客 (84)
- 前端 (2)
- 安装 (1)
- my (0)
- CentOS 下JDK安装 (1)
- nginx (2)
- JAVA多线程 (1)
- JAVA (7)
- ZooKeeper (4)
- XML格式化 (1)
- dubbox (2)
- JMS (3)
- mysql (3)
- spark (1)
- 传统企业转型升级趋势 (0)
- OFBiz (1)
- http://www.itmuch.com/page/2/ (0)
- DOCKER (2)
- Docker Compose (1)
- springboot mybatisplus (2)
- 将博客搬至CSDN (0)
- rabitmq (1)
- JaCoCo (1)
- springboot redis (1)
- redis (1)
最新评论
1.概述
RocketMQ是alibaba公司开源的一个纯java的开源消息中间件。
2.开发测试环境搭建
1. 安装&启动
进入到RocketMQ下载包解压的路径下
D:\machine\RocketMQ-3.0.8\RocketMQ-3.0.8>
接下来安装
执行下边的命令或者执行install.bat（在这个bat文件中的命令如下）对maven熟悉的一眼就知道是执行clean package install assembly等操作。
mvn -Dmaven.test.skip=true clean packageinstall assembly:assembly –U
操作信息如下：
[html] view plain copy 在CODE上查看代码片派生到我的代码片
[INFO] Scanning for projects...
[INFO] ------------------------------------------------------------------------
[INFO] Reactor Build Order:
[INFO]
[INFO] rocketmq-all 3.0.8
[INFO] rocketmq-remoting 3.0.8
[INFO] rocketmq-common 3.0.8
[INFO] rocketmq-client 3.0.8
[INFO] rocketmq-store 3.0.8
[INFO] rocketmq-broker 3.0.8
[INFO] rocketmq-tools 3.0.8
[INFO] rocketmq-research 3.0.8
[INFO] rocketmq-namesrv 3.0.8
[INFO] rocketmq-example 3.0.8
[INFO] rocketmq-qatest 3.0.8
[INFO]
[INFO] ------------------------------------------------------------------------
[INFO] Building rocketmq-all 3.0.8 3.0.8
[INFO]------------------------------------------------------------------------
[INFO]///省了…..编译打包过程
[INFO]------------------------------------------------------------------------
[INFO] Reactor Summary:
[INFO]
[INFO] rocketmq-all 3.0.8................................ SUCCESS [5.861s]
[INFO] rocketmq-remoting 3.0.8 ...........................SUCCESS [1.483s]
[INFO] rocketmq-common 3.0.8............................. SUCCESS [1.627s]
[INFO] rocketmq-client 3.0.8............................. SUCCESS [1.486s]
[INFO] rocketmq-store 3.0.8.............................. SUCCESS [1.398s]
[INFO] rocketmq-broker 3.0.8............................. SUCCESS [1.512s]
[INFO] rocketmq-tools 3.0.8.............................. SUCCESS [1.125s]
[INFO] rocketmq-research 3.0.8........................... SUCCESS [0.917s]
[INFO] rocketmq-namesrv 3.0.8............................ SUCCESS [0.609s]
[INFO] rocketmq-example 3.0.8............................ SUCCESS [0.604s]
[INFO] rocketmq-qatest 3.0.8............................. SUCCESS [0.057s]
[INFO] ------------------------------------------------------------------------
[INFO] BUILD SUCCESS
[INFO]------------------------------------------------------------------------
[INFO] Total time: 18.145s
[INFO] Finished at: Fri Mar 28 10:36:08 CST2014
[INFO] Final Memory: 60M/395M
[INFO]------------------------------------------------------------------------
D:\machine\RocketMQ-3.0.8\RocketMQ-3.0.8>
接下来把编译好的项目copy出来
[html] view plain copy
D:\machine\RocketMQ-3.0.8\RocketMQ-3.0.8\target> xcopy /E alibaba-rocketmq-3.0.8 D:\machine\RocketMQ-3.0.8\
D:\machine\RocketMQ-3.0.8>dir
驱动器 D 中的卷是 软件
卷的序列号是000F-1D4F
D:\machine\RocketMQ-3.0.8 的目录
2014/03/28 10:44 <DIR> .
2014/03/28 10:44 <DIR> ..
2014/03/28 10:44 <DIR> alibaba-rocketmq
2014/03/07 15:08 52pax_global_header
2014/03/28 10:37 <DIR> RocketMQ-3.0.8
1 个文件 52 字节
4 个目录 105,101,885,440 可用字节
D:\machine\RocketMQ-3.0.8>cd alibaba-rocketmq
启动服务
//启动mqnamesrv
[html] view plain copy 在CODE上查看代码片派生到我的代码片
D:\machine\RocketMQ-3.0.8\alibaba-rocketmq>start/b bin/mqnamesrv.exe >D:\logs\alibaba-rocketmq/mqnamesrv.log
可以通过jps查看一下是不是有了RocketMQ的进程，如下方的6484
[html] view plain copy 在CODE上查看代码片派生到我的代码片
C:\Users\houchangren>jps -v
6484 -Djava.ext.dirs=D:\machine\RocketMQ-3.0.8\alibaba-rocketmq\bin/../lib-Drocketmq.home.dir=D:\machine\RocketMQ-3.0.8\alibaba-rocketmq\bin/..-XX:MaxNewSize=512M -XX:MaxPermSize=128M -XX:NewSit abort
6876 JConsole -Denv.class.path=D:\ProgramFiles\Java\jdk1.6.0_26\lib -Dapplication.home=D:\Program Files\Java\jdk1.6.0_26-Djconsole.showOutputViewer
6936org.eclipse.equinox.launcher_1.2.0.v20110502.jar -Dosgi.requiredJavaVersion=1.5-Xms40m -Xmx512m -XX:MaxPermSize=256m
4140 Jps -Denv.class.path=D:\ProgramFiles\Java\jdk1.6.0_26\lib -Dapplication.home=D:\Program Files\Java\jdk1.6.0_26-Xms8m
看日志中信息D:\logs\alibaba-rocketmq/mqnamesrv.log
The Name Server boot success.
//启动broker
[html] view plain copy 在CODE上查看代码片派生到我的代码片
D:\machine\RocketMQ-3.0.8\alibaba-rocketmq>start/b bin/mqbroker.exe -n "10.57.41.19:9876">D:\logs\alibaba-rocketmq/mqbroker.log
看日志中信息D:\logs\alibaba-rocketmq/mqbroker.log
The broker[houchangren, 10.57.41.19:10911]boot success.
2.项目实例
1. 创建maven项目
Pom.xml文件如下
[html] view plain copy 在CODE上查看代码片派生到我的代码片
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0http://maven.apache.org/maven-v4_0_0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.ruishenh</groupId>
<artifactId>gomeTest</artifactId>
<packaging>war</packaging>
<version>0.0.1-SNAPSHOT</version>
<name>gomeTest Maven Webapp</name>
<url>http://maven.apache.org</url>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<dependency>
<groupId>com.alibaba.rocketmq</groupId>
<artifactId>rocketmq-client</artifactId>
<version>3.0.8</version>
</dependency>
<dependency>
<groupId>com.alibaba.rocketmq</groupId>
<artifactId>rocketmq-all</artifactId>
<version>3.0.8</version>
<type>pom</type>
</dependency>
<dependency>
<groupId>ch.qos.logback</groupId>
<artifactId>logback-classic</artifactId>
<version>1.1.1</version>
</dependency>
<dependency>
<groupId>ch.qos.logback</groupId>
<artifactId>logback-core</artifactId>
<version>1.1.1</version>
</dependency>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.10</version>
<scope>test</scope>
</dependency>
</dependencies>
<build>
<finalName>gomeTest</finalName>
</build>
</project>
2. 编写消息产生者Producer
文件路径：/gomeTest/src/main/java/com/ruishenh/rocketmq/example/Producer.java
[html] view plain copy 在CODE上查看代码片派生到我的代码片
package com.ruishenh.rocketmq.example;
import java.util.concurrent.TimeUnit;
import com.alibaba.rocketmq.client.exception.MQClientException;
import com.alibaba.rocketmq.client.producer.DefaultMQProducer;
import com.alibaba.rocketmq.client.producer.SendResult;
import com.alibaba.rocketmq.common.message.Message;
public classProducer {
public static void main(String[] args) throws MQClientException,
InterruptedException{
/**
* 一个应用创建一个Producer，由应用来维护此对象，可以设置为全局对象或者单例<br>
* 注意：ProducerGroupName需要由应用来保证唯一<br>
* ProducerGroup这个概念发送普通的消息时，作用不大，但是发送分布式事务消息时，比较关键，
* 因为服务器会回查这个Group下的任意一个Producer
*/
final DefaultMQProducerproducer = newDefaultMQProducer("ProducerGroupName");
producer.setNamesrvAddr("10.57.41.19:9876");
producer.setInstanceName("Producer");
/**
* Producer对象在使用之前必须要调用start初始化，初始化一次即可<br>
* 注意：切记不可以在每次发送消息时，都调用start方法
*/
producer.start();
/**
* 下面这段代码表明一个Producer对象可以发送多个topic，多个tag的消息。
* 注意：send方法是同步调用，只要不抛异常就标识成功。但是发送成功也可会有多种状态，<br>
* 例如消息写入Master成功，但是Slave不成功，这种情况消息属于成功，但是对于个别应用如果对消息可靠性要求极高，<br>
* 需要对这种情况做处理。另外，消息可能会存在发送失败的情况，失败重试由应用来处理。
*/
for (int i = 0; i < 10; i++){
try {
{
Messagemsg = newMessage("TopicTest1",// topic
"TagA",// tag
"OrderID001",// key
("Hello MetaQA").getBytes());// body
SendResultsendResult = producer.send(msg);
System.out.println(sendResult);
}
{
Messagemsg = newMessage("TopicTest2",// topic
"TagB",// tag
"OrderID0034",// key
("Hello MetaQB").getBytes());// body
SendResultsendResult = producer.send(msg);
System.out.println(sendResult);
}
{
Messagemsg = newMessage("TopicTest3",// topic
"TagC",// tag
"OrderID061",// key
("Hello MetaQC").getBytes());// body
SendResultsendResult = producer.send(msg);
System.out.println(sendResult);
}
}catch(Exception e) {
e.printStackTrace();
}
TimeUnit.MILLISECONDS.sleep(1000);
}
/**
* 应用退出时，要调用shutdown来清理资源，关闭网络连接，从MetaQ服务器上注销自己
* 注意：我们建议应用在JBOSS、Tomcat等容器的退出钩子里调用shutdown方法
*/
// producer.shutdown();
Runtime.getRuntime().addShutdownHook(new Thread(new Runnable() {
public void run() {
producer.shutdown();
}
}));
System.exit(0);
}
}
3. 编写消息消费者Consumer
文件路径：Test/src/main/java/com/ruishenh/rocketmq/example/PushConsumer.java
[java] view plain copy 在CODE上查看代码片派生到我的代码片
package com.ruishenh.rocketmq.example;
import java.util.List;
importcom.alibaba.rocketmq.client.consumer.DefaultMQPushConsumer;
importcom.alibaba.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
importcom.alibaba.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
importcom.alibaba.rocketmq.client.consumer.listener.MessageListenerConcurrently;
importcom.alibaba.rocketmq.client.exception.MQClientException;
importcom.alibaba.rocketmq.common.message.MessageExt;
public class PushConsumer {
/**
* 当前例子是PushConsumer用法，使用方式给用户感觉是消息从RocketMQ服务器推到了应用客户端。<br>
* 但是实际PushConsumer内部是使用长轮询Pull方式从MetaQ服务器拉消息，然后再回调用户Listener方法<br>
*/
publicstatic void main(String[] args) throws InterruptedException,
MQClientException{
/**
* 一个应用创建一个Consumer，由应用来维护此对象，可以设置为全局对象或者单例<br>
* 注意：ConsumerGroupName需要由应用来保证唯一
*/
DefaultMQPushConsumerconsumer = new DefaultMQPushConsumer(
"ConsumerGroupName");
consumer.setNamesrvAddr("10.57.41.19:9876");
consumer.setInstanceName("Consumber");
/**
* 订阅指定topic下tags分别等于TagA或TagC或TagD
*/
consumer.subscribe("TopicTest1","TagA || TagC || TagD");
/**
* 订阅指定topic下所有消息<br>
* 注意：一个consumer对象可以订阅多个topic
*/
consumer.subscribe("TopicTest2","*");
consumer.registerMessageListener(newMessageListenerConcurrently() {
publicConsumeConcurrentlyStatus consumeMessage(
List<MessageExt>msgs, ConsumeConcurrentlyContext context) {
System.out.println(Thread.currentThread().getName()
+" Receive New Messages: " + msgs.size());
MessageExtmsg = msgs.get(0);
if(msg.getTopic().equals("TopicTest1")) {
//执行TopicTest1的消费逻辑
if(msg.getTags() != null && msg.getTags().equals("TagA")) {
//执行TagA的消费
System.out.println(newString(msg.getBody()));
}else if (msg.getTags() != null
&&msg.getTags().equals("TagC")) {
//执行TagC的消费
System.out.println(newString(msg.getBody()));
}else if (msg.getTags() != null
&&msg.getTags().equals("TagD")) {
//执行TagD的消费
System.out.println(newString(msg.getBody()));
}
}else if (msg.getTopic().equals("TopicTest2")) {
System.out.println(newString(msg.getBody()));
}
returnConsumeConcurrentlyStatus.CONSUME_SUCCESS;
}
});
/**
* Consumer对象在使用之前必须要调用start初始化，初始化一次即可<br>
*/
consumer.start();
System.out.println("ConsumerStarted.");
}
}
Producer执行console:
12:05:39.399 [main] DEBUGi.n.u.i.l.InternalLoggerFactory - Using SLF4J as the default logging framework
12:05:39.405 [main] DEBUGi.n.c.MultithreadEventLoopGroup - -Dio.netty.eventLoopThreads: 8
12:05:39.411 [main] DEBUGi.n.util.internal.PlatformDependent - Platform: Windows
12:05:39.411 [main] DEBUGi.n.util.internal.PlatformDependent - Java version: 6
12:05:39.411 [main] DEBUGi.n.util.internal.PlatformDependent - -Dio.netty.noUnsafe: false
12:05:39.412 [main] DEBUGi.n.util.internal.PlatformDependent0 - java.nio.ByteBuffer.cleaner: available
12:05:39.413 [main] DEBUGi.n.util.internal.PlatformDependent0 - java.nio.Buffer.address: available
12:05:39.413 [main] DEBUGi.n.util.internal.PlatformDependent0 - sun.misc.Unsafe.theUnsafe: available
12:05:39.413 [main] DEBUGi.n.util.internal.PlatformDependent0 - sun.misc.Unsafe.copyMemory: available
12:05:39.413 [main] DEBUGi.n.util.internal.PlatformDependent0 - java.nio.Bits.unaligned: true
12:05:39.413 [main] DEBUGi.n.util.internal.PlatformDependent - sun.misc.Unsafe: available
12:05:39.413 [main] DEBUGi.n.util.internal.PlatformDependent - -Dio.netty.noJavassist: false
12:05:39.414 [main] DEBUGi.n.util.internal.PlatformDependent - Javassist: unavailable
12:05:39.414 [main] DEBUGi.n.util.internal.PlatformDependent - You don't have Javassist in your classpath or you don't have enough permission to load dynamically generatedclasses. Please check the configurationfor better performance.
12:05:39.414 [main] DEBUGi.n.util.internal.PlatformDependent - -Dio.netty.noPreferDirect: false
12:05:39.429 [main] DEBUGio.netty.channel.nio.NioEventLoop - -Dio.netty.noKeySetOptimization: false
12:05:39.429 [main] DEBUGio.netty.channel.nio.NioEventLoop - -Dio.netty.selectorAutoRebuildThreshold:512
12:05:39.481 [main] DEBUGi.n.util.internal.ThreadLocalRandom - -Dio.netty.initialSeedUniquifier:0x653a966ddb02e036
12:05:39.523[NettyClientWorkerThread_1] DEBUG io.netty.util.ResourceLeakDetector --Dio.netty.noResourceLeakDetection: false
SendResult [sendStatus=SEND_OK,msgId=0A39291300002A9F000000000001BA16, messageQueue=MessageQueue[topic=TopicTest1, brokerName=houchangren, queueId=0], queueOffset=66]
SendResult [sendStatus=SEND_OK,msgId=0A39291300002A9F000000000001BAAB, messageQueue=MessageQueue [topic=TopicTest2,brokerName=houchangren, queueId=0], queueOffset=66]
SendResult [sendStatus=SEND_OK,msgId=0A39291300002A9F000000000001BB41, messageQueue=MessageQueue[topic=TopicTest3, brokerName=houchangren, queueId=0], queueOffset=66]
SendResult [sendStatus=SEND_OK,msgId=0A39291300002A9F000000000001BBD6, messageQueue=MessageQueue[topic=TopicTest1, brokerName=houchangren, queueId=1], queueOffset=66]
SendResult [sendStatus=SEND_OK,msgId=0A39291300002A9F000000000001BC6B, messageQueue=MessageQueue [topic=TopicTest2,brokerName=houchangren, queueId=1], queueOffset=66]
SendResult [sendStatus=SEND_OK,msgId=0A39291300002A9F000000000001BD01, messageQueue=MessageQueue[topic=TopicTest3, brokerName=houchangren, queueId=1], queueOffset=66]
SendResult [sendStatus=SEND_OK,msgId=0A39291300002A9F000000000001BD96, messageQueue=MessageQueue[topic=TopicTest1, brokerName=houchangren, queueId=2], queueOffset=61]
SendResult [sendStatus=SEND_OK,msgId=0A39291300002A9F000000000001BE2B, messageQueue=MessageQueue [topic=TopicTest2,brokerName=houchangren, queueId=2], queueOffset=61]
SendResult [sendStatus=SEND_OK,msgId=0A39291300002A9F000000000001BEC1, messageQueue=MessageQueue[topic=TopicTest3, brokerName=houchangren, queueId=2], queueOffset=61]
SendResult [sendStatus=SEND_OK,msgId=0A39291300002A9F000000000001BF56, messageQueue=MessageQueue[topic=TopicTest1, brokerName=houchangren, queueId=3], queueOffset=61]
SendResult [sendStatus=SEND_OK,msgId=0A39291300002A9F000000000001BFEB, messageQueue=MessageQueue[topic=TopicTest2, brokerName=houchangren, queueId=3], queueOffset=61]
SendResult [sendStatus=SEND_OK,msgId=0A39291300002A9F000000000001C081, messageQueue=MessageQueue[topic=TopicTest3, brokerName=houchangren, queueId=3], queueOffset=61]
SendResult [sendStatus=SEND_OK,msgId=0A39291300002A9F000000000001C116, messageQueue=MessageQueue[topic=TopicTest1, brokerName=houchangren, queueId=0], queueOffset=67]
SendResult [sendStatus=SEND_OK,msgId=0A39291300002A9F000000000001C1AB, messageQueue=MessageQueue[topic=TopicTest2, brokerName=houchangren, queueId=0], queueOffset=67]
SendResult [sendStatus=SEND_OK,msgId=0A39291300002A9F000000000001C241, messageQueue=MessageQueue[topic=TopicTest3, brokerName=houchangren, queueId=0], queueOffset=67]
SendResult [sendStatus=SEND_OK,msgId=0A39291300002A9F000000000001C2D6, messageQueue=MessageQueue[topic=TopicTest1, brokerName=houchangren, queueId=1], queueOffset=67]
SendResult [sendStatus=SEND_OK,msgId=0A39291300002A9F000000000001C36B, messageQueue=MessageQueue[topic=TopicTest2, brokerName=houchangren, queueId=1], queueOffset=67]
SendResult [sendStatus=SEND_OK,msgId=0A39291300002A9F000000000001C401, messageQueue=MessageQueue[topic=TopicTest3, brokerName=houchangren, queueId=1], queueOffset=67]
SendResult [sendStatus=SEND_OK,msgId=0A39291300002A9F000000000001C496, messageQueue=MessageQueue[topic=TopicTest1, brokerName=houchangren, queueId=2], queueOffset=62]
SendResult [sendStatus=SEND_OK,msgId=0A39291300002A9F000000000001C52B, messageQueue=MessageQueue[topic=TopicTest2, brokerName=houchangren, queueId=2], queueOffset=62]
SendResult [sendStatus=SEND_OK,msgId=0A39291300002A9F000000000001C5C1, messageQueue=MessageQueue [topic=TopicTest3,brokerName=houchangren, queueId=2], queueOffset=62]
SendResult [sendStatus=SEND_OK,msgId=0A39291300002A9F000000000001C656, messageQueue=MessageQueue[topic=TopicTest1, brokerName=houchangren, queueId=3], queueOffset=62]
SendResult [sendStatus=SEND_OK,msgId=0A39291300002A9F000000000001C6EB, messageQueue=MessageQueue[topic=TopicTest2, brokerName=houchangren, queueId=3], queueOffset=62]
SendResult [sendStatus=SEND_OK,msgId=0A39291300002A9F000000000001C781, messageQueue=MessageQueue [topic=TopicTest3,brokerName=houchangren, queueId=3], queueOffset=62]
SendResult [sendStatus=SEND_OK,msgId=0A39291300002A9F000000000001C816, messageQueue=MessageQueue[topic=TopicTest1, brokerName=houchangren, queueId=0], queueOffset=68]
SendResult [sendStatus=SEND_OK,msgId=0A39291300002A9F000000000001C8AB, messageQueue=MessageQueue[topic=TopicTest2, brokerName=houchangren, queueId=0], queueOffset=68]
SendResult [sendStatus=SEND_OK,msgId=0A39291300002A9F000000000001C941, messageQueue=MessageQueue[topic=TopicTest3, brokerName=houchangren, queueId=0], queueOffset=68]
SendResult [sendStatus=SEND_OK,msgId=0A39291300002A9F000000000001C9D6, messageQueue=MessageQueue[topic=TopicTest1, brokerName=houchangren, queueId=1], queueOffset=68]
SendResult [sendStatus=SEND_OK,msgId=0A39291300002A9F000000000001CA6B, messageQueue=MessageQueue[topic=TopicTest2, brokerName=houchangren, queueId=1], queueOffset=68]
SendResult [sendStatus=SEND_OK,msgId=0A39291300002A9F000000000001CB01, messageQueue=MessageQueue[topic=TopicTest3, brokerName=houchangren, queueId=1], queueOffset=68]
Consumer执行console:
12:00:49.539 [main] DEBUGi.n.u.i.l.InternalLoggerFactory - Using SLF4J as the default logging framework
12:00:49.545 [main] DEBUGi.n.c.MultithreadEventLoopGroup - -Dio.netty.eventLoopThreads: 8
12:00:49.550 [main] DEBUGi.n.util.internal.PlatformDependent - Platform: Windows
12:00:49.550 [main] DEBUGi.n.util.internal.PlatformDependent - Java version: 6
12:00:49.550 [main] DEBUGi.n.util.internal.PlatformDependent - -Dio.netty.noUnsafe: false
12:00:49.551 [main] DEBUGi.n.util.internal.PlatformDependent0 - java.nio.ByteBuffer.cleaner: available
12:00:49.552 [main] DEBUGi.n.util.internal.PlatformDependent0 - java.nio.Buffer.address: available
12:00:49.552 [main] DEBUGi.n.util.internal.PlatformDependent0 - sun.misc.Unsafe.theUnsafe: available
12:00:49.552 [main] DEBUGi.n.util.internal.PlatformDependent0 - sun.misc.Unsafe.copyMemory: available
12:00:49.552 [main] DEBUGi.n.util.internal.PlatformDependent0 - java.nio.Bits.unaligned: true
12:00:49.552 [main] DEBUGi.n.util.internal.PlatformDependent - sun.misc.Unsafe: available
12:00:49.552 [main] DEBUGi.n.util.internal.PlatformDependent - -Dio.netty.noJavassist: false
12:00:49.553 [main] DEBUGi.n.util.internal.PlatformDependent - Javassist: unavailable
12:00:49.553 [main] DEBUGi.n.util.internal.PlatformDependent - You don't have Javassist in your classpath or you don't have enough permission to load dynamically generatedclasses. Please check the configurationfor better performance.
12:00:49.553 [main] DEBUGi.n.util.internal.PlatformDependent - -Dio.netty.noPreferDirect: false
12:00:49.568 [main] DEBUGio.netty.channel.nio.NioEventLoop - -Dio.netty.noKeySetOptimization: false
12:00:49.568 [main] DEBUGio.netty.channel.nio.NioEventLoop - -Dio.netty.selectorAutoRebuildThreshold:512
12:00:49.622 [main] DEBUGi.n.util.internal.ThreadLocalRandom - -Dio.netty.initialSeedUniquifier:0x2e4f8e2e67b4cc9b
12:00:49.663[NettyClientWorkerThread_1] DEBUG io.netty.util.ResourceLeakDetector --Dio.netty.noResourceLeakDetection: false
Consumer Started.
ConsumeMessageThread-ConsumerGroupName-4Receive New Messages: 1
Hello MetaQA
ConsumeMessageThread-ConsumerGroupName-2Receive New Messages: 1
Hello MetaQA
ConsumeMessageThread-ConsumerGroupName-1Receive New Messages: 1
Hello MetaQA
ConsumeMessageThread-ConsumerGroupName-6Receive New Messages: 1
Hello MetaQA
ConsumeMessageThread-ConsumerGroupName-5Receive New Messages: 1
ConsumeMessageThread-ConsumerGroupName-3Receive New Messages: 1
Hello MetaQA
ConsumeMessageThread-ConsumerGroupName-8Receive New Messages: 1
Hello MetaQA
Hello MetaQA
ConsumeMessageThread-ConsumerGroupName-9Receive New Messages: 1
Hello MetaQA
ConsumeMessageThread-ConsumerGroupName-10Receive New Messages: 1
Hello MetaQA
ConsumeMessageThread-ConsumerGroupName-7Receive New Messages: 1
Hello MetaQA
ConsumeMessageThread-ConsumerGroupName-11Receive New Messages: 1
Hello MetaQB
ConsumeMessageThread-ConsumerGroupName-12Receive New Messages: 1
Hello MetaQB
ConsumeMessageThread-ConsumerGroupName-13Receive New Messages: 1
Hello MetaQB
ConsumeMessageThread-ConsumerGroupName-15Receive New Messages: 1
Hello MetaQB
ConsumeMessageThread-ConsumerGroupName-14Receive New Messages: 1
Hello MetaQB
ConsumeMessageThread-ConsumerGroupName-16Receive New Messages: 1
ConsumeMessageThread-ConsumerGroupName-17Receive New Messages: 1
Hello MetaQB
Hello MetaQB
ConsumeMessageThread-ConsumerGroupName-18Receive New Messages: 1
ConsumeMessageThread-ConsumerGroupName-19Receive New Messages: 1
Hello MetaQB
Hello MetaQB
ConsumeMessageThread-ConsumerGroupName-20Receive New Messages: 1
Hello MetaQB
参考文档：http://sofar.blog.51cto.com/353572/1540874
分享到：
发表评论
相关推荐
RocketMQ 是一款开源的分布式消息中间件，由阿里巴巴开发并贡献给Apache基金会，它主要用于解决大规模分布式系统中的异步处理和解耦问题。本话题主要围绕RocketMQ的安装以及RocketMQ控制台JAR包的使用进行详细介绍。...
RocketMQ是阿里巴巴开源的一款分布式消息中间件，广泛应用于大数据、实时计算、微服务等领域。RocketMQ Console是RocketMQ的管理控制台，它提供了一个图形化的界面，方便用户监控和管理RocketMQ集群的状态，进行消息...
RocketMQ管理工具，原名为`rocketmq-console`，在发展过程中独立成为一个单独的项目，并更名为`rocketmq-dashboard`。这个工具是由阿里巴巴开源出来的一个强大且直观的管理界面，旨在简化RocketMQ消息中间件的监控、...
RocketMQ是一款开源的消息中间件，由阿里巴巴开发并贡献给Apache基金会，它被广泛应用于分布式系统中，用于处理大规模的消息传递。RocketMQConsole是RocketMQ的一个重要组成部分，它提供了可视化的管理界面，使得...
RocketMQ-Connect 二次开发源码。RocketMQ-Connect 二次开发源码。RocketMQ-Connect 二次开发源码。RocketMQ-Connect 二次开发源码。RocketMQ-Connect 二次开发源码。RocketMQ-Connect 二次开发源码。RocketMQ-...
RocketMQ是阿里巴巴开源的一款分布式消息中间件，广泛应用于大规模分布式系统中的消息传递。RocketMQ具有高可用、高并发、低延迟、稳定可靠等特性，支持发布/订阅模式和点对点模式的消息传递，适用于交易系统、...
RocketMQ是一款开源的消息中间件，由阿里巴巴开发并贡献给Apache软件基金会，被广泛应用于大数据、实时计算、微服务等场景。RocketMQ的核心功能包括消息发送与接收、消息队列、消息回溯、高可用保障、分布式事务等。...
【宝塔部署RocketMQ+可视化面板】：在IT行业中，RocketMQ是一款由阿里巴巴开源的分布式消息中间件，广泛应用于大数据处理、实时交易等场景。它提供了高可用、高并发的消息传输能力，支持发布/订阅模式和点对点模式，...
RocketMQ Dashboard 是一个基于Web的监控和管理工具，主要用于阿里巴巴开源的分布式消息中间件RocketMQ。RocketMQ是一款高效、稳定、可伸缩的分布式消息系统，广泛应用于大数据、实时计算、微服务等领域。RocketMQ ...
RocketMQ是一款由阿里巴巴开源的分布式消息中间件，它在处理高并发、大数据量的消息传递方面表现出色。RocketMQ Console是其官方提供的一个图形化管理工具，用于方便运维人员监控和管理RocketMQ集群的状态。这个...
安装 RocketMQ 1. 下载 rocketmq 二进制文件 wget --no-check-certificate https://dlcdn.apache.org/rocketmq/4.9.2/rocketmq-all-4.9.2-bin-release.zip 2. 解压缩 rocketmq 将 rocketmq 解压到 /usr/local/ 目录 ...
RocketMQ 是一个开源的分布式消息中间件，常用于构建高可用、高可靠的消息传递系统。在本文中，我们将深入探讨 RocketMQ 的应用、安装过程以及使用方法，以便更好地理解和掌握这个强大的工具。 首先，让我们来看...
RocketMQ是一款由阿里巴巴开源的分布式消息中间件，它在大规模分布式系统中被广泛用于实现可靠的消息传递和数据交换。RocketMQ的设计目标是提供高吞吐量、低延迟、高可用性和可扩展性的消息服务。本压缩包“rocketMQ...
Rocketmq-Console是Apache RocketMQ项目的一个重要组件，主要用于提供RocketMQ消息中间件的监控与管理界面。在本文中，我们将深入探讨Rocketmq-Console的源码，了解其设计思想和实现机制，以及如何解决从GitHub下载...
RocketMQ-Dashboard是一款专为Apache RocketMQ设计的可视化管理工具，它允许用户通过Web界面来监控、管理和操作RocketMQ集群，极大地简化了RocketMQ的日常运维工作。在本资源中，您将找到一个可以直接启动的jar包，...
RocketMQ是一款高性能、分布式的消息中间件，常用于大型分布式系统中的消息传递。Prometheus是一款流行的开源监控和警报工具，可以收集并存储时间序列数据，为包括RocketMQ在内的各种服务提供详细的监控。在这个场景...
【标题】：SpringBoot整合RocketMQ源码解析 在当今的微服务架构中，消息队列（Message Queue）已经成为解耦、异步处理以及提高系统可靠性的关键组件。本主题将深入探讨如何在SpringBoot应用中整合Apache RocketMQ，...
赠送jar包：rocketmq-client-3.6.2.Final.jar； 赠送原API文档：rocketmq-client-3.6.2.Final-javadoc.jar； 赠送源代码：rocketmq-client-3.6.2.Final-sources.jar； 包含翻译后的API文档：rocketmq-client-...
RocketMQ是阿里巴巴开源的一款分布式消息中间件，广泛应用于大数据、实时计算、微服务等领域。RocketMQ Console是一款基于Web的管理工具，用于可视化管理和监控RocketMQ集群。本压缩包提供的"rocketmq-console"包含...
RocketMQ，作为阿里巴巴开源的一款高性能、高可用、稳定可靠的消息中间件，已经在多个大型企业和项目中得到广泛应用。5.1.3版本的RocketMQ在前代基础上进行了诸多优化和改进，旨在提供更强大的消息处理能力和服务...