脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → activemq java 实例

基于Java ActiveMQ的实例讲解

 更新时间：2017年09月15日 08:34:59   作者：鼠标滚轮  
下面小编就为大家带来一篇基于Java ActiveMQ的实例讲解。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧

所需引入Jar包：

jms-1.1.jar

activemq-all-5.15.0.jar

生产者

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的实例讲解就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持脚本之家。

您可能感兴趣的文章:

相关文章

  • 浅谈二分法查找和原始算法查找的效率对比

    浅谈二分法查找和原始算法查找的效率对比

    这篇文章主要介绍了浅谈二分法查找和原始算法查找的效率对比，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
    2020-08-08
  • RestTemplate在Spring或非Spring环境下使用精讲

    RestTemplate在Spring或非Spring环境下使用精讲

    这篇文章主要为大家介绍了RestTemplate在Spring或非Spring环境下使用精讲，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
    2022-03-03
  • JVM垃圾收集器详解

    JVM垃圾收集器详解

    本文主要介绍了JVM垃圾收集器的相关知识。具有很好的参考价值，下面跟着小编一起来看下吧
    2017-02-02
  • Java网络编程TCP实现文件上传功能

    Java网络编程TCP实现文件上传功能

    这篇文章主要为大家详细介绍了Java网络编程TCP实现文件上传功能，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
    2021-07-07
  • SpringBoot+ Sharding Sphere 轻松实现数据库字段加解密功能

    SpringBoot+ Sharding Sphere 轻松实现数据库字段加解密功能

    在Spring Boot生态中,有一个非常厉害的开源框架：Apache ShardingSphere,它是一款分布式 SQL 事务和查询引擎,可通过数据分片、弹性伸缩、加密等能力对任意数据库进行增强,今天通过这篇文章,我们一起来了解一下如何在 Spring Boot 中快速实现数据的加解密功能
    2024-07-07
  • SpringBoot+微信小程序实现文件上传与下载功能详解

    SpringBoot+微信小程序实现文件上传与下载功能详解

    这篇文章主要为大家介绍了SpringBoot整合微信小程序实现文件上传与下载功能，文中的实现步骤讲解详细，快跟随小编一起学习一下吧
    2022-03-03
  • java7 简化变参方法调用实例方法

    java7 简化变参方法调用实例方法

    在本篇文章里我们给大家整理的是关于java7 简化变参方法调用实例方法以及实例代码，需要的朋友们学习下。
    2019-11-11
  • SpringIOC框架的简单实现步骤

    SpringIOC框架的简单实现步骤

    这篇文章主要介绍了SpringIOC框架简单实现步骤，帮助大家更好的理解和学习使用Spring，感兴趣的朋友可以了解下
    2021-05-05
  • java数组基础详解

    java数组基础详解

    下面小编就为大家带来一篇Java创建数组的几种方式总结。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧，希望能给大家带来帮助
    2021-06-06
  • java版十大排序经典算法:完整代码(2)

    java版十大排序经典算法:完整代码(2)

    优秀的文章也不少，但是Java完整版的好像不多，我把所有的写一遍巩固下，同时也真诚的希望阅读到这篇文章的小伙伴们可以自己去从头敲一遍，不要粘贴复制！希望我的文章对你有所帮助，每天进步一点点
    2021-07-07

最新评论