Java Socket编程 - 基于Socket实现HTTP下载客户端

本文涉及的产品
云解析 DNS,旗舰版 1个月
云解析DNS,个人版 1个月
公共DNS(含HTTPDNS解析),每月1000万次HTTP解析
简介: Java Socket编程 - 基于Socket实现HTTP下载客户端

没有借助任何第三方库,完全基于JAVA Socket实现一个最小化的HTTP文件下载客


户端。完整的演示如何通过Socket实现下载文件的HTTP请求(request header)发送


如何从Socket中接受HTTP响应(Response header, Response body)报文并解析与


保存文件内容。如何通过SwingWork实现UI刷新,实时显示下载进度。


首先看一下UI部分:


1354957740_6179.png

【添加下载】按钮:


点击弹出URL输入框,用户Copy要下载文件URL到输入框以后,点击[OK]按钮即开始


下载


1354957768_8405.png

【清除完成】按钮:


清除所有已经下载完成的文件列表


文件下载状态分为以下几种:

文件下载状态分为以下几种:

package com.gloomyfish.socket.tutorial.http.download;
 
public enum DownLoadStatus {
  NOT_STARTED,
  IN_PROCESS,
  COMPLETED,
  ERROR
}


UI部分主要是利用Swing组件完成。点击【添加下载】执行的代码如下:

final JDialog dialog = new JDialog(this,"Add File Link",true);
dialog.getContentPane().setLayout(new BorderLayout());
// dialog.setSize(new Dimension(400,200));
final URLFilePanel panel = new URLFilePanel();
panel.setUpListener(new ActionListener(){
  @Override
  public void actionPerformed(ActionEvent e) {
    if("OK".equals(e.getActionCommand())){
      if(panel.validateInput()) {
        DownloadDetailStatusInfoModel data = new DownloadDetailStatusInfoModel(panel.getValidFileURL());
        tableModel.getData().add(data);
        startDownlaod();
        refreshUI();
      }
      dialog.setVisible(false);
      dialog.dispose();
    } else if("Cancel".equals(e.getActionCommand())) {
      dialog.setVisible(false);
      dialog.dispose();
    }
  }});
 
dialog.getContentPane().add(panel, BorderLayout.CENTER);
dialog.pack();
centre(dialog);
dialog.setVisible(true);


【清除完成】按钮执行的代码如下:

private void clearDownloaded() {
  List<DownloadDetailStatusInfoModel> downloadedList = new ArrayList<DownloadDetailStatusInfoModel>();
  for(DownloadDetailStatusInfoModel fileStatus : tableModel.getData()) {
    if(fileStatus.getStatus().toString().equals(DownLoadStatus.COMPLETED.toString())) {
      downloadedList.add(fileStatus);
    }
  }
  tableModel.getData().removeAll(downloadedList);
  refreshUI();
}


让JFrame组件居中显示的代码如下:

  public static void centre(Window w) {
    Dimension us = w.getSize();
    Dimension them = Toolkit.getDefaultToolkit().getScreenSize();
    int newX = (them.width - us.width) / 2;
    int newY = (them.height - us.height) / 2;
    w.setLocation(newX, newY);
  }

HTTP协议实现部分:

概述:HTTP请求头与相应头报文基本结构与解释

HTTP请求:一个标准的HTTP请求报文如

1354959957_1059.png

其中请求头可以有多个,message-body可以没有,不是必须的。请求行的格式如下:


Request-Line = Method SP Request-URI SPHTTP-Version CRLF 举例说明如下:


Request-Line = GET http://www.w3.org/pub/WWW/TheProject.htmlHTTP/1.1\r\n


其中SP表示空格, CRLF表示回车换行符\r\n


当你想要上传文件时候,使用Post方式来填写数据到message-body中即可。发送一个


简单的HTTP请求报文如下:


GET /pub/WWW/TheProject.html HTTP/1.1\r\n


Host: www.w3.org\r\n

HTTP响应:一个标准的HTTP响应报文如下

1354960020_3451.png

最先得到是状态行,其格式如下:


Status-Line = HTTP-Version SP Status-CodeSP Reason-Phrase CRLF, 一个状态行的


简单例子如下:Status-Line = HTTP/1.1 200 OK一般大家最喜欢的就是Status-Code会


给你很多提示,最常见的就是404,500等状态码。状态码的意思可以参考RFC2616中


的解释。下载文件最要紧是的检查HTTP响应头中的Content-Length与Content-Type两


个中分别声明了文件的长度与文件的类型。其它如Accept-Ranges表示接受多少到多少


的字节。可能在多线程下载中使用。搞清楚了HTTP请求与响应的报文格式以后,我们


就可以通过Socket按照报文格式解析内容,发送与读取HTTP请求与响应。具体步骤


