Java HttpCacheContext类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中org.apache.http.client.cache.HttpCacheContext类的典型用法代码示例。如果您正苦于以下问题：Java HttpCacheContext类的具体用法？Java HttpCacheContext怎么用？Java HttpCacheContext使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

HttpCacheContext类属于org.apache.http.client.cache包，在下文中一共展示了HttpCacheContext类的8个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: setUp

import org.apache.http.client.cache.HttpCacheContext; //导入依赖的package包/类
@Before
public void setUp() {
    host = new HttpHost("foo.example.com", 80);

    route = new HttpRoute(host);

    body = HttpTestUtils.makeBody(entityLength);

    request = HttpRequestWrapper.wrap(new BasicHttpRequest("GET", "/foo", HttpVersion.HTTP_1_1));

    context = HttpCacheContext.create();
    context.setTargetHost(host);

    originResponse = Proxies.enhanceResponse(HttpTestUtils.make200Response());

    config = CacheConfig.custom()
        .setMaxCacheEntries(MAX_ENTRIES)
        .setMaxObjectSize(MAX_BYTES)
        .build();

    cache = new BasicHttpCache(config);
    mockBackend = EasyMock.createNiceMock(ClientExecChain.class);
    mockCache = EasyMock.createNiceMock(HttpCache.class);
    impl = createCachingExecChain(mockBackend, cache, config);
}

开发者ID:MyPureCloud，项目名称:purecloud-iot，代码行数:26，代码来源:AbstractProtocolTest.java

示例2: loadFeed

import org.apache.http.client.cache.HttpCacheContext; //导入依赖的package包/类
private EventStreamFeed loadFeed(final String url) throws IOException {
   try {
      final HttpGet httpget = new HttpGet(url + "?embed=rich");
      httpget.addHeader(ACCEPT_HEADER, ACCEPT_EVENTSTORE_ATOM_JSON);
      // httpget.addHeader("ES-LongPoll", "5");

      final HttpCacheContext context = HttpCacheContext.create();
      final CloseableHttpResponse response = httpclient.execute(httpget, context);
      try {
         if (context.getCacheResponseStatus() != null) {
            HttpCacheLoggingUtil.logCacheResponseStatus(name, context.getCacheResponseStatus());
         }

         final int statusCode = response.getStatusLine()
               .getStatusCode();
         if (HttpStatus.SC_NOT_FOUND == statusCode || HttpStatus.SC_NO_CONTENT == statusCode) {
            throw new EventStreamNotFoundException();
         }
         if (!(HttpStatus.SC_OK == statusCode)) {
            throw new RuntimeException("Could not load stream feed from url: " + url);
         }
         final EventStreamFeed result = gson.fromJson(new BufferedReader(new InputStreamReader(response.getEntity()
               .getContent())), EventStreamFeed.class);
         EntityUtils.consume(response.getEntity());
         return result;
      } finally {
         response.close();
      }
   } finally {
      httpclient.close();
   }
}

开发者ID:Qyotta，项目名称:axon-eventstore，代码行数:33，代码来源:EsReaderDefaultImpl.java

示例3: loadEvent

import org.apache.http.client.cache.HttpCacheContext; //导入依赖的package包/类
private EventResponse loadEvent(final String url) throws IOException {
   try {
      final HttpGet httpget = new HttpGet(url);
      httpget.addHeader(ACCEPT_HEADER, ACCEPT_EVENTSTORE_ATOM_JSON);

      LOGGER.info("Executing request " + httpget.getRequestLine());
      final HttpCacheContext context = HttpCacheContext.create();
      final CloseableHttpResponse response = httpclient.execute(httpget, context);
      try {
         if (context.getCacheResponseStatus() != null) {
            HttpCacheLoggingUtil.logCacheResponseStatus(name, context.getCacheResponseStatus());
         }

         final int statusCode = response.getStatusLine()
               .getStatusCode();
         if (HttpStatus.SC_GONE == statusCode) {
            throw new EventDeletedException();
         }
         if (!(HttpStatus.SC_OK == statusCode)) {
            throw new RuntimeException("Could not load stream feed from url: " + url);
         }
         final String read = read(response.getEntity()
               .getContent());
         final EventResponse result = gson.fromJson(read, EventResponse.class);
         EntityUtils.consume(response.getEntity());
         return result;
      } finally {
         response.close();
      }
   } finally {
      httpclient.close();
   }
}

开发者ID:Qyotta，项目名称:axon-eventstore，代码行数:34，代码来源:EsReaderDefaultImpl.java

示例4: setUp

