Google PubSub：如何自定义向消费者分发消息？

Question

我有一个场景，我们将把客户数据发送到pubsub并与java订阅者一起使用。我有多个订阅者订阅了同一订阅。有没有办法将所有具有相同customerID的消息路由到同一订户？

我知道Google Dataflow具有基于会话的窗口。但是，我想知道我们是否可以使用简单的Java使用者来实现它。

Answer 1

目前，Google Cloud Pub / Sub无法过滤传递给特定订阅者的消息。如果您事先知道拥有的订户数量，则可以自己决定。您可以创建与订阅者一样多的主题，然后将客户ID存储到不同的主题中，为每个客户ID将消息发布到正确的主题。您将在每个主题上创建一个订阅，每个订阅者将从这些订阅之一接收消息。

缺点是，如果有任何订阅者想要所有客户ID的数据，则必须在每个主题上有一个额外的订阅，并且该订阅者必须从所有这些订阅中获取消息。

请记住，您不想创建超过10,000个主题，否则您可能会遇到配额问题。