在Spring Cloud Stream Reactive方法中有没有动态更改目标的方法？
在Spring Cloud Stream Reactive方法中，可以通过更改绑定器的配置来动态更改目标。具体来说，可以使用BindingService接口的bindConsumer和bindProducer方法来动态绑定或解绑消费者和生产者。
对于消费者，可以使用BindingService.bindConsumer方法来动态绑定消费者。该方法接受三个参数：目标名称、目标类型和绑定器配置。目标名称是用于标识消费者的唯一名称，目标类型是消费者的类型，绑定器配置是一个Map对象，用于配置绑定器的属性。绑定器配置中可以包含destination属性，用于指定消费者的目标。
对于生产者，可以使用BindingService.bindProducer方法来动态绑定生产者。该方法接受三个参数：目标名称、目标类型和绑定器配置。目标名称是用于标识生产者的唯一名称，目标类型是生产者的类型，绑定器配置是一个Map对象，用于配置绑定器的属性。绑定器配置中可以包含destination属性，用于指定生产者的目标。
通过调用BindingService.bindConsumer和BindingService.bindProducer方法，可以在运行时动态更改消费者和生产者的目标。这样就可以实现动态更改目标的功能。
在腾讯云的产品中，与Spring Cloud Stream相关的产品是腾讯云消息队列 CMQ（Cloud Message Queue）。CMQ是一种高可用、高可靠、高性能的消息队列服务，适用于异步通信、解耦、削峰填谷、流量削峰等场景。您可以通过以下链接了解更多关于腾讯云消息队列 CMQ的信息：
腾讯云消息队列 CMQ产品介绍：https://cloud.tencent.com/product/cmq
相关·内容
我知道如果我以Spring reactive的方式实现SC流函数，我就不能像传统的命令式方式那样发送DLQ。难道我不应该在onErrorContinue中生成它吗？*>
Flux.just(MessageBuilder.withPayload(String(source.payload as ByteArr
浏览 8提问于2021-03-04得票数 0
回答已采纳
类似于：spring.cloud.stream.instanceCount=n
spring.cloud.stream.in
浏览 6提问于2021-05-08得票数 5
2回答
用Spring流测试错误流
、、、、
我只有两个流绑定如下： stream: channelone: <artifactId>spring-cloud-stream-test-support</artifactId>我发送的信息如下：
event
浏览 3提问于2019-10-29得票数 1
回答已采纳
1回答
我们所有的消费者应用程序都使用spring-cloud-stream。因此，我们决定在body中发送一个标头。{ ~~ "payload": { }但是
浏览 0提问于2020-04-28得票数 0
回答已采纳
我还使用了Spring Cloud Stream Kafka和Spring Cloud Bus，同时启用了Spring Security基本身份验证。
浏览 7提问于2018-07-09得票数 0
SpringWebReactive中有一个类WebClient and ClientRequest。如果我们查看文档，下面是使用ClientRequest使用WebClient的方法。gradle依赖项中，ClientRequest.GET方法不可用。') compile('org.springframe
浏览 6提问于2017-01-31得票数 1
我正在尝试在Spring Cloud数据流中配置DLQ。=raw | log --spring.cloud.stream.bindings.input.consumer.headerMode=raw" --name ticktran
streamapps.custom-transform.spring.cloud.stream.bindings.input.consumer.headerMode
浏览 0提问于2016-09-16得票数 0
2回答
我试图组合，方法是使用来自Function类型的函数式bean的返回Flux<Message<T>>，并为每个Message设置标题spring.cloud.stream.sendto.destinationBean return person -> Flux.fromIterable(Stream.ofperson.g
浏览 0提问于2020-06-07得票数 1
回答已采纳
我已经使用spring文档为客户端和服务器创建了演示。我正在使用git属性文件进行外部配置。如果我对外部配置文件做了任何更改并刷新了客户端，那么它就可以正常工作了。但我不想每次都刷新。我看了一下春季文档，我想我们可以用下面的方法来完成它。
目前，我正在尝试第一个与，但它没有工作。
浏览 3提问于2015-12-22得票数 3
1回答
我使用spring-boot-starter-data-mongodb-reactive和spring-cloud-vault-config-databases进行动态秘密旋转。不幸的是，我没有办法做到这一点，因为credentials字段在MongoClientImpl.settings中无法重新分配。是否有任何有效的方法来实现这一点，而不交换洞MongoDB客户端配置？
浏览 5提问于2022-08-18得票数 0
回答已采纳
当Kinesis流使用者遇到错误，并在使用@StreamListener注释的方法中抛出异常时，如何配置绑定以使消息重新排队或发送到DLQ？我在Spring Cloud Stream中看到了对Rabbit和Kafka的这种级别的支持，但我没有看到对Kinesis绑定的支持。在Kinesis流处理器中处理错误的推荐方法是什么？
浏览 24提问于2019-05-16得票数 1
回答已采纳
我使用： <dependency> <artifactId>spring-cloud-starter-stream-rabbit我试过这个： spring: config: discovery:
浏览 114提问于2019-12-27得票数 0
回答已采纳
我能做这样的事吗spring.cloud.stream.bindings.output.binder=kafka我目前甚至试图将Function分解为2：
它的输入绑定到web客户端，其输出动态绑定到第二个函数(使用spring.cloud.stream.sendto.destination)。然而，这种方法</
浏览 1提问于2019-11-29得票数 4
回答已采纳
方法在控制器中调用：public Mono<String> index(Model model) { compile 'org.synchronoss.cloud:nio-multipart-parser'
compile 'org.springframework.boot:spring-boot-sta
浏览 1提问于2018-01-24得票数 9
1回答
我需要一种根据传入消息的类型动态解析入站通道的方法。我不寻找任何基于头的解决方案，这已经在此链接https://cloud.spring.io/spring-cloud-static/spring-cloud-stream/3.0.0.M1/spring-cloud-stream.html如果有一个自定义绑定可以在
浏览 13提问于2020-04-11得票数 0
在同一个项目中，我有两个AWS帐户。在一个帐户中，我有一个需要访问的DynamoDB数据库。在另一个，我有亚马逊动态。/:5.3.20]
我不知道如何指定spring-cloud-stream或spring-cloud-stream-binder-kinesis它应该使用哪个bean。Bean，spring-cloud-stream将尝试创建自己的bea
浏览 12提问于2022-10-26得票数 1
回答已采纳
下面是我的两个RabbitMQ队列和方法： private final Queue igListenerQueue;
@WriteOperation
浏览 12提问于2020-07-10得票数 0
回答已采纳
Cloud Stream绑定我的流 @EnableBinding(LoansStreams.class)} 3-配置Kafka属性 spring(KafkaStreamsStreamListenerSetupMethodOrchestrator.java:510) ~[spring-cloud-stream-binder-kafka-streams(KafkaStreamsStreamListenerSetupMethodOrc
浏览 368提问于2019-04-27得票数 16
回答已采纳
KeyValue.pair(k, OutputType.createFrom(v)); }
我的application.yaml现在为租户A配置流应用程序：spring.cloud.stream.kafka.streams.binder.functions.myfunctiondefinition:
applicationId:
浏览 5提问于2022-05-13得票数 4
回答已采纳
我正在尝试做一个简单的spring-cloud-stream单元测试来验证流之间的连接；基本上，处理程序可以从一个流中读取并写入到另一个流中。这部分运行得很好。问题是，应用程序的其他部分也在启动；即rabbitMQ侦听器。在另一个类中有一个方法(除了我正在测试的那个)，它有一个@RabbitListener。这就是被调用的方法。我删除了webEnvironment参数，但这并没有什么不同。目前，解决方法是将s
浏览 46提问于2019-01-11得票数 0
回答已采纳
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
腾讯云开发者
