与Spring Cloud Stream的千分尺集成

Question

我正在将Spring Cloud Stream应用程序迁移到功能方法。到目前为止，我使用了提供Spring集成的千分尺指标。请参见Spring集成-千分尺集成。

自迁移以来，使用StreamBridge生成的消息不再生成度量。这似乎是因为Spring集成在将通道定义为bean时创建了它的度量，而StreamBridge则动态创建通道。

话虽如此，我的问题是：

• SCS是否提供任何其他类型的度量？
• 如果没有，有没有办法强制应用程序事先声明通道为bean？

提前谢谢。

使现代化

下面的测试表明，即使在bean的属性中定义绑定目标，也不会在启动时创建。

用于测试的版本为：

Spring启动： 2.5.4

Spring-云-流： 3.1.3

class MessageChannelBeanTests {

    @Test
    void declaredOutputBindingsCreatesMessageChannelBeans() {

        TestChannelBinderConfiguration.applicationContextRunner(MessageChannelBeanTestsConfiguration.class)
                .withPropertyValues("spring.cloud.stream.bindings.myBinding.destination=myDestination",
                        "spring.cloud.stream.bindings.syso-in-0.destination=my-topic")
                .run(context -> {
                    final Map<String, MessageChannel> channels = context.getBeansOfType(MessageChannel.class);


                    /*
                     * Just to see which channels are declared as a bean
                     * The ouput is:
                     *
                     * nullChannel
                     * errorChannel
                     * syso-in-0
                     * my-topic.anonymous.errors
                     */
                    channels.entrySet()
                            .stream()
                            .map(Entry::getKey)
                            .forEach(System.out::println);

                    // Asserts that the channel is created as a bean even if the binding is set by properties
                    assertThat(channels)
                            .containsKey("myBinding");


                });

    }


    @EnableAutoConfiguration
    static class MessageChannelBeanTestsConfiguration {

        @Bean
        public Consumer<String> syso() {
            return System.out::println;
        }
    }
}

请注意，创建的MessageChannel bean包括：

nullChannel errorChannel syso-in-0我的主题。匿名的错误

但是没有我的绑定的痕迹

Answer 1

是的，如果您为不存在的绑定定义属性，它将被提前创建为bean。例如，假设在消息传递系统中，您有一个名为myDestation的目的地（队列，主题等）。比你能拥有这样的东西

spring.cloud.stream.bindings.myinding.destination

使用网桥并将其发送到myBinding。