rocketmq系列文章四基于demo实践

接上文，搭建好环境，用exampl中的示例只能进行有限的测试任务。Rocket-console消息，所以自定义测试任务需要自行编写demo程序。下载myeclipse添加自定义jdk环境：参考文章 File--New--Other--MavenProjuect--(Createasimple配置src--NewPackage--NewClass--

下的Producer，下文的Consumerpackagepackageimportcom.alibaba.rocketmq.client.exception.MQClientException;importducer.DefaultMQProducer;ducer.LocalTransactionExecuter;importducer.LocalTransactionState;importducer.SendResult;importimportpublicclassProducerpublicstaticvoidmain(String[]args)throwsMQClientException,InterruptedException//tc_pro1为ProducergroupDefaultMQProducerproducer=new//手动指定Namesrv服务地址// for(inti=0;i<1;{tryMessagemsg=newMessage("tc_demo",//topic"TagA",//tag("HelloRocketMQ"+i).getBytes(RemotingHelper.DEFAULT_CHARSET)//SendResultsendResult=LocalTransactionExecutertranExecuter=newLocalTransactionExecuter()Objectarg)

publicLocalTransactionStateexecuteLocalTransactionBranch(Message//TODOAuto‐generatedmethodstubreturnnull;}//producer.sendMessageInTransaction(msg,tranExecuter,arg)}catch(Exception}}}}xxxPackage--NewClass--importimportcom.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;mon.consumer.ConsumeFromWhere;importmon.message.MessageExt;importjava.util.List;publicstaticvoidmain(String[]args)throwsInterruptedException,MQClientException//tc_con1为Consumergroupname,如果broker关闭了自动订阅功能，请手动添加订阅tc_con1，以确保能DefaultMQPushConsumerconsumer=new//手动指定Namesrv服务地址consumer.subscribe("tc_demo","*");consumer.registerMessageListener(newMessageListenerConcurrently(){{

publicConsumeConcurrentlyStatusconsumeMessage(Listmsgs,ConsumeConcurrentlyContextSystem.out.println(Thread.currentThread().getName()+"ReceiveNewMessages:"+return}System.out.println("Consumer}}前提：环境搭建成功，Namesrv和Broker服务运行正常，可通 runConsumer.javaProducer.java从myeclipse--console可以看到Consumer角色成功启动、Producer消息发mye上RocketMQ的demo实践流程就走通了，更多的自定义扩展可以参考其项目源码参考文章D：Producr多topi发送，Consumr多topic消费mvnmvn

Error:JAVA_HOMEissettoaninvaliddirectory.JAVA_HOME="C:\ProgramFiles\Java\jdk1.7.0_17\bin"PleasesettheJAVA_HOMEvariableinyourenvironmenttomatchthelocationofyourJavainstallation.jdk,mven的环境变量虽已在thjdk正常。但maven启动另需JAVA_HOME添加JAVA_HOME