为什么spring找不到spring cloud stream创建的@Source bean通道？

Question

我正在尝试使用Spring Cloud Stream来发布和使用Kafka消息。我一直在访问绑定通道上处理留档。我正在尝试为我的主题在通道上使用自定义名称，因此当我尝试注入它时，我有一个@Qualifier，但Spring找不到相关的bean。它说“对于每个绑定接口，Spring Cloud Stream将生成一个实现该接口的bean”，但自动连接不起作用。

我得到的错误是“com中构造函数的参数0…MessagingManager需要找不到类型为“org.springframework.messaging.MessageChannel”的bean。”

我尝试在示例中的MessagingManager构造函数之前使用@Autow的，但是在bean工厂中得到了一个类似的错误，大约有2个，所以我把它拿出来，得到了当前的错误。

我试图使用处理器可能会使事情变得复杂。

这是我的组件。我正在用spring boot运行它，并尝试用以下内容进行测试：

@Component
public class StartupTester implements ApplicationListener<ContextRefreshedEvent> {
    MessagingManager messagingManager;

    @Override
    public void onApplicationEvent(ContextRefreshedEvent event) {
        messagingManager.sendThingCreatedMessage(new ThingCreated("12345", "667788"));
    }
}

@Component
public class MessagingManager {

    private MessageChannel thingCreatedChannel;

    public MessagingManager(@Qualifier(ThingChannelProcessor.THING_CREATED) MessageChannel output) {
        thingCreatedChannel = output;
    }

    public void sendThingCreatedMessage(ThingCreated thingCreated) {  
thingCreatedChannel.send(MessageBuilder.withPayload(thingCreated).build());
    }
}


@Component
    public interface ThingsChannelProcessor extends Processor {

    String THING_REQUEST = "thing-request";
    String THING_CREATED = "thing-created";

    @Input(THING_REQUEST )
    SubscribableChannel thingsRequest();

    @Output(THING_CREATED )
    MessageChannel thingCreated();
}

我的主类上还有@EnableBinding（ThingsMessagingManager.class），该类用@SpringBootApplication注释。

Answer 1

我无法再现你的错误。但我有几点你可以遵循：

1. 无需使用组件为接口添加注释
2. 似乎您的启用绑定（EnableBinding）上有一个拼写错误，您应该使用启用绑定（ThingsChannelProcessor.class）而不是消息管理器（ThingsMessagingManager）
3. 您也不需要扩展处理器，这可能是您第一次得到2个bean的原因。如果您正在自定义频道，则无需从接收器/源/处理器下降，请查看文档中的咖啡师示例
4. 侦听contextRefresh也不会工作，因为我们在刷新上下文后进行绑定

实际上，让我更清楚地了解一下4。我们创建了一个子上下文，因此为了确保您的上下文已完全初始化，请确保您也在启动器上实现了ApplicationContextAware，并且在发送消息之前，请检查上下文是否相同，否则，如果（this.context.equals（event.getApplicationContext（）））