腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
aio_pika
。
消息
从
队列
中
随机
丢失
rabbitmq
、
pika
、
aio
我有异步生成器的
消息
消费。GeneratorExit: else: await self.queue.put(message) 我的问题是一些
消息
会
随机
地
从
队列
中</e
浏览 25
提问于2020-12-18
得票数 0
回答已采纳
1
回答
JMSTemplate和DefaultMessageListenerContainer
spring
、
spring-jms
我在Redhat ActiveMQ中有两个
队列
,一个用于消费,另一个用于产生和消费对象
消息
。一旦
从
主
队列
消费了它,它就被推送到第二个
队列
进行进一步处理,然而,当使用JmsTemplate时,
消息
会
随机
丢失
, 我在2个DMLC容器和JmsTemplate上使用相同的Bean和ActiveMQConnectionFactory让我知道如何确保
消息
不会在JmsTemplate
中
丢失
。
浏览 0
提问于2017-07-28
得票数 0
回答已采纳
1
回答
IBM一对多
消息
流
messaging
、
ibm-mq
我的问题是IBM中使用单个
队列
的一对多
消息
流。我是MQ的新手。
队列
中有1条
消息
(
从
逻辑上说是用于进程1)。他们都会在等待的时候得到
消息<
浏览 4
提问于2012-10-10
得票数 2
回答已采纳
1
回答
RabbitMQ集群
中
镜像的持久
消息
的行为
rabbitmq
、
synchronization
我正在试图弄清楚,在镜像
队列
中
是否只有持续
消息
,是否仍有可能在再同步过程
中
丢失
消息
。情况是 在步骤3
中</
浏览 1
提问于2019-07-22
得票数 0
回答已采纳
1
回答
卡夫卡100%的交货(和加工)保证,
从
生产者到消费者
apache-kafka
、
rabbitmq
、
queue
、
partition
、
broker
我正在应用程序
中
构建
消息
队列
系统。生产者发送到
队列
的每一条
消息
都必须在使用者
中
传递和处理。绝对不允许数据
丢失
。但我找不到卡夫卡100%的送货保证。
消息
在
队列
中
存储一段特定的时间或直
浏览 4
提问于2022-03-21
得票数 0
1
回答
Azure服务总线
队列
:未发送
消息
azure
、
azureservicebus
我正在将
消息
从
工作角色发送到服务总线
队列
。我注意到一些
消息
会
随机
丢失
。 当我调试时,我在Send方法之后设置了一个断点,并登录到我的Azure面板来检查
消息
队列
是否增加了。我发现奇怪的是,
消息
有时不会添加到
队列
中
。但这不是
随机
的。模式是:一条
消息
被正确添加,下一条
消息
丢失
,然后再一次,下一条
消息
是ok,下一条<
浏览 1
提问于2012-09-03
得票数 1
回答已采纳
1
回答
RabbitMQ在消费者重启后停止向消费者下发
消息
java
、
rabbitmq
、
openshift
、
mqtt
我有多个Spring Boot应用程序,使用来自RabbitMQ
队列
的
消息
。所有消费者都使用MqttDefaultFilePersistence。这是我为连接到RabbitMQ
队列
而编写的代码: options.setUserName正如我在RabbitMQ管理控制台中看到的那样,
队列
中
的
消息
正在填满。RabbitMQ日志
中
没有错误
消息<
浏览 1
提问于2017-11-24
得票数 0
2
回答
队列
与TCP全局同步
tcp
、
qos
如果我们有几个主机与其他主机有TCP连接(例如,通过互联网),并且我们的网络被阻塞了,如果有大量的流量被发送,或者通常,如果发送了太多的通信量,接收所有这些通信量的设备的
队列
会被填满,尾部下降,这会导致与所有这些
浏览 0
提问于2022-10-16
得票数 1
回答已采纳
1
回答
地铁:没有消费者
.net
、
masstransit
有一个关于地铁ESB的新手问题我有一个web应用程序和一个控制台应用程序试图分别进行发布/消费。 h.Password(password);然后
从
webvar pubr = Bus.Publish<T>(message); pubr.
浏览 0
提问于2015-11-10
得票数 4
回答已采纳
1
回答
启动作业-网关和持久
队列
spring-integration
、
spring-batch
我已经配置了spring集成,以便在新
消息
到达时启动一个春季批处理作业。我向附加到JobLaunchingGateway的spring集成通道发送一条
消息
,对于每一条
消息
,JobLaunchingGateway尝试启动一个新的TaskExecutor。让通道由一个持久
队列
(例如ActiveMQ )支持,让任务执行器池大小等于2。我想配置系统,以便在已经使用了执行器池大小时,新
消息
不会被JobLaunchingGateway使用,而是保留在持久
队列
上。如有
浏览 2
提问于2016-10-28
得票数 0
回答已采纳
1
回答
高流量,500M+每天点击(分析类似)应用程序架构在Azure上
architecture
、
azure
、
analytics
、
azure-table-storage
我非常确信,我必须实现某种
队列
,它将存储所有传入的命中,并在每分钟运行一次的后端实现“聚合器”,以处理
队列
中
的新项目。建议的解决方案 如果我错了,请纠正我,但我认为将这些事务直接写入数据库(某种类型的日志表)将是一个错误,因此我将使用Azure存储帐户(Table)作为
队列
,并派生出几个Azure工作者角色(根据需要)此外,通过使用Azure存储,我可以读取一个行块(以解释单个事务),或者我必须在同一时间读取一个记录的
队列
?最后,对每一行执行DB insert/update对我的聚合器来说都是过
浏览 2
提问于2013-02-11
得票数 1
回答已采纳
1
回答
为什么
消息
在通过lambda处理后仍保留在SQS
中
?
javascript
、
node.js
、
amazon-web-services
、
aws-lambda
、
amazon-sqs
我编写了以下lambda来将
消息
从
"queueA“移动到"queueB”。const response = await reprocess_messages("queueA", "queueB");} 另外,根据下面的lambda日志,在queueA
浏览 18
提问于2022-08-28
得票数 0
回答已采纳
1
回答
JMS回滚有多可靠?
java
、
transactions
、
jms
、
spring-transactions
、
spring-jms
事务启动(使用Spring @ Transaction注释) 如果不是,那么如何从事务下的
队列
中
读取
消息
(步骤2)? 是否使用某种
队列
浏览器,以便
从
队列
读取
消息
,但不使用?
浏览 0
提问于2016-11-01
得票数 1
回答已采纳
2
回答
readQueue和writeQueue有什么不同
rocketmq
在RocketMQ
中
,readQueue的数量和writeQueue的数量可以分别设置,在我看来,只有公共部分才能像预期的那样工作。例如,如果将readQueueNum设置为8,而将writeQueueNum设置为16,则不会处理一半的
消息
。 我试图在代码
中
找出这种设计的基本原理,但还没有找到任何线索。有人能帮我解释一下吗?
浏览 7
提问于2019-05-12
得票数 3
1
回答
在MSMQ
中
处理有害
消息
c#
、
sql
、
msmq
当前的设置包括一个windows服务,它从本地
队列
中
获取一条
消息
并提取信息,并将其放入我的SQL database.According
中
。 服务
从
队列
中
获取
消息
(这里使用Peek() )。异常示例:如果在将
消息
保存到数据库的过程
中
丢失
了DBconnection,那么
消息
就不会
丢失
,因为它们在
队列
中
。直到
从
D
浏览 3
提问于2014-01-15
得票数 0
回答已采纳
1
回答
AWS SQS死信
队列
重驱策略
amazon-web-services
、
queue
、
amazon-sqs
在我的系统中有一个主
队列
和一个死信
队列
.主
队列
中
消息
失败的原因有时是
随机
的,不是关键的,即如果
从
主
队列
重试
消息
,就可以处理
消息
。在我的系统
中
,对任何失败
消息
都有3次尝试,这意味着
从
死信
队列
向主
队列
发送
浏览 8
提问于2022-04-08
得票数 1
1
回答
如何等待异步流读取()直到当前协同器完成读取
python
、
python-asyncio
我正在使用异步流上的提供的这个示例来写入数据和
从
套接字
中
读取数据。 self.reader, self.writer = await asyncio.open_connection(self.host, self.port, loop=self.loop) 在使用
消息
时,我只需将
消息
发送到套接字并读取响应,然后将响应发布到另一个
队列
(经过一些
浏览 6
提问于2022-02-05
得票数 0
2
回答
RabbitMQ -名称为"amq.gen-*“的
随机
队列
正在自动生成
android
、
node.js
、
rabbitmq
我设置了
从
服务器(NodeJS)向持久
队列
发送
消息
,而客户端(android app)监听各自
队列
中
的
消息
(每个android设备监听其对应的
队列
,这是唯一的)。根据RabbitMQ文档,当我们尝试连接到一个名称为空的
队列
(即"")时,RabbitMQ会生成一个名称以"amq.gen-“开头的
随机
队列
。但是,
从
客户端或服务器代码中看不到任何地方,我试图连接到一个名称为空
浏览 3
提问于2014-03-05
得票数 13
回答已采纳
3
回答
在CMS上进行并发仲裁
ruby-on-rails
、
web-applications
、
concurrency
、
content-management-system
我正在建立一个自定义的CMS,允许用户发布
消息
到它。
消息
很短,就像推文一样。任何想法都是值得欣赏的。干
浏览 2
提问于2010-08-21
得票数 0
2
回答
如何
随机
化RabbitMQ
中
消息
的顺序?
rabbitmq
假设我有m条
消息
在
队列
中
,我有n条
消息
需要发布。如何以
随机
顺序插入
队列
中
的n条
消息
,而不是附加到
队列
末尾?换句话说,我如何使用rabbitMQ进行混洗?
浏览 0
提问于2016-04-19
得票数 3
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
RabbitMQ实战:可用性分析和实现
消息队列是如何保证高可用的
RabbitMQ教程C#版-工作队列
消息持久化
RabbitMQ消息可靠性分析
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券