ActiveMQ的topic消息突然丢失,必须重启服务才能再收到 10C

有没有哪位大神遇到过这种情况,监听ActiveMQ的topic消息时,服务刚启动时是好的,可以收到消息,但几个小时以后就突然收不到了,也不报错,必须重启服务才能再收到消息。我使用的是spring boot集成activemq,但我觉得跟这个关系不大,因为我单独跑mq也遇到同样的问题,求大神解答

2
u011187858
素56 你好,我现在也出现了这个问题,请问你是怎么解决的呢
4 个月之前 回复

1个回答

ActiveMQ做大并发的缓冲,消息的生产和消费都是用的spring封装的消息监听容器。

在系统测试过程中偶然发现,消费无法发送,发送端直接报异常。显示连接拒绝。直接重启ActiveMQ,问题依然存在。

只能重启消费发送的服务,消息可以发送了。查看ActiveMQ控制台,有消息发送成功了,但是没有消费者。重启消费者服务,可以了。

可以以为是spring的消息监听容器的问题,找了半天,没有找到断开重连的参数。

继续网上找,终于发现只要修改ActiveMQ的连接串就可以了。将tcp://127.0.0.1:61616 改成 failover:tcp://127.0.0.1:61616" OK了!

0
Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
ActiveMQ服务重启 收不到消息
ActiveMQ做大并发的缓冲,消息的生产和消费都是用的spring封装的消息监听容器。 在系统测试过程中偶然发现,消费无法发送,发送端直接报异常。显示连接拒绝。直接重启ActiveMQ,问题依然存在。 只能重启消费发送的服务,消息可以发送了。查看ActiveMQ控制台,有消息发送成功了,但是没有消费者。重启消费者服务,可以了。 可以以为是spring的消息监听容器的问题,找了半天,没有找到
ActiveMQ Topic发布订阅消息
package com.googlecode.garbagecan.jmsstudy.activemq.topic; import org.apache.activemq.ActiveMQConnectionFactory; import javax.jms.*; public class TopicPublisher { public static void main(...
JMS ActiveMQ 消息丢失
对于单点故障情况断线期间所有消息自动丢弃r 请教一下各位大虾是如何解决类似问题的
activemq丢失消息问题
目前有两个服务器,程序在一个服务器上运行正常,但是另一个服务器上总是丢失消息,DB都是一样的,请问activemq是否和服务器的配置有什么关系呢,我已经做了持久化处理。
ActiveMQ Topic消息失败重发
       消息失败重发指的是当消息的接收方没有成功的消费消息,我们需要重发消息,让消息的接收方成功消费这个消息,保证事务的完整性和消息的一致性。 一、JMS消息确认机制     在session接口中定义的几个常量:    AUTO_ACKNOWLEDGE =  1    自动确认   CLIENT_ACKNOWEDGE =  2    客户端手动确认   DUPS_OK_ACKNO...
ActiveMQ突然挂了,已经发送的消息(Topic)没有被消费者消费,重启后怎么才能获取到这条消息?
ActiveMQ突然挂了,如果生产者已经生产了消息,但没有被消费者消费,重启之后,消费者能够重新获取到这些消息么?怎么才能获取到?
服务(service)如何才能收到 SERVICE_CONTROL_SHUTDOWN 消息?
怎样才能得到系统(win2000)关机的消息?我的服务根本收不到这样的消息,查msdn时说只要安装了service pack1就可以了,但我都已经装了sp3了还是不行!救救我呀!
淘淘商城系列——ActiveMQ发送topic消息和接收topic消息
我相信大家通过前面的学习,已然知道了如何发送队列消息及消费队列消息。本文我们将一起学习如何发送topic消息和接收topic消息。 我们依然在TestActiceMQ单元测试类中添加一个测试方法,用来测试发送topic消息,如下图所示,其实这个方法与发送队列消息几乎一样,只是创建Destination对象的时候不一样而已。 为了方便大家复制,现将testTopicProducer测试方法的代
Activemq 消息服务
1、简介 ActiveMQ 自己看百科 2、下载安装  去 apache 官网下载,http://archive.apache.org/dist/activemq/  3、安装 a、解压 tar -xvf apache-activemq-5.14.4-bin.tar.gz  b、拷贝到/usr/local下 mv apache-activemq-5.14.4 /usr/loca...
ActiveMQ消息服务配置
ActiveMQ配置说明,包括java内存调整,主从集群配置,自动清理离线客户端(避免长时间持久订阅占用内存)等
JMS消息服务-ActiveMQ
JMS消息服务-ActiveMQ sf2gis@163.com 2015年7月28日   1  JMS消息服务 目标:网络或进程间的消息异步、同步通信、点对点或发布模式通信。将消息的收、发方解耦。 原理:Java提供JMS(Java Message Service)作为消息服务的规范,可以有不同的实现方法。发送方将消息发向JMS服务器,由JMS服务器处理消息后再发送到收取方。 参考:
activemq消息持久化丢失的问题
问题描述:rn 我使用activemq之后,有下面的一种情况消息没法持久化:rn 我的持久化环境已经搭好了的前提下:rn 首先不要启动消费者。然后启动生产者往mq里面仍消息。这时候让mq宕机,由于没有消费者订阅过这个消息mq就宕机了,所以再次重启mq之后,发现刚刚生产者发送的消息都没有了,rn 当然这种情况或许有大兄弟会说控制好启动顺序不就得了,但是生产中是会出现我刚才说的情况的,rnrn请问各位大兄弟你们的解决方案是什么,我要的是亲自实操过的方案,谢谢啦!!!
ACTIVEMQ Topic消息 生产者 发布消息后 消费者收不到消息
 rnrn rn  
ActiveMQ的消息模式——主题模式(Topic)
主题模式 又名 发布订阅者模式(Pub/Sub)。 一、主题模式特点 客户端包括发布者和订阅者 主题中的消息被所有订阅者消费 消费者不能消费订阅之前就发送到主题中的消息 二、创建过程 1.创建连接Connection2.创建会话Session3.通过Session来创建其它的(MessageProducer、MessageConsu...
一个jms activemq Topic 消息实例
一个jms activemq Topic 消息实例 关于jms JMS 是接口,相当于jdbc ,要真正使用它需要某些厂商进行实现 ,即jms provider 常见的jms provider 有 ActiveMQ JBoss 社区所研发的 HornetQ (在jboss6 中默认即可以使用它) jbossmq 等 在jboss 5 之前好像一直在用jbossmq ,而从6 开始使用HornetQ ,hornetq 也可以脱离jboss 单独使用 hornetq 的配置在jboss-6.0.0.20100429-M3/server/default/deploy/hornetq/目录进行配置
ActiveMQ 发布订阅(topic)模式_发送消息和接收消息
发布订阅模式流程: 监听JMS 1) 客户机发送消息到JMS消息中间件 2) 服务端负责监听JMS消息目的地。 3) 发现JMS里面有消息产生,服务就可以订阅。 特点: 1) 消息可以被多个服务共享 2) 消息直到被所有消费后,消息消失。
ActiveMQ(九)--持久的Topic消息示例
生产者 import org.apache.activemq.ActiveMQConnectionFactory; import javax.jms.*; public class PersistenceSender { public static void main(String[] args) throws JMSException, InterruptedException ...
ActiveMq使用(三) Topic消息持久化
1.生产者 <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instanc
ActiveMQ实战之 Topic发布订阅消息【转】
对于此类消息,其实就是指使用JMS中的发布订阅消息模型的消息,下面是一个简单的例子 消息发布者 view plain copy to clipboard print ? package  com.googlecode.garbagecan.jmsstudy.activemq.topic;      import  org.apache.ac...
ActiveMQ(八)--非持久的Topic消息示例
对于非持久的topic消息的发送 基本跟前面发送队列信息是一样的,只是把创建Destination的地方,由创建队列替换成创建Topic,例如:Destination destination = session.createTopic("MyTopic"); 对于非持久的topic消息的接收 1.必须要接收方在线,然后客户端再发送消息,接收方才能接收到消息 2.同样把创建Destination的...
深入浅出JMS(五)--ActiveMQ Topic发布订阅消息
消息发布者: package com.googlecode.garbagecan.jmsstudy.activemq.topic; import org.apache.activemq.ActiveMQConnectionFactory; import javax.jms.*; public class Top
kafka单机重启topic丢失问题排查
这个问题,在线上集群环境一般不容易出现,因为相关的日志文件参数都已经配置好了,而且经受住时间的的验证了。 作为新手,我在本地配置了一个单机kafka,用得是kafka自带的zookeeper服务。 kafka安装很简单如下: 1).下载kafka: wget http://apache.fayea.com/kafka/0.10.1.0/kafka_2.10-0.10.1.0.tgz
服务器80端口突然不通, 必须重启IBM HTTP 服务就好。
在服务器运行一段时间(4天) 就出现一次80端口不通, 但服务器上用netstat 看80端口还是好的。就是别的机器连不上80端口, 本机也不行, 重启一下IBM HTTP 服务就ok了, 不需要重启Websphere。 为什么? 不会是并发太多?
activemq接收到的消息为空
发送客户端成功发送activemq消息,接收客户端也收到消息通知,但是内容为空。 1.通过在发送客户端抓包,发现已经成功发送出去了;可能原因为接收客户端解析不出来 2.通过http://10.18.36.27:8161/admin/网页上进行测试,发现接收客户端能够接收到; 3.后面通过测试发送“1234”简单消息内容,发现接收客户端能够收到 4.最后猜测是消息内容为中文导致的,需要转化A
突然不发消息给ActiveMQ但能接收
        今天项目在联调过程中,ActiveMQ突然不好使了。在此之前一月内,项目组的人都没有去修改、重启过MQ服务。         虽然现在知道是由于权限的问题导致只能收不能发(站在ActiveMQ角度是收不到,但可以发)。只是到现在还不知道原来没变过的代码,怎么以前可以用,现在却不行了???        通过查询示例代码,发现有connectionFactory.setUser...
