资讯专栏INFORMATION COLUMN

上云采购季！| 2核2G4M爆款云服务器低至59元/年，更有多台、长期优惠，快来选购！

立即前往
首页/文章专栏/重拾Java Network Programming（四）URLConnection & C

重拾Java Network Programming（四）URLConnection & C

魏明 / 1807人阅读

摘要：从而一方面减少了响应时间，另一方面减少了服务器的压力。表明响应只能被单个用户缓存，不能作为共享缓存即代理服务器不能缓存它。这种情况称为服务器再验证。否则会返回响应。

前言

本文将根据最近所学的Java网络编程实现一个简单的基于URL的缓存。本文将涉及如下内容：

HTTP协议

HTTP协议中与缓存相关的内容

URLConnection 和 HTTPURLConnection

ResponseCache，CacheRequest，CacheResponse

WHAT & WHY

正常来说，服务器和客户端的HTTP通信需要首先通过TCP的三次握手建立连接，然后客户端再发出HTTP请求并接收服务器的响应。但是，在有些时候，服务器的资源并没有发生改变。此时重复的向服务器请求同样的资源会带来带宽的浪费。针对这种情况我们可以采用缓存的方式，既可以是本地缓存，也可以是代理服务器的缓存，来减少对服务器资源的不必要的访问。从而一方面减少了响应时间，另一方面减少了服务器的压力。

那么我们如何知道，何时可以直接使用缓存，何时因为当前的缓存已经过时，需要重新向资源所在的服务器发出请求呢？

缓存关键字

HTTP1.0和HTTP1.1分别针对缓存提供了一些HEADER属性供连接双方参考。需要注意，如果是HTTP1.0的服务器，将无法识别HTTP1.1的缓存属性。所以有时候为了向下兼容性，我们会设置多个和缓存相关的属性。当然，它们彼此之间是存在优先级的，后面将会详细介绍。

Expires

支持HTTP1.0，说明该资源在Expires内容之后过期。Expires关键字使用的是绝对日期。

Cache-control

支持HTTP1.1，使用相对日期对缓存进行管理。它可定义的属性包括：
max-age=[seconds]: 当前时间经过n秒后缓存资源失效
s-maxage=[seconds]: 从共享缓存获取的数据在n秒后失效，私有缓存往往可以更久一些
public: 表明响应可以被任何对象（包括：发送请求的客户端，代理服务器，等等）缓存。
private: 表明响应只能被单个用户缓存，不能作为共享缓存（即代理服务器不能缓存它）。
no-cache: 允许缓存，但每次访问缓存时必须重新验证缓存的有效性
no-store: 缓存不应存储有关客户端请求或服务器响应的任何内容。
must-revalidate: 缓存必须在使用之前验证旧资源的状态，并且不可使用过期资源。
还有许多相关的属性，想要详细了解的话可以参考这篇文章。

If-Modified—Since/If-Unmodified-Since

仅仅是已缓存文档的过期并不意味这它和原始服务器上目前处于活跃状态的资源有实际的区别，只是意味着到了要核实的时间。这种情况称为服务器再验证。

if-modified-since:说明在date之后文档被修改了的话，就执行请求的方法，即条件式的再验证。通常和服务器的last-modified响应头部配合使用。last-modified说明该资源最后一次的修改时间。如果资源的这个属性发生变化，则说明缓存已经失效。则服务器会返回最新的资源。否则会返回304 not modified响应。

这种方式的好处在于，如果资源未失效，则无需重传资源，可以有效的节省带宽。

与之相类似的有if-unmodified-since，该属性的意思是如果资源在该日期之后被修改了，则不执行请求方法。通常在进行部分文件传输时，获取文件的其余部分之前要确保文件未发生变化，此时这个首部很有用。

If-None-Match/If-Match/If-Range

有些时候，仅仅是使用最后修改日期再验证是不够的：

有些文档可能被周期性重写，但是实际的数据常常是一样的。也就是说内容没有变化，但是修改日期变化了。

有些文档可能被修改了，但是所做的修改并不重要，不需要所有的缓存都重装数据。