import org.apache.http.client.cache.HttpCacheContext; //导入依赖的package包/类
@SuppressWarnings("unchecked")
@Before
public void setUp() {
    mockRequestPolicy = createNiceMock(CacheableRequestPolicy.class);
    mockValidityPolicy = createNiceMock(CacheValidityPolicy.class);
    mockBackend = createNiceMock(ClientExecChain.class);
    mockCache = createNiceMock(HttpCache.class);
    mockSuitabilityChecker = createNiceMock(CachedResponseSuitabilityChecker.class);
    mockResponsePolicy = createNiceMock(ResponseCachingPolicy.class);
    mockHandler = createNiceMock(ResponseHandler.class);
    mockUriRequest = createNiceMock(HttpUriRequest.class);
    mockCacheEntry = createNiceMock(HttpCacheEntry.class);
    mockResponseGenerator = createNiceMock(CachedHttpResponseGenerator.class);
    mockCachedResponse = createNiceMock(CloseableHttpResponse.class);
    mockConditionalRequestBuilder = createNiceMock(ConditionalRequestBuilder.class);
    mockConditionalRequest = createNiceMock(HttpRequest.class);
    mockStatusLine = createNiceMock(StatusLine.class);
    mockResponseProtocolCompliance = createNiceMock(ResponseProtocolCompliance.class);
    mockRequestProtocolCompliance = createNiceMock(RequestProtocolCompliance.class);
    mockStorage = createNiceMock(HttpCacheStorage.class);
    config = CacheConfig.DEFAULT;
    asyncValidator = new AsynchronousValidator(config);

    host = new HttpHost("foo.example.com", 80);
    route = new HttpRoute(host);
    request = HttpRequestWrapper.wrap(new BasicHttpRequest("GET", "/stuff",
        HttpVersion.HTTP_1_1));
    context = HttpCacheContext.create();
    context.setTargetHost(host);
    entry = HttpTestUtils.makeCacheEntry();
    impl = createCachingExecChain(mockBackend, mockCache, mockValidityPolicy,
        mockResponsePolicy, mockResponseGenerator, mockRequestPolicy, mockSuitabilityChecker,
        mockConditionalRequestBuilder, mockResponseProtocolCompliance,
        mockRequestProtocolCompliance, config, asyncValidator);
}

开发者ID:MyPureCloud，项目名称:purecloud-iot，代码行数:36，代码来源:TestCachingExecChain.java

示例5: setUp

import org.apache.http.client.cache.HttpCacheContext; //导入依赖的package包/类
@Before
public void setUp() {
    host = new HttpHost("foo.example.com", 80);

    route = new HttpRoute(host);

    body = makeBody(entityLength);

    request = new BasicHttpRequest("GET", "/foo", HTTP_1_1);

    context = HttpCacheContext.create();
    context.setTargetHost(host);

    originResponse = Proxies.enhanceResponse(make200Response());

    final CacheConfig config = CacheConfig.custom()
            .setMaxCacheEntries(MAX_ENTRIES)
            .setMaxObjectSize(MAX_BYTES)
            .build();

    final HttpCache cache = new BasicHttpCache(config);
    mockBackend = EasyMock.createNiceMock(ClientExecChain.class);
    mockEntity = EasyMock.createNiceMock(HttpEntity.class);
    mockCache = EasyMock.createNiceMock(HttpCache.class);

    impl = createCachingExecChain(mockBackend, cache, config);
}

开发者ID:MyPureCloud，项目名称:purecloud-iot，代码行数:28，代码来源:TestProtocolDeviations.java

示例6: execute

import org.apache.http.client.cache.HttpCacheContext; //导入依赖的package包/类
private HttpResponse execute(HttpRequestBase method) throws
        IOException {
  HttpCacheContext context = HttpCacheContext.create();
  HttpResponse response = httpClient.execute(method, context);

  try {
    CacheResponseStatus responseStatus = context.getCacheResponseStatus();
    switch (responseStatus) {
      case CACHE_HIT:
        SpotifyApi.LOGGER.log(
                Level.CONFIG,
                "A response was generated from the cache with no requests sent upstream");
        break;
      case CACHE_MODULE_RESPONSE:
        SpotifyApi.LOGGER.log(
                Level.CONFIG,
                "The response was generated directly by the caching module");
        break;
      case CACHE_MISS:
        SpotifyApi.LOGGER.log(
                Level.CONFIG,
                "The response came from an upstream server");
        break;
      case VALIDATED:
        SpotifyApi.LOGGER.log(
                Level.CONFIG,
                "The response was generated from the cache after validating the entry with the origin server");
        break;
    }
  } catch (Exception e) {
    SpotifyApi.LOGGER.log(Level.SEVERE, e.getMessage());
  }

  return response;
}

开发者ID:thelinmichael，项目名称:spotify-web-api-java，代码行数:36，代码来源:SpotifyHttpManager.java

示例7: setResponseStatus

import org.apache.http.client.cache.HttpCacheContext; //导入依赖的package包/类
private void setResponseStatus(final HttpContext context, final CacheResponseStatus value) {
    if (context != null) {
        context.setAttribute(HttpCacheContext.CACHE_RESPONSE_STATUS, value);
    }
}

开发者ID:MyPureCloud，项目名称:purecloud-iot，代码行数:6，代码来源:CachingExec.java

