基于Java ActiveMQ的實例講解
更新時間：2017年09月15日 08:34:59 作者：鼠標滾輪
下面小編就為大家?guī)硪黄贘ava ActiveMQ的實例講解。小編覺得挺不錯的，現(xiàn)在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧
所需引入Jar包：
jms-1.1.jar
activemq-all-5.15.0.jar
生產(chǎn)者
package com.mousewheel.demo;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.ObjectMessage;
import javax.jms.Session;
import org.apache.activemq.ActiveMQConnectionFactory;
public class MQConsumerDemo {
public static void main(String[] args) throws JMSException {
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("admin", "admin", "tcp://192.168.31.33:61616");
Connection connection = null;
try {
connection = connectionFactory.createConnection();
connection.start();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Destination destination = session.createQueue("test-queue");
MessageConsumer consumer = session.createConsumer(destination);
consumer.setMessageListener(new MessageListener() {
@Override
public void onMessage(Message message) {
try {
MqBean bean = (MqBean) ((ObjectMessage) message).getObject();
System.out.println(bean);
if (null != message) {
System.out.println("收到消息" + bean.getName());
}
} catch (Exception e) {
// TODO: handle exception
}
}
});
System.out.println("Begin listen");
} catch (Exception e) {
// TODO: handle exception
}
}
}
消費者
package com.mousewheel.demo;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.ObjectMessage;
import javax.jms.Session;
import org.apache.activemq.ActiveMQConnectionFactory;
public class MQConsumerDemo {
public static void main(String[] args) throws JMSException {
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("admin", "admin", "tcp://192.168.31.33:61616");
Connection connection = null;
try {
connection = connectionFactory.createConnection();
connection.start();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Destination destination = session.createQueue("test-queue");
MessageConsumer consumer = session.createConsumer(destination);
consumer.setMessageListener(new MessageListener() {
@Override
public void onMessage(Message message) {
try {
MqBean bean = (MqBean) ((ObjectMessage) message).getObject();
System.out.println(bean);
if (null != message) {
System.out.println("收到消息" + bean.getName());
}
} catch (Exception e) {
// TODO: handle exception
}
}
});
System.out.println("Begin listen");
} catch (Exception e) {
// TODO: handle exception
}
}
}
以上這篇基于Java ActiveMQ的實例講解就是小編分享給大家的全部內(nèi)容了，希望能給大家一個參考，也希望大家多多支持腳本之家。
相關文章
自從 14 年發(fā)布 Java 8 以后，我們古老 java.util.Date 終于不再是我們 Java 里操作日期時間的唯一的選擇，其實 Java 里的日期時間的相關 API 一直為世猿詬病，今天我們來了解新的日期時間API是怎么使用吧2021-11-11
Spring Boot + thymeleaf 實現(xiàn)文件上傳下載功能
最近同事問我有沒有有關于技術的電子書，我打開電腦上的小書庫，但是郵件發(fā)給他太大了，公司又禁止用文件夾共享，于是花半天時間寫了個小的文件上傳程序，部署在自己的Linux機器上,需要的朋友可以參考下2018-01-01
這篇文章主要介紹了Java簡單實現(xiàn)約瑟夫環(huán)算法,簡單描述了約瑟夫環(huán)問題,并結合實例形式分析了Java實現(xiàn)約瑟夫環(huán)的具體操作技巧,需要的朋友可以參考下2017-09-09
這篇文章主要介紹了java后端解決跨域的幾種問題解決，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2021-03-03
解決 IDEA 創(chuàng)建 Gradle 項目沒有src目錄問題
這篇文章主要介紹了解決 IDEA 創(chuàng)建 Gradle 項目沒有src目錄問題，本文圖文并茂給大家介紹的非常詳細，具有一定的參考借鑒價值,需要的朋友可以參考下2018-06-06
在我們?nèi)粘＿B接中，如果超時時長過長的話，在開發(fā)時會影響測試，下面這篇文章主要給大家分享了關于Java中Socket設置連接超時的代碼，需要的朋友可以參考借鑒，下面來一起看看吧。2017-06-06
SpringBoot中實現(xiàn)異步調(diào)用@Async詳解
這篇文章主要介紹了SpringBoot中實現(xiàn)異步調(diào)用@Async詳解,在SpringBoot的日常開發(fā)中,一般都是同步調(diào)用的,但實際中有很多場景非常適合使用異步來處理,需要的朋友可以參考下2024-01-01
這篇文章主要介紹了詳解Android系統(tǒng)中的Root權限獲得原理,安卓基于Linux,所以原理也相當于Linux中的root用戶,需要的朋友可以參考下2015-08-08
AppCDS的全稱是Application Class-Data Sharing。主要是用來在不同的JVM中共享Class-Data信息，從而提升應用程序的啟動速度。這篇文章主要介紹了JDK13的新特性:AppCDS詳解,需要的朋友可以參考下2020-05-05
這篇文章主要介紹了SpringBoot整合Swagger的方法示例，詳細介紹了SpringBoot如何整合Swagger以及swagger注解，具有一定的參考價值，感興趣的小伙伴們可以參考一下2018-10-10