腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(1063)
视频
沙龙
1
回答
如何
防止
java
应用程序
在
停止
程
序时
丢弃
未
确认
的
RabbitMQ
消息
?
java
、
spring
、
rabbitmq
、
spring-rabbit
、
rabbitmq-exchange
我写了一个使用
RabbitMQ
的
java
项目。我
在
调试模式下开始我
的
Spring项目,
在
ListenerExample.
java
中显示System.out.println(input);
的
代码行上有一个断点。
在
应用程序
的
另一部分中,我使用以下代码行向此队列发送一条
消息
: rabbitTemplate.convertAndSend(ManagerExample.getTopicExc
浏览 18
提问于2021-01-08
得票数 0
4
回答
处理因错误
停止
时
的
RabbitMQ
拒绝
消息
php
、
symfony
、
rabbitmq
我正在为一个
应用程序
使用Symfony和
RabbitMQ
包,并且遇到了以下问题:当消费者服务抛出一个
未
捕获
的
异常/错误(例如:内存不足)时,
消息
会一次又一次地重新发布和使用,直到它得到一个拒绝或
确认
信号我希望更改此行为,以便在第一次使用
消息
时发生任何
未
捕获
的
异常/错误时
丢弃
该
消息
。 这是可能
的
吗?如果可能,是
如何
实现
的
?谢谢!
浏览 0
提问于2016-11-06
得票数 1
1
回答
RabbitMQ
-将
未
确认
的
消息
传递到不同
的
队列
c#
、
.net
、
rabbitmq
、
amqp
我正在为我
的
消息
传递系统使用
RabbitMQ
。非常感谢!
浏览 3
提问于2013-12-08
得票数 2
1
回答
我
的
容器化
Java
RabbitMQ
消费者不再使用
java
、
docker
、
spring-boot
、
rabbitmq
我已经使用Spring Boot编写了一个
Java
,并将其容器化为
RabbitMQ
容器。当我
在
我
的
MacBook上运行这个容器时,它可以很好地使用它
的
32个并发使用者来处理所有排队
的
消息
。但是,当我部署相同
的
Docker镜像并在生产服务器上运行它时,它会在一段时间后
停止
使用。上面的图像就是它
停止
的
地方。我已经将
RabbitMQ
客户端配置为使用32个并发使用者,预取计数为
浏览 1
提问于2018-04-09
得票数 0
1
回答
如何
在Spring中使用Ack或Nack
rabbitmq
、
spring-amqp
、
spring-rabbit
我是春季AMQP
的
新手。我有一个
应用程序
,它是一个生产者,它向另一个作为使用者
的
应用程序
发送
消息
。,如果数据是正确
的
,我们必须从队列中删除
消息
。如果数据不正确,我们必须对数据进行NACK(负
确认
),以便在
RabbitMQ
中重新排队。);**(当异常发生时,它将请求
消息
) 但就我
的
情况而言,我将
确认
基于验证
的</
浏览 1
提问于2016-09-16
得票数 18
回答已采纳
2
回答
使用
java
停止
队列侦听
RabbitMQ
java
、
rabbitmq
、
message-queue
嗨,我
在
我
的
java
应用程序
中使用
rabbitMQ
。当我
停止
应用程序时
,我需要确保
在
停止
应用程序
之前
停止
队列侦听器(
停止
从队列接收
消息
)。我不确定我需要打电话给channel.close()还是channel.basicCancel("tag").编写了以下代码以
停止
队列侦听。
浏览 8
提问于2014-12-24
得票数 1
回答已采纳
1
回答
在
中处理发行者
确认
超时
spring
、
rabbitmq
、
spring-rabbit
我正在测试AMQP
的
Spring实现,我想使用publisher
确认
。我
在
文档和代码中缺少
的
是
如何
处理某个年龄
的
未
确认
消息
。裸
RabbitMQ
客户端
java
库提供了一个工作良好
的
方法,但这将迫使我
在
Spring抽象下更深入,为什么我不想继续发布和重新尝试
未
确认
的
消息
?我确实找到了,但是我遇到<
浏览 3
提问于2015-06-26
得票数 1
回答已采纳
1
回答
XMS mq client_acknowledge -单独
确认
消息
c#
、
ibm-mq
、
xms
我正在尝试编写MQ客户端,它将抵抗意外
的
情况。client_acknowledge模式创建了客户端:
在
XMS文档中,有关于CLIENT_ACKNOWLEDGE
的
信息:
应用程序
可以单独
确认
每条
消息
的
接收,或者它可以接收一批
消息
,并且只对接收到
的
最后一条
消息</em
浏览 7
提问于2016-01-22
得票数 0
2
回答
RabbitMQ
在
处理长时间运行
的
任务时关闭连接,超时设置会产生错误
python
、
rabbitmq
、
amqp
、
pika
、
python-pika
我使用
RabbitMQ
生产者向使用者发送长时间运行
的
任务(30 mins+)。问题是,当关闭到服务器
的
连接并请求
未
确认
的
任务时,使用者仍在处理一个任务。 通过研究,我了解到可以使用或来解决这个问题。这两种解决方案
在
尝试时都会引发错误。
在
阅读类似帖子
的
答案时,我还了解到,自从发布答案以来,
RabbitMQ
已经实现了许多更改(例如,默认心跳超时已从
RabbitMQ
3.5.5之前
的
58
浏览 2
提问于2016-03-21
得票数 17
回答已采纳
1
回答
通道预取计数和使用者预取计数之间有什么区别?
rabbitmq
最近对
RabbitMQ
服务器
的
升级中,管理面板中
的
使用者报告
的
预取计数发生了变化。 我们应该使用什么参数组合到Model.BasicQos(prefetchLength, prefetchCount, global);客户端上
的
c#调用?
浏览 2
提问于2017-05-04
得票数 19
1
回答
当
消息
数量达到阈值时,是否有可能得到“推送”?
rabbitmq
、
push
、
message-queue
、
messaging
、
threshold
我想检查一下 我可以声明一个阈值来接收推送通知吗?
浏览 2
提问于2014-06-01
得票数 0
回答已采纳
1
回答
在
nodejs中使用amqplib可以
在
队列太大时
丢弃
rabbitmq
消息
吗?
node.js
、
rabbitmq
、
amqp
、
node-amqplib
我
在
一个nodejs
应用程序
中使用amqplib。在前端有一些繁重
的
处理,导致
rabbitmq
消息
的
接收出现一些延迟。当使用rabbitmqctl list_queues监视我
的
队列时,等待处理
的
消息
数量从未
停止
攀升。 有没有办法设置我
的
通道,以便在队列有给定数量
的
等待
消息
时
丢弃
消息
?下面是我
如何
设置我
浏览 35
提问于2018-02-05
得票数 0
回答已采纳
1
回答
如何
使用ConnectionListner和/或ChannelListner记录
RabbitMQ
中
消息
传递
的
失败/成功
rabbitmq
、
spring-amqp
、
spring-rabbit
我试图记录在
RabbitMQ
中发送
消息
时发生
的
任何信息或异常,因为我试图
在
现有的连接工厂中添加ConnectionListener。但是,当我
停止
RabbitMQ
服务时,我得到了但这个异常
浏览 4
提问于2021-03-31
得票数 0
回答已采纳
1
回答
弹簧反应流-意外关闭
spring
、
spring-cloud-stream
、
spring-rabbit
、
reactive-streams
、
spring-reactive
我们
在
RabbitMQ
中使用Spring反应性流。 当Spring Reactive将
消息
从队列中取出时,它就会立即
确认
该
消息
。因此,
在
消息
处理期间发生
的
任何错误、未处理
的
异常都需要在
应用程序
中处理(这与非反应性流不同,其中可以抛出未处理
的
异常,并拒绝
消息
,从而将其发送到死信队列)。当
消息
正在运行时,我们应该
如何
处理
应用程序
中<
浏览 5
提问于2020-04-09
得票数 0
1
回答
RabbitMQ
java
客户端
停止
使用
消息
。
java
、
heroku
、
spring-boot
、
rabbitmq
、
spring-rabbit
我
的
应用程序
使用来自
RabbitMQ
的
一些
消息
并对它们进行处理。我有大约10个队列,每个队列最多有10个使用者(线程)。我
的
预取值为5,我正在使用CloudAMQP插件(
RabbitMQ
作为服务)
在
Heroku运行我
的
安装程序。 我运行
的
默认心跳和连接超时设置(60秒)。我
的
java
应用程序
是一个使用Spring-兔子库
的
spring引导
浏览 0
提问于2016-08-04
得票数 4
回答已采纳
2
回答
为上游google gcm构建xmpp服务器
android
、
google-cloud-messaging
、
xmpp
、
ejabberd
假设有一个
应用程序
,它在给定
的
时间点拥有10多万
的
安装量和10多万
的
活跃用户。我需要将用户
的
活动数据记录到我
的
服务器上。目前,我从设备向我
的
服务器发出HTTP请求。我有一堆运行web服务器
的
机器,位于amazon
的
ELB后面。他们解析来自设备
的
数据,并将其放入mongodb。现在,我想使用Google
的
GCM提供
的
上游CCS来捕获设备数据(这样我就可以利用GCM来更可靠地传递数据)
浏览 0
提问于2015-10-20
得票数 4
1
回答
RabbitMQ
内存使用率上升并阻塞调用...为什么?
rabbitmq
我正在使用
RabbitMQ
来处理
应用程序
日志(windows server2008安装)。
应用程序
将
消息
发送到交易所。我有一个专用
的
队列,可以将
消息
转发给它。许多客户端都有长时间运行
的
连接。 当
消息
被从队列中拉出时,它们会被自动
确认
,因此队列中不会有任何
未
确认
的
消息
。然而,我看到Rabbit
的
记忆随着时间
的
推移而增长。它在第一次
浏览 2
提问于2012-10-27
得票数 1
1
回答
应用程序
实例之间
的
不兼容性:
防止
rabbitmq
使用具有特定标头
的
消息
java
、
spring
、
rabbitmq
、
spring-rabbit
我有两个同一个
java
应用程序
的
实例,它们使用spring和
rabbitmq
。实例向队列发送
消息
,但我无法预测哪个实例将使用它(如预期
的
那样)。我们不能在部署新版本
的
同时中断服务,因此不能同时
停止
这两个实例。我们必须
停止
实例A,用更新重新启动实例A,然后
浏览 1
提问于2017-01-12
得票数 0
回答已采纳
1
回答
兔
java
、
rabbitmq
、
amqp
我正在与
java
应用程序
一起使用
rabbitmq
服务器。当
应用程序
收到粒子队列上
的
消息
时,它会生成一些数据并将它们发送到另一个队列中。当运行
应用程序时
,它接收
消息
,生成数据并将它们发送到正确
的
队列中。这些数据
在
服务器上得到了很好
的
接收,而且它们是正确
的
。但是,当
应用程序
试图向服务器发送
确认
时,我将得到一个AlreadyClosedExceptio
浏览 1
提问于2015-12-15
得票数 3
回答已采纳
2
回答
我
的
未
确认
数量怎么会比工人数量多呢?
rabbitmq
、
bunny
我有一个只有一个工人
的
队列。实施。看起来是这样
的
: connection = get_connection channel = connection.create_channel但让我困惑
的
是,
在
RabbitMQ
管理UI中,我有时会看到该队列有2到3个
未
确认
的
队列。但这怎么可能呢?
浏览 5
提问于2016-03-05
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
RabbitMQ实战:运行和管理RabbitMQ
我们来浅谈云计算服务架构任务池的搭建和使用,看你能吸收多少?
RabbitMQ教程C#版-工作队列
如何在Python中实现异步执行?
2400字带你把云计算服务架构指令池的搭建和使用一次性搞懂
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券