有些服务器无法准确的判定最后的修改日期

有些文档会在更小的时间粒度发生变化（比如监视器，股票等），此时以秒为最小单位的修改日期可能不够用

为此，HTTP提供了实体标签（ETag）的比较。当发布者对文档进行修改时，可以修改文档的实体标签来说明新的版本。这样，只要实体标签改变，缓存就可以用If-None-Match条件首部来获取新的副本。

服务器在响应中会标记当前资源的ETag。一旦文档过期后，可以使用HEAD请求来条件式再验证。如果服务器上ETag改变，则会返回最新的资源。当然，ETag可以包含多个内容，说明本地存储了多个版本的副本。如果没有命中这些副本，再返回完整资源。

</>复制代码 
  1. If-None-Match: "v2.4","v2.5","v2.6"

如果服务器收到的请求中既带有if-modified-since，又带有实体标签条件首部，那么只有这两个条件都满足时，才会返回304 not modified响应。

Cache in JAVA

默认情况下。JAVA不缓存任何任何内容。我们需要通过自己的实现来支持URL的缓存。我们需要实现以下抽象类：

ResponseCache

CacheRequest

CacheResponse

这里其实使用的是Template Pattern。有兴趣的话可以去了解一下。

ResponseCache 需要实现的方法

</>复制代码 
  1.     //根据URI，请求的方法以及请求头获取缓存的响应。如果响应过期，则重新发出请求
  2.     public abstract CacheResponse get(URI uri, String rqstMethod, Map> rqstHeaders) throws IOException; 
  3.     //在获取到响应之后调用该方法
  4.     //如果该响应不可以被缓存，则返回null
  5.     //如果该响应可以被缓存，则返回CacheRequest对象，可以利用其下的OutputStream来写入缓存的内容
  6.     public CacheRequest put(URI uri, URLConnection conn) throws IOException;

CacheRequest需要实现的方法：

</>复制代码 
  1.     //获取写入缓存的输入流
  2.     @Override
  3.     public OutputStream getBody() throws IOException;
  4.     
  5.     //放弃当前的缓存
  6.     @Override
  7.     public void abort();

CacheResponse需要实现的方法

</>复制代码 
  1.     //获取响应头
  2.     @Override
  3.     public Map> getHeaders() throws IOException; 
  4.     //获取响应体的输入流，即从InputStream中即可读取缓存的内容
  5.     @Override
  6.     public InputStream getBody() throws IOException;

这里的流程基本如下：
当启动URLConnection连接时，URLConnection会先访问ResponseCache的get方法，询问缓存是否命中想要的数据。输入的参数包括URI，请求方法（通常指缓存GET请求），以及请求头（如果请求头中明确要求不访问缓存，则直接返回null）。如果命中，则返回CacheResponse对象，从该对象中获取缓存的输入流。 如果没有命中，则会启动连接，并将获取的数据使用ResponseCache的put方法写入缓存。该方法会返回一个输出流用于存储缓存。

Cache Implementation In JAVA

现在我需要实现缓存，我将会在put时判断该资源是否允许缓存（通常有cache-control参数来提供）。我也会在get时判读能否从缓存中命中资源以及该资源是否失效，如果失效就从缓存中删除，否则直接返回，无需访问服务器。这里我还通过一个后台线程遍历缓存数据结构，及时将失效的资源从缓存中删除。

MyCacheRequest使用ByteArrayOutputStream将缓存内容通过内存IO存储在内存中

</>复制代码 
  1. import java.io.ByteArrayOutputStream;
  2. import java.io.IOException;
  3. import java.io.OutputStream;
  4. import java.net.CacheRequest;
  5. public class MyCacheRequest extends CacheRequest{
  6.     private ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
  7.     public MyCacheRequest(){
  8.     }
  9.     @Override
  10.     public OutputStream getBody() throws IOException {
  11.         return outputStream;
  12.     }
  13.     @Override
  14.     public void abort() {
  15.         outputStream.reset();
  16.     }
  17.     public byte[] getData(){
  18.         if (outputStream.size() == 0) return null; else return outputStream.toByteArray();
  19.     }
  20. }

