腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
如何
处理
队列
通道
中
的
消息
丢失
?
java
、
spring-integration
、
spring-dsl
我正在使用
队列
容量为1000
的
队列
通道
,这是我想知道
的
。当我
的
应用程序重新启动时,存储在我
的
队列
中
的
那些
消息
会发生什么。会有
消息
丢失
吗?有没有可能在不
丢失
消息
的
情况下
处理
这种情况。
浏览 15
提问于2020-11-10
得票数 1
1
回答
RabbitMQ:将
消息
路由到线程
ruby
、
rabbitmq
、
amqp
我有一个用Ruby编写
的
应用程序,它有多个线程,每个线程都向远程AMQP端点发送请求。当必须运行新任务时,会不时产生这些线程。如果我为每个线程使用临时
的
独占
队列
来发送对它们
的
请求
的
响应,那么在这个Ruby服务
中
编写代码来
处理
传入
的
消息
就会变得很容易。一旦关联
的
通道
关闭,
队列
就会被删除,这样它们就不会在它们
的
目的结束后逗留。我能想到
的
替代方案都需要
浏览 16
提问于2016-07-30
得票数 1
回答已采纳
2
回答
WebSphere MQ
中
的
MQRC资源问题
ibm-mq
这是在集群环境
中
。
队列
管理器在群集中
丢失
了其标识,并且无法连接到其他服务器。所有到存储库和其他
通道
的
通道
都在重新尝试状态。03/06/11 08:24:26 AMQ9544:
消
浏览 8
提问于2011-03-07
得票数 4
1
回答
事务轮询器向错误
通道
提交异常
spring-integration
我有一个事务性轮询器,定期从jdbc支持
的
队列
通道
轮询
消息
。1)防止
消息
从我
的
源
丢失
,以防进程在
处理
消息
的
过程
中
死亡。2)通过将相关异常丢弃到错误
通道
(并继续到下一条
消息
),防止单个错误格式
的
消息
中断整个过程。我
的
问题是: 我
如何
设置(最好是通过dsl)事务轮询器,以便它在不
浏览 3
提问于2019-02-26
得票数 0
回答已采纳
1
回答
NetMsmqBinding关闭时
丢失
消息
.net
、
wcf
、
msmq
、
netmsmqbinding
我一直在使用非事务性
队列
测试WCF
的
NetMsmqBinding。我发现服务,即从
队列
中
读取
的
部分,在关闭时偶尔会
丢失
一条
消息
。例如,如果我有一个包含编号为1- 10
的
消息
的
队列
,并允许它在重启之前读取前五条
消息
(1,2,3,4,5),那么我可能得到
的
其余
消息
是(7,8,9,10)。“6”,它将在服务关闭之前接收
的
消息<
浏览 2
提问于2012-07-18
得票数 2
2
回答
弹簧集成备份
通道
spring
、
spring-integration
将接收到
的
每条
消息
存储到备份目标
中
。通常是文件附录,每个
消息
都存储在文件
的
末尾。也可以是jms
队列
。备份使我们有机会获得
消息
,并在整个系统故障和数据
丢失
时重播。 弹簧集成网关看起来很合适。我可以使用默认请求
通道
作为主流,错
浏览 6
提问于2012-11-09
得票数 0
1
回答
消息
传递到QueueChannel后
如何
处理
错误?
spring-integration
、
spring-integration-amqp
我有10个rabbitMQ
队列
,分别称为event.q.0、event.q.2、<...>、event.q.9。这些
队列
中
的
每个
队列
都接收从event.consistent-hash交换路由
的
消息
。我想构建一个容错解决方案,它将以顺序
的
方式使用特定事件
的
消息
,因为顺序很重要。为此,我设置了一个侦听这些
队列
的
流,并根据事件ID将
消息
路由到特定
的<
浏览 41
提问于2019-01-30
得票数 0
回答已采纳
1
回答
spring-集成amqp拒绝
消息
,如果不被触发
spring-integration
、
amqp
我有两个amqp客户设置来获取一条
消息
。autoStartup(false) .channel(taskChannel())} taskChannel是排队机制,但只允许一次使用一条
消息
,因此不允许并行
处理
。如果另一条
消息
花了很长时间才能继续进行,我
如何
在超时后拒绝一条
消息
。那么这条
消息
将返回到
队列
中
,由另一个节点继续进行吗?我
的
意思是,这两个消费
浏览 3
提问于2015-07-09
得票数 1
回答已采纳
1
回答
Spring集成
中
的
异常:
如何
记录而不是拦截
spring
、
exception
、
transactions
、
integration
如果入站
消息
子系统支持它,则
消息
将被多次重新传递,直到它最终被发布到死信
队列
中
。这很好--只是异常本身
丢失
了,从诊断
的
角度来看,这是非常恼人
的
。</poller>然后捕获异常并成为myErrorChannel上
消息
的
有效负载
的</e
浏览 7
提问于2014-08-29
得票数 2
回答已采纳
1
回答
JMS
队列
之间
的
事务
spring-integration
我有一个场景,
队列
1使用数据库启动事务,并通过出站
通道
适配器将
消息
放入
队列
2。如果
队列
2
中
发生异常,我也应该在
队列
1
中
回滚。示例代码会很有帮助。
浏览 0
提问于2018-04-10
得票数 0
1
回答
如何
使用RabbitMQ管理单个
队列
上多个消费者
的
并发?
rabbitmq
、
.net-core
我想创建
队列
,将接收一些标识符
的
多个
消息
。我希望异步
处理
此
队列
,但有一个条件,如果使用者正在
处理
标识符为x
的
消息
,则不能将具有相同标识符
的
其他
消息
发布给其他使用者。一旦消费者
处理
完该
消息
,它就会返回报告,并且可以再次发布具有该标识符
的
消息
。基本上,queue将分支到多个
通道
,每个
通道
代表一个标识符,这些
浏览 0
提问于2016-12-13
得票数 0
1
回答
使用任务执行器
的
事务性轮询程序是否将数据库资源用于排队
的
消息
spring-integration
、
channel
、
transactional
、
poller
我有一个服务激活器,它使用轮询器从
通道
中
拉出
消息
。该
通道
具有一个
队列
,该
队列
由对数据库
的
持久存储支持。轮询器还配置了一个任务执行器,以便向来自
通道
的
消息
处理
添加一些并发性。任务执行器配置了一个
队列
容量。 由于轮询器从数据库
的
通道
中
检索
消息
,并且这被配置为事务性
的
,那么如果任务执行器没有更多<e
浏览 5
提问于2015-04-23
得票数 1
1
回答
在Camel
的
SEDA
队列
中保存失败
的
消息
java
、
apache-camel
、
eip
我使用seda
队列
作为死信
通道
终结点。如果网络出现故障或其他应用程序出现故障,则工作正常。我会在死信
通道
终结点SEDA
队列
中
丢失
消息
吗?
浏览 0
提问于2012-05-24
得票数 0
回答已采纳
2
回答
当RabbitMQ使用者崩溃时,获取
消息
会发生什么?
queue
、
rabbitmq
、
message-queue
、
amqp
如果我有一个RabbitMQ使用者批量检索100条
消息
,但在将这些
消息
标记为已
处理
之前就会崩溃,那么这些
消息
是否
丢失
了?我希望
队列
中
的
每条
消息
至少
处理
一次。在确认
消息
之前,有什么推荐
的
方法来
处理
那些崩溃
的
消费者? RabbitMQ是否以某种方式将它们重新放到了
队列
中
,或者我需要做些什么来实现它呢?
浏览 8
提问于2017-02-21
得票数 11
1
回答
从参与者链
中
确认MQ
消息
的
正确方法是什么?
rabbitmq
、
akka
、
message-queue
我们希望使用Akka实现从
消息
队列
( messages,RabbitMQ)
中
获取
消息
,然后由一系列参与者
处理
的
场景。
队列
是持久
的
,不能
丢失
消息
。因此,我们需要将确认(BasicAck in RabbitMQ)发送回
队列
,以便最后确定已退出
队列
的
消息
。因此,
处理
链
中
的
最后一个参与者需要进行确认。
浏览 3
提问于2015-12-30
得票数 0
回答已采纳
1
回答
使用netMsmqBinding为WCF
通道
设置故障
wcf
、
netmsmqbinding
我有一个基于netMsmqBinding
的
WCF服务(MSMQ3)。服务代码不在WCF事务控制下运行,因为服务
中
的
某些操作不具有事务功能,也不能回滚。据我所知,这意味着我没有获得有害
消息
处理
等
的
任何好处。因此,一旦我
的
服务代码被调用,
消息
就永远不会出现在
队列
中
。 在我
的
服务出现严重故障
的
情况下,我希望防止进一步
的
消息
丢失
。与任何
浏览 2
提问于2012-05-25
得票数 0
1
回答
带有选择器表达式
的
收件人列表路由器
spring
、
spring-integration
、
router
我正在获取
队列
中
的
字符串
消息
。我正在使用它,并使用下面的
通道
processMessage进行进一步
的
处理
。 &l
浏览 2
提问于2018-01-03
得票数 0
回答已采纳
1
回答
RabbitMQ流应用程序中发生
的
异常需要侦听器类
spring
、
rabbitmq
、
spring-amqp
、
spring-cloud-stream
、
spring-cloud-dataflow
即接收器模块,从链接到exchange
的
队列
中
接收有效负载并打印。最后,在此过程
中
,在100,000条
消息
中
,消费者只收到98,484条
消息
。因此,由于
通道
连接关闭,我们在传输
中
丢失
了数据。我
的
问题:在流应用程序
中
是否有RabbitMQ侦听器类可用于
浏览 0
提问于2019-02-18
得票数 0
1
回答
启动作业-网关和持久
队列
spring-integration
、
spring-batch
我正在做一个与spring启动,spring批
处理
和spring集成有关
的
项目。 我已经配置了spring集成,以便在新
消息
到达时启动一个春季批
处理
作业。我向附加到JobLaunchingGateway
的
spring集成
通道
发送一条
消息
,对于每一条
消息
,JobLaunchingGateway尝试启动一个新
的
TaskExecutor。让
通道
由一个持久
队列
(例如ActiveMQ )支持,让任务执行器池大
浏览 2
提问于2016-10-28
得票数 0
回答已采纳
1
回答
Spring Integration Queue
通道
是多线程
的
吗
spring
、
multithreading
、
spring-integration
我正在尝试了解多个线程是否可以并发/并行地
处理
来自Spring Integration Queue Channel
的
消息
。假设我有以下配置: <int:queue />从文档
中
我了解到,通过使用
队列
通道
生产者和消费者被解耦,并且两者都发生在不同
的
线程
中
。我
的</
浏览 0
提问于2018-04-04
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
ZWave 中的消息队列机制
消息队列是如何保证高可用的
如何打造高可靠高性能的消息队列
消息队列之事务消息,RocketMQ 和 Kafka 是如何做的?
关于消息队列的思考:如何满足多种消费语义
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券