这篇文章主要介绍“Java如何实现断点续传功能”的相关知识,小编通过实际案例向大家展示操作过程,操作方法简单快捷,实用性强,希望这篇“Java如何实现断点续传功能”文章能帮助大家解决问题。
题目实现:网络资源的断点续传功能。
获取要下载的资源网址
显示网络资源的大小
上次读取到的字节位置以及未读取的字节数
输入下载的起始位置和结束位置,开始下载网络资源
如果没有下载完成,可以接着上次的下载位置继续下载
创建一个类:BreakPointSuperveneFrame,继承JFrame窗体类。
定义一个download()方法:用于实现网络资源的断点续传。
核心重点:通过设置请求参数RANGE实现,通过RANGE参数可以指定下载网络的字节区间,从而可以实现每次下载部分网络资源的功能
例如:将该参数设置为“RANGEbytes=0-1024”,就表示将网络资源中从0~1024之间的内容下载到客户机;如果将该参数设置为“RANGE:bytes=1024-”,就表示将网络资源中从1024到结束位置的内容全部下载到客户机。
测试下载这个链接
BreakPointSuperveneFrame
package com.xiaoxuzhu; import java.awt.BorderLayout; import java.awt.Color; import java.awt.EventQueue; import java.awt.Font; import java.awt.event.ActionEvent; import java.awt.event.ActionListener; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; import java.net.HttpURLConnection; import java.net.MalformedURLException; import java.net.URL; import javax.swing.JButton; import javax.swing.JFrame; import javax.swing.JLabel; import javax.swing.JOptionPane; import javax.swing.JTextField; /** * Description: * * @author xiaoxuzhu * @version 1.0 * * <pre> * 修改记录: * 修改后版本 修改人 修改日期 修改内容 * 2022/5/29.1 xiaoxuzhu 2022/5/29 Create * </pre> * @date 2022/5/29 */ public class BreakPointSuperveneFrame extends JFrame { private JTextField tf_totalLength; private JTextField tf_residuaryLength; private JTextField tf_readToPos; private JTextField tf_address; private JTextField tf_endPos; private JTextField tf_startPos; private String urlAddress = "";// 用于存储网络资源的地址 private long totalLength = 0;// 存储网络资源的大小,以字节为单位 private long readToPos = 0;// 存储上次读取到的位置 private long residuaryLength = 0;// 存储未读内容的大小 /** * Launch the application * * @param args */ public static void main(String args[]) { EventQueue.invokeLater(new Runnable() { public void run() { try { BreakPointSuperveneFrame frame = new BreakPointSuperveneFrame(); frame.setVisible(true); } catch (Exception e) { e.printStackTrace(); } } }); } /** * Create the frame */ public BreakPointSuperveneFrame() { super(); getContentPane().setLayout(null); setTitle("下载网络资源的断点续传"); setBounds(100, 100, 514, 238); setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); tf_startPos = new JTextField(); tf_startPos.setBounds(80, 165, 113, 22); getContentPane().add(tf_startPos); final JLabel label = new JLabel(); label.setText("起始位置:"); label.setBounds(10, 167, 74, 18); getContentPane().add(label); final JLabel label_1 = new JLabel(); label_1.setText("结束位置:"); label_1.setBounds(199, 167, 74, 18); getContentPane().add(label_1); tf_endPos = new JTextField(); tf_endPos.setBounds(267, 165, 117, 22); getContentPane().add(tf_endPos); final JLabel label_2 = new JLabel(); label_2.setText("网络资源的地址:"); label_2.setBounds(10, 52, 113, 18); getContentPane().add(label_2); tf_address = new JTextField(); tf_address.addActionListener(new ActionListener() { public void actionPerformed(final ActionEvent e) { try { urlAddress = tf_address.getText().trim(); URL url = new URL(urlAddress);// 获得网络资源的URL HttpURLConnection connection = (HttpURLConnection) url .openConnection();// 获得连接对象 connection.connect();// 连接网络资源 totalLength = connection.getContentLength();// 获得网络资源的长度 connection.disconnect();// 断开连接 tf_totalLength.setText(String.valueOf(totalLength));// 显示总长度 tf_readToPos.setText("0");// 显示上次读取到的位置 residuaryLength = totalLength;// 未读内容为文件总长度 tf_residuaryLength.setText(String.valueOf(residuaryLength));// 显示未读内容 } catch (MalformedURLException e1) { e1.printStackTrace(); } catch (IOException e2) { e2.printStackTrace(); } } }); tf_address.setBounds(119, 50, 365, 22); getContentPane().add(tf_address); final JLabel label_3 = new JLabel(); label_3.setForeground(new Color(0, 0, 255)); label_3.setFont(new Font("", Font.BOLD, 14)); label_3.setText("输入网络资源的地址并回车,可以获得网络资源的大小。"); label_3.setBounds(10, 10, 384, 22); getContentPane().add(label_3); final JLabel label_4 = new JLabel(); label_4.setForeground(new Color(128, 0, 0)); label_4.setText("网络资源的大小为"); label_4.setBounds(10, 76, 113, 38); getContentPane().add(label_4); final JLabel label_5 = new JLabel(); label_5.setText("上次读取到"); label_5.setBounds(10, 123, 74, 18); getContentPane().add(label_5); tf_readToPos = new JTextField(); tf_readToPos.setBounds(80, 121, 113, 22); tf_readToPos.setEnabled(false); getContentPane().add(tf_readToPos); final JLabel label_6 = new JLabel(); label_6.setText("字节处,还剩"); label_6.setBounds(202, 123, 87, 18); getContentPane().add(label_6); tf_residuaryLength = new JTextField(); tf_residuaryLength.setBounds(285, 120, 117, 22); tf_residuaryLength.setEnabled(false); getContentPane().add(tf_residuaryLength); final JLabel label_7 = new JLabel(); label_7.setText("字节未读。"); label_7.setBounds(404, 123, 80, 18); getContentPane().add(label_7); final JLabel label_4_1 = new JLabel(); label_4_1.setForeground(new Color(128, 0, 0)); label_4_1.setText("个字节。"); label_4_1.setBounds(404, 76, 80, 38); getContentPane().add(label_4_1); tf_totalLength = new JTextField(); tf_totalLength.setBounds(119, 84, 283, 22); tf_totalLength.setEnabled(false); getContentPane().add(tf_totalLength); final JButton button = new JButton(); button.setBounds(395, 162, 89, 28); getContentPane().add(button); button.addActionListener(new ActionListener() { public void actionPerformed(final ActionEvent e) { if (totalLength == 0) { JOptionPane.showMessageDialog(null, "没有网络资源。\n\n请输入正确的网址,然后回车。"); return; } long startPos = 0;// 起始位置 long endPos = 0;// 结束位置 try { startPos = Long.parseLong(tf_startPos.getText().trim());// 起始位置 endPos = Long.parseLong(tf_endPos.getText().trim());// 结束位置 } catch (Exception ex) { JOptionPane.showMessageDialog(null, "输入的起始位置或结束位置不正确。"); return; } readToPos = endPos;// 记录读取到的位置 residuaryLength = totalLength - readToPos;// 记录未读内容的大小 tf_readToPos.setText(String.valueOf(readToPos));// 显示读取到的位置 tf_residuaryLength.setText(String.valueOf(residuaryLength));// 显示未读字节数 tf_startPos.setText(String.valueOf(readToPos));// 设置下一个读取点的开始位置 tf_endPos.setText(String.valueOf(totalLength));// 设置下一个读取点的结束位置 tf_endPos.requestFocus();// 使结束位置文本框获得焦点 tf_endPos.selectAll();// 选择结束位置文本框中的全部内容,方便输入结束位置值 download(startPos, endPos);// 调用方法进行下载 } }); button.setText("开始下载"); } public void download(long startPosition, long endPosition) { try { URL url = new URL(urlAddress);// 获得网络资源的URL HttpURLConnection connection = (HttpURLConnection) url .openConnection();// 获得连接对象 connection.setRequestProperty("User-Agent", "NetFox");// 设置请求属性 String rangeProperty = "bytes=" + startPosition + "-";// 定义请求范围属性 if (endPosition > 0) { rangeProperty += endPosition;// 调整请求范围属性 } connection.setRequestProperty("RANGE", rangeProperty);// 设置请求范围属性 connection.connect();// 连接网络资源 InputStream in = connection.getInputStream();// 获得输入流对象 String file = url.getFile();// 获得文件对象 String name = file.substring(file.lastIndexOf('/') + 1);// 获得文件名 FileOutputStream out = new FileOutputStream("d:/" + name, true);// 创建输出流对象,保存下载的资源 byte[] buff = new byte[2048];// 创建字节数组 int len = 0;// 定义存储读取内容长度的变量 len = in.read(buff);// 读取内容 while (len != -1) { out.write(buff, 0, len);// 写入磁盘 len = in.read(buff);// 读取内容 } out.close();// 关闭流 in.close();// 关闭流 connection.disconnect();// 断开连接 if (readToPos > 0 && readToPos == totalLength) { JOptionPane.showMessageDialog(null, "完成网络资源的下载。\n单击“确定”按钮退出程序。"); System.exit(0); } } catch (Exception e) { e.printStackTrace(); } } }
点击开始下载,提示要--》输入地址后回车
输入地址后回车,会获取文件的大小
尝试先下载 0-1024 ,下载后,会自动计算未下载的起始和结束位置。
下载后,写入本地文件,文件存储在D:盘目录下
下载成功提示:
文件存储在D:盘目录下
关于“Java如何实现断点续传功能”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识,可以关注亿速云行业资讯频道,小编每天都会为大家更新不同的知识点。
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。