腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(694)
视频
沙龙
1
回答
Spring
Cloud
Stream
-
Functions
-
如何
手动
确认
rabbitmq
消息
?
spring-integration
、
spring-cloud
、
spring-cloud-stream
、
spring-amqp
、
spring-rabbit
我正在使用
spring
cloud
stream
和rabbitbinder。使用@StreamListener,我可以通过将通道和deliveryTag注入到方法中来
手动
确认
rabbitmq
消息
,如下所示: @StreamListener(target = MySink.INPUT1**************"); System.out.println("Received message " + message.getPay
浏览 131
提问于2020-04-14
得票数 2
回答已采纳
2
回答
使用
Spring
Cloud
Stream
RabbitMQ
手动
确认
rabbitmq
、
spring-cloud-stream
我正在尝试设置一个场景,监听器将
手动
向
RabbitMQ
发送
确认
。我的application.properties里有这个
spring
.
cloud
.
stream
.rabbit.bindings.input.consumer.acknowledge-mode=MANUAL
如何
从监听程序发送ack?我从中看到,对于Kafka,我们创建了一个
确认
对象,并在其中调用object ()。
RabbitMQ
有没有这样做的例子?
浏览 3
提问于2016-08-20
得票数 4
1
回答
如何
使用
spring
云流侦听两个
RabbitMQ
队列
spring-boot
、
kotlin
、
rabbitmq
、
spring-cloud-stream
但是,当我添加另一个消耗
消息
的bean并试图将其绑定到另一个队列时,这两个队列都不是在
RabbitMQ
中创建的,
手动
创建时也不会从这些队列中使用任何
消息
。=localhost
spring
.
rabbitmq
.username=guest
spring
.
c
浏览 1
提问于2021-03-09
得票数 0
回答已采纳
1
回答
同步队列的所有使用者,使其一次只处理一条
消息
java
、
rabbitmq
、
amqp
、
spring-cloud-stream
我正在运行一个
Spring
Cloud
Stream
应用程序,使用来自
RabbitMq
的
消息
。我想实现这样一种行为:给定的队列有三个消费者实例,只向其中任何一个实例传递一条
消息
,然后等待下一条
消息
传递,直到当前
消息
被
确认
(所有消费者之间的某种同步)。我认为这可以使用启用全局选项的https://www.
rabbitmq
.com/consumer-prefetch.html来完成,但我找不
浏览 17
提问于2020-12-02
得票数 0
回答已采纳
1
回答
Spring
Cloud
Stream
RabbitMQ
-使用头部而不是路由键进行分区
rabbitmq
、
partitioning
、
spring-cloud-stream
我正在浏览文档,但找不到任何与此相关的内容,所以我在这里向您
确认
。
RabbitMQ
插件允许这样做,但是
spring
cloud
stream
在某种程度上允许这样做吗? 谢谢并致以问候。
浏览 2
提问于2019-10-07
得票数 0
2
回答
spring
cloud
stream
'bindingService‘错误
spring-boot
、
spring-cloud
、
hystrix
、
turbine
、
spring-cloud-stream
(BinderFactoryConfiguration.java:100) ~[
spring
-
cloud
-
stream
-1.0.0.RC1.jar:1.0.0.RC1] at org.springframework.
cloud
.
stream
.config.BinderFactoryConfiguration$$EnhancerBySpringCGLIB$$b9b6d96.CGLIB$binderTypeRegistry$1(<generated>) ~[
spring
-
浏览 7
提问于2016-04-30
得票数 5
1
回答
如何
在重新发布到dlq后
确认
或拒绝邮件
spring-cloud-stream
当消费者在
消息
处理期间并且在
手动
ack工作之前抛出异常republishToDlq时,但是原始队列
消息
总是处于nack状态。环境
Spring
Boot:2.1.11.RELEASE
Spring
Cloud
:Greenwich.SR4
Spring
Cloud
Stream
:Fishtown.SR4
spring
-
cloud
-
stream
-binder-rabbit:2.1.4.
浏览 11
提问于2020-01-17
得票数 0
回答已采纳
1
回答
针对不同用户的每个
消息
的主题
spring
、
spring-cloud
、
spring-cloud-stream
我要寻找的拓扑是到目前为止,我还没有看到在
Cloud
中定义每个
消息
的主题的方法。我知道消费者将被绑定到特定的主题,但是在将
消息
发送到交换之前,生产者
如何
设置每个
消息
的主题?=guest
spring
.
cloud
.
stream
.bindings.o
浏览 0
提问于2018-05-05
得票数 2
回答已采纳
1
回答
无法在
rabbitmq
上发布
消息
,无法使用
spring
cloud
的路由密钥直接交换
spring-cloud
、
spring-cloud-stream
、
spring-rabbit
我正尝试使用
spring
云流将
消息
发布到此交换,但
消息
未到达队列<dependency> <artifactId>
spring
-
cloud
-starter-
stream
-rabbit</artifactId> </dependency>
浏览 13
提问于2019-08-16
得票数 1
1
回答
处理死信队列的配置
java
、
configuration
、
rabbitmq
、
spring-cloud-stream
、
dead-letter
我有一个使用
RabbitMQ
在微服务中交换
消息
的项目。对我的项目至关重要的一件事是,我绝不能失去任何信息。=true
spring
.
cloud
.
stream
.rabbit.bindings.input.consumer.dlq-ttl=300000
spring
.
cloud
浏览 3
提问于2019-12-09
得票数 0
回答已采纳
1
回答
Spring
cloud
stream
RabbitMQ
动态路由报文
java
、
rabbitmq
、
spring-cloud-stream
我已经实现了如下所示的示例 在
rabbitmq
中,它动态创建一个交换,但没有提供绑定或路由关键字的选项。我的要求是使用路由关键字向这个动态创建的交换发送一条
消息
。我需要
如何
实现它才能设置路由密钥?
浏览 1
提问于2017-07-06
得票数 0
1
回答
如何
配置
spring
boot以使用
spring
-
cloud
-
stream
和rabbit binder将供应商绑定到
rabbitmq
队列?
java
、
spring-boot
、
rabbitmq
、
amqp
、
spring-cloud-stream
我想使用一个非常简单的
spring
启动应用程序向
rabbitmq
队列demo-queue发送
消息
: package com.example.demo; import java.time.LocalDateTime因此启动供应商并向其查询新
消息
。但是,我没有看到
rabbitmq
中的队列被创建并填充了生成的
消息
。 pom.xml为: <?xml version="1.0" encoding="UTF-8"?<artifactId><
浏览 32
提问于2020-11-24
得票数 1
回答已采纳
1
回答
带有兔子绑定的
Spring
云流-源/接收器队列名称不匹配
spring-cloud
、
spring-rabbit
、
spring-cloud-stream
最近,我开始使用和
RabbitMQ
绑定。} compile(
浏览 3
提问于2016-02-05
得票数 3
回答已采纳
1
回答
@StreamListener在
Spring
的主应用程序类外不可见。可能是什么原因?
java
、
spring
、
spring-boot
、
rabbitmq
、
spring-cloud-stream
我正在发布来自
RabbitMQ
管理接口的
消息
。=localhost
spring
.
rabbitmq
.username=guest
spring
.
cloud
.
stream
.rabbit.bindings.slideInputStream.consumer.consumerTagPrefi
浏览 2
提问于2020-09-05
得票数 1
回答已采纳
1
回答
Cloud
上的:将
RabbitMq
源代码绑定到流应用程序
spring-cloud-stream
、
spring-cloud-dataflow
我很简单地需要将
Stream
应用程序部署到我们的内部云铸造实例中。该流有一个
消息
的,定义如下,用于在PC上本地运行它:
stream
create myMessageStream --definition "rabbit --rabbit.queues=
cloud
-
stream
-source--rabbit.requeue=true --
spring
.
rabbitmq
.host=localhost --
spring
.
rabbitmq<
浏览 1
提问于2016-11-07
得票数 0
回答已采纳
2
回答
本地的
RabbitMQ
替代方案
spring
、
rabbitmq
、
spring-cloud-stream
我正在提供新的软件设计,并将使用
RabbitMQ
作为
消息
总线以及
Spring
Cloud
Stream
。 其中一个问题是开发人员无法在本地计算机上安装Erlang或
RabbitMQ
。
Spring
Cloud
stream
不支持ActiveMQ。在unix环境中使用
RabbitMQ
时,有没有什么方法可以在本地机器上安装队列并使用它?
浏览 6
提问于2018-10-04
得票数 1
1
回答
注意并处理代理中的错误
java
、
spring
、
spring-boot
、
rabbitmq
、
spring-cloud-stream
对于使用
消息
传递开发分布式应用程序,尤其是
Spring
,我是相当陌生的。目前,我想知道
如何
处理代理端的错误的最佳实践。这些配置如下所示:
spring
.
cloud
.
stream
.bindings.consumeA-in-0.group=$Default
spring
.
cloud
浏览 10
提问于2022-01-19
得票数 1
2
回答
Spring
Cloud
Stream
Kafka批量-
手动
提交整个批量
spring-kafka
、
spring-cloud-stream
我们使用
spring
cloud
streams Hoxton.SR4来消费来自Kafka topic的
消息
。我们已经启用了每次轮询获取2000条记录的
spring
.
cloud
.
stream
.bindings..consumer.batch-mode=true,。我想知道是否有一种方法可以
手动
确认
/提交整个批次。
浏览 264
提问于2020-12-10
得票数 0
1
回答
Spring
Cloud
Stream
测试的错误测试
spring
、
spring-cloud
、
spring-test
、
spring-cloud-stream
我们使用
spring
-
cloud
-
stream
来管理应用程序之间的
消息
。AMQP configuration
spring
.
rabbitmq
.host=
rabbitmq
spring
.
rabbitmq
.password=admin
spring
.
cloud
.<
浏览 0
提问于2018-04-07
得票数 2
1
回答
弹性APM是否支持
Spring
Cloud
Stream
spring-boot
、
elasticsearch
、
spring-cloud-stream
、
apm
、
distributed-tracing
我对Elastic APM非常陌生,不确定它
如何
支持不同的框架。我可以从文档中看到APM支持
Spring
Boot。我用APM测试了一个
Spring
Boot应用程序,它看起来很有前途。我想知道APM是否也支持
Spring
Cloud
Stream
。
Spring
Cloud
Stream
通过使用
Spring
Boot和
消息
中间件来提供事件驱动架构。中间件可以是Kafka、
RabbitMQ</
浏览 34
提问于2019-03-24
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Spring Cloud Stream如何处理消息重复消费?
精通springcloud:消息驱动的微服务,了解Spring Cloud Stream
Spring Cloud Stream简单入门
译:基于Spring Cloud Stream构建和测试 message-driven 微服务
消息驱动-生产消费模式
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券