MyCacheResponse存储了请求头，并将cache-control的信息封装在了CacheControl类中：

</>复制代码 
  1. import java.io.ByteArrayInputStream;
  2. import java.io.IOException;
  3. import java.io.InputStream;
  4. import java.net.CacheResponse;
  5. import java.net.URLConnection;
  6. import java.util.Date;
  7. import java.util.List;
  8. import java.util.Map;
  9. public class MyCacheResponse extends CacheResponse {
  10.     private final MyCacheRequest cacheRequest;
  11.     private final Map> headers;
  12.     private final Date expires;
  13.     private final CacheControl control;
  14.     public MyCacheResponse(MyCacheRequest cacheRequest, URLConnection uc, CacheControl control){
  15.         this.cacheRequest = cacheRequest;
  16.         this.headers = uc.getHeaderFields();
  17.         this.expires = new Date(uc.getExpiration());
  18.         this.control = control;
  19.     }
  20.     @Override
  21.     public Map> getHeaders() throws IOException {
  22.         return this.headers;
  23.     }
  24.     @Override
  25.     public InputStream getBody() throws IOException {
  26.         return new ByteArrayInputStream(cacheRequest.getData());
  27.     }
  28.     public boolean isExpired() {
  29.         Date now = new Date();
  30.         if (control.getMaxAge() !=null && control.getMaxAge().before(now)) return true;
  31.         else if (expires != null) {
  32.             return expires.before(now);
  33.         } else {
  34.             return false;
  35.         }
  36.     }
  37.     public CacheControl getControl() {
  38.         return control;
  39.     }
  40. }

CacheControl类如下这里只用到了基本的max-age属性和no-store属性

</>复制代码 
  1. import java.util.Date;
  2. import java.util.Locale;
  3. /**
  4.  * 封装HTTP协议中cache—control对应的属性
  5.  */
  6. public class CacheControl {
  7.     private Date maxAge;
  8.     private Date sMaxAge;
  9.     private boolean mustRevalidate;
  10.     private boolean noCache;
  11.     private boolean noStore;
  12.     private boolean proxyRevalidate;
  13.     private boolean publicCache;
  14.     private boolean privateCache;
  15.     private static final String MAX_AGE = "max-age=";
  16.     private static final String SMAX_AGE = "s-maxage=";
  17.     private static final String MUST_REVALIDATE = "must-revalidate";
  18.     private static final String PROXY_REVALIDATE = "proxy-revalidate";
  19.     private static final String NO_CACHE = "no-cache";
  20.     private static final String NO_STORE = "no-store";
  21.     private static final String PUBLIC_CACHE = "public";
  22.     private static final String PRIVATE_CACHE = "private";
  23.     public CacheControl(String s){
  24.         if (s == null || s.trim().isEmpty()) {
  25.             return; // default policy
  26.         }
  27.         String[] components = s.split(",");
  28.         Date now = new Date();
  29.         for (String component : components){
  30.             try {
  31.                 component = component.trim().toLowerCase(Locale.US);
  32.                 if (component.startsWith(MAX_AGE)){
  33.                     int secondsInTheFuture = Integer.parseInt(component.substring(MAX_AGE.length()));
  34.                     maxAge = new Date(now.getTime() + 1000 * secondsInTheFuture);
  35.                 }else if (component.startsWith(SMAX_AGE)){
  36.                     int secondsInTheFuture = Integer.parseInt(component.substring(SMAX_AGE.length()));
  37.                     sMaxAge = new Date(now.getTime() + 1000 * secondsInTheFuture);
  38.                 }else if (component.equals(MUST_REVALIDATE)){
  39.                     mustRevalidate = true;
  40.                 }else if (component.equals(PROXY_REVALIDATE)){
  41.                     proxyRevalidate = true;
  42.                 }else if (component.equals(NO_CACHE)){
  43.                     noCache = true;
  44.                 }else if (component.equals(NO_STORE)){
  45.                     noStore = true;
  46.                 }else if (component.equals(PUBLIC_CACHE)){
  47.                     publicCache = true;
  48.                 }else if (component.equals(PRIVATE_CACHE)){
  49.                     privateCache = true;
  50.                 }
  51.             }catch (RuntimeException ex) {
  52.                 continue; }
  53.         }
  54.     }
  55.     public Date getMaxAge() {
  56.         return maxAge;
  57.     }
  58.     public Date getsMaxAge() {
  59.         return sMaxAge;
  60.     }
  61.     public boolean isMustRevalidate() {
  62.         return mustRevalidate;
  63.     }
  64.     public boolean isNoCache() {
  65.         return noCache;
  66.     }
  67.     public boolean isNoStore() {
  68.         return noStore;
  69.     }
  70.     public boolean isProxyRevalidate() {
  71.         return proxyRevalidate;
  72.     }
  73.     public boolean isPublicCache() {
  74.         return publicCache;
  75.     }
  76.     public boolean isPrivateCache() {
  77.         return privateCache;
  78.     }
  79. }

