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

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

3个回答

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

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

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

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

Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
spring+activemq 发布订阅模式,短期运行正常后监听消失
activeMQ发布/订阅模式下,消费者端通过异步消息监听器(messagelistener)实现消息订阅,同样的消费者端应用被部署到两台linux服务器上,正常监听一段时间后,经过没有消息发送阶段后,等到消息生产者再次开始发布消息时,其中一台服务器上的消费者端应用没有监听线程了,请问这是啥原因?请大神们赐教!!配置了失效重连机制
ActiveMQ发布订阅模式
发布订阅模式由消息生产者发布一条消息,所有订阅者都可以消费消息,如果有多个订阅者,在spring配置时需要不同的clientid。测试需要消息发布类与订阅者监听消息的类:package activemq.publisher;import org.springframework.jms.core.JmsTemplate; import org.springframework.scheduling.an
ActiveMQ发布订阅模式及Spring整合
Topic主题发布和订阅消息 前面讲的案例都是点对点的消息,即一个生产者发送的一条消息只能被一个消费者消费,然后就移除了。 而topic模式一条消息可以被多个消费者订阅,关系如下: 定义生产者 package com.sxt.demo; import java.net.URI; import java.util.Date; import javax.jms.Connection; impo...
activeMq的发布订阅模式
发送者: public static void main(String[] args) throws JMSException { ConnectionFactory connFactory = new ActiveMQConnectionFactory(null,null,"tcp://localhost:61616"); Connection conn = connFactory.c
ActiveMQ的发布订阅模式
1、ActivaMQ的发布订阅模式的简介       发布订阅模式有点类似于我们日常生活中订阅报纸。每年到年尾的时候,邮局就会发一本报纸集合让我们来选择订阅哪一个。在这个表里头列了所有出版发行的报纸,那么对于我们每一个订阅者来说,我们可以选择一份或者多份报纸。比如北京日报、潇湘晨报等。那么这些个我们订阅的报纸,就相当于发布订阅模式里的topic。有很多个人订阅报纸,也有人可能和我订阅了相同的报纸
Spring Redis与ActiveMQ发布订阅模式源码分析
文章对SpringRedis和ActiveMQ的源码及使用简要分析一下,希望能起到抛砖引玉的作用。笔者之前在博客中写了一篇关于生产消费者模式的一个工程使用案例,10W级数据更新操作__生产消费者模式。其实发布订阅模式与生产消费者只是两种模式上的不同,在业务处理逻辑上还是比较相似的。前者数据结构是一对多队列模式,后者是点对点队列模式。
Spring整合activeMq(二):发布订阅模式
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:util="http://www.springframework.org/schema/util" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.al
SpringBoot2.0之整合ActiveMQ(发布订阅模式)
SpringBoot2.0之整合ActiveMQ(发布订阅模式) 发布订阅模式与前面的点对点模式很类似,简直一毛一样 注意:发布订阅模式 先启动消费者 公用pom: &lt;project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" x...
使用Spring配置ActiveMQ的发布订阅模式
通过Spring对ActiveMQ进行配置开发,发布订阅模式,支持消息的持久化。 需要Spring2.5版本以上,如果有多个订阅者,每个订阅者需要指定不同的 clientId 。   发布者的配置:   &amp;lt;?xml version=&quot;1.0&quot; encoding=&quot;UTF-8&quot;?&amp;gt; &amp;lt;beans xmlns=&quot;http://www.springframework....
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点对点模式和发布订阅模式使用
activeMQ:消息中间件是在分布式系统中完成消息的发送和接受的基础软件 应用场景: 支付成功后由activeMQ进行后续的成本计算、商户计费、财务更新、风控归档等推送消息 有点对点模式和发布者订阅者模式(rabbitMQ)上架商品时项目中更改商品状态、发送消息到MQ中,商品信息保存到索引库,单品页静态化处理 点对点模式: 发送方; &lt;!-- 配置 工厂 连接...
spring环境整合activemq之发布订阅
一:整合需要的jar &amp;lt;dependency&amp;gt; &amp;lt;groupId&amp;gt;org.apache.activemq&amp;lt;/groupId&amp;gt; &amp;lt;artifactId&amp;gt;activemq-client&amp;lt;/artifactId&amp;gt; &amp;lt;version&amp;gt;5.13.4&amp;lt;/version&amp;gt; &amp;lt;/dependency&am
activemq发布订阅
一:加入jar &amp;lt;dependency&amp;gt; &amp;lt;groupId&amp;gt;org.apache.activemq&amp;lt;/groupId&amp;gt; &amp;lt;artifactId&amp;gt;activemq-client&amp;lt;/artifactId&amp;gt; &amp;lt;version&amp;gt;5.13.4&amp;lt;/version&amp;gt; &amp;lt;/dependency&amp;gt
ActiveMQ 发布订阅(topic)模式_发送消息和接收消息
发布订阅模式流程: 监听JMS 1) 客户机发送消息到JMS消息中间件 2) 服务端负责监听JMS消息目的地。 3) 发现JMS里面有消息产生,服务就可以订阅。 特点: 1) 消息可以被多个服务共享 2) 消息直到被所有消费后,消息消失。
activemq发布订阅持久化集成spring环境
一:pom.xml &amp;lt;artifactId&amp;gt;spring_activemq_demo&amp;lt;/artifactId&amp;gt; &amp;lt;properties&amp;gt; &amp;lt;spring.version&amp;gt;4.2.4.RELEASE&amp;lt;/spring.version&amp;gt; &amp;lt;/properties&amp;gt; &amp;lt;dependencies&amp;gt; &a
Redis发布订阅与ActiveMQ的比较
(1)ActiveMQ支持多种消息协议,包括AMQP,MQTT,Stomp等,并且支持JMS规范,但Redis没有提供对这些协议的支持; (2)ActiveMQ提供持久化功能,但Redis无法对消息持久化存储,一旦消息被发送,如果没有订阅者接收,那么消息就会丢失; (3)ActiveMQ提供了消息传输保障,当客户端连接超时或事务回滚等情况发生时,消息会被重新发送给客户端,Redis没有提供消息...
activemq发布订阅消息持久化
一:消息生产者MessageProducer调用setDeliverMode设置发布消息持久化方式,不设置默认也是持久化 import org.apache.activemq.ActiveMQConnectionFactory; import javax.jms.*; public class TopicProducer { public static void main(Str...
ActiveMq 点对点 发布订阅demo
简单的ActiveMq 点对点和发布订阅demo 直接运行main方法就好
ActiveMQ Topic发布订阅消息
package com.googlecode.garbagecan.jmsstudy.activemq.topic; import org.apache.activemq.ActiveMQConnectionFactory; import javax.jms.*; public class TopicPublisher { public static void main(...
ActiveMQ(4)-发布订阅
前面介绍的producer和consumer为点对点的消息,本篇介绍一下activemq的一对多消息。 发布订阅模式类似于日常生活中订阅报纸。每到年尾的时候,邮局就会发报纸集合让选择订阅那一种。在这个表里面列出所有出版社发行的报纸,那么对于我们每一个订阅者来说,我们可以选择一份或者多分报纸。比如人名日报,环球时报等。那么这些我们的报纸就相当于发布订阅模式里面的topic。有很多人订阅报纸,也有人可
发布订阅模式
1.
发布订阅模式
发布订阅模式,又叫做观察者模式,描述对象间的一对多依赖关系。我举几个常见例子以便理解:报纸或杂志发布订阅、js编程中的事件模型、手机流量超限制提醒等等 使用场景 应用于异步编程,替代传统回调。 用它的好处是可以切换我们的关注点,关注点集中在订阅事件,而在异步回调中我们需要关注内部运行状态。 取代对象之间的硬编码机制,对象之...
Spring实现activemq(队列模式和主题模式)
Spring实现activemq(队列模式和主题模式)(1) 队列模式的消息演示(先运行生产者,再运行消费者)(2) 主题模式的消息演示(先运行消费者,再运行生产者)(3) ConnectionFactory:一个spring为我们提供的连接池(4) JmsTemplate:每项发消息重建都会重新创建连接,会话和producer(5) Spring中提供了SingleConnectionFacto...
activemq正常启动后停止
activemq正常启动后,访问localhost:8161/admin 异常,并且./bin/activemq status显示ActiveMQ not running,即ActiveMQ当前是停止状态。 但在启动时日志输出是正常的。 分析解决 在activemq目录下运行 ./bin/activemq console 会以调试模式启动,并将日志输出到当前页面。 运行后报错如下: ...
redis 消息队列发布订阅模式spring boot实现
最近做项目的时候写到一个事件推送的场景。之前的实现方式是起job一直查询数据库,看看有没有最新的消息。这种方式非常的不优雅,反正我是不能忍,由于羡慕本身就依赖redis,刚好redis 也有消息队列的功能,就简单的使用redis 来实现这个消息推送。 之前参考网上的例子,发现全部来自一个地方,spring 官方的一个例子,某些打着“非官方例子”的头号,还是一样就复制了一下官方的例子,怕是自己都没
J2SE 使用spring初始化activeMq监听
一句话:new 出一个ApplicationContext的实例FileSystemXmlApplicationContext context = new FileSystemXmlApplicationContext(&quot;config/applicationContext-activeMq.xml&quot;);来看下FileSystemXmlApplicationContext 实现public clas...
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依赖 &lt;!-- activemq --&gt; &lt;dependency&gt; &lt;groupI...
ActiveMQ 点对点和发布订阅 入门demo
一、点对点模式       点对点的模式主要建立在一个队列上面,当连接一个列队的时候,发送端不需要知道接收端是否正在接收,可以直接向ActiveMQ发送消息,发送的消息,将会先进入队列中,如果有接收端在监听,则会发向接收端,如果没有接收端接收,则会保存在activemq服务器,直到接收端接收消息,点对点的消息模式可以有多个发送端,多个接收端,但是一条消息,只会被一个接收端给接收到,哪个接收端先连上...
SpringBoot整合ActiveMQ实战之发布订阅模式(pub/sub)
2018年 SpringBoot2.x视频教程 rn 70多节课,18年5月份新录制,采用Springboot2.x版本rn新版本新特性,包含基础框架讲解、热部署等 到使用。rn整合多个主流框架,后到阿里云部署项目等知识。rn 学习笔记-源代码-答疑专属答疑群rn购买课程后加入qq群 699347262(备注订单号后四位)
redis的发布订阅模式
发布订阅模式:就是一个发布者发布消息,多个订阅者进行消息的订阅,目的是为了消息的传送, 1.发布订阅模式的结构    主要包含三个部分:发布者,订阅者和Channel。   结合上图和消息中间件,可以将channel和消息中间件中的topic主题对应起来 2. Redis发布订阅功能 命令 用例和描述 subscribe subscribe channel [cha...
Redis发布订阅模式
PUBLISH/SUBSCRIBE 发布订阅模式的原理 包含两个角色,一个是发布者,一个是订阅者 订阅者可以订阅一个或者多个频道channel 发布者可以向指定频道发布信息 通过PUBLISH发布消息 PUBLISH channel message PUBLISH channel1.1 'maiziedu' 通过SUBSCRIBE命令订阅频道 SUBSCRIBE channel
JavaScript之发布订阅模式
发布订阅模式 发布订阅模式定义对象间的一种一对多的依赖关系,当一个对象的状态发生改变时,所有依赖于它的对象都将得到通知。通过它,不必定时的去查询监听对象的状态是否发生改变。 在发布订阅模式中,我们经常定义一个事件中心来管理所有事件的发布和订阅。这也是和观察者模式最主要的区别。 观察者模式中只有两个角色,观察者和被观察者,两者之间存在一定的耦合关系。发布订阅模式,则有三个角色,发布者、订阅者和事...
观察者模式和发布订阅模式(JS)
最近被人问到设计模式,观察者(Observer)模式和发布(Publish)/订阅(Subscribe)模式二者有什么区别。其实这两种模式还是有些许差异的,本质上的区别是调度的方式不同。 观察者模式 观察者模式,目标和观察者是基类,目标提供维护观察者的一系列方法,观察者提供更新接口。具体观察者和具体目标继承各自的基类,然后具体观察者把自己...
设计模式之---【发布订阅模式】
什么是发布订阅模式 为什么要使用发布订阅模式 怎么做 先开个头。。。
JavaScript 发布订阅模式实现
来自迅雷前端的一道笔试题 实现一个EventEmitter类,实现以下方法: 1.emitter.on(name,fn) //订阅name事件,监听函数为fn,可多次订阅 2.emitter.once(name,fn) //功能与on类似,但监听函数为一次性的,触发后自动移除 3.emitter.emit(name,data1,data2,...,datan) //发布name事件,所有订...
Redis的发布订阅模式
Redis提供了发布订阅功能,跟消息中间件是类似的,可以用于消息的传输,Redis提供了一组命令可以让开发者实现“发布/订阅”模式 (publish/subscribe) ,该模式同样可以实现进程间的消息传递。 它的实现原理是发布/订阅模式包含两种角色,分别是发布者和订阅者。订阅者可以订阅一个或多个频道,而发布者可以向指定的 频道发送消息,所有订阅此频道的订阅者都会收到该消息。 发布消息: 订阅...
javascript 观察者模式 发布订阅模式
观察者模式 观察者模式,每一个观察者对象有两个方法 添加监听subscribe 发布事件publish 观察者有个list存放所有的已经添加监听,当需要的时候,遍历当前观察者的list,达到发布给list的所有的观察者。 //观察者模式 class Hunter { constructor(name, level) { this.name = name; ...
redis之发布订阅模式
发布订阅模式原理包含两个角色,一个发布者,一个订阅者订阅者可以订阅一个火多个频道channel发布者可以向指定频道发布信息通过publish发布消息,publish channel1 'fern'通过subscribe订阅频道,subscribe channel1 channel2psubscribe channel?    指定规则订阅...
JS设计模式之发布订阅模式
发布 — 订阅模式又叫观察者模式,它定义对象间的一种一对多的依赖关系,当一个对象的状 态发生改变时,所有依赖于它的对象都将得到通知。在 JavaScript开发中,我们一般用事件模型 来替代传统的发布 — 订阅模式。现实中的发布-订阅模式不论是在程序世界里还是现实生活中,发布 — 订阅模式的应用都非常之广泛。 比如我们平时看新闻时有不同的版块,我们只想看我们想关注的版块时。那么新闻推送就是一个
相关热词 c# xml的遍历循环 c# 取 查看源码没有的 c#解决高并发 委托 c#日期转化为字符串 c# 显示问号 c# 字典对象池 c#5.0 安装程序 c# 分页算法 c# gmail 发邮件 c# 多层文件