java消息队列ActiveMQ之Comsumer

1、需要添加在上一篇博客中说到的依赖jar包
2、创建创建消费者

package com.activemq.demo;import java.util.concurrent.atomic.AtomicInteger;import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.JMSException;
import javax.jms.MessageConsumer;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;public class Comsumer {private static final String USERNAME = ActiveMQConnection.DEFAULT_USER;private static final String PASSWORD = ActiveMQConnection.DEFAULT_PASSWORD;private static final String BROKEN_URL = "tcp://192.168.0.0:61616";ConnectionFactory connectionFactory;Connection connection;Session session;ThreadLocal<MessageConsumer> threadLocal = new ThreadLocal<>();AtomicInteger count = new AtomicInteger();public void init() {try {connectionFactory = new ActiveMQConnectionFactory(USERNAME,PASSWORD, BROKEN_URL);connection = connectionFactory.createConnection();connection.start();session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);} catch (JMSException e) {e.printStackTrace();}}public void getMessage(String disname) {try {Queue queue = session.createQueue(disname);MessageConsumer consumer = null;if (threadLocal.get() != null) {consumer = threadLocal.get();} else {consumer = session.createConsumer(queue);threadLocal.set(consumer);}while (true) {Thread.sleep(1000);TextMessage msg = (TextMessage) consumer.receive();if (msg != null) {msg.acknowledge();System.out.println("接收到消息：" + msg.getText() + " ||  "+ count.getAndIncrement());} else {break;}}} catch (JMSException e) {e.printStackTrace();} catch (InterruptedException e) {e.printStackTrace();}}
}

3、测试

package com.activemq.demo;public class TestGetMsg {public static void main(String[] args) {Comsumer comsumer = new Comsumer();comsumer.init();TestGetMsg testGetMsg = new TestGetMsg();try {Thread.sleep(3000);} catch (InterruptedException e) {e.printStackTrace();}new Thread(testGetMsg.new ProductorMq(comsumer)).start();}private class ProductorMq implements Runnable {Comsumer comsumer;public ProductorMq(Comsumer comsumer) {this.comsumer = comsumer;}@Overridepublic void run() {while (true) {comsumer.getMessage("LGZ-MQ");
//              try {//                  Thread.sleep(500);
//              } catch (InterruptedException e) {//                  e.printStackTrace();
//              }}}}
}

java消息队列ActiveMQ之Comsumer相关推荐

Java消息队列--ActiveMq 初体验
1.下载安装ActiveMQActiveMQ官网下载地址:http://activemq.apache.org/download.htmlActiveMQ 提供了Windows 和Linux.Unix ...
Java消息队列-Spring整合ActiveMq
1.概述首先和大家一起回顾一下Java 消息服务,在我之前的博客<Java消息队列-JMS概述>中,我为大家分析了: 消息服务:一个中间件,用于解决两个或多个程序之间的耦合,底层由Jav ...
java 消息队列详解_Java消息队列-Spring整合ActiveMq的详解
本篇文章主要介绍了详解Java消息队列-Spring整合ActiveMq ,小编觉得挺不错的,现在分享给大家,也给大家做个参考.一起跟随小编过来看看吧 1.概述首先和大家一起回顾一下Java 消息服 ...
java分布式面试题之消息队列ActiveMQ部分
java分布式面试题之消息队列ActiveMQ部分 java分布式面试题之消息队列ActiveMQ部分 1.如何使用ActiveMQ解决分布式事务? 在互联网应用中,基本都会有用户注册的功能.在注册的 ...
java 消息队列_java消息队列
Java消息服务(Java Message Service,JMS)应用程序接口是一个Java平台中关于面向消息中间件(MOM)的API,用于在两个应用程序之间,或分布式系统中发送消息,进行异步通信. ...
CentOS源码安装消息队列ActiveMQ
消息队列ActiveMQ介绍 JMS全称:Java Message Service中文:Java消息服务.JMS是java的一套API标准,最初的目的是为了是应用程序能够访问现有的MOM系统(MOM是 ...
Java 消息队列、缓存、同步（个人理解：空谈）
Java 消息队列.缓存.同步. 消息队列我的理解:消息队列,将消息存入消息队列,然后就OK了. 系统之间原先调用通用接口,但引入了消息队列后,系统之间调用MQ消息队列. 好处:响应快,能累积请求, ...
消息队列 - ActiveMQ
消息队列 - ActiveMQ 一.入门概述 1.在什么场景下使用消息中间件,为什么使用 2. 消息队列是什么 3. 去哪下二.ActiveMQ的安装和控制台 1.Linux安装 2.Apache ...
Java消息队列总结只需一篇解决ActiveMQ、RabbitMQ、ZeroMQ、Kafka
一.消息队列概述消息队列中间件是分布式系统中重要的组件,主要解决应用解耦,异步消息,流量削锋等问题,实现高性能,高可用,可伸缩和最终一致性架构.目前使用较多的消息队列有ActiveMQ,Rabbit ...

java消息队列ActiveMQ之Comsumer

java消息队列ActiveMQ之Comsumer相关推荐

最新文章

热门文章