rocketmq系列文章四基于demo實踐

接上文，搭建好環(huán)境，用exampl中的示例只能進(jìn)行有限的測試任務(wù)。Rocket-console消息，所以自定義測試任務(wù)需要自行編寫demo程序。下載myeclipse添加自定義jdk環(huán)境：參考文章 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服務(wù)地址// 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關(guān)閉了自動訂閱功能，請手動添加訂閱tc_con1，以確保能DefaultMQPushConsumerconsumer=new//手動指定Namesrv服務(wù)地址consumer.subscribe("tc_demo","*");consumer.registerMessageListener(newMessageListenerConcurrently(){{

publicConsumeConcurrentlyStatusconsumeMessage(Listmsgs,ConsumeConcurrentlyContextSystem.out.println(Thread.currentThread().getName()+"ReceiveNewMessages:"+return}System.out.println("Consumer}}前提：環(huán)境搭建成功，Namesrv和Broker服務(wù)運行正常，可通 runConsumer.javaProducer.java從myeclipse--console可以看到Consumer角色成功啟動、Producer消息發(fā)mye上RocketMQ的demo實踐流程就走通了，更多的自定義擴(kuò)展可以參考其項目源碼參考文章D：Producr多topi發(fā)送，Consumr多topic消費mvnmvn

Error:JAVA_HOMEissettoaninvaliddirectory.JAVA_HOME="C:\ProgramFiles\Java\jdk1.7.0_17\bin"PleasesettheJAVA_HOMEvariableinyourenvironmenttomatchthelocationofyourJavainstallation.jdk,mven的環(huán)境變量雖已在thjdk正常。但maven啟動另需JAVA_HOME添加JAVA_HOME