腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
AMQP入站和JMS出站之间的全局
事务
、
我们需要在
RabbitMQ
和MQSeries之间传输
消息
。 </int-jms:request-handler-advice-chain>我们希望确认
RabbitMQ
队列中的
消息
,以防MQSeries写得很好。我们如何测试这样的场景:
消息
在MQSeries队列(蓝色箭头)中写得很好,但在
浏览 22
提问于2020-03-11
得票数 1
回答已采纳
3
回答
RabbitMQ
后续
消息
原子性
、
、
我有一个
RabbitMQ
消息
结构,其中
消息
A应该生成许多
消息
,我们称之为B和C。工作进程接收
消息
A,然后处理它并生成
消息
B和C。假定的工作流流程如下: 在任何情况下,工作进程都会在
消息
A的处理过程中死亡,或者当is尚未完成
浏览 6
提问于2016-06-07
得票数 1
2
回答
Spring /
RabbitMQ
:
事务
管理
、
、
、
为了简化我的问题,我 问题是,有时,App2试图在
事务
提交到App1之前使用
RabbitMQ
消息
。这意味着App2无法读取数据库中的
浏览 1
提问于2013-07-02
得票数 10
2
回答
Rabbit Boot属性
、
、
、
以下属性之间的主要区别是什么: 1)spring.
rabbitmq
.listener.direct.prefetch= #单次请求处理的
消息
数。它应该大于或等于
事务
大小(如果使用)。2)spring.
rabbitmq
.listener.simple.prefetch= #单次请求处理的
消息
数。它应该大于或等于
事务
大小(如果使用)。
浏览 2
提问于2018-09-21
得票数 1
1
回答
提交或回滚后不将
消息
发布到
RabbitMQ
、
我在将
消息
发布到
RabbitMQ
时遇到问题。我们的应用程序必须工作在
事务
层。 但是,我不明白有一种情况:如果我首先启动
事务
并提交它,那么接下来的所有
消息
都不会发布到
RabbitMQ
。$connection = new \AMQPConnection([ 'port' => 5672, 'login'
浏览 8
提问于2019-09-22
得票数 0
1
回答
事务
Spring
、
我正在开发一个模块,该模块消耗一些HTTP资源,编写一个postgres,最后将
消息
推到
消息
总线( message,
RabbitMQ
)。我想知道如何处理模块内的
事务
:如何封装我的postgres操作和对
RabbitMQ
的推送(即,如果
消息
不能推送到
RabbitMQ
,我的DB操作应该被回滚)? 谢谢。
浏览 0
提问于2016-06-02
得票数 1
回答已采纳
1
回答
与兔子MQ交互的多个服务器
、
、
现在,我们需要将传入的
消息
持久化到队列中,以防停电或磁盘故障。据我所知,我们可以使用默认的Mule对象存储库,它将
消息
“持久化”到共享内存网格。我们的另一个选择是使用单独的队列产品,如
RabbitMQ
或ActiveMQ。但是,这些是否与HA集群集成得很好?这些产品中是否有确保同一
消息
不会同时被两台机器接收的机制?考虑这个场景(基于观察者模式): 骡子从队列中获取一条
消息
,并尝试将其传递给订阅服
浏览 1
提问于2014-03-19
得票数 1
回答已采纳
1
回答
Rabbitmq
重启后重新返回所有
消息
rabbitmq
服务器或集群重启后,所有队列都恢复了所有
消息
,即使
消息
已经确认(从
rabbitmq
服务器启动时开始),并重新处理所有
消息
。队列详细信息根据我的理解,在
消息
参数中将persistenet设置为false,如果代理重新启动,
消息
将不会继续存在。此外,我还将队列的durabele设置为false。
浏览 1
提问于2018-07-10
得票数 0
1
回答
什么时候使用AMQP比较合适?
、
在我以前的工作中,我使用了AMQP的好处,但我没有参与
rabbitMQ
子项目开发。在我目前的工作中,我想负责集成一个AMQP实现(可能是
rabbitMQ
)。我正在阅读"
RabbitMQ
in Action“,Videla先生写道,AMQP可以改进任何系统,但我不知道如何改进我的项目。我们只使用两个服务器在中间调用API,所以我们现在没有可伸缩性问题。请省略标准的“日志”和“广播
消息
”情况:)
浏览 2
提问于2013-02-13
得票数 7
1
回答
面向个人用户的PubsubwithNode.js和Socket.io
、
、
、
、
编辑:,或者,在相应的用户id旁边维护所有连接的客户端id的散列是否更实用,然后当新
消息
出现时,使用var socket = hash[userID]; socket.emit(message);将该
消息
发送给特定的客户端
浏览 2
提问于2013-03-25
得票数 3
1
回答
Spring AMQP/
RabbitMQ
和Hibernate
事务
管理器
、
、
、
它还使用Spring AMQP (
RabbitMQ
)。container.setChannelTransacted(true); return container;所以基本上我已经指定了
消息
的接收需要是
事务
性的
消息
侦听器调用一个服务,该服务可以具有带有@Transactional注释的方法,并且可能在DB上执行CRUD操作。我的问题是,在SimpleMessageListenerContainer级别使用Hiber
浏览 0
提问于2012-06-28
得票数 5
1
回答
RabbitMQ
未加标记
消息
、
、
我可以在
RabbitMQ
消息
中看到传入率平均为5.2/s,我在4台虚拟机(每个VM 60台)中分布了240个用户,每个工作人员处理一个持续20秒的任务。从理论上讲,我不需要排队就能处理100K任务。我看到了大量未加解密的
消息
。如何处理未加标记的
消息
,或者添加一个定时器来杀死它们,这对我的员工来说是个问题吗?CELERY_RESULT_BACKEND = "amqp"BROKER_URL = 'amqp:/
浏览 3
提问于2016-10-01
得票数 0
回答已采纳
1
回答
在将完整日志发送到logstash/elasticsearch之前将一半日志发送到
RabbitMQ
的方法
、
、
、
、
logstash;即然后,这需要最终进入elasticsearch;喜欢 add2RMQ(transactionId,/* Last point of transaction */ com
浏览 0
提问于2015-09-27
得票数 0
2
回答
RabbitMQ
将
消息
分组为一条
消息
即合并
消息
、
、
、
我正在尝试理解在
RabbitMQ
中合并或分块传入
消息
的最佳方法(直接使用Spring AMQP或Java client )。换句话说,我想接受100条传入
消息
,并将它们组合为1,然后以可靠(正确地ACKed )的方式将其重新发送到另一个队列。我相信这在企业信息门户中被称为模式。我知道Spring Integration ,但它的实现看起来并不安全(这就是说,它看起来必须确认并使用
消息
来构建合并的
消息
,因此,如果您在这样做的同时关闭它,您会丢失
消息
吗?)。
浏览 4
提问于2013-02-25
得票数 2
回答已采纳
1
回答
如何确保在关闭连接之前成功地发布最后一条AMQP
消息
?
、
、
当系统关闭时,每个进程都需要向主进程发送通知(通过
RabbitMQ
),然后退出。这个程序是用C++编写的,我正在使用。AMQPCPP的文件说: 发布的
消息
通常不被服务器确认,
RabbitMQ
将不会发送回报告来通知您
消息
是否已成功发布。如果您在中途收到错误,就无法确定向代理发送了多少条
消息
,以及应该重新发布多少条
消息
。如果这很重要,您可以将发布命令包装在<e
浏览 9
提问于2016-09-09
得票数 0
2
回答
是否可能只为
RabbitMQ
发布失败方案实现
事务
性发件箱模式?
、
、
、
、
我有一个系统,它使用mongoDB作为持久性,使用
RabbitMQ
作为
消息
代理。我面临一个挑战,我只想为发布失败场景实现
RabbitMQ
。我不确定这是否可能,因为我也有使用相同mongoDB持久性的使用者,所以当我编写一个代码,涵盖
RabbitMQ
发布失败场景的
事务
性发件箱时,发布的
消息
会在mongoDB commitTransaction之前到达消费者,因此由于延迟,我的使用者无法在mongoDB中找到
消息
。我的代码如下所示;2-
浏览 28
提问于2021-08-30
得票数 1
回答已采纳
1
回答
RabbitMQ
和DB
事务
、
、
RabbitMQ
是否支持在DB
事务
提交时发送接收到的
消息
确认的场景? 目前,我们在DB
事务
提交后发送ack。如果服务在两者之间失败,我们将获得数据复制-服务将再次获得相同的
消息
。
浏览 3
提问于2010-03-02
得票数 4
回答已采纳
3
回答
TxSelect和TransactionScope
、
、
NServiceBus通过在TransactionScope中登记MSMQ来处理
事务
。其他
事务
感知操作也可以在相同的TransactionScope中登记(如MSSQL),因此一切都是真正的原子操作。我看到在
RabbitMQ
的C#客户端应用程序接口中有一个IModel.TxSelect()和一个IModel.TxCommit()。这可以很好地避免在提交之前向交换发送
消息
。这涵盖了发送到交换的多个
消息
需要是原子
消息
的用例。然而,有没有一种好的方法来使数据库调用(比如对MSSQL)与
浏览 0
提问于2012-07-31
得票数 5
回答已采纳
1
回答
MongoDb、
RabbitMq
和发件箱模式
、
、
我有一些用例,需要将文档保存到数据库中,然后将一些事件发布到message (
RabbitMq
)。保存的文档必须与发布的事件一致--这意味着如果我保存文档,我还必须发送
消息
(解决方案必须具有弹性,例如,文档保存和
消息
发送之间的服务器关机),因此我决定使用发件箱模式。在关系(sql)数据库中,这个问题很简单:我只需启动新
事务
,然后持久化/更改新对象,然后持久化某种数据库调度器记录(在提交
事务
后向
RabbitMq
发送
消息
),然后提交。如何在mongodb中实现这一
浏览 10
提问于2022-04-22
得票数 0
1
回答
跨
RabbitMQ
队列的
消息
弹性最佳实践
、
我试图理解如何最好地使用
RabbitMQ
来满足以下问题。 作为上下文,我不关心这个用例中的性能(这个流的峰值TPS是2个TPS),但我关心的是弹性。我在集群中安装了
RabbitMQ
,忽略了死信队列--基本流程是,我有一个服务接收一个请求,创建一个持久
消息
,它在
事务
中将该
消息
排队到一个持久队列(此时,我很高兴请求被保护到磁盘)。然后,我让另一个进程侦听
消息
,它读取
消息
(不使用自动ack),执行大量操作,将新
消息
写入
事务
中的不同交换队列(
浏览 3
提问于2016-04-27
得票数 4
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
RabbitMQ 消息顺序、消息幂等、消息重复、消息事务、集群
Rabbitmq-消息队列
RabbitMQ消息确认机制
分布式事务解决方案之RabbitMQ
rabbitMQ消息队列入门
热门
标签
更多标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
活动推荐
运营活动
广告
关闭
领券