activemq中消费者监听的方法进不去

activemq连接本地的服务能正常执行,如果连其他IP地址的服务,一直卡在消费者监听方法这里, messageConsumer.setMessageListener(new MessageListener() {

            public void onMessage(Message message) {  
                            .....//不会到这个方法里面来
                            }
                            }
0

1个回答

1
Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
ActiveMQ多个消费者监听一个列队,最后是谁消费了?
看过消息队列资料的同学应该在网上都看到过这段代码: //创建一个Queue Queue queue = new ActiveMQQueue("testQueue"); Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); //注册消费者1 MessageCon
ActiveMQ中消费者是如何接收消息的
一、 http://blog.csdn.net/manzhizhen/article/details/52606716 二、 http://blog.csdn.net/manzhizhen/article/details/52606717
activemq 三种消息监听器
在Spring整合JMS的应用中我们在定义消息监听器的时候一共可以定义三种类型的消息监听器,分别是MessageListener、SessionAwareMessageListener和MessageListenerAdapter。下面就分别来介绍一下这几种类型的区别。 1.3.1  MessageListener MessageListener是最原始的消息监听器,它是JMS规范中定义的一个
使用ActiveMQ遇到了一个监听器方式的消费者一段时间会自动断开连接的问题
Activemq我遇到了一个问, 就是mq部署到外网linux时, 我的消费者用的是messageListener, 可是过半个小时左右, 我在发消息的时候, 消费者就是接收不到了, 而且过一会就会发现mq管理页面发现消费者和mq断开连接, 这是什么原因呢? 问题一直困扰了我好久,最近突然找到了原因,记录一下 首先看一下官方文档 ActiveMQ InactivityMonitor The...
spring与activemq(三种消息监听方式)
   1.3     消息监听器MessageListener        在Spring整合JMS的应用中我们在定义消息监听器的时候一共可以定义三种类型的消息监听器,分别是MessageListener、SessionAwareMessageListener和MessageListenerAdapter。下面就分别来介绍一下这几种类型的区别。 1.3.1  MessageList...
ActiveMQ学习总结(10)——ActiveMQ采用Spring注解方式发送和监听
对于ActiveMQ消息的发送,原声的api操作繁琐,而且如果不进行二次封装,打开关闭会话以及各种创建操作也是够够的了。那么,Spring提供了一个很方便的去收发消息的框架,spring jms。整合Spring后,代码不仅变得非常优雅,而且易用性和扩展性更好。 1. maven依赖 activemq --> dependency> groupId>org.apache.xbeangrou
ActiveMQ之发布/订阅实现(监听模式MessageListener)
一.模式图 二.相关概念 1,主题(Topic) 2,发布者(Publisher) 3,订阅者(Subscriber) 客户端将消息发送到主题。多个发布者将消息发送到Topic,系统将这些消息传递给多个订阅者。 三.特点 1,每个消息可以有多个消费者 2,发布者和订阅者之间有时间上的依赖性。针对某个主题(Topic)的订阅者,它必须创建一个订阅者之后,
spring JMS、activemq中消费者收不到生产者发送的消息的原因解析
我们使用jms一般是使用spring-jms和activemq相结合,通过spring的JmsTemplate发送消息到指定的Destination。       首先定义一个activemq的连接池:   Xml代码   <bean id="connectionFactory" class="org.apache.activemq.pool.PooledConn...
ActiveMQ消费者详解
JMS(ActiveMQ) PTP和PUB/SUB模式实例:[url]http://donald-draper.iteye.com/blog/2347445[/url] ActiveMQ连接工厂、连接详解:[url]http://donald-draper.iteye.com/blog/2348070[/url] ActiveMQ会话初始化:[url]http://donald-draper....
第五章 多个消费者监听同一个队列
生产者:代码如上一章 消费者1:代码如前一章 消费者2:与消费者1代码完全相同 注意:此时,消费者1和2监听在同一个队列上,队列会以轮训的方式将10个消息分别交给消费者1和2进行处理。 但是这种情况下,如果消费者1处理的消息比较繁重,而消费者2处理的消息比较轻松地话,实际上应该让消费者2多处理一些消息,在消费者代码添加中如下代码: /** * ba...
ActiveMQ的监控和停止
原文地址:http://activemq.apache.org/version-5-getting-started.html#Version5GettingStarted-MonitoringActiveMQ Monitoring ActiveMQ You can monitor ActiveMQ using the Web Console by pointing your b
ActiveMQ:点对点队列消费者接收不到消息
一.环境说明 Windows 1709 阿里云ECS CentOS 7.4 ActiveMQ 5.15.2 JDK 1.8 IDEA 2017.3 Maven 3.5.0 二.问题说明远程消息服务器使用的是阿里云ECS,在windows上编写测试类测试消息队列的点对点的通信,却发现,无法消费生产者生产的消息,即接收不到消息.三.代码testProducer @Test public v
ActiveMQ中消费者是如何接收消息的(二)
上篇文章大致讲述了同步消费者和异步消费者接收消息的异同(详见《ActiveMQ中消费者是如何接收消息的(一)》http://manzhizhen.iteye.com/blog/2094130 ),但我们还未讲到消息是在什么时候放入消费者ActiveMQMessageConsumer类的“消息容器”unconsumedMessages中的,这很关键,因为为了解耦,消费者类不需要知道你ActiveMQ
Spring整合activemq,实现单消费者消费
1.ActiveMQ 是Apache出品,最流行的,能力强劲的开源消息总线,实现了JMS(Java MessageService,实际上是指JMS API)可用来实现基于消息的RPC(过程远程调用) 对于Spring和Java程序员来说不一定要实现JMS,还有另外一种可选方案—AMQP(advanced message queuing protocol),即高级队列消息协议 下面将介绍的是
spring与activemq(搭建简单的消息发送与监听)
  一、JMS简介           JMS的全称是Java Message Service,即Java消息服务。它主要用于在生产者和消费者之间进行消息传递,生产者负责产生消息,而消费者负责接收消息。把它应用到实际的业务需求中的话我们可以在特定的时候利用生产者生成一消息,并进行发送,对应的消费者在接收到对应的消息后去完成对应的业务逻辑。对于消息的传递有两种类型,一种是点对点的,即一个生产者和...
Spring与ActiveMQ整合(多线程并发发送与接收消息)
本文博客介绍生产者和消费者方都使用多线程技术并发发送和接收消息。
activeMQ的高级特性之messageGroup,一个队列多个消息消费者
一个队列多个消息消费者的情况 我们都知道queue是P2P 点对点的消息传递方式,那么当一个队列上注册了多个消费者的时候会是什么情况呢? activeMQ 的 这个 message group 高级功能(在apache官方文档的 高级功能一栏可以查看到) 这个消息组实际上的作用 就是在一个队列里,各个group 会成为独立的互不干扰的子队列, 应用于你需要消息队列的机制但是你运行
ActiveMQ中消费者是如何接收消息的(一)
事先说明,本博客关于ActiveMQ的文章都是基于ActiveMQ5.10版本。        初步用过ActiveMQ但又没去研究过源码的朋友肯定有些好奇ActiveMQ中消费者是如何接收消息的呢?本文我就和大家一起从源码角度来初步探讨消费者接收消息的过程。        我们知道,消息传送有两种模型:点对点(P2P)和发布订阅(PUB/SUB),队列模式中,消息生产者叫做发送者,消息消费者叫做
activemq中的消费者生成及消息处理
增加一个消息消费者 在transportConnection中注册了一个消息监听器DefaultTransportListener 当客户端有动作的的时候,通过消息监听器的oncommand进行处理。 当有一个消费者进入,则调用该类中的processAddConsumer 方法。具体调用流程如下:   消息到达服务器端之后,会被Subscriptio
ActiveMQ(四):Topic方式使用MessageListener监听的方式接收消息
发布/订阅模式
Spring-boot中简单操作activemq(生产者消费者代码)
pom.xml添加依赖: <!-- activemq --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-activemq</artifactId> </dependency&gt
ActiveMQ Broker发送消息给消费者过程详解
JMS(ActiveMQ) PTP和PUB/SUB模式实例:[url]http://donald-draper.iteye.com/blog/2347445[/url] ActiveMQ连接工厂、连接详解:[url]http://donald-draper.iteye.com/blog/2348070[/url] ActiveMQ会话初始化:[url]http://donald-draper....
activeMQ一个消费者同时订阅多个主题
这篇博客是在上一次基本发布订阅者模式的基础上改的,如果看不懂请点这里看我的这篇博客。 订阅一个主题和订阅多个主题前面的配置都是一样的,只要加一个监听器就可以了,十分简单,配置如下 订阅者只订阅一个主题是这样的 <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.
ActiveMQ 点对点-使用监听器接收消息
public class ConsumerListener {//默认连接用户名 private static final String USERNAME = ActiveMQConnection.DEFAULT_USER; //默认连接密码 private static final String PASSWORD = ActiveMQConnection.DEFAULT_...
ActiveMQ:设置多个并行的消费者
消息队列本来就是一种经典的生产者与消费者模式。生产者向消息队列中发送消息,消费者从消息队列中获取消息来消费。
activemq配置多个消费者
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:context="http://www.springframework.org/schema/context" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:amq="http:/
Activemq的端口监听介绍及端口优化
在activemq的conf/activemq.xml主配置文件里,有这样一段话,如图:   这个图里里的transportConnectors字段就是mq对各个网络协议端口的规定,由图可见,openwire这个name使用的接入端口是61616,amqp这个name的接入端口号是5672。name里的值是随便写的,它也会体现在mq的web Connections界面里,而0.0.0....
MQ的概念及用ActiveMQ实现一个生产者多个消费者共享消息队列
MQ的优点及使用场景: 消息总线(Message Queue),后文称MQ,是一种跨进程的通信机制,用于上下游传递消息。 在互联网架构中,MQ是一种非常常见的上下游“逻辑解耦+物理解耦”的消息通信服务。 使用了MQ之后,消息发送上游只需要依赖MQ,逻辑上和物理上都不用依赖其他服务。 什么时候不使用消息总线? 既然MQ是互联网分层架构中的解耦利器,那所有通讯都使用MQ岂不是很好?这是一...
Spring Boot 集成 ActiveMQ ,生成者与消费者,@Configration初始化参数
    之前很多人在CSDN上写过许多Spring Boot集成ActiveMQ文章,当然Spring IO 上也有对对应的Demo,大多数对JMSTemplate的使用是通过,application.properity来初始化相关参数,下面本人给出通过@Configuration来初始化相关的配置。JMSConfig.java@Configuration public class JMSConf...
activeMQ创建生产者与消费者
普通web项目,未使用maven 配置文件:default.properties,放到conf下就行。#---- activeMQ配置参数 ---------------------- AMQ_USER = admin AMQ_PASSWORD = admin #URL = ActiveMQConnection.DEFAULT_BROKER_URL; AMQ_URL = failover
spring JMS、activemq中消费者收不到生产者发送的消息的原因解析
我们使用jms一般是使用spring-jms和activemq相结合,通过spring的JmsTemplate发送消息到指定的Destination。       首先定义一个activemq的连接池:   Xml代码   bean id="connectionFactory" class="org.apache.activemq.pool.PooledC
ActiveMQ消息传递
ActiveMQ ActiveMQ 是Apache出品,最流行的,能力强劲的开源消息总线。ActiveMQ 是一个完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现,尽管JMS规范出台已经是很久的事情了,但是JMS在当今的J2EE应用中间仍然扮演着特殊的地位。 简单来说ActiveMQ是JMS规范的实现者之一,因为它免费,所以用的人就多 要想使用Activ...
折腾ActiveMQ时遇到的问题和解决方法
1.先讲严重的:服务挂掉。 这得从ActiveMQ的储存机制说起。在通常的情况下,非持久化消息是存储在内存中的,持久化消息是存储在文件中的,它们的最大限制在配置文件的节点中配置。但是,在非持久化消息堆积到一定程度,内存告急的时候,ActiveMQ会将内存中的非持久化消息写入临时文件中,以腾出内存。虽然都保存到了文件里,但它和持久化消息的区别是,重启后持久化消息会从文件中恢复,非持久化的临时文件会
ActiveMQ服务重启 收不到消息
ActiveMQ做大并发的缓冲,消息的生产和消费都是用的spring封装的消息监听容器。 在系统测试过程中偶然发现,消费无法发送,发送端直接报异常。显示连接拒绝。直接重启ActiveMQ,问题依然存在。 只能重启消费发送的服务,消息可以发送了。查看ActiveMQ控制台,有消息发送成功了,但是没有消费者。重启消费者服务,可以了。 可以以为是spring的消息监听容器的问题,找了半天,没有找到
activemq中多个consumer引起接收不到信息
使用activemq时,若一个mq有两个comsumer时,会有接收不到信息的情况
ActiveMQ经典的使用模式(利用多线程处理消费端)
今天看视频,里面讲了一个经典的例子,是工作中很常用的,特此将这种模式记录下来.这个例子使用了ActiveMQ的选择器,也使用了之前学的自定义线程池.队列的使用,而且很好的利用多线程并发的处理了任务,提高了吞吐量.首先看生产端:package com.jvm.activemq.bhz.mq; import com.jvm.util.PropertiesUtil; import org.apache...
activemq 三种消息监听方式
1.activemq 消息监听的三种方式。点击打开链接
ActiveMQ独占消费模式
本文主要介绍一下ActiveMQ消息独占模式   1、消息独占模式(Exclusive Consumer)   Queue中的消息是按照顺序被分发到consumers的。然而,当你有多个consumers同时从相同的queue中提取消息时,你将失去这个保证。因为这些消息是被多个线程并发的处理。有的时候,保证消息按照顺序处理是很重要的。例如,你可能不希望在插入订单操作结束之前执行更新这个...
ActiveMQ 的独占消费模式
本文主要介绍一下ActiveMQ消息独占模式   1、消息独占模式(Exclusive Consumer)   Queue中的消息是按照顺序被分发到consumers的。然而,当你有多个consumers同时从相同的queue中提取消息时,你将失去这个保证。因为这些消息是被多个线程并发的处理。有的时候,保证消息按照顺序处理是很重要的。例如,你可能不希望在插入订单操作结束之前执行更新这个订单...
spring+activemq配置多个生产者,多个消费者并发处理消息
先贴配置
文章热词 机器学习教程 Objective-C培训 交互设计视频教程 颜色模型 设计制作学习
相关热词 mysql关联查询两次本表 native底部 react extjs glyph 图标 java学习中记混方法 学习产品经理的方法