文档章节

RocketMQ在windows上安装和开发使用

偶尔诗文
 偶尔诗文
发布于 2015/08/25 13:55
字数 2511
阅读 669
收藏 3
点赞 0
评论 2
  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出来(也就是把target目录下的文件拷出来放在你想放的位置)
    [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 DefaultMQProducer  producer = new  DefaultMQProducer("ProducerGroupName");  
          producer.setNamesrvAddr("10.57.41.19:9876");  //需要些实际电脑的IP地址,并且电脑环境变量端口号与此端口号一致
          producer.setInstanceName("Producer");  

          /**  
           * Producer对象在使用之前必须要调用start初始化,初始化一次即可<br>  
           * 注意:切记不可以在每次发送消息时,都调用start方法  
           */  
          producer.start();  
          /**  
           * 下面这段代码表明一个Producer对象可以发送多个topic,多个tag的消息。  
           * 注意:send方法是同步调用,只要不抛异常就标识成功。但是发送成功也可会有多种状态,  
           * 例如消息写入Master成功,但是Slave不成功,这种情况消息属于成功,但是对于个别应用如果对消息可靠性要求极高,
           * 需要对这种情况做处理。另外,消息可能会存在发送失败的情况,失败重试由应用来处理。  
           */  
          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来清理资源,关闭网络连接,从rocketMQ服务器上注销自己  
           * 注意:我们建议应用在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服务器推到了应用客户端。
              * 但是实际PushConsumer内部是使用长轮询Pull方式从MetaQ服务器拉消息,然后再回调用户Listener方法
              */  
             publicstatic void main(String[] args) throws InterruptedException,  
                                MQClientException{  
                       /**
                        * 一个应用创建一个Consumer,由应用来维护此对象,可以设置为全局对象或者单例
                        * 注意:ConsumerGroupName需要由应用来保证唯一
                        */  
                       DefaultMQPushConsumer  consumer = new DefaultMQPushConsumer( "ConsumerGroupName");  
                       consumer.setNamesrvAddr("10.57.41.19:9876");  //需要些实际电脑的IP地址,并且电脑环境变量端口号与此端口号一致
                       consumer.setInstanceName("Consumber");  
                       /**
                        * 订阅指定topic下tags分别等于TagA或TagC或TagD
                        */  
                       consumer.subscribe("TopicTest1","TagA || TagC || TagD");  
                       /**
                        * 订阅指定topic下所有消息<br>
                        * 注意:一个consumer对象可以订阅多个topic
                        */  
                       consumer.subscribe("TopicTest2","*");  
                       consumer.registerMessageListener(new  MessageListenerConcurrently() {  
                                public  ConsumeConcurrentlyStatus consumeMessage( List<MessageExt>msgs, ConsumeConcurrentlyContext context) {  
                                         System.out.println(Thread.currentThread().getName() +" Receive New Messages: " + msgs.size());  
                                         MessageExt  msg = 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初始化,初始化一次即可

                        */  
                       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://www.iyunv.com/thread-16475-1-1.html

共有 人打赏支持
偶尔诗文
粉丝 9
博文 135
码字总数 59732
作品 0
沈阳
高级程序员
加载中

评论(2)

偶尔诗文
偶尔诗文

引用来自“moluqianli”的评论

mqbroker.exe 我怎么找不到啊???
可以去rocketMQ的GitHub下载https://github.com/alibaba/RocketMQ
陌路千里
陌路千里
mqbroker.exe 我怎么找不到啊???
RocketMQ:一个纯java的开源消息中间件--开发测试环境搭建

一、简介 RocketMQ的前身是Metaq,当Metaq3.0发布时,产品名称改为RocketMQ MetaQ2.x版本由于依赖了alibaba公司内部其他系统,对于公司外部用户使用不够友好,推荐使用3.0版本。 项目地址:h...

cloud-coder
2014/02/18
0
15
让你rocketmq用得比预期要好的 1 种方法

匠心零度 转载请注明原创出处,谢谢! 方法 让你rocketmq用得比预期要好的 1 种方法:就是认真思考下面的几个问题: 使用rocketmq能解决那些问题?那些问题是不能解决的? 我们什么时候该添加...

匠心零度
04/19
0
0
《Apache RocketMQ用户指南》官方文档

RocketMQ–导读 原文链接 译者:小村长 最近两个项目中用到了RocketMQ消息中间件,每次都是在网上找几个Demo,而没有去看它的官方文档。年前面试某大型互联网企业。RocketMQ多有提及。今借此...

小村长
01/23
0
0
rocketmq番外篇(一):开发命令行

匠心零度 转载请注明原创出处,谢谢! 说在前面 虽然是以rocketmq引出的开发命令行,但是任何java应用如果需要都可以借鉴引用,也是通用技术。 主题 rocketmq使用例子 Apache Commons CLI简介...

匠心零度
04/17
0
0
RocketMQ部分数据消费不了问题排查

问题现象 今天忽然收到RocketMQ预警信息如下: 提醒有部分数据没有消费,产生堆积情况。 打开RocketMq-Console-Ng查看如下图形式: 备注:第一反应是Consumer Group内订阅了多个topic?(为什...

匠心零度
05/14
0
0
RocketMQ与Kafka对比

RocketMQ与Kafka对比(18项差异) 淘宝内部的交易系统使用了淘宝自主研发的Notify消息中间件,使用Mysql作为消息存储媒介,可完全水平扩容,为了进一步降低成本,我们认为存储部分可以进一步...

莫问viva
2015/05/08
0
0
linux下RocketMQ的安装

下载和构建 从 https://www.apache.org/dyn/closer.cgi?path=rocketmq/4.2.0/rocketmq-all-4.2.0-source-release.zip 下载 4.2.0 的源码版本,执行以下命令来解压4.2.0源码版本并构建二进制文...

yushiwh
05/21
0
0
CentOS7.3安装rocketmq

安装环境 安装 编译克隆 构建速度较慢 最好自己搭建一个nexus, 感兴趣的参考博客 配置jvm内存 配置启动mqnamesrv 配置启动broker 关闭服务器 配置windows控制台github rocketmq-console 文件...

paascloud
2017/09/04
0
0
消息中间件—RocketMQ的RPC通信(二)

文章摘要:如何设计RPC通信层模型是任何一款性能强劲的MQ所要重点考虑的问题 在(一)篇中主要介绍了RocketMQ的协议格式,消息编解码,通信方式(同步/异步/单向)、消息发送/接收以及异步回调...

癫狂侠
07/01
0
0
RocketMQ(八):消息发送

匠心零度 转载请注明原创出处,谢谢! RocketMQ网络部署图 NameServer:在系统中是做命名服务,更新和发现 broker服务。 Broker-Master:broker 消息主机服务器。 Broker-Slave: broker 消息...

匠心零度
06/19
0
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

前端基础

1. get请求传参长度的误区 误区:我们经常说get请求参数的大小存在限制,而post请求的参数大小是无限制的。 实际上HTTP 协议从未规定 GET/POST 的请求长度限制是多少。对get请求参数的限制是...

wenxingjun
今天
0
0
Android 复制和粘贴功能

做了一回搬运工,原文地址:https://blog.csdn.net/kennethyo/article/details/76602765 Android 复制和粘贴功能,需要调用系统服务ClipboardManager来实现。 ClipboardManager mClipboardM...

她叫我小渝
今天
0
0
拦截SQLSERVER的SSL加密通道替换传输过程中的用户名密码实现运维审计(一)

工作准备 •一台SQLSERVER 2005/SQLSERVER 2008服务 •SQLSERVER jdbc驱动程序 •Java开发环境eclipse + jdk1.8 •java反编译工具JD-Core 反编译JDBC分析SQLSERVER客户端与服务器通信原理 SQ...

紅顏為君笑
今天
6
0
jQuery零基础入门——(六)修改DOM结构

《jQuery零基础入门》系列博文是在廖雪峰老师的博文基础上,可能补充了个人的理解和日常遇到的点,用我的理解表述出来,主干出处来自廖雪峰老师的技术分享。 在《零基础入门JavaScript》的时...

JandenMa
今天
0
0
linux mint 1.9 qq 安装

转: https://www.jianshu.com/p/cdc3d03c144d 1. 下载 qq 轻聊版,可在百度搜索后下载 QQ7.9Light.exe 2. 去wine的官网(https://wiki.winehq.org/Ubuntu) 安装 wine . 提醒网页可以切换成中...

Canaan_
今天
0
0
PHP后台运行命令并管理运行程序

php后台运行命令并管理后台运行程序 class ProcessModel{ private $pid; private $command; private $resultToFile = ''; public function __construct($cl=false){......

colin_86
今天
1
0
数据结构与算法4

在此程序中,HighArray类中的find()方法用数据项的值作为参数传递,它的返回值决定是否找到此数据项。 insert()方法向数组下一个空位置放置一个新的数据项。一个名为nElems的字段跟踪记录着...

沉迷于编程的小菜菜
今天
1
1
fiddler安装和基本使用以及代理设置

项目需求 由于开发过程中客户端和服务器数据交互非常频繁,有时候服务端需要知道客户端调用接口传了哪些参数过来,这个时候就需要一个工具可以监听这些接口请求参数,已经接口的响应的数据,这种...

银装素裹
今天
0
0
Python分析《我不是药神》豆瓣评论

读取 Mongo 中的短评数据,进行中文分词 对分词结果取 Top50 生成词云 生成词云效果 看来网上关于 我不是药神 vs 达拉斯 的争论很热啊。关于词频统计就这些,代码中也会完成一些其它的分析任...

猫咪编程
今天
0
0
虚拟机怎么安装vmware tools

https://blog.csdn.net/tjcwt2011/article/details/72638977

AndyZhouX
昨天
1
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部