一、載入與安置

徑直去官網(wǎng)（http://activemq.apache.org/）載入最新本子即可，因為這是免安置的，只須要解壓就行了。安置完之保守入bin目次，雙擊activemq.bat文獻（linux下在bin目次下實行activemqstart）

二、考察遏制臺

在欣賞器輸出：http://ip:8161/admin/，展示如次界面表白啟用勝利,默許的用戶名暗號都是admin

三、竄改端標(biāo)語

61616為對外效勞端標(biāo)語

8161為遏制器端標(biāo)語

當(dāng)端標(biāo)語辯論時，不妨竄改這兩個端標(biāo)語。cdconf,竄改activemq.xml竄改內(nèi)里的61616端口。竄改jetty.xml，竄改內(nèi)里的8161端口。

queue部隊形式：

和rabbitmq大略部隊形式一律，假如有多個耗費者耗費同一個部隊中的動靜的話，默許也是輪詢體制的耗費

示例代碼：

publicclassProductor{publicstaticfinalStringBORKER_URL="tcp://127.0.0.1:61616";publicstaticfinalStringQUEUE_NAME="queue1";publicstaticvoidmain(String[]args)throwsJMSException{//創(chuàng)造工場ActiveMQConnectionFactoryfactory=newActiveMQConnectionFactory(BORKER_URL);//創(chuàng)造tcp貫穿Connectionconnection=factory.createConnection();//創(chuàng)造貫穿connection.start();/***創(chuàng)造對話，1.能否打開工作，2.簽收形式*/Sessionsession=connection.createSession(false,Session.AUTO_ACKNOWLEDGE);//創(chuàng)造部隊(動靜的手段地)Queuequeue=session.createQueue(QUEUE_NAME);//創(chuàng)造消費者MessageProducerproducer=session.createProducer(queue);//動靜非長久化producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);//動靜長久化默許是長久化的//producer.setDeliveryMode(DeliveryMode.PERSISTENT);//創(chuàng)造動靜TextMessagemessage=session.createTextMessage("您好嗎");//發(fā)送動靜producer.send(message);producer.close();session.close();connection.close();System.out.println("發(fā)送勝利！");}}publicclassConsumer{publicstaticfinalStringBORKER_URL="tcp://127.0.0.1:61616";publicstaticfinalStringQUEUE_NAME="queue1";publicstaticvoidmain(String[]args)throwsJMSException{//創(chuàng)造工場ActiveMQConnectionFactoryfactory=newActiveMQConnectionFactory(BORKER_URL);//創(chuàng)造tcp貫穿Connectionconnection=factory.createConnection();//創(chuàng)造貫穿connection.start();/***創(chuàng)造對話，1.能否打開工作，2.簽收形式*/Sessionsession=connection.createSession(false,Session.AUTO_ACKNOWLEDGE);//創(chuàng)造/證明部隊(動靜的手段地)Queuequeue=session.createQueue(QUEUE_NAME);//創(chuàng)造耗費者MessageConsumerconsumer=session.createConsumer(queue);/*while(true){//receive會阻礙線程TextMessagemessage=(TextMessage)consumer.receive();System.out.println("接受到動靜："+message.getText());}*///監(jiān)聽的辦法耗費consumer.setMessageListener(message->{TextMessagetextMessage=(TextMessage)message;try{System.out.println("1號接受到動靜："+textMessage.getText());}catch(JMSExceptione){e.printStackTrace();}});}}topic部隊形式：

稱為頒布訂閱形式，消費者把動靜發(fā)送給訂閱給某個topic中心的耗費者，是散發(fā)的形式，這種形式默許須要先啟用耗費者，否則就算消費者頒布了某個topic中心的動靜，耗費者也耗費不了；只有耗費者提早訂閱，而且做了動靜長久化的處置，如許后啟用耗費者本領(lǐng)耗費提早推送的動靜。

代碼：

publicclassProductor{publicstaticfinalStringBORKER_URL="tcp://127.0.0.1:61616";publicstaticfinalStringTOPIC_NAME="topic1";publicstaticvoidmain(String[]args)throwsJMSException{//創(chuàng)造工場ActiveMQConnectionFactoryfactory=newActiveMQConnectionFactory(BORKER_URL);//異步送達factory.setUseAsyncSend(true);//創(chuàng)造tcp貫穿Connectionconnection=factory.createConnection();/***創(chuàng)造對話，1.能否打開工作，2.簽收形式*/Sessionsession=connection.createSession(false,Session.AUTO_ACKNOWLEDGE);//創(chuàng)造/證明topic(動靜的手段地)Topictopic=session.createTopic(TOPIC_NAME);//創(chuàng)造消費者ActiveMQMessageProducerproducer=(ActiveMQMessageProducer)session.createProducer(topic);//長久化producer.setDeliveryMode(DeliveryMode.PERSISTENT);//創(chuàng)造貫穿connection.start();//創(chuàng)造動靜TextMessagemessage=session.createTextMessage("您好嗎");//發(fā)送動靜,異步發(fā)送回調(diào)因變量producer.send(message,newAsyncCallback(){@OverridepublicvoidonSuccess(){System.out.println("success");}@OverridepublicvoidonException(JMSExceptione){System.out.println("fail");}});producer.close();session.close();connection.close();System.out.println("發(fā)送勝利！");}}publicclassConsumer1{publicstaticfinalStringBORKER_URL="tcp://127.0.0.1:61616";publicstaticfinalStringTOPIC_NAME="topic1";publicstaticvoidmain(String[]args)throwsJMSException{//創(chuàng)造工場ActiveMQConnectionFactoryfactory=newActiveMQConnectionFactory(BORKER_URL);//創(chuàng)造tcp貫穿Connectionconnection=factory.createConnection();//擬訂clientIdconnection.setClientID("my");/***創(chuàng)造對話，1.能否打開工作，2.簽收形式*/Sessionsession=connection.createSession(false,Session.AUTO_ACKNOWLEDGE);//創(chuàng)造/證明topic(動靜的手段地)Topictopic=session.createTopic(TOPIC_NAME);//訂閱中心TopicSubscribersubscriber=session.createDurableSubscriber(topic,"remark");//創(chuàng)造貫穿connection.start();while(true){//receive會阻礙線程//接受訂閱的動靜TextMessagemessage=(TextMessage)subscriber.receive();System.out.println("接受到動靜："+message.getText());}/*//創(chuàng)造耗費者MessageConsumerconsumer=session.createConsumer(topic);//創(chuàng)造貫穿connection.start();*//*while(true){//receive會阻礙線程TextMessagemessage=(TextMessage)consumer.receive();System.out.println("接受到動靜："+message.getText());}*//*//監(jiān)聽的辦法耗費consumer.setMessageListener(message->{TextMessagetextMessage=(TextMessage)message;try{System.out.println("1號接受到動靜："+textMessage.getText());}catch(JMSExceptione){e.printStackTrace();}});*/}}怎樣保護動靜的真實性

回復(fù)這個題目重要從長久化，工作，簽收這幾個上面動手

動靜長久化的中心代碼：

//queue形式的動靜長久化默許是長久化的producer.setDeliveryMode(DeliveryMode.PERSISTENT);/***topic形式的長久化*/Topictopic=session.createTopic(TOPIC_NAME);ActiveMQMessageProducerproducer=(ActiveMQMessageProducer)session.createProducer(topic);producer.setDeliveryMode(DeliveryMode.PERSISTENT);connection.start();工作的中心代碼（偏消費者）：

//參數(shù)樹立成trueconnection.createSession(false,Session.AUTO_ACKNOWLEDGE);//工作提交session.commit();簽收的中心代碼（偏耗費者）：

//參數(shù)樹立成手動提交connection.createSession(false,Session.CLIENT_ACKNOWLEDGE);//動靜簽收message.acknowledge();提防：假如既打開工作，又打開手動簽收，以工作為準(zhǔn)，只有工作被提交了也默許動靜被簽收了

本能提高：

1.運用nio的和議比tcp的本能高，

擺設(shè)辦法：在conf目次下activemq.xml照著底下擺設(shè)<broker>...<transportConnectors><transportConnectorname="nio"uri="nio://0.0.0.0:61616"/></<transportConnectors>...</broker>第二步是代碼考察辦法由tcp改為nio//創(chuàng)造工場ActiveMQConnectionFactoryfactory=newActiveMQConnectionFactory("nio://127.0.0.1:61616");2.jdbc+Journaling普及惟有jdbc長久化的本能，它在做長久化入數(shù)據(jù)庫之前，會先將數(shù)據(jù)生存到Journaling文獻中，之后才漸漸同步到數(shù)據(jù)庫中，即是中央加了一層緩沖層。

把數(shù)據(jù)庫mysql的啟動包放到lib目次下擺設(shè)辦法：在conf目次下activemq.xml照著底下擺設(shè),個中有個createTablesOnStartup屬性，默許值是true，表白歷次啟用后去數(shù)據(jù)庫機動建表<persistenceAdapter><kahaDBdirectory="${activemq.data}/kahadb"/></persistenceAdapter>//上頭是默許擺設(shè)找到改成底下的擺設(shè)<persistenceAdapter><journalPersistenceAdapterFactoryjournalLogFiles="5"dataDirectory="${basedir}/activemq-data"dataSource="#mysql-ds"/></persistenceAdapter>//底下的代碼寫在<beans>節(jié)點中<beanid="mysql-ds"class="org.apache.commons.dbcp.BasicDataSource"destroy-method="close"><propertyname="driverClassName"value="com.mysql.jdbc.Driver"/><propertyname="url"value="jdbc:mysql://localhost/activemq?relaxAutoCommit=true"/><propertyname="username"value="activemq"/><propertyname="password"value="activemq"/><propertyname="poolPreparedStatements"value="true"/></bean>