ActiveMQ中間消息件如何在Java項目中使用
今天就跟大家聊聊有關(guān)ActiveMQ中間消息件如何在Java項目中使用，可能很多人都不太了解，為了讓大家更加了解，小編給大家總結(jié)了以下內(nèi)容，希望大家根據(jù)這篇文章可以有所收獲。
目前創(chuàng)新互聯(lián)建站已為成百上千的企業(yè)提供了網(wǎng)站建設(shè)、域名、網(wǎng)站空間、綿陽服務(wù)器托管、企業(yè)網(wǎng)站設(shè)計、維西網(wǎng)站維護等服務(wù)，公司將堅持客戶導向、應用為本的策略，正道將秉承"和諧、參與、激情"的文化，與客戶和合作伙伴齊心協(xié)力一起成長，共同發(fā)展。
消息一共有兩種接收和發(fā)送形式：點對點和發(fā)布定閱模式，也就是“一對一”和“一對多”。
1.導包（maven)：
org.apache.activemq activemq-client 5.13.4
2.開始寫類，提供者(發(fā)送者)和消費者(接收者)是兩個不同的項目,我們先創(chuàng)建普通的maven項目，而不是web項目點對點的方式(消息只能被消費一次，如果同時有多個消費者，誰先搶到就是誰的)
消息提供者
public static void main(String[] args) throws JMSException {
//創(chuàng)建連接工廠，這個參數(shù)就是自己的activeMQ的地址
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.25.180:61616");
//2.創(chuàng)建連接
Connection connection = connectionFactory.createConnection();
//3.啟動連接
connection.start();
//4.獲取session(會話對象)
/*
arg0 是否啟用事務(wù)
arg1 消息的確認方式 自動確認
*/
Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
//5.創(chuàng)建一個隊列對象,名稱
Queue firstQueue = session.createQueue("firstQueue");
//6.創(chuàng)建一個消息的生產(chǎn)者對象
// Destination destination = ;//目標對象
MessageProducer producer = session.createProducer(firstQueue);
//7.創(chuàng)建一個消息
TextMessage textMessage = session.createTextMessage("歡迎來到奇的天喻軟件");
//8.發(fā)送消息
producer.send(textMessage);
//9.關(guān)閉資源
producer.close();
session.close();
connection.close();
}消息消費者
前幾步是一樣的，都是創(chuàng)建連接，只有第6步不一樣,創(chuàng)建的是一個消費者
public static void main(String[] args) throws JMSException, IOException {
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.25.180:61616");
//2.創(chuàng)建連接
Connection connection = connectionFactory.createConnection();
//3.啟動連接
connection.start();
//4.獲取session(會話對象)
/*
arg0 是否啟用事務(wù)
arg1 消息的確認方式 自動確認
*/
Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
//5.創(chuàng)建一個隊列對象,名稱
Queue firstQueue = session.createQueue("firstQueue");
//6.創(chuàng)建消息消費者對象
MessageConsumer consumer = session.createConsumer(firstQueue);
//7.設(shè)置監(jiān)聽
consumer.setMessageListener(new MessageListener() {
@Override
public void onMessage(Message message) {
TextMessage textMessage = (TextMessage)message;
try {
System.out.println("提取的消息是"+textMessage.getText());
} catch (JMSException e) {
e.printStackTrace();
}
}
});
//8.等待鍵盤輸入
//目的是為了讓程序停止來看效果
System.in.read();
//9.關(guān)閉資源
consumer.close();
session.close();
connection.close();
}發(fā)布訂閱模式（發(fā)布消息后，只有在之前運行的消費者才能收到，消息被任何一個消費者消費后，以后啟動的消費者不能消費之前的消息）
消息提供者
//創(chuàng)建連接工廠
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.25.180:61616");
//2.創(chuàng)建連接
Connection connection = connectionFactory.createConnection();
//3.啟動連接
connection.start();
//4.獲取session(會話對象)
/*
arg0 是否啟用事務(wù)
arg1 消息的確認方式 自動確認
*/
Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
//5
Topic topic = session.createTopic("first-topic");
//6.創(chuàng)建一個消息的生產(chǎn)者對象
// Destination destination = ;//目標對象
MessageProducer producer = session.createProducer(topic);
//7.創(chuàng)建一個消息
TextMessage textMessage = session.createTextMessage("歡迎來到奇的天喻軟件");
//8.發(fā)送消息
producer.send(textMessage);
//9.關(guān)閉資源
producer.close();
session.close();
connection.close();消費者
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.25.180:61616");
//2.創(chuàng)建連接
Connection connection = connectionFactory.createConnection();
//3.啟動連接
connection.start();
//4.獲取session(會話對象)
/*
arg0 是否啟用事務(wù)
arg1 消息的確認方式 自動確認
*/
Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
//5
Topic topic = session.createTopic("first-topic");
//6.創(chuàng)建消息消費者對象
MessageConsumer consumer = session.createConsumer(topic);
//7.設(shè)置監(jiān)聽
consumer.setMessageListener(new MessageListener() {
@Override
public void onMessage(Message message) {
TextMessage textMessage = (TextMessage)message;
try {
System.out.println("提取的消息是"+textMessage.getText());
} catch (JMSException e) {
e.printStackTrace();
}
}
});
//8.等待鍵盤輸入
//目的是為了讓程序停止來看效果
System.in.read();
//9.關(guān)閉資源
consumer.close();
session.close();
connection.close();看完上述內(nèi)容，你們對ActiveMQ中間消息件如何在Java項目中使用有進一步的了解嗎？如果還想了解更多知識或者相關(guān)內(nèi)容，請關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道，感謝大家的支持。
分享題目：ActiveMQ中間消息件如何在Java項目中使用
網(wǎng)站地址：http://m.jiaotiyi.com/article/gpghio.html