Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
Spring AMQP RabbitMQ 如何直接发送到Queue而不需要Exchange
我正在使用 Spring AMQP 和 Rabbitmq 模板 如何直接将消息发送到队列而不使用Exchange 我该怎么做 我该怎么做 你不能 发布者不知道队列 只是交换和路由密钥 但是 所有队列都绑定到默认交换器 以队列名称作为其路由键
Spring
rabbitmq
send
springamqp
springrabbit
Spring AMQP - 使用带 TTL 的死信机制进行消息重新排队
就像是 休斯顿 我们这里有问题 在第一次尝试处理事件失败后 我需要安排 延迟消息 5 分钟 我在这种情况下实现了死信交换 失败时的消息将路由至 DLX gt 重试队列 并在 TTL 为 5 分钟后返回工作队列以进行另一次尝试 这是我正在使用
Java
Spring
springboot
springamqp
springrabbit
春云流兔的退避设置
我仍在使用rabbitmq和spring云消息传递设置示例消息传递系统 但遇到了错误 或者我误解了文档 使用spring boot版本2 0 3 RELEASE 为了这个例子 我想要以下设置 spring cloud stream rabb
Java
Spring
springboot
springrabbit
springmessaging
使用Camel的spring-rabbitmq组件时如何自动声明交换?
我正在尝试从 Camel 3 x 迁移到 Camel 4 x 版本 因此我需要从rabbitmq替换组件spring rabbitmq With rabbitmq我正在使用的组件declare https camel apache org
rabbitmq
apachecamel
springrabbit
如何根据条件限制并发消息消耗
场景 我已经简化了事情 许多最终用户可以从前端 Web 应用程序 生产者 开始工作 繁重的工作 例如渲染大型 PDF 这些作业被发送到单个持久的 RabbitMQ 队列 许多工作应用程序 消费者 处理这些作业并将结果写回到数据存储中 这个相
rabbitmq
springrabbit
在rabbitmq autoconfig connectionfactory bean上设置heartbeat属性
我应该如何在rabbitmq spring中的CachingConnectionFactory bean上设置heartbeat属性 这是在云铸造环境中 因此 应用程序将通过清单文件使用服务绑定 并且我没有代理主机名 在我的SimpleMe
Spring
cloudfoundry
springrabbit
即使配置 SSL 属性后,Spring RMQ 侦听器也始终使用 PLAIN 身份验证
我有一个 Spring Boot 应用程序 我正在尝试将侦听器配置为已有的队列 以下是我在我的配置中配置的application yml文件 我还用注释注释了我的配置类 EnableRabbit和听众 RabbitListener参考 sp
Java
Spring
springboot
springrabbit
spring中rabbitmq监听器的异常处理
使用spring 我是rabbitmq的新手 我想知道我错在哪里 我编写了一个rabbitmq连接工厂和一个包含侦听器的侦听器容器 我还为侦听器容器提供了错误处理程序 但它似乎不起作用 我的春豆
SpringMVC
rabbitmq
springrabbit
使用 Spring Security 和 Rabbitmq 进行 OAuth2 授权
目前 我们有许多 Spring 微服务与 REST 端点和 RabbitMQ 队列进行通信 我们刚刚在所有服务上实现了 OAuth2 安全性 并且 REST 端点得到了适当的保护 我们编写了一个库 用于创建 RabbitTemplate 和
Java
Spring
SpringSecurityOAuth2
springamqp
springrabbit
如何在 Spring Boot 中使用 @Lazy 延迟加载 RabbitMQ 队列?
实际上 在我的 RabbitMQ 配置中 我为每个队列声明了 10 个消费者 因此 所有消费者线程都是在我的 Spring Boot 应用程序完全启动之前创建的 因此应用程序启动需要时间 我想在项目启动时延迟加载所有 Rabbitmq 队列
springboot
rabbitmq
lazyloading
springrabbit
向rabbitmq服务器发送确认取决于转换器和监听器
首先 我介绍一下我的案例背景 我在用spring boot and spring rabbitmq 它对我有用 你应该知道我必须为收到的消息实现自定义转换器 1 从这个转换器可以抛出异常 例如在不正确的消息等情况下 2 成功转换后 无例外
Java
springboot
springamqp
springrabbit
使用 Spring AMQP 和 RabbitMQ HA 进行故障转移
有多篇文章建议在 RabbitMQ 集群前面使用负载均衡器 然而 也有多个参考资料显示 Spring AMQP 正在使用一些 故障转移实现 例如代理恢复时连接重置 我对这个主题有几个问题 考虑到这些文章或多或少是旧的 而且今天是 2018
rabbitmq
failover
springrabbit
Rabbitmq:在无限循环中重新处理失败的消息
这是我的rabbitmq配置
Java
Spring
rabbitmq
springrabbit
RabbitMQ 的 Spring SimpleMessageListenerContainer 因无效消息而中止
我正在使用 springs SimpleMessageListenerContainer 来消费来自 RabbitMQ 队列的消息 一切工作正常 但是当无效消息发送到队列 例如无效 json 时 侦听器就会中止 关闭工作线程并且不接受任何进
Java
Spring
rabbitmq
springrabbit
Rabbitmq:代理重启后未确认的消息不会消失
我们观察到了 RabbitMQ 的以下行为 并试图了解它是否正确以及如何解决它 设想 持久 消息被传递到持久队列中 单个 消费者 Spring AMQP 获取消息并开始处理 gt 消息从 READY 变为 UNACK 现在代理已关闭 gt
rabbitmq
springamqp
springrabbit
如何使用 Spring RabbitMQ 在不同队列中配置超时、重试或最大尝试次数
是否可以为每个队列进行这些设置 我有一些重要的队列 因此我需要大量的重试 但有一些不那么重要的队列 我不想配置重试 尝试等 public Queue newQueue String name return new Queue name du
Java
rabbitmq
springamqp
springrabbit
Spring RabbitTemplate 未使用 TTL 创建死信队列
我正在使用 spring rabbit1 1 和 RabbitMQ 3 3 1 我的 spring 配置将在 Rabbit MQ 上的 RabbitTemplate 的帮助下创建任何队列 但如果队列已配置 x dead letter exc
Spring
rabbitmq
AMQP
springamqp
springrabbit
rabbitmq中预取计数与无ack有什么区别
我需要知道rabbitmq中预取计数与无ack之间有什么区别 还 以下陈述有什么区别 如果我设置预取计数为 10 是否会创建 10 个消费者线程 或者 如果我注册 10 个消费者 它会创建 10 个线程吗 以上哪种方式效率更高 专门针对 s
rabbitmq
springamqp
springrabbit
通过 spring-rabbitmq 自动重试连接到代理
我读过这个文档片段 RabbitMQ 自动连接 拓扑恢复 自 Spring AMQP 第一个版本以来 该框架提供了其 在代理发生故障时 可以恢复自己的连接和通道 此外 如第 3 1 10 节 配置代理 中所述 RabbitAdmin 将在以
Java
springboot
springintegration
springamqp
springrabbit
Spring cloud Stream中的事务
Problem 我正在尝试逐行读取一个大文件并将消息放入 RabbitMQ 中 我想在文件末尾提交rabbitMQ 如果文件中的任何记录是坏的 那么我想撤销发布到队列的消息 技术 弹簧靴 春云流水 RabbitMQ 您能帮我实现这个过渡吗
Spring
springboot
rabbitmq
springcloudstream
springrabbit
1
2
»