设为首页 收藏本站

运维网

 找回密码
 立即注册
查看: 10486|回复: 0

[经验分享] RocketMQ在windows上安装和开发使用

[复制链接]
4若
累计签到：1 天
连续签到：1 天
发表于 2014-3-31 09:02:38 | 显示全部楼层 |阅读模式
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

操作信息如下：
[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 plaincopy
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
D:\machine\RocketMQ-3.0.8\alibaba-rocketmq>start/b bin/mqnamesrv.exe  >D:\logs\alibaba-rocketmq/mqnamesrv.log  


可以通过jps查看一下是不是有了RocketMQ的进程，如下方的6484
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
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文件如下
<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

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
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

windows, 开发

相关帖子


运维网声明 1、欢迎大家加入本站运维交流群:群②:261659950 群⑤:202807635 群⑦870801961 群⑧679858003
2、本站所有主题由该帖子作者发表，该帖子作者与运维网享有帖子相关版权
3、所有作品的著作权均归原作者享有，请您和我们一样尊重他人的著作权等合法权益。如果您对作品感到满意，请购买正版
4、禁止制作、复制、发布和传播具有反动、淫秽、色情、暴力、凶杀等内容的信息，一经发现立即删除。若您因此触犯法律，一切后果自负，我们对此不承担任何责任
5、所有资源均系网友上传或者通过网络收集，我们仅提供一个展示、介绍、观摩学习的平台，我们不对其内容的准确性、可靠性、正当性、安全性、合法性等负责，亦不承担任何法律责任
6、所有作品仅供您个人学习、研究或欣赏，不得用于商业或者其他用途，否则，一切后果均由您自己承担，我们对此不承担任何法律责任
7、如涉及侵犯版权等问题，请您及时通知我们，我们将立即采取措施予以解决
8、联系人Email：admin@iyunv.com 网址：www.yunweiku.com

所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其承担任何法律责任,如涉及侵犯版权等问题,请您及时通知我们,我们将立即处理,联系人Email:kefu@iyunv.com,QQ:1061981298 本贴地址：https://www.yunweiku.com/thread-16475-1-1.html 上篇帖子： macbook pro安装了win8 ，但是osx删掉了，怎么按装回去，成为双系统 下篇帖子： wowza4安装包(含windows和Linux两个) windows 开发
回复

使用道具 举报

返回列表
高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

扫码加入运维网微信交流群X

扫码加入运维网微信交流群

扫描二维码加入运维网微信交流群，最新一手资源尽在官方微信交流群！快快加入我们吧...

扫描微信二维码查看详情

客服 E-mail:iyunvcom@gmail.com

本站由青云提供云计算服务

运维网--中国最专业的运维工程师交流社区

豫ICP备20007574号-1 Copyright © 2012-2025

关于我们

发展历程

联系我们

关注我们

广告服务

广告案例

隐私条款

免责声明

用户登录

用户注册

版主守则

申请版主

手机版

金币获取

帮助中心

每日签到

Good Good

Study

Day Day

UP


客服E-mail:kefu@iyunv.com 客服QQ：1061981298


QQ群⑦：运维网交流群⑦ QQ群⑧：运维网交流群⑧ k8s群：运维网kubernetes交流群


提醒：禁止发布任何违反国家法律、法规的言论与图片等内容；本站内容均来自个人观点与网络等信息，非本站认同之观点.


本站大部分资源是网友从网上搜集分享而来，其版权均归原作者及其网站所有，我们尊重他人的合法权益，如有内容侵犯您的合法权益，请及时与我们联系进行核实删除！



合作伙伴: 青云cloud

快速回复 返回顶部 返回列表