每特教育學(xué)院螞蟻課堂4期消息中間件activemq隊(duì)列與發(fā)布訂閱

JMSPoint-to-Point(P2P)Point-to-Point(P2P)Publish/Subscribe(Pub/Sub)---消息隊(duì)列發(fā)送者接收者者可以被多個消費(fèi)者處理的話，那么可以采用Pub/Sub模型調(diào)用監(jiān)聽器的onMessage方法。MQErlang編寫的一個開源的消息隊(duì)列，本身支持很多的協(xié)議：AMQP，XMPPSMTP,載均衡(Loadbalance)或者數(shù)據(jù)持久化都有很好的支持。儲系統(tǒng)，但它本身支持MQ功能，所以完全可以當(dāng)做一個輕量級的隊(duì)列服務(wù)來使用。對于RabbitMQRedis10010萬次記錄一次執(zhí)行時(shí)間。的無法忍受；出隊(duì)時(shí)，無論數(shù)據(jù)大小，RedisRabbitMQ的出隊(duì)性能則遠(yuǎn)低于Redis。號稱最快的消息隊(duì)列系統(tǒng)，尤其針對大吞吐量的需求場景。ZMQRabbitMQ不擅的Storm中使用ZeroMQ作為數(shù)據(jù)流的傳輸。ActiveMQ均支持常用的多種語言客戶端C++、Java、.Net,、Python、Php、Ruby等。KafkaApachePublish/Subscribe消息隊(duì)O(1)的系統(tǒng)開銷下進(jìn)行消息持久化；高吞吐，在一臺普通的服務(wù)器上既10W/s的吞吐速率；完全的分布式系統(tǒng)，Broker、Producer、Consumer都原生統(tǒng)所看重的。ApacheKafka相對于ActiveMQ是一個非常輕量級的消息系統(tǒng)，除了性能非AmazonSQS就不再一一分析。ActiveMQ、windowActiveMQ和windows64位操作系統(tǒng)的啟動腳本。輸入用戶名密碼后便可看到如下圖的ActiveMQ控制臺界面了。NumberOfConsumersMessagesEnqueuedMessagesDequeued出了隊(duì)列的消息可以理解為是消費(fèi)這消費(fèi)掉的數(shù)量當(dāng)有一個消息進(jìn)入這個隊(duì)列時(shí)，等待消費(fèi)的消息是1，進(jìn)入隊(duì)列的消息是1。在來一條消息時(shí)，等待消費(fèi)的消息是1，進(jìn)入隊(duì)列的消息就是2.PendingMessages有消費(fèi)者消費(fèi)的時(shí)候Pedding會減少出隊(duì)列會增加到最后就是入隊(duì)列和出隊(duì)列的數(shù)量一樣多使用ActiveMQ（p2p）通訊模式引入pom文件依賴privatefinalstaticStringURL=privatefinalstaticStringQUEUENAME=publicstaticvoidmain(String[]args)throwsJMSException1.創(chuàng)建ActiveMQConnectionFactoryfactory=new2.Connectioncnnection=//3.啟動連接4.創(chuàng)建Session不開啟事務(wù),Sessionsession=cnnection.createSession(false,5.Queuequeue=MessageProducerproducer=for(inti=1;i<=10;i++)TextMessagetextMessagesession.createTextMessage("消息//8.發(fā)送消息}//9.關(guān)閉連接}publicpublicclassConsumerprivatefinalstaticStringURL=privatefinalstaticStringQUEUENAME=publicstaticvoidmain(String[]args)throwsJMSException1.創(chuàng)建Connectioncnnection=//3.啟動連接Queuequeue=MessageConsumercreateConsumer=session.createConsumer(queue);createConsumer.setMessageListener(newMessageListener(){try}catch(Exceptione)//TODO:handle}}}}1、帶事務(wù)的不帶事務(wù)的sessionsessionActivemq支持一下三種模式：Session.AUTO_ACKNOWLEDGE消息自動簽收Session.CLIENT_ACKNOWLEDGEacknowledge消息何時(shí)被確認(rèn)取決于創(chuàng)建會話時(shí)的應(yīng)答模式（acknowledgementmode）。該參數(shù)有以下三個可選值：NumberOfConsumersMessagesEnqueuedMessagesDequeuedpublicpublicclassProducter2privatefinalstaticStringURL=privatefinalstaticStringTOPICNAME=publicstaticvoidmain(String[]args)throwsJMSExceptionConnectioncnnection=//3.啟動連接TopiccreateTopic=//設(shè)置消息持久化for(inti=1;i<=10;i++){//8.發(fā)送消息}//9.關(guān)閉連接}}publicpublicclassConsumer2privatefinalstaticStringURL=privatefinalstaticStringTOPICNAME=publicstaticvoidmain(String[]args)throwsJMSExceptionConnectioncnnection=//3.啟動連接Topictopic=MessageConsumercreateConsumer=session.createConsumer(topic);createConsumer.setMessageListener(newMessageListener(){tryTextMessagetextMessage=(TextMessage)message;}catch(Exceptione)//TODO:handle}}}}maven<relativePath/><!--lookupparentfromrepository--application.ymluser:adminpassword:adminport:publicclass{@Value("${queue}")publicQueuelogQueue()returnnew}}publicclassProducer{privateJmsMessagingTemplatejmsMessagingTemplate;privateQueue@Scheduled(fixedDelay@Scheduled(fixedDelay=5000)publicvoidsend(){jmsMessagingTemplate.convertAndSend(queue,測試消息隊(duì)列}}publicclassApp{publicstaticvoidmain(String[]{SpringApplication.run(App.class,}}mavenYMLuser:adminpassword:adminport:publicpublicclassCon