如下:

一:根据用户输入的文件URL建立Socket连接

1.URL url = new URL(fileInfo.getFileURL());
String host = url.getHost();
int port = (url.getPort() == -1)  ? url.getDefaultPort():url.getPort();
System.out.println("Host Name = " + host);
System.out.println("port = " + port);
System.out.println("File URI = " + url.getFile());
 
// create socket and start to construct the request line
Socket socket = new Socket();
SocketAddress address = new InetSocketAddress(host, port);
socket.connect(address);


用了URL类来把用户输入的url string变成容易解析一点的URL。

二:构造HTTP请求

BufferedWriter bufferedWriter = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream(), "UTF8"));
String requestStr = "GET " + url.getFile() + " HTTP/1.1\r\n"; // request line
 
// construct the request header - 构造HTTP请求头(request header)
String hostHeader = "Host: " + host + "\r\n";
String acceptHeader = "Accept: text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8\r\n";
String charsetHeader = "Accept-Charset: GBK,utf-8;q=0.7,*;q=0.3\r\n";
String languageHeader = "Accept-Language: zh-CN,zh;q=0.8\r\n";
String keepHeader = "Connection: close\r\n";

三:发送HTTP请求

// 发送HTTP请求
bufferedWriter.write(requestStr);
bufferedWriter.write(hostHeader);
bufferedWriter.write(acceptHeader);
bufferedWriter.write(charsetHeader);
bufferedWriter.write(languageHeader);
bufferedWriter.write(keepHeader);
bufferedWriter.write("\r\n"); // 请求头信息发送结束标志
bufferedWriter.flush();

四:接受HTTP响应并解析内容,写入创建好的文件

// 准备接受HTTP响应头并解析
CustomDataInputStream input = new CustomDataInputStream(socket.getInputStream());
File myFile = new File(fileInfo.getStoreLocation() + File.separator + fileInfo.getFileName());
String content = null;
HttpResponseHeaderParser responseHeader = new HttpResponseHeaderParser();
BufferedOutputStream output = new BufferedOutputStream(new FileOutputStream(myFile));
boolean hasData = false;
while((content = input.readHttpResponseHeaderLine()) != null) {
  System.out.println("response header contect -->> " + content);
  responseHeader.addResponseHeaderLine(content);
  if(content.length() == 0) {
    hasData = true;
  }
  if(hasData) {
    int totalBytes = responseHeader.getFileLength();
    if(totalBytes == 0) break; // no response body and data
    int offset = 0;
    byte[] myData = null;
    if(totalBytes >= 2048) {
      myData = new byte[2048];
    } else {
      myData = new byte[totalBytes];
    }
    int numOfBytes = 0;
    while((numOfBytes = input.read(myData, 0, myData.length)) > 0 && offset < totalBytes) {
      offset += numOfBytes;
      float p = ((float)offset) / ((float)totalBytes) * 100.0f;
      if(offset > totalBytes) {
        numOfBytes = numOfBytes + totalBytes - offset;
        p = 100.0f;
      }
      output.write(myData, 0, numOfBytes);
      updateStatus(p);
    }
    hasData = false;
    break;
  }
}

简单的HTTP响应头解析类HttpResponseHeaderParser代码如下:

package com.gloomyfish.socket.tutorial.http.download;
 
import java.util.HashMap;
import java.util.Map;
 
/**
 * it can parse entity header, response head
 * and response line <status code, CharSet, ect...>
 * refer to RFC2616,关于HTTP响应头,请看RFC文档,描写的很详细啊!!
 * 
 * @author fish
 *
 */
public class HttpResponseHeaderParser {
  public final static String CONTENT_LENGTH = "Content-Length";
  public final static String CONTENT_TYPE = "Content-Type";
  public final static String ACCEPT_RANGES = "Accetp-Ranges";
  
  private Map<String, String> headerMap;
  public HttpResponseHeaderParser() {
    headerMap = new HashMap<String, String>();
  }
  /**
   * <p> get the response header key value pair </p>
   * @param responseHeaderLine
   */
  public void addResponseHeaderLine(String responseHeaderLine) {
    if(responseHeaderLine.contains(":")) {
      String[] keyValue = responseHeaderLine.split(": ");
      if(keyValue[0].equalsIgnoreCase(CONTENT_LENGTH)) {
        headerMap.put(CONTENT_LENGTH, keyValue[1]);
      } else if(keyValue[0].equalsIgnoreCase(CONTENT_TYPE)) {
        headerMap.put(CONTENT_TYPE, keyValue[1]);
      } else {
        headerMap.put(keyValue[0], keyValue[1]);
      }
    }
  }
  
  public int getFileLength() {
    if(headerMap.get(CONTENT_LENGTH) == null){
      return 0;
    }
    return Integer.parseInt(headerMap.get(CONTENT_LENGTH));
  }
  
