Блог

Я использую фильтры на стороне клиента Jerseys для кэширования. Запрос на чтение и ответ для кэширования значений. Как прочитать тело объекта из фильтра ответов клиента, нет таких методов, как read, getEntity при использовании обычных клиентских вызовов из client builder. Единственный метод, который я нашел, возможно, полезным, — это 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;
}
 

Предполагая, что вы используете Джерси 2.x, ClientResponseContext он может быть приведен к конкретному Джерси ClientResponse , у которого есть readEntity(..) метод (аналогичный методу клиента Response#readEntity() ). Вы также можете выполнить вызов bufferEntity() перед чтением объекта. Таким образом, клиент сможет снова прочитать объект.

Так, например, если вы хотите получить ответ в виде строки JSON, вы можете просто сделать

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