腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
3
回答
带第
一条
消息
到达两个
队列
中
的
一个
jms
、
ibm-mq
我希望它
一次
只
处理
1条
消息
,如果
使用者
忙于
处理
消息
(来自任何一个
队列
),其他挂起
的
消息
(在任何一个
队列
上)都应该保留在它们
的
队列
中,直到
使用者
再次空闲为止(这给其他
使用者
处理
新
消息
的
机会)。在单独
的
线程中同时订阅两个
队列
似乎无法工作,因为:
浏览 3
提问于2014-09-10
得票数 3
1
回答
多
队列
上
的
ActiveMQ prefetchSize
jms
、
activemq
我有消费者
处理
需要大量时间和资源
的
工作。因此,消费者
一次
处理
一个以上
的
工作是不合理
的
。我
的
问题是:
使用者
可能会从多个
队列</
浏览 5
提问于2022-08-02
得票数 0
回答已采纳
4
回答
如何理解JMS中
的
“
同步
”和“异步”
消息
?
java
、
asynchronous
、
jms
、
synchronous
见本页:若要异步使用
消息
,请使用下一节中描述
的
消息
侦听器。异步
消息
侦听器是充当
消息
异步事件
处理
程序
的
对象。该对象实现MessageListener接口,其中包含一个方法onMessage。在onMessage方法中,定义
消息
到达时要采取
的
操作。生产者将
消息
发布到
浏览 3
提问于2014-02-28
得票数 24
回答已采纳
1
回答
同步
队列
的
所有
使用者
,
使其
一次
只
处理
一条
消息
java
、
rabbitmq
、
amqp
、
spring-cloud-stream
我正在运行一个Spring Cloud Stream应用程序,使用来自RabbitMq
的
消息
。我想实现这样一种行为:给定
的
队列
有三个消费者实例,
只
向其中任何一个实例传递
一条
消息
,然后等待下
一条
消息
传递,直到当前
消息
被确认(
所有
消费者之间
的
某种
同步
)。我认为这可以使用启用全局选项
的
https://www.rabbitmq.com
浏览 17
提问于2020-12-02
得票数 0
回答已采纳
1
回答
弹簧集成-最大吞吐量消费者
spring
、
message-queue
、
messaging
、
spring-integration
、
event-driven-design
Spring集成元素
的
配置(如果有的话)将支持以下模型: 每个
使用者
只
在没有工作可做
的
情况下才投票;如果它目前正在
处理
一条
消息
如果它没有做任何工作,每X秒轮询
一次
,看看新
的
工作是否已经到来。
浏览 1
提问于2012-07-05
得票数 0
回答已采纳
1
回答
有什么办法让皮卡BlockingConnection
一次
只
吃
一条
信息吗?
rabbitmq
、
pika
() rollbar.report_exc_info() channel.close()这是我用来使用
消息
的
代码问题是,假设我在test
队列
中有100条
消息
。一旦启动了
使用者
,它将得到
所有
100条
消息
并逐一
处理
,即
队列
状态变为:MessageReady: 0,unacked: 100,总计: 100。因此,我无法让新
的
<
浏览 1
提问于2018-10-10
得票数 1
回答已采纳
1
回答
RabbitMQ -不要在最后一个被加进之前传送
消息
rabbitmq
我计划为我们
的
系统实现一个message,并且大部分已经决定使用RabbitMQ。但是,我需要知道,使用RabbitMQ是可能
的
。为对象O生成2条
消息
B (更新同一个O对象). 在客户端(多个消费者)注册到
队列
以获取对象O
的
消息
的
,我希望B
只
在A被添加之后才被传递。目标--为对象O
处理
创建,然后为该对象
处理
更新。
浏览 1
提问于2015-11-18
得票数 0
2
回答
RabbitMQ :为多个消费者从
队列
中发送固定
消息
rabbitmq
、
spring-amqp
是否有一种方法可以限制RabbitMQ
队列
只将固定数量
的
消息
从
队列
发送给消费者?我有两个
队列
Q1和Q2,10个consumers.Every
使用者
可以
处理
来自Q1和Q2
的
消息
,在任何给定
的
时间,只有两个消费者应该
处理
来自Q2
的
消息
,
所有
这10个消费者都可以同时
处理
来自Q1
的
消息
。在Rabbit
浏览 0
提问于2019-03-09
得票数 1
回答已采纳
2
回答
带有
使用者
代码
的
Executor服务框架
java
我计划使用带有固定线程池和IBM
消息
传递
的
ExecutorService编写类似于生产者和
使用者
的
代码。 每个消费者工作者线程都接受这10条
消息
,就像每条
消
浏览 2
提问于2013-08-13
得票数 1
回答已采纳
2
回答
多个
使用者
在字段上
同步
锁定
消息
队列
message-queue
、
locks
我们有一个系统,多个
使用者
从
队列
中获取
消息
(目前是用数据库实现
的
)。这些
消息
有一个order字段。一个特定顺序
的
所有
消息
都应该
同步
处理
。这意味着同一顺序
的
2条
消息
永远不应该由不同
的
消费者同时
处理
。我们过去
只
处理
少数几条
消息
,但经过几次扩展之后,我们目前正在
处理
大约400条<e
浏览 0
提问于2019-09-13
得票数 1
回答已采纳
1
回答
具有多个Lambda触发器集
的
AWS SQS行为
amazon-web-services
、
queue
、
amazon-lambda
我已经设置了一个SQS
队列
,并将多个Lambdas配置为触发器。虽然AWS
的
API允许这样做,但不清楚预期
的
行为是什么。从我
的
测试来看,这似乎是后者,但在我
的
一生中,我无法在任何地方找到这个文档。考虑到AWS
的
并发功能,后者对我来说也没有意义。
浏览 0
提问于2018-10-15
得票数 5
回答已采纳
1
回答
RabbitMQ:
一次
多个
队列
/一个(长)任务
python
、
rabbitmq
我使用RabbitMQ来管理多台执行持久任务
的
服务器。每个服务器可以侦听一个或多个
队列
,但每个服务器
一次
只能
处理
一个任务。每次在服务器中启动
使用者
时,我都会使用channel.basic_qos(prefetch_count=1)对其进行配置,以便为相应
的
队列
只
处理
一个任务。如果下
一条
消息
同时生成:- messageA for tasks1 - messageB for tasks2 - messa
浏览 5
提问于2017-05-22
得票数 0
1
回答
只
在RabbitMQ报头中传递
一次
消息
rabbitmq
、
message-queue
、
pika
我从本文中
的
代码开始: --有一个头交换,多个消费者
队列
被用不同
的
头值绑定到它。这样,我可以设置两个消费者A和B。A提供环境"foo“和"bar”,而B只提供"bar“。现在,当一个需要环境"bar“
的<
浏览 3
提问于2015-11-17
得票数 2
回答已采纳
1
回答
AWS SQS FIFO
队列
真的准确吗-
一次
传递
amazon-web-services
、
amazon-sqs
、
fifo
、
aws-sqs-fifo
,虽然我不
处理
在数据库中创建记录
的
验证逻辑(已经存在),但我看到具有相同ID
的
数据库记录被创建了两次,这意味着同
一条
消息
处理
了不止
一次
!在我
的
代码中,我在成功
处理
后删除
消息
,或者在失败时抛出异常,假设
所有
剩余
的
有序
消息
都将返回到
队列
,任何
使用者
都可以重新
处理
,但我现在可以看到代码失败,因为相同
的</em
浏览 0
提问于2021-05-10
得票数 1
1
回答
RabbitMQ如何
一次
只有
一条
消息
而不请求失败
rabbitmq
、
spring-amqp
、
spring-rabbit
、
prefetch
我们
的
系统有一群
使用者
,他们使用兔子来为长期运行
的
任务使用
消息
。目前,我们在
处理
结束时进行编码,这样如果
使用者
崩溃,
消息
就会被请求。我们想要
的
是,
使用者
一次
只
处理
一条
消息
,而不预取
一条
消息
,这样另一种
使用者
就可以
处理
下
一条
消息
,如果出现崩溃
浏览 2
提问于2022-02-25
得票数 1
1
回答
为什么请求响应流中
的
组件不应该在kafka主题上使用
消息
?
apache-kafka
、
architecture
、
microservices
作为我
的
客户端站点设计决策
的
一部分,http请求-响应流中涉及
的
组件(微服务)允许生成关于kafka主题()
的
消息
,但不允许使用来自kafka主题
的
消息
。这类组件(微服务)可以读写数据库,可以与其他组件对话,可以生成主题
消息
,却不能使用来自卡夫卡主题
的
消息
。 相反,设计建议编写单独
的
实用程序,使用kafka主题
的
消息
并将其存储在数据库中。涉及请求-响应流程
浏览 2
提问于2021-01-29
得票数 0
1
回答
AMQP延时投递,防止重复
消息
process
、
message-queue
、
delay
、
amqp
、
duplicate-removal
我有一个系统,将产生零星
的
消息
,我想
只
提交零或
一条
消息
每5分钟。如果没有生成任何
消息
,则
队列
使用者
将不会
处理
任何内容。如果在5分钟内生成了100条相同
的
消息
,我
只
希望从
队列
中使用其中
的
一条
。我是否可以检查
队列
的
内容,以确保不会插入重复
的
内容?
队列
检查似乎不是
浏览 2
提问于2009-07-16
得票数 4
回答已采纳
1
回答
有关java
消息
队列
的
查询
jms
我有一个关于
队列
的
设计查询。我
的
设想如下: 我必须使用具有单个生产者和多个
使用者
(异步)
的
消息
传递系统。生产者将不同类型
的
消息
推入
消息
传递系统。根据
消息
类型
的
不同,特定
的
使用者
必须使用该
消息
。(每个
使用者
都运行在不同
的
服务器上)。如果一个
使用者
处于故障状态,并且为该
使用者
提供
浏览 2
提问于2010-12-09
得票数 1
2
回答
JMS和Weblogic集群
java
、
jakarta-ee
、
jms
、
weblogic-10.x
、
cluster-computing
我正在使用
的
Weblogic应用程序服务器是集群
的
。我创建了一个JMS
队列
,它有一个JNDI名称。当消费者查找jndi名称并在
队列
上发布事件时,它是否会在两个应用服务器中创建
的
队列
中发布?相同
的
MDB将在两台服务器上运行-哪一台服务器将把
消息
发布到
队列
?如果我需要删除放在
队列
上
的
消息
,我是否应该遍历
所有
节点并删除该
消息
? 谢谢。
浏览 4
提问于2012-03-20
得票数 3
1
回答
仅向RabbitMQ中
的
多个
使用者
中
的
一个发送
一条
消息
rabbitmq
、
messaging
、
amqp
、
spring-amqp
我对RabbitMQ有一个比较独特
的
用例,我不确定如何解决这个问题。我希望有一个绑定了多个消费者
的
队列
,然后让RabbitMQ
一次
只
向一个消费者发送
一条
消息
,并在向任何其他消费者发送另
一条
消息
之前等待ACK。我意识到这会扼杀吞吐量,基本上会让其他消费者挨饿,但对我来说,这是可以接受
的
。出现这种奇怪用例
的
原因是,
使用者
与之交谈
的
服务
一次
只能
浏览 1
提问于2013-05-23
得票数 1
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
揭秘 RocketMQ 新特性以及在金融场景下的实践
九浅一深之RabbitMQ
RabbitMQ在分布式系统中的应用
Java学习Script异步编程实现过程解读
肝了很久的字节跳动消息队列面经,我不信你能看完!!
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券