ResponseCache类使用ConcurrentHashMap进行缓存的同步读写。这里默认缓存达到上限就不再存入新的缓存。建议可以通过队列或是LinkedHashMap实现FIFO或是LRU管理。

</>复制代码 
  1. import java.io.IOException;
  2. import java.net.*;
  3. import java.util.List;
  4. import java.util.Map;
  5. public class MyResponseCache extends ResponseCache{
  6.     private final Map responses;
  7.     private final int SIZE;
  8.     public MyResponseCache(Map responses, int size){
  9.         this.responses = responses;
  10.         this.SIZE = size;
  11.     }
  12.     /**
  13.      *
  14.      * @param uri 路径 - equals方法将不会调用DNS服务
  15.      * @param rqstMethod - 请求方法 一般只缓存GET方法
  16.      * @param rqstHeaders - 判断是否可以缓存
  17.      * @return
  18.      * @throws IOException
  19.      */
  20.     @Override
  21.     public CacheResponse get(URI uri, String rqstMethod, Map> rqstHeaders) throws IOException {
  22.         if ("GET".equals(rqstMethod)) {
  23.             MyCacheResponse response = responses.get(uri); // check expiration date
  24.             if (response != null && response.isExpired()) {
  25.                 responses.remove(uri);
  26.                 response = null;
  27.             }
  28.             return response;
  29.         }
  30.         return null;
  31.     }
  32.     @Override
  33.     public CacheRequest put(URI uri, URLConnection conn) throws IOException {
  34.         if (responses.size() >= SIZE) return null;
  35.         CacheControl cacheControl = new CacheControl(conn.getHeaderField("Cache-Control"));
  36.         if (cacheControl.isNoStore()){
  37.             System.out.println(conn.getHeaderField(0));
  38.             return null;
  39.         }
  40.         MyCacheRequest myCacheRequest = new MyCacheRequest();
  41.         MyCacheResponse myCacheResponse = new MyCacheResponse(myCacheRequest, conn ,cacheControl);
  42.         responses.put(uri, myCacheResponse);
  43.         return myCacheRequest;
  44.     }
  45. }

CacheValidator后台任务，将失效的缓存删除：

</>复制代码 
  1. import java.net.URI;
  2. import java.util.Map;
  3. import java.util.concurrent.ConcurrentHashMap;
  4. public class CacheValidator implements Runnable{
  5.     boolean stop;
  6.     private ConcurrentHashMap map;
  7.     public CacheValidator(ConcurrentHashMap map){
  8.         this.map = map;
  9.     }
  10.     @Override
  11.     public void run() {
  12.         while (!stop){
  13.             for (Map.Entry entry : map.entrySet()){
  14.                 if (entry.getValue().isExpired()){
  15.                     System.out.println(entry.getKey());
  16.                     map.remove(entry.getKey());
  17.                 }
  18.             }
  19.         }
  20.     }
  21. }

最后使用主线程启动缓存，注意这里需要显式的设置缓存器和开启URLConnection的缓存。默认情况下，JAVA不开启缓存。同时JAVA全局只支持一个缓存的存在。