示例8: fetchJsonRpc

import org.apache.http.client.cache.HttpCacheContext; //导入依赖的package包/类
protected FetchData fetchJsonRpc(String uri, ScrapeTemplate template, Map<String, Object> actualParams) throws IOException, ExecutionException, RetryException {
    final FetchData fetchData = new FetchData();
    fetchData.setUri(uri);
    fetchData.setProtocol(template.getProtocol());
    fetchData.setProtocolVersion(template.getProtocolVersion());
    fetchData.getRequestParams().putAll(actualParams);

    final HttpCacheContext context = HttpCacheContext.create();
    final HttpPost postReq = new HttpPost(uri);
    final JsonRpc2MethodCall methodCall = new JsonRpc2MethodCall();
    methodCall.setMethod(template.getRpcMethod());
    methodCall.getParams().putAll(actualParams);
    postReq.setEntity(
            new StringEntity(JsonUtils.mapper.writeValueAsString(methodCall), ContentType.APPLICATION_JSON)
    );

    final Retryer<JsonRpc2MethodResult> retryer = RetryerBuilder.<JsonRpc2MethodResult>newBuilder()
            .retryIfExceptionOfType(HttpStatusNotOkException.class)
            .retryIfExceptionOfType(SocketException.class)
            .withStopStrategy(StopStrategies.stopAfterAttempt(10))
            .withWaitStrategy(WaitStrategies.fixedWait(30, TimeUnit.SECONDS))
            .build();

    fetchData.setJsonRpcResult(retryer.call(() -> {
        log.info("Trying fetch {} {} {} {} {} ...",
                template.getProtocol(), template.getProtocolVersion(), uri, template.getRpcMethod(), actualParams);
        try (CloseableHttpResponse resp = httpClient.execute(postReq, context)) {
            log.info("Received {} {} {} bytes {}", context.getCacheResponseStatus(),
                    resp.getEntity().getContentType(), resp.getEntity().getContentLength(),
                    resp.getFirstHeader("Content-Encoding"));
            final String entityBody = IOUtils.toString(resp.getEntity().getContent(), StandardCharsets.UTF_8);
            if (resp.getStatusLine().getStatusCode() < 200 || resp.getStatusLine().getStatusCode() >= 300) {
                log.warn("{} {} {} {} {} HTTP Error {} {}: {}",
                        template.getProtocol(), template.getProtocolVersion(), uri, template.getRpcMethod(), actualParams,
                        resp.getStatusLine().getStatusCode(),
                        resp.getStatusLine().getReasonPhrase(), entityBody);
                throw new HttpStatusNotOkException(String.format("%s %s %s %s %s HTTP Error %s %s: %s",
                        template.getProtocol(), template.getProtocolVersion(), uri, template.getRpcMethod(), actualParams,
                        resp.getStatusLine().getStatusCode(),
                        resp.getStatusLine().getReasonPhrase(), entityBody));
            }
            try {
                final JsonRpc2MethodResult methodResult = JsonUtils.mapper.readValue(entityBody, JsonRpc2MethodResult.class);
                log.trace("JSON-RPC Method result: {}", methodResult);
                if (methodResult.getError() != null) {
                    throw new ScrapeException(methodResult.getError(), "Error fetching %s: %s", uri, methodResult.getError());
                }
                return methodResult;
            } catch (Exception e) {
                log.error(String.format("Error converting %s %s %s %s %s to JSON: %s",
                        template.getProtocol(), template.getProtocolVersion(), uri, template.getRpcMethod(), actualParams,
                        entityBody), e);
                throw new ScrapeException(e, "Error converting %s %s %s %s %s to JSON (see previous log)",
                        template.getProtocol(), template.getProtocolVersion(), uri, template.getRpcMethod(), actualParams);
            }
        }
    }));

    return fetchData;
}

开发者ID:soluvas，项目名称:soluvas-scrape，代码行数:61，代码来源:Fetcher.java

注：本文中的org.apache.http.client.cache.HttpCacheContext类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java EntityHeartFX类代码示例发布时间：2022-05-22

Java ReducedMetric类代码示例发布时间：2022-05-22

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：18277|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9678|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8179|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8549|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8457|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9393|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8431|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7865|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8416|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7394|2022-11-06

客服电话

电子邮件

Java HttpCacheContext类代码示例

示例1: setUp

示例2: loadFeed

示例3: loadEvent

示例4: setUp

示例5: setUp

示例6: execute

示例7: setResponseStatus

示例8: fetchJsonRpc

请发表评论

全部评论

上一篇：

下一篇：

librespeed/speedtest: Self-hosted Speedt

avehtari/BDA_m_demos: Bayesian Data Anal

四维彩超怎么看性别？四维看男孩女孩诀窍

微信小程序--微信小程序tabBar不显示：缺少

medfreeman/markdown-it-toc-and-anchor: m

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053