您好,登錄后才能下訂單哦!
本篇文章為大家展示了java中怎么連接并訪問activemq,內(nèi)容簡明扼要并且容易理解,絕對能使你眼前一亮,通過這篇文章的詳細(xì)介紹希望你能有所收獲。
bin存放的是腳本文件 conf存放的是基本配置文件 data存放的是日志文件 docs存放的是說明文檔 examples存放的是簡單的實(shí)例 lib存放的是activemq所需jar包 webapps用于存放項(xiàng)目的目錄
啟動(dòng)ActiveMQ非常的簡單。進(jìn)入bin目錄
雙擊“activemq.bat”就啟動(dòng)運(yùn)行了。因?yàn)锳ctiveMQ是用Java編寫的,所以必須確保電腦已經(jīng)安裝了JDK。
雙擊運(yùn)行之后就可以在瀏覽器里面輸入:http://localhost:8161/admin。就能夠進(jìn)入ActiveMQ的后臺頁面了。帳號密碼默認(rèn)都是:admin
Java程序連接端口:61616
修改61616端口,可以修改文件conf>activemq.xml
修改登錄名和密碼,可以修改文件conf>jetty-realm.properties
3、創(chuàng)建一個(gè)ActiveMQ工程
這里還是先放一張圖:
根據(jù)這張圖我們實(shí)現(xiàn)了一個(gè)隊(duì)列Queue的代碼如下
1.pom.xml
<dependency> <groupId>org.apache.activemq</groupId> <artifactId>activemq-core</artifactId> <version>5.7.0</version></dependency>
2.消費(fèi)者代碼
package cn.duanjt;import java.io.IOException;import javax.jms.Connection;import javax.jms.ConnectionFactory;import javax.jms.JMSException;import javax.jms.Message;import javax.jms.MessageConsumer;import javax.jms.MessageListener;import javax.jms.Queue;import javax.jms.Session;import javax.jms.TextMessage;import org.apache.activemq.ActiveMQConnection;import org.apache.activemq.ActiveMQConnectionFactory;import org.apache.activemq.ActiveMQSession;/** * 消費(fèi)者 * @author 段江濤 * @date 2018-11-23 */public class Consumer { // 全部使用缺省值 private static String USERNAME = ActiveMQConnection.DEFAULT_USER; private static String PASSWORD = ActiveMQConnection.DEFAULT_PASSWORD; private static String BROKER = ActiveMQConnection.DEFAULT_BROKER_URL; public static void main(String[] args) throws IOException { ConnectionFactory factory; Connection connection = null; Session session; Queue queue; Message message; MessageConsumer consumer; try { factory = new ActiveMQConnectionFactory(USERNAME, PASSWORD, BROKER); connection = factory.createConnection(); connection.start(); session = connection.createSession(false, ActiveMQSession.AUTO_ACKNOWLEDGE); queue = session.createQueue("zd-duanjt"); consumer = session.createConsumer(queue); //注釋部分為同步方式 /*while (true) { message = consumer.receive(); TextMessage tmsg = (TextMessage) message; System.out.println("接收到數(shù)據(jù):" + tmsg.getText()); }*/ //下面是異步方式,通過注冊監(jiān)聽 consumer.setMessageListener(new MessageListener() { @Override public void onMessage(Message message) { TextMessage tmsg = (TextMessage) message; try { System.out.println("接收到數(shù)據(jù):" + tmsg.getText()); } catch (JMSException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }); } catch (Exception e) { e.printStackTrace(); } finally{ // 之前在這里把連接關(guān)閉了,導(dǎo)致一直無法消費(fèi)數(shù)據(jù),注意,這里千萬不要關(guān)閉連接 } }}
3.生產(chǎn)者代碼
package cn.duanjt;import javax.jms.Connection;import javax.jms.ConnectionFactory;import javax.jms.JMSException;import javax.jms.Message;import javax.jms.MessageProducer;import javax.jms.Queue;import javax.jms.Session;import org.apache.activemq.ActiveMQConnection;import org.apache.activemq.ActiveMQConnectionFactory;import org.apache.activemq.ActiveMQSession;/** * 生產(chǎn)者產(chǎn)生數(shù)據(jù) * @author 段江濤 * @date 2018-11-23 */public class Productor { // 全部使用缺省值 private static String USERNAME = ActiveMQConnection.DEFAULT_USER; private static String PASSWORD = ActiveMQConnection.DEFAULT_PASSWORD; private static String BROKER = ActiveMQConnection.DEFAULT_BROKER_URL; public static void main(String[] args) throws JMSException { ConnectionFactory factory = new ActiveMQConnectionFactory(USERNAME, PASSWORD, BROKER); Connection connection = factory.createConnection(); connection.start(); Session session = connection.createSession(false, ActiveMQSession.AUTO_ACKNOWLEDGE); Queue queue = session.createQueue("zd-duanjt"); MessageProducer productor = session.createProducer(queue); for (int i = 0; i < 3; i++) { String msg = "Hello world:" + i; Message message = session.createTextMessage(msg); productor.send(message); System.out.println("發(fā)送數(shù)據(jù):" + msg); } connection.close(); }}
重點(diǎn)說明:
1.Queue queue = session.createQueue("zd-duanjt");表示創(chuàng)建一個(gè)隊(duì)列,我們也可以創(chuàng)建一個(gè)Topic,Topic topic=session.createTopic("zd-topic");
2.注意這里面的JMS相關(guān)的類都在包javax.jms.*下
上述內(nèi)容就是java中怎么連接并訪問activemq,你們學(xué)到知識或技能了嗎?如果還想學(xué)到更多技能或者豐富自己的知識儲(chǔ)備,歡迎關(guān)注億速云行業(yè)資訊頻道。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。