</>复制代码 
  1. import java.io.BufferedInputStream;
  2. import java.io.IOException;
  3. import java.net.*;
  4. import java.util.concurrent.ConcurrentHashMap;
  5. import java.util.concurrent.TimeUnit;
  6. public class Main {
  7.     public static void main(String[] args) throws InterruptedException {
  8.         ConcurrentHashMap map = new ConcurrentHashMap<>();
  9.         MyResponseCache myResponseCache = new MyResponseCache(map, 20);
  10.         //设置默认缓存器
  11.         ResponseCache.setDefault(myResponseCache);
  12.         //设置后台线程
  13.         Thread thread = new Thread(new CacheValidator(map));
  14.         thread.setDaemon(true);
  15.         thread.start();
  16.         System.out.println(map.size());
  17.         fetchURL(SOME_URL);
  18.         TimeUnit.SECONDS.sleep(20000);
  19.     }
  20.     public static void fetchURL(String location){
  21.         try {
  22.             URL url = new URL(location);
  23.             URLConnection uc = url.openConnection();
  24.             //开启缓存
  25.             uc.setDefaultUseCaches(true);
  26.             BufferedInputStream bfr = new BufferedInputStream(uc.getInputStream());
  27.             int c;
  28.             while ((c = bfr.read()) != -1){
  29. //                System.out.print((char) c);
  30.                 //do something
  31.             }
  32.         } catch (MalformedURLException e) {
  33.             e.printStackTrace();
  34.         } catch (IOException e) {
  35.             e.printStackTrace();
  36.         }
  37.     }
  38. }


想要了解更多开发技术，面试教程以及互联网公司内推，欢迎关注我的微信公众号！将会不定期的发放福利哦~

参考书籍 
</>复制代码 
  1. HTTP 权威指南
    Java Network Programming
云服务器 GPU云服务器 java&lt c&gt 重拾 URLConnection? URLConnection

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/61957.html

相关文章

  • 重拾Java Network Programming（四）URLConnection &amp; C

    摘要：从而一方面减少了响应时间，另一方面减少了服务器的压力。表明响应只能被单个用户缓存，不能作为共享缓存即代理服务器不能缓存它。这种情况称为服务器再验证。否则会返回响应。 前言 本文将根据最近所学的Java网络编程实现一个简单的基于URL的缓存。本文将涉及如下内容： HTTP协议 HTTP协议中与缓存相关的内容 URLConnection 和 HTTPURLConnection Respo...

    Guakin_Huang 评论0 收藏0

  • 重拾Java Network Programming（一）IO流

    摘要：不同类型的流入，往往对应于不同类型的流数据。所以通常会将字节缓存到一定数量后再发送。如果是，则将两个标记都抛弃并且将之前的内容作为一行返回。因此二者陷入死锁。因此推出了和类。 前言 最近在重拾Java网络编程，想要了解一些JAVA语言基本的实现，这里记录一下学习的过程。 阅读之前，你需要知道 网络节点(node)：位于网络上的互相连通的设备，通常为计算机，也可以是打印机，网桥，路由器等...

    Lycheeee 评论0 收藏0

  • 重拾Java Network Programming（二）InetAddress

    摘要：前言今天，我将梳理在网络编程中很重要的一个类以及其相关的类。这类主机通常不需要外部互联网服务，仅有主机间相互通讯的需求。可以通过该接口获取所有本地地址，并根据这些地址创建。在这里我们使用阻塞队列实现主线程和打印线程之间的通信。 前言 今天，我将梳理在Java网络编程中很重要的一个类InetAddress以及其相关的类NetworkInterface。在这篇文章中将会涉及： InetA...

    daryl 评论0 收藏0

  • Glide的源码分析(二) 2.2

    摘要：从网络加载图片加载从加载从网络加载从加载具体的方法实现接口的类以后再做分析，而从网络加载两步从网络获取数据处理数据。 4.从网络加载 EngineJob current = jobs.get(key); if (current != null) { current.addCallback(cb); if (...

    warkiz 评论0 收藏0

发表评论

登陆后可评论

0条评论

魏明

男|高级讲师
我要私信

TA的文章

阅读更多
最新活动
阅读需要支付1元查看
<