import org.glassfish.jersey.client.filter.EncodingFilter; //导入依赖的package包/类
private void configureCompression(ClientBuilder clientBuilder) {
  if (jerseyClientConfig.httpCompression != null) {
    switch (jerseyClientConfig.httpCompression) {
      case SNAPPY:
        clientBuilder.register(SnappyEncoder.class);
        break;
      case GZIP:
        clientBuilder.register(GZipEncoder.class);
        break;
      case NONE:
      default:
        break;
    }
    clientBuilder.register(EncodingFilter.class);
  }
}
 

import org.glassfish.jersey.client.filter.EncodingFilter; //导入依赖的package包/类
@Test
public void create_gzip_compressed_request_and_response() throws Exception {
    final Response response = RestTest.target(getPort(), "whois/test/person?password=test")
            .property(ClientProperties.USE_ENCODING, "gzip")
            .register(EncodingFilter.class)
            .register(GZipEncoder.class)
            .request()
            .post(Entity.entity(map(PAULETH_PALTHEN), new Variant(MediaType.APPLICATION_XML_TYPE, (String) null, "gzip")), Response.class);

    assertThat(response.getHeaderString("Content-Type"), is(MediaType.APPLICATION_XML));
    assertThat(response.getHeaderString("Content-Encoding"), is("gzip"));

    final WhoisResources whoisResources = response.readEntity(WhoisResources.class);
    assertThat(whoisResources.getErrorMessages(), is(empty()));
    final WhoisObject object = whoisResources.getWhoisObjects().get(0);
    assertThat(object.getAttributes(), hasItem(new Attribute("person", "Pauleth Palthen")));
}
 

import org.glassfish.jersey.client.filter.EncodingFilter; //导入依赖的package包/类
/**
 * Used for injecting a test client
 * in unit tests
 *
 * @param authenticationType The type of authentication to use in the request
 * @param client A specific client object to use for the request
 */
protected JerseyClient(final ClientFactory.AuthenticationType authenticationType, final Client client) {
    this.client = client
            .register(GZipEncoder.class)
            .register(EncodingFilter.class)
            .register(createMoxyJsonResolver());

    switch(authenticationType) {
        case PREEMPTIVE_BASIC:
            client.register(HttpAuthenticationFeature.basicBuilder().build());
            break;

        case NON_PREEMPTIVE_BASIC:
            client.register(HttpAuthenticationFeature.basicBuilder().nonPreemptive().build());
            break;

        case DIGEST:
            client.register(HttpAuthenticationFeature.digest());
            break;

        case NON_PREEMPTIVE_BASIC_DIGEST:
            client.register(HttpAuthenticationFeature.universalBuilder().build());

        case NONE:
        default:
    }
}
 

import org.glassfish.jersey.client.filter.EncodingFilter; //导入依赖的package包/类
protected JerseyGet() {
    client = ClientBuilder.newClient()
    .register(EncodingFilter.class)
    .register(GZipEncoder.class)
    .property(ClientProperties.USE_ENCODING, ENCODING_TYPE);
    webTarget = client.target(SEARCH_URL);
}
 

import org.glassfish.jersey.client.filter.EncodingFilter; //导入依赖的package包/类
private static Client createClient(String httpAuthenticationUser, String httpAuthenticationPassword) {
    ClientConfig cc = new ClientConfig().register(new JacksonFeature());
    Client client = ClientBuilder.newBuilder().withConfig(cc).build();
    client.register(GZipEncoder.class);
    client.register(EncodingFilter.class);
    client.register(DeflateEncoder.class);
    if (!Strings.isNullOrEmpty(httpAuthenticationUser) && !Strings.isNullOrEmpty(httpAuthenticationPassword) ){
        client.register(HttpAuthenticationFeature.basic(httpAuthenticationUser, httpAuthenticationPassword));
    }
    JacksonJaxbJsonProvider provider = new JacksonJaxbJsonProvider();
    provider.setMapper(ObjectMapperBuilder.buildNewObjectMapper());
    client.register(provider);
    return client;
}
 

import org.glassfish.jersey.client.filter.EncodingFilter; //导入依赖的package包/类
private void initializeHTTPClient() {
    ClientConfig clientConfig = new ClientConfig();
    clientConfig.register(JacksonFeature.class);
    clientConfig.register(GZipEncoder.class);
    clientConfig.register(EncodingFilter.class);
    clientConfig.property(ClientProperties.READ_TIMEOUT, getConnectionTimeoutPreference());

    Client client = ClientBuilder.newClient(clientConfig);

    String serviceEndpoint = getConnection().getServerUrlRoot();
    serviceEndpoint = serviceEndpoint + constructServiceEndpoint();
    endpoint = client.target(serviceEndpoint);
}
 

import org.glassfish.jersey.client.filter.EncodingFilter; //导入依赖的package包/类
@Test
public void search_gzip_compressed_response() throws Exception {
    final Response response = RestTest.target(getPort(), "whois/search?query-string=TP1-TEST&source=TEST")
            .register(EncodingFilter.class)
            .register(GZipEncoder.class)
            .request(MediaType.APPLICATION_XML)
            .get();

    assertThat(response.getHeaderString("Content-Type"), is(MediaType.APPLICATION_XML));
    assertThat(response.getHeaderString("Content-Encoding"), is("gzip"));

    final WhoisResources whoisResources = response.readEntity(WhoisResources.class);
    assertThat(whoisResources.getWhoisObjects(), hasSize(1));
}
 

import org.glassfish.jersey.client.filter.EncodingFilter; //导入依赖的package包/类
@Test
public void search_zlib_compressed_response() throws Exception {
    final Response response = RestTest.target(getPort(), "whois/search?query-string=TP1-TEST&source=TEST")
            .register(EncodingFilter.class)
            .register(DeflateEncoder.class)
            .request(MediaType.APPLICATION_XML)
            .get();

    assertThat(response.getHeaderString("Content-Type"), is(MediaType.APPLICATION_XML));
    assertThat(response.getHeaderString("Content-Encoding"), is("deflate"));

    final WhoisResources whoisResources = response.readEntity(WhoisResources.class);
    assertThat(whoisResources.getWhoisObjects(), hasSize(1));
}