Android中使用ActiveMQ重连遇到的问题 5C
最近Android端需要接收服务器端推送的消息,故需要长连接,使用了Apache ActiveMQ服务器,使用Eclipse paho服务,正常连接没有问题,客户端与服务器连接断掉以后,客户端重新连接服务器,会出现出现多个连接对象的情况,希望相关技术人员给予解答,谢谢!
0

1个回答

我当时使用的是mqtt协议连接amq,自动重连正常,好像没出现多个连接对象的问题。

0
xiaoshengfdyh
小生array 可以分享一下mq服务器,以及使用的客户端程序吗、这个多对象的问题一直没有解决,,谢谢了
一年多之前 回复
Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
ActiveMQ常见问题及重连机制
1. ActiveMQ服务器宕机怎么办?这得从ActiveMQ的储存机制说起。在通常的情况下,非持久化消息是存储在内存中的,持久化消息是存储在文件中的,它们的最大限制在配置文件的<systemUsage>节点中配置。但是,在非持久化消息堆积到一定程度,内存告急的时候,ActiveMQ会将内存中的非持久化消息写入临时文件中,以腾出内存。虽然都保存到了文件里,但它和持久化消息的区别是,重启...
ActiveMQ的断线重连机制
断线重连机制是ActiveMQ的高可用性具体体现之一。 具体就是使用failover方式,使得连接断开之后,可以不断的重试连接到一个或多个brokerURL。 例如:failover:(tcp://127.0.0.1:61616) ,这里可以使用多个url。 默认情况下,如果client与broker直接的connection断开,则client会新起一个线程, 不断的从url参数中获取一
activemq 重新连接的机制
最近一个项目要用到ActiveMq,并且需要最大程度的保证消息不丢失。以前对activeMq不是很熟悉,完全是摸着石头过河,目前基 本配置都搞定了。只是对于它的自动重连一直找不到好的解决办法,我希望的效果是当一个broker(假设只有这一个,没有备用的)如果异常down掉的 话,那么监听程序能够等待broker重启后再自动重新连接。看了它的文档似乎 设置一下failover:(tcp://loca
ACTIVEMQ遇到的坑与经验
经验: 1、后台启动   nohup ./activemq start > /usr/local/apache-activemq-5.2.0/data/run.log 2>&1 & 2、本地测试速度,topic,单生产者,单线程生产速度2w-3w/s ,消费者单消费者,单线程消费速度为1W-2W/s ,比生产者速度慢。 3、topic主题式,每个消费者消费从连接MQ之后的全部消息。 4、M
activeMQ 自动重连机制
在使用activeMQ的时候(没有集成spring),发现当broker挂掉或者重启的时候,consumer就会断开,不会在次尝试去接受消息, (使用spring集成activeMQ)会解决这个问题. 如果说你不想使用spring,那么接下来告诉你该怎么办. 在apache官网上有介绍自动重连机制. connectionFactory = new ActiveMQConnectionFa
activemq客户端android版本
更新之前分享的activemq,解决之前第一次进入连接不成功FC问题,更新jar包为:org.eclipse.paho.android.service-1.1.1.jar、org.eclipse.paho.client.mqttv3-1.1.1.jar,并在AndroidManifest.xml文件中添加<service android:name="org.eclipse.paho.android.service.MqttService"/>
activeMQ连接服务器失败后实现spring BackOff接口自定义退避算法,解决activeMQ一直重连导致资源消耗的问题
实现spring BackOff接口,自定义退避算法,用于activeMQ配置监听器容器重连服务器策略--这里设置最大尝试重连3次,每3次尝试重连后,重置重连次数,下次则根据初始间隔的倍数递增进行重连在spring配置activeMQ监听容器时,使用自定义的spring backoff退避算法,例如实现spring BackOff接口的类代码示例:package com.southgis.ibas...
activemq断线重连
断线重连机制是ActiveMQ的高可用性具体体现之一。 具体就是使用failover方式,使得连接断开之后,可以不断的重试连接到一个或多个brokerURL。 例如:failover:(tcp://127.0.0.1:61616) ,这里可以使用多个url。 默认情况下,如果client与broker直接的connection断开,则client会新起一个线程, 不断的从url参数中获取一
ActiveMQ_使用failover模式进行连接切换时,线程断开
ActiveMQ_使用failover模式进行连接切换时,线程断开 ,ActiveMQ_使用failover模式进行连接切换时,线程断开
Active MQ技术文章 -- Active Mq连接池重连
现象     Active Mq 客户端连接Active Mq服务端时,如果因为服务器重启等原因导致Mq客户端无法发送Mq消息 原因    Mq客户端的连接和服务端已经断开,但是客户端没有进行重连 解决方法    Mq断开连接后,可以自动重连     main.properties   main.openmq.sName=330103000000800536 main.ope...
activemq 重新连接的机制
activemq 重新连接的机制
rabbitmq遇到的一些坑
关于rabbitmq的自动恢复重连。 自己的实践测试后的一些结果(version4.0.2) 消费端:    自动恢复重连方法:队列和消息持久化,开启应答后,当mq服务端断开重启后,消费端能够实现自动恢复消费。 生产端:   自动恢复的是channel。(一直认为的是当mq服务器断开重启后,生产者能自动恢复到以前的生产地方继续生产,结果恢复的是已声明的channel,刚开始使用rabbi
Android MQTT 单向认证以及手动重连
一、单向认证 public class SSLSingleTrustManager implements TrustManager, X509TrustManager { public void checkClientTrusted(X509Certificate[] chain, String authType)throws CertificateExc...
spring activeMQ 整合(二): 重发机制(消息发送失败后的重新发送)
之前已经写了一个spring   activemq整合的demo   ,今天继续完善一下这个demo,让功能更强大。 Spring ActiveMQ 整合(一): 一个简单的demo,测试消息的发送与接收            假如现在我手里有一个很重要的消息的,想要发给一个人,但是很不幸,消息发送失败了。这时候怎么办呢怎么解决这种尴尬的情况,这时候我们可以利用activeMQ的 
Android:RxJava 结合 Retrofit 全面实现 网络请求出错重连
前言 Rxjava,由于其基于事件流的链式调用、逻辑简洁 & 使用简单的特点,深受各大 Android开发者的欢迎。 如果还不了解RxJava,请看文章:Android:这是一篇 清晰 & 易懂的Rxjava 入门教程 RxJava如此受欢迎的原因,在于其提供了丰富 & 功能强大的操作符,几乎能完成所有的功能需求 今天,我将为大家带来 Rxjava创建操作符的实际开发需求场景:网络请求出错重连
ActiveMQ-CPP在vs2017上测试通过
ActiveMQ-CPP在vs2017上测试通过,测试时间 2018年12月30日
使用ActiveMQ时遇到的坑
最近项目要做一个消息系统,选来选去,最后锁定到了ActiveMQ上,但是在使用中遇到了一个坑,分享给大家。 在使用PooledConnectionFactory做连接池来优化的时候,我原先按照官方API以及网上其他的相关资料引用了下面的包: geronimo-j2ee-management_1.1_spec-1.0.1.jar geronimo-jms_1.1_spec-1.1.1.jar
【Android学习】断线重连、长连接心跳机制
1,心跳机制 1)概念 定时发送一个自定义的结构体(心跳包),让服务器知道自己还活着,以确保连接的有效性。 长连接比较耗电。 在TCP机制里面,本身是存在有心跳包机制的,也就是TCP选项:SO_KEEPALIVE. 系统默认是设置的2小时的心跳频率。 2)场景 由于手机的无线运营商为了减少网关映射表的负荷,会在表中删除一段时间内未通信的链路,造成链路中断。为了避免这种中断,应用需要...
ActiveMQ故障转移传输
故障转移传输层重新连接任何其他传输器之上的逻辑。配置语法允许您指定任意数量的复合URI。故障转移传输随机选择一个复合URI,并尝试建立与之的连接。如果它不成功,或者如果随后失败,则从列表中随机选择一个其他URI,建立一个新的连接。   配置语法 failover:(uri1,...,uriN)?transportOptions&nestedURIOptions 要么
springboot整合activemq,应答模式,消息重发机制,消息持久化
准备工作: activemq的消息确认机制就是文档中说的ack机制有: AUTO_ACKNOWLEDGE = 1    自动确认 CLIENT_ACKNOWLEDGE = 2    客户端手动确认    DUPS_OK_ACKNOWLEDGE = 3    自动批量确认 SESSION_TRANSACTED = 0    事务提交并确认 INDIVIDUAL_ACKNOWLEDG
Android集成消息推送之MQTT
完美的处理MQTT初学者遇到的问题,mqtt采坑记录,处理了自动断开重连问题,以及切换网络断开重连问题。
折腾ActiveMQ时遇到的问题和解决方法
1.先讲严重的:服务挂掉。 这得从ActiveMQ的储存机制说起。在通常的情况下,非持久化消息是存储在内存中的,持久化消息是存储在文件中的,它们的最大限制在配置文件的节点中配置。但是,在非持久化消息堆积到一定程度,内存告急的时候,ActiveMQ会将内存中的非持久化消息写入临时文件中,以腾出内存。虽然都保存到了文件里,但它和持久化消息的区别是,重启后持久化消息会从文件中恢复,非持久化的临时文件会
ActiveMQ使用笔记(八)使用过程中出现的问题
报错日志:Usage Manager Store is Full, 100% of 1073741824. Stopping producer (ID:db01-48754-1336034955132-0:5:1:1) to prevent flooding queue://queue.land.group. See http://activemq.apache.org/producer-flow
vue项目中使用webscoket心跳重连
首先在created定义心跳检测对象 that.websock.send(&quot;ping&quot;)  send方法是webscoket自带的一种给服务器发送消息的方法 that.heartCheck = heartCheck  表示把heartCheck对象等于在data上面定义的heartCheck 对象 然后把原来的heartCheck = null 来释放掉 避免内存泄露 that.ini...
activemq动态部署的遇到的问题
1.网管把公司网络的广播禁止了,导致动态主机之间不能自动找到.
paho mqtt 重连后无法订阅问题
参考代码 https://github.com/eclipse/paho.mqtt.c/blob/master/src/samples/paho_c_sub.c 方法1: conn_opts.cleanstart = 0; 缺点: 当我把mqtt server 清除数据重新部署后,mqtt client reconnect后,无法自动订阅;   方法2:   conn_opts...
ijkplayer中遇到的问题汇总
在做音频播放的时候,很多公司使用的是开源的ijkplayer播放器,ijkplayer底层是基于ffmpeg,在某机型上面可能常常遇到各种问题。今天整理了大家在使用ijk...
ActiveMQ问题解决记录
[b][size=large]问题4:Networks of Brokers[/size][/b] 在每个activemq server的配置文件activemq.xml里加入如下内容,每个activemq server都需要设置内容相类型的multicase,如果activemq的连接设置了安全权限,则需要在networkConnector元素中加入userName password内容。 ...
ActiveMQ NMS使用过程中的一点经验
最近,项目中使用到了ActiveMQ获取第三方推送过来的数据。具体背景是:公司需要监控全国各地车辆实时运行的GPS数据,但监控本身不是公司做的,而是交给第三方公司做,第三方采集GPS数据后推送给我们。全国各地,近万台车辆,每台车辆每隔几秒就发送一次GPS位置数据,如果我们提供API给第三方公司去调用,显然无论是第三方还是我们这边,服务器都是是扛不住的,这么做也是不合理的,于是,便采取了消息队列,第
Android Socket通信 发送心跳包 重连
最近项目中,有使用Socket与后端进行通信,然后简单的了解了下Socket使用,大致流程是配置服务端的Ip、端口号,连接,监听数据和发送数据,数据的读取和发送都是以流的形式实现的,然后自己将项目中的代码写了简单的管理类,测试下代码。下面是demo的两个界面,连接和发送接收界面   这里使用了一个Tcp调试助手,模拟服务端发送和接收数据,通讯模式选择TcpService ,本地端口随意...
ActiveMQ Demo(C#)
ActiveMQ Demo程序,包括发送和接收程序,WinForm开发 关于ActiveMQ的介绍,请看我的这篇文章:http://blog.csdn.net/bodybo/article/details/5647968
android xmpp开发 asmack实现断线自动重连
android xmpp开发 asmack实现断线自动重连 asmack本身封装了断线重连机制,但是有一点需要注意 在设置链接属性钱,要加载ReconnectionManager这个类,否则没有效果。 直接上代码: 第一步 [java] view plaincopy try {        
Activemq 结合Spring的常用配置
[size=large][b]需要配置的参数:[/[/b]size] [b]消息消费者的配置[/b] [b]一、connectionFactory:[/b] [code=&quot;java&quot;] [/code] 以上配置指明MQ服务所在的服务器。 [b]二、配置queue:[/b] [code=&quot;java&quot;] [/code] 服务器上有几个Q,这里就配置几个,p...
Java ActiveMQ连接池使用
所需要的的jar: activemq-all-5.7.0.jar activemq-pool-5.7.0.jar commons-pool-1.6.jar 代码案例:importjavax.jms.JMSException; importorg.apache.activemq.ActiveMQConnectionFactory; importorg.apache.activemq
Android N蓝牙BLE鼠标重连问题总结
Android N取消鼠标功能后重新打开
【android学习】断线重连机制
【解决问题】 android端连接网络之后,当网络断开连接时,为了提高用户体验,android自动检测网络,当有网络时,用户无需进行多余操作,android端自动重新连接网络。 【解决方案】 1、设置网络断开连接标志:NET_BAD 1)每次发送数据,若发送数据不成功,检测网络状态,若断开则置网络状态为NET_BAD 2)若手机网络关闭,则置网络状态为NET_BAD 如果网络未连接,做
metaq的客户端自动断线重连机制
1.metaq的数据传输基于gecko2.metaq的RemotingClientWrapper是gecko的RemotingClient的包装类,通过ConcurrentHashMap&amp;lt;String/* url */, Set&amp;lt;Object&amp;gt;/* references */&amp;gt;成员变量添加了连接的建立和关闭计数功能。 3.remoteclient的连接语句如下: ...
使用ActiveMQ遇到了一个监听器方式的消费者一段时间会自动断开连接的问题
Activemq我遇到了一个问, 就是mq部署到外网linux时, 我的消费者用的是messageListener, 可是过半个小时左右, 我在发消息的时候, 消费者就是接收不到了, 而且过一会就会发现mq管理页面发现消费者和mq断开连接, 这是什么原因呢? 问题一直困扰了我好久,最近突然找到了原因,记录一下 首先看一下官方文档 ActiveMQ InactivityMonitor The...
基于okhttp和RxJava封装的自动重连的WebSocket
RxWebSocket是一个基于okhttp和RxJava封装的WebSocket客户端,此库的核心特点是 除了手动关闭WebSocket(就是RxJava取消订阅),WebSocket在异常关闭的时候(onFailure,发生异常,如WebSocketException等等),会自动重连,永不断连.其次,对WebSocket做的缓存处理,同一个URL,共享一个WebSocket.
关于ActiveMQ中Session和Connection资源的管理
       配置完了持久化之后,我们就可以使用代码来发送和接收ActiveMQ中的消息了,我这里配置的持久化是KahaDB。需要导入的jar包:一段发送消息的代码:             Java   1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 ...
文章热词 机器学习教程 Objective-C培训 交互设计视频教程 颜色模型 设计制作学习
相关热词 mysql关联查询两次本表 native底部 react extjs glyph 图标 java学习中遇到的问题 在大数据学习中遇到的问题