  public String getFileType() {
    return headerMap.get(CONTENT_TYPE);
  }
  public Map<String, String> getAllHeaders() {
    return headerMap;
  }
 
}

可执行的Jar文件下载地址(这次我要点分):

http://download.csdn.net/detail/jia20003/4862076

转载请务必注明

相关文章
|
15天前
|
Java 开发者
Java面试题:请解释内存泄漏的原因,并说明如何使用Thread类和ExecutorService实现多线程编程,请解释CountDownLatch和CyclicBarrier在并发编程中的用途和区别
Java面试题:请解释内存泄漏的原因,并说明如何使用Thread类和ExecutorService实现多线程编程,请解释CountDownLatch和CyclicBarrier在并发编程中的用途和区别
17 0
|
15天前
|
存储 缓存 监控
Java面试题:在Java中,对象何时可以被垃圾回收?编程中,如何更好地做好垃圾回收处理?
Java面试题:在Java中,对象何时可以被垃圾回收?编程中,如何更好地做好垃圾回收处理?
23 0
|
1天前
|
安全 Java 数据处理
Java并发编程:线程同步与协作的深度解析
在探索Java并发编程的海洋中,线程同步与协作的灯塔指引着航向。本文将深入挖掘线程同步机制的核心原理,揭示锁、条件变量等工具如何确保数据的一致性和线程间有序的通信。通过案例分析,我们将解码高效并发模式背后的设计哲学,并探讨现代Java并发库如何简化复杂的同步任务。跟随文章的步伐,您将获得提升多线程应用性能与可靠性的关键技能。 【7月更文挑战第24天】
13 5
|
3天前
|
监控 Java
Java并发编程:深入理解线程池
在Java并发编程领域,线程池是提升应用性能和资源管理效率的关键工具。本文将深入探讨线程池的工作原理、核心参数配置以及使用场景,通过具体案例展示如何有效利用线程池优化多线程应用的性能。
|
11天前
|
安全 Java 开发者
Java并发编程中的线程安全性与性能优化
在Java编程中,处理并发问题是至关重要的。本文探讨了Java中线程安全性的概念及其在性能优化中的重要性。通过深入分析多线程环境下的共享资源访问问题,结合常见的并发控制手段和性能优化技巧,帮助开发者更好地理解和应对Java程序中的并发挑战。 【7月更文挑战第14天】
|
11天前
|
监控 Java API
Java并发编程之线程池深度解析
【7月更文挑战第14天】在Java并发编程领域,线程池是提升性能、管理资源的关键工具。本文将深入探讨线程池的核心概念、内部工作原理以及如何有效使用线程池来处理并发任务,旨在为读者提供一套完整的线程池使用和优化策略。
|
14天前
|
存储 安全 算法
深入理解Java并发编程:线程安全与性能优化
【5月更文挑战第72天】 在现代软件开发中,尤其是Java应用开发领域,并发编程是一个无法回避的重要话题。随着多核处理器的普及,合理利用并发机制对于提高软件性能、响应速度和资源利用率具有重要意义。本文旨在探讨Java并发编程的核心概念、线程安全的策略以及性能优化技巧,帮助开发者构建高效且可靠的并发应用。通过实例分析和理论阐述,我们将揭示在高并发环境下如何平衡线程安全与系统性能之间的关系,并提出一系列最佳实践方法。
|
1天前
|
监控 Java 开发者
深入理解Java并发编程:线程池的原理与实践
【5月更文挑战第85天】 在现代Java应用开发中,高效地处理并发任务是提升性能和响应能力的关键。线程池作为一种管理线程的机制,其合理使用能够显著减少资源消耗并优化系统吞吐量。本文将详细探讨线程池的核心原理,包括其内部工作机制、优势以及如何在Java中正确实现和使用线程池。通过理论分析和实例演示,我们将揭示线程池对提升Java应用性能的重要性,并给出实践中的最佳策略。
|
1天前
|
网络协议 Java
如何在Java中使用Socket编程实现TCP连接?
在Java中,通过Socket编程实现TCP连接非常常见。以下演示了基本的TCP通信流程,可根据具体需求进行扩展。
|
1天前
|
Java 开发者
Java 并发编程之深入理解线程池
在Java并发编程的世界中,线程池扮演着至关重要的角色。本文将深入探讨线程池的内部机制、使用场景以及如何合理配置线程池参数以优化性能。我们将通过实际案例和统计数据,分析线程池对于提升应用性能的具体影响,并讨论在不同应用场景下选择合适线程池策略的重要性。文章旨在为Java开发者提供关于线程池的全面理解和实践指导,帮助其在多线程编程中做出更明智的决策。