spring+activemq 发布订阅模式,短期运行正常后监听消失

activeMQ发布/订阅模式下,消费者端通过异步消息监听器(messagelistener)实现消息订阅,同样的消费者端应用被部署到两台linux服务器上,正常监听一段时间后,经过没有消息发送阶段后,等到消息生产者再次开始发布消息时,其中一台服务器上的消费者端应用没有监听线程了,请问这是啥原因?请大神们赐教!!配置了失效重连机制

0

3个回答

看你的日志打印了什么异常信息

0
u012588094
马提斯亚胡 回复gesanghua601: 正常的TCP连接是比较可靠的,既然消费者断掉,说明TCP连接断开了,如果不是通信方主要关闭连接的话,可能是网络通讯异常导致TCP断开,你看看那台服务器的网络状况呢,同时可以把你的日志级别设置成DEBUG
一年多之前 回复
gesanghua601
爱鞋小姐 日志里没有异常信息,activemq监控平台上消息订阅者数量减少
一年多之前 回复

日志里没有异常信息,activemq监控平台上消息订阅者数量减少

0

我最后是添加了一个消息生产者定时向activemq发送消息,测试了一段时间,没有断了

0
Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
ActiveMQ PTP/发布订阅者模式及与Spring结合(四)
PTP    PTP的过程理解起来简单。它好比两个人打电话,这两个人是独享这一条通信链路的。一方是发送消息,另外一方接收,就这么简单。在实际应用中因为有多个用户对使用PTP的链路,他的通信场景如下Publish-Subscribe    发布订阅模式有点类似于我们日常生活中订阅报纸。每年到年尾的时候,邮局就会发一本报纸集合让我们来选择订阅哪一个。在这个表里头裂了所有出版发行的报纸,那么对于我们每一...
spring boot整合activeMQ,实现queue和topic两者消息模式
如何下载安装MQ我就不说了,百度一大把,老规矩先上一下项目目录结构: 先看一下配置文件,主要是中间件的配置: ps:1.主要注意的是activeMQ默认提供ptp模式,若要使用topic模式需要假如最后一个配置为truespring.activemq.broker-url=tcp://localhost:61616 spring.activemq.in-memory=true spring.
activeMq点对点和发布/订阅模式demo
刚接触activemq时写的一些demo,感兴趣的可以参考一下。。。
spring整合ActiveMQ订阅模式(对象消息发送)
归纳一下spring整合activemq的基础配置以及使用,监听到消息后的更多逻辑操作需要自己完成,需要源代码可联系:993610778
spring+activemq 发布订阅模式,短期运行正常后监听消失
activeMQ发布/订阅模式下,消费者端通过异步消息监听器(messagelistener)实现消息订阅,同样的消费者端应用被部署到两台linux服务器上,正常监听一段时间后,经过没有消息发送阶段后,等到消息生产者再次开始发布消息时,其中一台服务器上的消费者端应用没有监听线程了,请问这是啥原因?请大神们赐教!!配置了失效重连机制
使用Spring配置ActiveMQ的发布订阅模式
通过Spring对ActiveMQ进行配置开发,发布订阅模式,支持消息的持久化。 需要Spring2.5版本以上,如果有多个订阅者,每个订阅者需要指定不同的 clientId 。   发布者的配置 <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/X
ActiveMQ消息中间件和Spring框架整合--队列模式和发布订阅模式
1.使用方法 官方网站:http://activemq.apache.org/ 下载最新版本 解压 启动 bin/win64/activemq.bat 访问 http://127.0.0.1:8161/admin/ 用户和密码都是admin pom的依赖坐标 &amp;lt;dependencies&amp;gt; &amp;lt;dependency&amp;gt; &amp;lt;grou...
初入activeMQ,spring+activeMQ的整合实现发布订阅
*spring+activeMQ整合一直想写博客,技术用的都太多,但是都不久,总是忘记,老大让搞老项目,今天自己在公司搞了MQ,记录一下:介绍就不需要了,网上一大堆,我喜欢直接上干货,直接撸,看起来也爽。 spring的原理就不用说了,首先spring里面配置能够扫描到这个xml我的xml命名为applicationContext-activemq-container.xml 需要spring加载
ActiveMQ实战(五)--Spring整合ActiveMQ实现点对点与主题发布订阅通信
一、项目结构 二、加入Maven依赖 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 ht
Spring+ActiveMQ消息持久化,Topic持久化订阅
消息持久化就是将消息保存到磁盘,这样的好处就是如果服务挂了,则消息还保存在磁盘不会丢失,服务起来后还能找到消息并在此发送,消息的持久化和消息的发送模型是没有关系的。 消息持久化的配置很方便的,所以其他的那些就不写出来了,可以看看上一篇文章中的同步异步实现方式。这里只把持久化配置的列出来。 [html] view plain copy  print?
ActiveMQ订阅模式持久化实现
我的诉求是,建一个订阅通道,然后多个客户端监听,当某个客户端掉线后,再上线的时候可以收到它没有接收到的消息。 本文主要参考了《使用Spring配置ActiveMQ的发布订阅模式》(http://nettm.iteye.com/blog/1828268),将他们复制粘贴过来,基本上就ok了。 在找到这篇文章前,《如何实现ActiveMq的Topic的持久订阅》(http://www.my
ActiveMQ 点对点和发布订阅 入门demo
一、点对点模式       点对点的模式主要建立在一个队列上面,当连接一个列队的时候,发送端不需要知道接收端是否正在接收,可以直接向ActiveMQ发送消息,发送的消息,将会先进入队列中,如果有接收端在监听,则会发向接收端,如果没有接收端接收,则会保存在activemq服务器,直到接收端接收消息,点对点的消息模式可以有多个发送端,多个接收端,但是一条消息,只会被一个接收端给接收到,哪个接收端先连上...
Spring Redis与ActiveMQ发布订阅模式源码分析
文章对SpringRedis和ActiveMQ的源码及使用简要分析一下,希望能起到抛砖引玉的作用。笔者之前在博客中写了一篇关于生产消费者模式的一个工程使用案例,10W级数据更新操作__生产消费者模式。其实发布订阅模式与生产消费者只是两种模式上的不同,在业务处理逻辑上还是比较相似的。前者数据结构是一对多队列模式,后者是点对点队列模式。
SpringBoot+ActiveMq实现订阅模式(Topic)消息队列
上文已经详细介绍了点对点模式(Queue)下的消息队列,今天就来再介绍一下消息队列的另一种模式:订阅模式。 一、订阅模式的流程 生产者产生一条消息message放入一个topic中,该topic已经三个消费者订阅了,那么被放入topic中的这条消息,就会同时被这三个消费者取走(当然他们必须都处于在线状态),并进行“消费”。其实就类似现实生活中的手机接收推送。 二、订阅模式的应用场景 ...
springboot 整合activemq 消息发布和订阅
1.maven依赖 &lt;!--activemq的依赖--&gt; &lt;dependency&gt; &lt;groupId&gt;org.springframework.boot&lt;/groupId&gt; &lt;artifactId&gt;spring-boot-starter-activemq&lt...
ActiveMQ之发布/订阅实现(监听模式MessageListener)
一.模式图 二.相关概念 1,主题(Topic) 2,发布者(Publisher) 3,订阅者(Subscriber) 客户端将消息发送到主题。多个发布者将消息发送到Topic,系统将这些消息传递给多个订阅者。 三.特点 1,每个消息可以有多个消费者 2,发布者和订阅者之间有时间上的依赖性。针对某个主题(Topic)的订阅者,它必须创建一个订阅者之后,
基于SpringBoot开发的ActiveMQ虚拟主题客户端(包含发布者和订阅者)
基于SpringBoot开发的ActiveMQ虚拟主题客户端,达到消费者多点消费、负载均衡和故障转移的目的。 详情可以参考这里: https://my.oschina.net/noryar/blog/1573047 https://my.oschina.net/noryar/blog/1575003
ActiveMQ的使用与遇到的相关坑(点对点,发布与订阅,resreq)
1、介绍 ActiveMQ是Apache出品,最流行的,能力强劲的开源消息总线。ActiveMQ 是一个完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现,尽管JMS规范出台已经是很久的事情了,但是JMS在当今的J2EE应用中间仍然扮演着特殊的地位。 MQ可以是不同应用之间进行沟通的桥梁, 支持多种语言和协议编写客户端,如: Java,C,C++,C#,Ruby,
SpringBoot整合ActiveMQ消息队列和双向队列、点对点与发布订阅
ActiveMQ 是Apache出品,最流行的,能力强劲的开源消息总线。ActiveMQ 是一个完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现,尽管JMS规范出台已经是很久的事情了,但是JMS在当今的J2EE应用中间仍然扮演着特殊的地位。  1.添加SpringBoot集成ActiveMQ所需依赖  &amp;lt;!-- activeMQ--&amp;gt; &amp;lt;dep...
ActiveMQ服务重启 收不到消息
ActiveMQ做大并发的缓冲,消息的生产和消费都是用的spring封装的消息监听容器。 在系统测试过程中偶然发现,消费无法发送,发送端直接报异常。显示连接拒绝。直接重启ActiveMQ,问题依然存在。 只能重启消费发送的服务,消息可以发送了。查看ActiveMQ控制台,有消息发送成功了,但是没有消费者。重启消费者服务,可以了。 可以以为是spring的消息监听容器的问题,找了半天,没有找到
ActiveMQ 发布- 订阅消息模式实现
1、消息生产者-消息发布者 /** * 消息生产者 * @author Administrator * */ public class JMSProducer { private static final String USERNAME=ActiveMQConnection.DEFAULT_USER; // 默认的连接用户名 private static final St...
ActiveMQ和spring整合,订阅主题和消息消费
本文章适用初学ActiveMQ的统同学。 本演示为windows下进行 首先下载ActiveMQ 1.ActiveMQ地址     ActiveMQ官方网站:http://activemq.apache.org/  2.下载完成或解压到本地F:/目录下 3.启动本地ActiveMQ服务。   进入到安装目录双击activemq.bat文件启动,如果启动时窗口一闪而
ActiveMQ发布-订阅消息模式(同点对点模式的区别)
1、消息生产者-消息发布-Topic [html] view plain copy /**   * 消息生产者-消息发布者   * @author Administrator   *   */  public class JMSProducer {      private static final String USERNAME=ActiveMQConnection
activemq中的订阅模式以及消息时长和确认机制
直接上代码 发布主题 package com.activemq; import org.apache.activemq.ActiveMQConnectionFactory; import javax.jms.*; public class TopicPub { public static void main(String[] args) throws JMSException {
springboot activemq(二) 同时使用jms的Queue(队列)和Topic(发布订阅)
1.在启动类Application.java中加入 @Configuration @EnableJms public class JmsConfig { @Bean public JmsListenerContainerFactory&amp;lt;?&amp;gt; topicListenerFactory(ConnectionFactory connectionFactory) { Default...
ActiveMQ的发布订阅模式
1、ActivaMQ的发布订阅模式的简介       发布订阅模式有点类似于我们日常生活中订阅报纸。每年到年尾的时候,邮局就会发一本报纸集合让我们来选择订阅哪一个。在这个表里头列了所有出版发行的报纸,那么对于我们每一个订阅者来说,我们可以选择一份或者多份报纸。比如北京日报、潇湘晨报等。那么这些个我们订阅的报纸,就相当于发布订阅模式里的topic。有很多个人订阅报纸,也有人可能和我订阅了相同的报纸
分布式消息中间件(二)——ActiveMQ发布-订阅消息模式
1、消息生产者-消息发布-Topic /** * 消息生产者-消息发布者 * @author Administrator * */ public class JMSProducer { private static final String USERNAME=ActiveMQConnection.DEFAULT_USER; // 默认的连接用户名 private static fin
分析ActiveMQ的点对点和发布/订阅二种消息传递形式
ActiveMQ对于消息的传递有两种类型: 一种是点对点的,即一个生产者和一个消费者一一对应; 另一种是发布/订阅模式,即一个生产者产生消息并进行发送后,可以由多个消费者进行接收。 首先是点对点的这种消息传递,提供方演示代码如下 public void Test() throws JMSException { // 第一步:创建ConnectionFactory对象,需...
active mq 多个消费者实战(发布订阅模式)
注意:所有的配置文件都在src文件下            声明:  在这里不讲activemq 是什么,本人只是根据平时用到的东西整理一下希望对大家有所帮助。         首先是生产者的配置文件 <beans xmlns="http://www.springframework.org/schema/beans" xmlns:context="http://www.springfra
activeMQ发布订阅者模式使用
发送方:                                                                                                                                                                                 
ActiveMQ实战(三)--ActiveMQ的通信方式之主题发布订阅式(publish-subscribe)
一、简介 发布/订阅方式用于多接收客户端的方式.作为发布订阅的方式,可能存在多个接收客户端,并且接收端客户端与发送客户端存在时间上的依赖。一个接收端只能接收他创建以后发送客户端发送的信息。作为subscriber ,在接收消息时有两种方法,destination的receive方法,和实现message listener 接口的onMessage 方法。  发布订阅模式有点
activemq持久订阅工作原理
对activemq消息订阅模式来说有两种:持久订阅/非持久订阅。 非持久订阅consumer只能消费在该consumer激活状态时传送给对应topic的消息才能被该consumer消费,一旦该consumer 挂掉到下次启动期间发布到该topic的消息不能被该consumer重新恢复时使用!!! 持久订阅:订阅之后,无论消息是否是在该consumer激活或者down掉期间发送的,最终都会被该c...
ActiveMQ使用spring JmsTemplate生成和订阅消息(二)
生成类: @Component("topicProvider") public class TopicProvider { @Resource private JmsTemplate topicJmsTemplate; /** * 向指定的topic发布消息 * * @param topic * @param msg
springboot整合activeMQ案例,queue、topic两种模式
一.activeMQ安装    可以查看我的以前博客:点击打开链接  (Linux下activeMq安装与配置),windows安装更为简单,下载Windows版本的activeMQ,解压,进入目录,如下图:我的电脑是64位的,直接双击activemq.bat即可,32位的进入win32文件夹下双击activemq.bat即可。二.Springboot整合activemq项目项目目录结构如下:po...
activemq的几种基本通信方式总结(点对点-发布订阅)
简介      在前面一篇文章里讨论过几种应用系统集成的方式,发现实际上面向消息队列的集成方案算是一个总体比较合理的选择。这里,我们先针对具体的一个消息队列Activemq的基本通信方式进行探讨。activemq是JMS消息通信规范的一个实现。总的来说,消息规范里面定义最常见的几种消息通信模式主要有发布-订阅、点对点这两种。另外,通过结合这些模式的具体应用,我们在处理某些应用场景的时候也衍生
用C#实现的ActiveMQ发布/订阅消息传送
用C#实现的ActiveMQ发布/订阅消息传送源程序
ActiveMQ点对点模式实例
消息队列一般有两种模型 1.点对点模型(基于队列 Point to Point,PTP) 每个消息只能有一个消费者。消息的生产者和消费者之间没有时间上的 相关性.可以有多个发送者,但只能被一个消费者消费。 一个消息只能被一个接受者接受一次 生产者把消息发送到队列中(Queue),接受者无需订阅,当接受者未接受到消息时就会处于阻塞状态 2.  发布者/订阅者模型(基于主题的Publish/Sub...
activemq的三种基本通信方式总结 点对点 发布订阅 请求应答
简介      在前面一篇文章里讨论过几种应用系统集成的方式,发现实际上面向消息队列的集成方案算是一个总体比较合理的选择。这里,我们先针对具体的一个消息队列Activemq的基本通信方式进行探讨。activemq是JMS消息通信规范的一个实现。总的来说,消息规范里面定义最常见的几种消息通信模式主要有发布-订阅、点对点这两种。另外,通过结合这些模式的具体应用,我们在处理某些应用场景的时候也衍生
spring与activemq(三种消息监听方式)
   1.3     消息监听器MessageListener        在Spring整合JMS的应用中我们在定义消息监听器的时候一共可以定义三种类型的消息监听器,分别是MessageListener、SessionAwareMessageListener和MessageListenerAdapter。下面就分别来介绍一下这几种类型的区别。 1.3.1  MessageList...
springboot + rabbitmq 发布订阅 (广播)
springboot + rabbitmq 发布订阅 (广播) 配置类 @Configuration public class RabbitMqConfig2 { @Bean public Queue queue1(){ return new Queue(&quot;queue1&quot;); } @Bean public Queue queue2(){ return new Queue...
文章热词 机器学习教程 Objective-C培训 交互设计视频教程 颜色模型 设计制作学习
相关热词 mysql关联查询两次本表 native底部 react extjs glyph 图标 短期数据库培训 云计算短期培训班