如何在GCP Pub/Sub Java客户端实现CLI的pull请求过滤功能

结论 #

当前GCP官方Pub/Sub Java客户端库不支持在单次pull请求中携带过滤参数实现服务端过滤，你提到的gcloud pubsub subscriptions pull --filter命令的过滤能力本质是客户端层面的本地过滤，而非服务端处理，你可以通过两种方式在Java应用中实现同等效果：

实现方案 #

• 方案1：本地模拟gcloud的过滤逻辑（和--filter效果完全一致）
  先正常调用pull接口拉取一批消息，再在应用侧按照你需要的规则（匹配消息属性、消息内容、发布时间等）做过滤，不符合要求的消息直接调用nack方法放回订阅队列即可。如果需要复用gcloud的filter语法，可直接引入GCP开源的表达式解析库做规则匹配。
• 方案2：服务端订阅过滤（效率更高，适合规则固定场景）
  如果你的过滤规则是长期固定的，可以在创建订阅时直接配置服务端过滤规则，配置完成后Pub/Sub服务端只会将符合规则的消息投递到该订阅，你pull时拿到的所有消息都满足过滤条件，无需客户端再做二次处理，能大幅降低不必要的带宽消耗。
  Java端创建带过滤规则的订阅示例代码如下：

  import com.google.cloud.pubsub.v1.SubscriptionAdminClient;
  import com.google.pubsub.v1.Subscription;
  import com.google.pubsub.v1.SubscriptionName;
  import com.google.pubsub.v1.TopicName;
  
  public class CreateFilteredSubscription {
    public static void main(String... args) throws Exception {
      String projectId = "your-project-id";
      String topicId = "your-topic-id";
      String subscriptionId = "your-filtered-subscription-id";
      // 过滤规则示例：仅投递属性中type值为order_event的消息
      String filterExpression = "attributes.type = \"order_event\"";
  
      try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
        TopicName topicName = TopicName.of(projectId, topicId);
        SubscriptionName subscriptionName = SubscriptionName.of(projectId, subscriptionId);
        
        Subscription subscription = subscriptionAdminClient.createSubscription(
          Subscription.newBuilder()
            .setName(subscriptionName.toString())
            .setTopic(topicName.toString())
            .setFilter(filterExpression)
            .build()
        );
        System.out.println("带过滤规则的订阅创建成功：" + subscription.getName());
      }
    }
  }
  

内容的提问来源于stack exchange，提问作者Marcin J