全新java高级架构师项目实战智能运营助手rocketmq基础

每特学院Java互联网架构培 老MQ概序提供丰富的消息拉取模式高效的订阅者水平扩展能力实时的消息订阅机制亿级消息MQ包含的组NameNameServerNameServershare-nothingNameServerNameServerNameServer所有状态都从Broker上报而来，本身 NameServerBrokerBrokergroupgroupmaster，slave。masterslaveslavemastermaster客户端消费可以从master和slave消费。在默认情况下，消费者都从master消费，在master挂后，客户端由于从NameServer中感知到Broker，就会从slave消费。Broker向所有的NameServer结点建立长连接，Topic信息。MQ优MQ环境安Hostviservicenetwork注意Error:NosuitabledevicefoundnodevicefoundforconnectionSystemifconfigaifconfigaMACHWADDRvim/etc/sysconfig/network-scripts/ifcfg-eth0ifconfigMACHWADDR值；#上传alibaba-mq-3.2.6.tar.gz文件至/usr/local#tar-zxvfalibaba-mq-3.2.6.tar.gz-C/usr/local#mvalibaba-mqalibaba-mq-3.2.6#ln-salibaba-mq-3.2.6mq创建路径【两台机器#mkdir #mkdir/usr/local/mq/store/consumequeue#mkdir/usr/local/mq/store/indexMQ#vim/usr/local/mq/conf/2m-noslave/perties#mkdir-p/usr/local/#cd mq/conf&&sed-i mq#g'XX:PermSize=128m-XX:MaxPermSize=320m"vim/usr/local/XX:PermSize=128m-XX:MaxPermSize=320m"#cd/usr/local/mq/bin#nohupshmqnamesrv&cd/usr/local/#nohupshmqbroker-c #netstat-ntlp#jps#tail-f-n500/usr/local/mq/logs/#tail-f-n500/usr/local/mq/logs/cd/usr/local/#nohupshmqbroker-c #netstat-ntlp#jps#tail-f-n500/usr/local/mq/logs/mqlogs/broker.log#tail-f-n500/usr/local/ MQ mq-web-console部署到 jdkviexportexportexportPATH=$JAVA_HOME/bin:$PATHsourceJava操 mq-<artifactId>logback-<artifactId>logback-publicpublicclassProducerpublicstaticvoidmain(String[]args)throwsExceptionDefaultMQProducerproducer=newDefaultMQProducer("rmq-tryfor(inti=0;i<10;i++){Thread.sleep(1000);每秒发送一次MQMessagemsgnewMessage("itmayiedu-topic", 名"TagA",tag临时)//SendResultsendResult=producer.send(msg);}}}catch(Exceptione){}}}publicpublicclassConsumerpublicstaticvoidmain(String[]args)throwsExceptionDefaultMQPushConsumerconsumer=newDefaultMQPushConsumer("rmq-consumer.subscribe("itmayiedu-topic","TagA");consumer.registerMessageListener(newMessageListenerConcurrently()publicConsumeConcurrentlyStatusconsumeMessage(List<MessageExt>msgs,ConsumeConcurrentlyContextcontext){for(MessageExtmsg:msgs)System.out.println(msg.getMsgId()+"---"+new}return}System.out.println("ConsumerStarted.");}}MQ重试机MQMQpublicpublicclassConsumerpublicstaticvoidmain(String[]args)throwsExceptionDefaultMQPushConsumerconsumer=newDefaultMQPushConsumer("rmq-consumer.subscribe("itmayiedu-topic","TagA");consumer.registerMessageListener(newMessageListenerConcurrently()publicConsumeConcurrentlyStatusconsumeMessage(List<MessageExt>msgs,ConsumeConcurrentlyContextcontext){for(MessageExtmsg:msgs)System.out.println(msg.getMsgId()+"---"+new}tryinti=1/}catch(Exceptione){需要重return}不需要重return}System.out.println("ConsumerStarted.");}}IDIDMQIDIDIDID、订单号msg.setKeys生产者publicpublicclassProducerpublicstaticvoidmain(String[]args)throwsExceptionDefaultMQProducerproducer=newDefaultMQProducer("rmq-producersetNamesrvAddr("192168110195:9876;192168110199:9876");producersetInstanceName("producer");producerstart();try{for(inti=0;i<1;i++)Threadsleep(1000秒发送一次MessagemsgnewMessage("itmayiedu-topic 名"TagAtag时("itmayiedu-6igetBytes(body内msgsetKeys(SystemcurrentTimeMillis()+"");SendResultsendResult=producersend(msg);Systemoutprintln(sendResulttoString());}}catch(Exceptione)e}producer}}消费者staticstaticprivateMap<String,String>logMap=newpublicstaticvoidmain(String[]args)throwsExceptionDefaultMQPushConsumerDefaultMQPushConsumerconsumer=newDefaultMQPushConsumer("rmq-consumer.subscribe("itmayiedu-topic","TagA");consumer.registerMessageListener(newMessageListenerConcurrently(){publicConsumeConcurrentlyStatusconsumeMessage(List<MessageExt>msgs,ConsumeConcurrentlyContextcontext){Stringkey=null;StringmsgId=null;try{for(MessageExtmsg:msgs){key=msg.getKeys();if(logMap.containsKey(key))System.out.println(