springboot2整合activemq的demo内含queue消息和topic消息
springboot2整合activemq的demo内含queue消息和topic消息,需要使用者修改application.yml的连接地址信息就可以了,端口号是默认的可以不用修改
ActiveMQ点对点及topic使用
ActiveMQ点对点及topic使用
ActiveMQ Topic 实例
欢迎下载ActiveMQ Topic 实例!
ActiveMQ消息处理机制-Topic方式
**特点:** Topic方式每个消息都可以有多个订阅者(消费者),只要消费者订阅了这个主题(Topic),就可以获得这个消息。发布者和订阅者之间有时间上的依赖性。针对某个主题(Topic)的订阅者,它必须创建一个订阅者之后,才能消费发布者的消息,而且为了消费消息,订阅者必须保持运行的状态(也就是说在必须先启动消费者那方)。
ActiveMQ的Topic消息发送与接收
消息中间件是搭建大型企业级项目必不可少的成员,只有掌握了消息中间件的使用和应用场景,才能开发真正的大型分布式系统。rnActiveMQ支持JMS,是apache的顶级项目,在全球开源消息中间件中影响力大!
ActiveMQ的topic的简单使用
上一篇写了queue的简单使用,实际差不多,直接上代码 这个topic就类似与微信公众号的感觉,一个生产者可以对应多个消费者 代码在运行的时候需要先运行一下消费者,相当于你订阅了这个topic(类似于关注了一个微信公众号) ,不然接收不到消息 生产者: package com.test.mq.topic; import javax.jms.Connection; import jav...
activemq的安装和使用【3】activemq的topic模式
上一篇文章我们已经看过activemq的点对点模式,本文将阐述使用java完成发布订阅值topic模式的应用,所谓topic模式,其实就是广播。 1、前提约束 已经安装和启动activemq https://www.jianshu.com/p/47d6d824ad50 2、使用idea创建一个maven的项目 https://www.jianshu.com/p/042073b7710b 3...
学习淘淘商城第五十八课(ActiveMQ发送topic消息和接收topic消息)
前两节我们一起学习了发送队列消息及消费队列消息,这节我们一起学习下如何发送topic消息。        我们在测试类中添加一个测试方法,用来测试发送topic消息,如下图所示,其实这个方法与发送队列消息几乎一样,只是创建Destination对象的时候不一样而已。        测试代码如下: @Test public void testTopicProducer() thro
sql server 服务突然中断,无法重启
开机后sql server服务正常启动,可以运行,但过一段时间后就无法连接sql server了,停止服务后,也无法重启服务.只有重启机器才行.但过不了多久又死了.以前都是好好的,昨天开始突然这样了.rn大家帮帮忙啊.
Header Control 怎么才能收到WM_DRAWITEM消息
Header Control 怎么才能收到WM_DRAWITEM消息
Spring整合Blazeds实现ActiveMQ JMS消息服务
NULL 博文链接:https://yunzhongxia.iteye.com/blog/789698
JMS(Java消息服务)(Activemq简单介绍)
是什么? JMS(java消息服务)是规范,它定义了一些规则,一些接口。具体实现由各种做这个产品的厂家或开源组织来实现。 为什么? 在JMS还没有诞生前,每个企业都会有自己的一套内部消息系统,比如项目组A需要调用到项目组B的系统,项目组B也有可能会调用到项目组C的系统。这样每个公司都有自己的一套实现。很不规范。 怎么办? Java定义了消息服务的规范,不管哪个厂商做的消息服务的中间件,我
Docker学习之搭建ActiveMQ消息服务
前言 ActiveMQ 是Apache出品,最流行的,能力强劲的开源消息总线。ActiveMQ 是一个完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现,尽管JMS规范出台已经是很久的事情了,但是JMS在当今的J2EE应用中间仍然扮演着特殊的地位。 在生产项目中,很多时候需要消息中间件来进行分布式系统间的通信。它具有低耦合、可靠投递、广播、流量控制、最终一致性等一系列功能。...
activemq(java 消息服务及事务、集群)
这个一个activemq服务项目,内有activemq事务,集群,我在里面作了一个spring的事务,Atomikos的事务相应jar包。希望大家下载给出建议,(我在做这个时花了很长的时间,下载其他的文件也花了很多时间,所以在下载时,资源是8分。希望大家谅解)
重启sqlserver服务,记录会丢失??? (asp+sqlserver2000)
问题是这样的,我们一论坛(asp+sqlserver2000),在访问量一大时,sqlserver2000显得很繁忙(具体表现是,直接在服务器上打开企业管理器时连接local都很慢,但此时系统占用的CPU,内存并不是很大,我们设置其最大占用1G内存,服务器为4核,2G内存),数据库一繁忙导致外面的访问便很慢,这时候不得不重启服务,但重启SQLSERVER服务后,论坛里有些刚发不久的帖子就丢失了.有的时候重启sqlserver服务也不行,但再重启下IIS就好了.但之前刚发不久的记录都丢失了.rnrn现在为防止这问题发生,我想出了在ASP代码端改进的方法rn1: 减少ASP代码中的sessionrn2: 将asp执行的增删改的SQL语句换成用存储过程来代替.rnrn但是心里总还没底,特发此问,征求大家建议...不尽感谢.