Spring Cloud LoadBalancer 的高级特性-服务实例过滤器（二）

@Service
@RequiredArgsConstructor
public class MyService {

  private final WebClient.Builder webClientBuilder;

  @GetMapping("/my-endpoint")
  public Mono<String> myEndpoint() {
    return webClientBuilder.build()
        .get()
        .uri("lb://my-service")
        .attributes(ClientRequest.CONNECT_TIMEOUT_ATTR, Duration.ofSeconds(1))
        .retrieve()
        .bodyToMono(String.class);
  }
}

public class MyPredicateFilter implements ServiceInstanceListSupplierFilter {

  @Override
  public List<ServiceInstance> getFilteredServiceInstances(List<ServiceInstance> instances) {
    List<ServiceInstance> filteredInstances = new ArrayList<>();
    for (ServiceInstance instance : instances) {
      if (instance.getMetadata().containsKey("myKey")
          && instance.getMetadata().get("myKey").equals("myValue")) {
        filteredInstances.add(instance);
      }
    }
    return filteredInstances;
  }
}