客户端响应过滤器读取实体问题泽西岛

如何解决客户端响应过滤器读取实体问题泽西岛

我使用 Jersey 客户端过滤器进行缓存。 请求读取和响应缓存值。 如何从客户端响应过滤器读取实体主体，在使用来自客户端构建器的普通客户端调用时，没有像 read、getEntity 这样的方法。 我发现的唯一可能有用的方法是 getEntityStream 但没有太多运气。 使用 EhCache 缓存即时消息。 我是新手用户帮助:)

请求：

公共类 ClientCacheResponseFilter 实现 ClientResponseFilter

private Ehcache ehcache;

public ClientCacheRequestFilter(Ehcache ehcache) {
    this.ehcache = ehcache;
}

@Override
public void filter(ClientRequestContext request) throws IOException {
    System.out.println("REQUEST FILTER");

    if (!request.getmethod().equalsIgnoreCase("GET")) {
        return;
    }
    String key = request.getUri().toString();
    System.out.println("REQ KEY: " + key);

    System.out.println("LOOKING FOR CACHE");
    if (!ehcache.getClientCache().containsKey(key)) {
        System.out.println("EMPTY CACHE");
        return;
    }

    Cache<String,Object> cache = ehcache.getClientCache();
    Object value = cache.get(key);
    if (value != null) {

        System.out.println("REQUEST FILTER - SECOND TIME READING CACHE");
        System.out.println("CACHE ENTRY VALUE: " + value);

        Response response = Response.ok()
                .entity(value)
                .type(MediaType.APPLICATION_JSON)
                .build();

        System.out.println("SENDING ENTITY");
        request.abortWith(response);
    }
}

回复：

private Ehcache ehcache;

public ClientCacheResponseFilter(Ehcache ehcache) {
    this.ehcache = ehcache;
}

@Override
public void filter(ClientRequestContext request,ClientResponseContext response) throws IOException {
    System.out.println("RESPONSE FILTER");
    if (!request.getmethod().equalsIgnoreCase("GET")) {
        return;
    }

    if (response.getStatus() == 200) {

        System.out.println("CACHING VALUE");
        String key = request.getUri().toString();

        ehcache.getClientCache().put(key,?);  // GET ENTITY FROM RESPONSE ?
        
    }
}

客户来电：

    WebTarget webTarget = CLIENT.target(API_URL).path("games");
    Invocation.Builder builder = webTarget.request(MediaType.APPLICATION_JSON);
    
    try (Response response = builder.get()) {
        
        if (response.getStatus() == 200) {
            return response.readEntity(new GenericType<List<Game>>() {
            });
        }
    }
    return Collections.EMPTY_LIST;
}

解决方法

假设您使用的是 Jersey 2.x，ClientResponseContext 可以转换为 Jersey 特定的 ClientResponse，它具有 readEntity(..) 方法（类似于客户端 Response#readEntity()方法）。您也可以在读取实体之前调用 bufferEntity()。这样客户端就可以再次读取实体。

例如，如果您想获得 JSON 字符串响应，您可以简单地执行

// in response filter
ClientResponse res = (ClientResponse) response;
res.bufferEntity();
String jsonResponse = res.readEntity(String.class);