腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
AMQP入站和JMS出站之间的全局事务
、
我们需要在RabbitMQ和MQSeries之间传输消息。<int:channel id="channelRmqMQ"></int:channel> queue-names=" QUEUE_OUT " connecti
浏览 22
提问于2020-03-11
得票数 1
回答已采纳
1
回答
从symfony/控制台启动后台symfony/进程
、
、
、
我有两条命令,一条是
消费
,一条是听。
消费
是用于侦听的包装器,因此它可以在后台运行。侦听是
MQ
的一个长时间运行的转储,它在将附加消息添加到消息队列时显示附加消息。Problem:当试图从内部
消费
中调用cli命令时,它会启动进程并给出PID,但是子进程会立即死亡。我需要弄清楚如何获得消耗来分离多个侦听进程,这些进程实际上一直在运行。一些代码(相关代码段) // Runs as: php mycli.php
mq
:listen // Keeps run
浏览 2
提问于2015-03-13
得票数 3
回答已采纳
1
回答
当用户组启动时,收到错误"CODE: 22 Not found,V3_0_6_SNAPSHOT this group consumer boot first“,RocketMQ
版本: 3.2.6当一个新的
消费
者启动时,我将尝试从
mq
获取
消费
者偏移量:但是我碰巧遇到了返回-1的情况,并且我看到了错误: CODE: 22 Not found, V3_0_6_SNAPSHOT maybe this group consumer
浏览 1
提问于2016-08-23
得票数 0
1
回答
AMQP客户端从RabbitMQ缓存队列内容吗?
、
、
问题:生产者的生产速度高于
消费
者。现在,在停止生产者时,
消费
者仍然继续使用队列中的数据。但是队列在兔子
MQ
控制台上显示为空。 客户端库是否缓存队列中的内容?为什么会发生这种行为?
浏览 2
提问于2014-06-10
得票数 2
回答已采纳
1
回答
Activemq虚拟主题订阅在代理网络中的传播是如何工作的?
、
、
" uri="static:(tcp://
mq
002:61616)?而且因为它不是一个双工,所以它只从
mq
002到
mq
001工作。然后,我向主题发布消息:它正被
消费
者在
mq
001和
mq
002上
消费
。所以每个
消费
者只消耗了一条信息。如果我用更多的信息
重复
它,它仍然是一样的。没有副本到达,也没有丢失的消息。每个物理队列上
浏览 2
提问于2013-06-03
得票数 1
回答已采纳
1
回答
类似RabbitMq的主题交换与Masstransit
、
、
、
正如你所能想象的,只有有限的大陆,但几乎无限的城市和街道,这两者都可以有
重复
的名称(如NorthAmerica.GeorgsTown.Mainstreet,Europe.GeorgsTown.Mainstreet(这里有某种支持,但我也可以使用一个通用的RabbitMq客户机) 几乎没有
消费
者对整个欧洲大陆感兴趣--但也有一些
消费</em
浏览 2
提问于2021-10-08
得票数 0
1
回答
如何在Mule4中使用消息id或关联id发布IBM
MQ
中的消息
、
、
、
、
我需要向
MQ
(REQUEST.QUEUE)发布一条消息,并使用来自应答队列(REPLY.QUEUE)的回复消息。我正在使用MuleSoft IBM发布-
消费
操作发布消息。我还在发布-
消费
配置中指定了一个应答队列,因为应答进入了应答队列。我还设置了“请求-回复-模式”,但它似乎没有使用正确的信息。下面是发布-
消费
操作符的配置。我能够发布消息,但使用者正在读取任何已位于回复队列中的随机消息。="CORRELATION_ID" config-ref="IBM_
MQ
_Config&q
浏览 6
提问于2022-10-12
得票数 0
1
回答
使用消息队列和协调服务设计系统
、
、
、
如果有人能澄清这些概念,那就太好了:我将有生产者服务,它将创建消息并添加到
MQ
。
消费
者将使用此消息并执行适当的操作。一旦
消费
者确认消息处理完成,
MQ
将把偏移量移动到下一个偏移量。我不希望我的消息被遗漏,因此我必须确保消息被成功
消费
。另外,我正在尝试让这个系统只使用一次消息(尝试尽可能接近)。现在,基于这种理解,我有以下问题: 1)如果我希望我的生产者和
消费
者在同一个DC中运行多个实例(为了高可用性),那么我是否需要让生产者和<em
浏览 1
提问于2016-04-26
得票数 0
2
回答
ActiveMQ未确认消息会发生什么情况
、
、
是否会再次发送给
消费
者?或者这样的消息会发生什么?
浏览 1
提问于2020-02-18
得票数 1
1
回答
尝试使用导入时出现错误
、
、
、
我正在编写一个应用程序,有2个服务与rabbitmq(发布者和
消费
者)集成。我有一个文件夹库,其中包含一个类manager_
mq
,用于管理我的应用程序的发布/订阅进程。在我的
消费
者或发布者.py文件中,当我尝试导入manager_
mq
时,返回一个错误。我的导入是这样的: from services.lib.manager_
mq
import Manager 但是,控制台上会返回错误。most recent call last): File "consumer.py", l
浏览 24
提问于2021-06-22
得票数 0
1
回答
Apache camel不使用创建的所有动态队列。
、
我使用apache camel来使用IBM,我使用jms来实现它,一切都很好,但是在性能测试中,api创建了很多动态队列,但只使用了一次,我使用了很多属性来解决这个问题,但我还没有得到它。我的api使用模式InOut,因此响应在动态队列中,当存在大量响应时,例如,我的api创建了50个动态队列,但只使用其中的3个。
浏览 14
提问于2022-07-17
得票数 2
回答已采纳
1
回答
在IBM
MQ
中将单个消息发送到多个队列的最佳实践
正如标题所暗示的,我追求的是使用IBM
MQ
8向多个客户发送消息的最佳方式。我刚开始使用
MQ
,我想知道通常被认为是将消息分发给多个接收点的最佳/但最简单的方式。我的想法只是启用“某些功能”,允许将所有传入消息放到多个队列中,然后由每个队列上的不同
消费
者
消费
。斯科特,提前谢谢你
浏览 11
提问于2018-09-03
得票数 0
1
回答
几次后ActiveMQ崩溃
、
我有许多
消费
者通过stomp连接连接到ActiveMQ。 我有大约2000名用户连接到唯一的队列。我现在的问题是,ActiveMQ总是在几个小时后崩溃/挂起,日志没有显示任何错误。
浏览 7
提问于2015-10-11
得票数 0
1
回答
使用生产者和
消费
者方法在两个不同的服务之间同步事务
、
、
我想创建一个使用
消费
者和生产者架构的分布式应用程序。我的问题是:一个服务可以同时是
消费
者和生产者吗?要给出更多关于
消费
者和生产者流程的上下文:很抱歉长文本,但我想探索更多使用队列和分布式系统的场景
浏览 3
提问于2021-03-13
得票数 1
1
回答
合流kafka -速率限制
、
速率限制:由于Kafka能够以远高于
MQ
消耗的速率生成消息,我们是否可以使用一些配置设置@ kafka consumer来启用速率限制传输,以保护
MQ
的稳定性?同样-只需一次语义-理解kafka只支持一次语义,这将阻止已经被
消费
者
消费
的消息的重新传输。有人可以指导我如何设置此配置吗? 我们在组织中使用的是confluent kafka企业版。
浏览 1
提问于2020-10-07
得票数 0
1
回答
ActiveMQ代理存储使用
我有3个ActiveMQ代理,在三个代理中,有一个代理遇到了一个问题,它说持久性存储已经满了。使用信息: percentUsageMinDelta=1%;Parent:Usage(default:store):percentUsage=99%,usage=537210471,limit=536870912,percentUsage=100%,usage=537210471,limit=536870912,percentUsageMinDelta=1%:Persistent存储已满,536870912的100%。停止生产者(ID: AK对联MU-1-31754-1388571228
浏览 1
提问于2018-10-03
得票数 1
1
回答
Spring Integration <inbound-channel-adapter> Rabbit
MQ
正在断开连接
、
、
、
我们正在开发一个使用Spring集成和Rabbit
MQ
的POC。我们有两个模块,生产者模块和
消费
者模块,它们都运行在不同的JVM中。生产者和
消费
者代码都工作得很好,但在一些理想的项目之后,
消费
者模块与Rabbit
MQ
断开了连接。我们在incoming.q.in队列中看到消息,但是使用者没有处理。当我登录到Rabbit
MQ
管理/管理工具“incoming.q.in”
消费
者列表是空的,消息是“...没有
消费
者...“。
消费
浏览 3
提问于2013-07-23
得票数 0
1
回答
如何在camel路由中提交
MQ
事务?
、
、
、
-- do some exception handling --> <from uri="
mq
:queue://QMgr/我们使用的是,我认为这个回滚是由
MQ
执行的,而不是从camel路由执行的。所以问题是:我是否可以告诉
MQ
我已经处理了异常,并且它不应该再次回滚?
浏览 13
提问于2017-02-03
得票数 1
1
回答
如何保持Elasticsearch与MySQL数据库的同步?
、
在更新MySQL中的数据时,我将这些数据排队到
MQ
中,并让一些
消费
者服务更新Elasticsearch。 如果
MQ
出现故障,如何避免产生脏读?
浏览 0
提问于2016-04-27
得票数 0
1
回答
卡夫卡-处理缓慢的
消费
者的最佳做法。如何实现更多的并行性?
、
我知道,在
消费
者组中,活动
消费
者的最大数量是主题的分区数。一个例子:由生产者每秒生成6个分区和数千条消息的主题。所以我在这个群体中最多有6个
消费
者。考虑到处理这些消息是复杂的,
消费
者比生产者慢得多。其结果是,
消费
者总是在最后的抵消背后,滞后在增加。在传统的
MQ
系统中,我们只需添加越来越多的用户来保持最新的状态。 如何使用Kafka来实现这一点,因为在一个组中的总
消费
者最多是分区的数量
浏览 0
提问于2019-06-06
得票数 6
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
MQ消息中间件技术精讲10 高级篇三 幂等性保障不重复消费
基于PHP-Resque、Redis的生产消费MQ
RabbitMQ 如何避免消息重复消费?
Kafka 的数据丢失和重复消费
RocketMQ系列之消息重试+重复消费
热门
标签
更多标签
云服务器
ICP备案
实时音视频
对象存储
云直播
活动推荐
运营活动
广告
关闭
领券