使用Spring Cloud Stream，我应该为每个事件类型配置通道吗？

Question

我正在做一个项目，使用springboot、Spring cloud Netflix等来构建微服务。

对于一些异步通信，我使用Spring Cloud Stream来生成和使用事件。e、 g.在合同服务中起草业务合同后，该服务发布一个合同创建事件，该事件将由审计服务使用，以初始化审计过程。此外，用户服务将使用该事件为相关方创建通知。

场景是我有很多事件，消费者会根据事件类型订阅感兴趣的事件。我的问题是，我有许多事件类型，很快，我的配置文件中就会充斥着通道配置。例如

spring.cloud.stream.bindings.creation.destination=contract-creation
spring.cloud.stream.bindings.revocation.destination=contract-revocation
spring.cloud.stream.bindings.termination.destination=contract-termination
...

我做错什么了？我正在考虑这些替代方案：

1. David Turanski！有一个示例将按类型选择性地使用事件。这是一个很好的解决方案，但我在想，Spring Cloud Stream有原生解决方案吗？
2. 我应该使用Apache Camel还是Spring Integr？我没有复杂的路由规则，这些框架看起来像是矫枉过正。

我在信息传递方面是个新手，希望这里的人们能给我指明一个正确的方向。

Answer 1

David的博客文章中提到的条件表达式属性被烘焙到@StreamListener注释中，因此您可以将不同的事件类型从同一个目的地路由到不同的侦听器。

Answer 2

这真的要看情况，我很抱歉以这个开头回答。

使用带有选择器的单个通道是最简单的选择，但需要注意的是，每个消费者都将使用来自该目的地的所有消息。如果这是您的用例，那就去做吧。

另一个用例是事件源类型，其中大多数消费者只对事件的子集感兴趣，您可能会更好地将事件（或更好的聚合根）放置在每个目标上。这将允许您更好地扩展，并避免经纪人与消费者之间不必要的聊天。

在您的示例中，您可以使用以下内容：

public interface Contracts {

    @Output("contract-creation") MessageChannel creation();
    @Output("contract-revogation") MessageChannel revogation();
    @Output("contract-termination") MessageChannel termination();

} 

这会为每个eventType创建一个主题，可能有点过头了

也许您应该创建一个类型为的接口事件，并让事件从中派生出来，然后改为：

public interface Events {
    @Output MessageChannel user();
    @Output MessageChannel contract();
}

现在，所有合同事件（创建、废除、终止）都将到达相同的目的地。在接收端，您可以创建选择器来选择要应用的选择器：

@StreamListener(target = "contract", condition = "payload.type=='created'")
    public void contractCreated(@Payload ContractCreatedEvent){

    }

    @StreamListener(target = "contract", condition = "payload.type=='terminated'")
    public void contractTerminated(@Payload ContractTerminatedEvent){

    }