java流操作对文件的分割和合并

学习文件的输入输出流,自己做一个小的示例,对文件进行分割和合并。

大家好,又见面了,我是全栈君。

     学习文件的输入输出流,自己做一个小的示例,对文件进行分割和合并。

    下面是代码:


<span style="font-size:14px;">package com.dufy.file;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.SequenceInputStream;
import java.util.ArrayList;
import java.util.Collections;
import java.util.Enumeration;
import java.util.List;
/**
 * 文件的切割和合并
 * 1.要切割和合并文件:主要考虑的就是文件的源地址,目标地址,暂存文件地址和文件名称
 * 2.切割文件:判断给的暂存地址是否存在,不存在,则创建;从源地址中读出文件,按照给定的大小进行文件的切割操作放入暂存地址中
 * 3.合并文件:判断给定的目标地址是否存在,不存在,则创建;定义List集合将暂存地址中的文件全部读取出来,放到list集合中
 * 			然后使用Enumeration列举出所有文件,合并流合并文件
 * 			最后写入到目标的地址中
 * 注:本例子中所有的异常都采用抛出的方式处理
 * @author aflyun
 *
 */
public class TestFileCutUnion {

	public static void main(String[] args) throws IOException {
		
		String fSrc = "D:/1.jpg";//源文件的目录
		String fDir = "D:/1";//目标文件的目录
		String fTemp = "D:/2";//暂存文件的目录
		File srcFile = new File(fSrc);
		File dirFile = new File(fDir);
		File tempFile = new File(fTemp);
		String fileName = srcFile.getName();//获取文件的名称
		cutFile(srcFile,tempFile);//调用分割方法
		unionFile(dirFile,tempFile,fileName);//调用合并方法
		
		
	}
	
	/**
	 * 切割文件
	 * @param srcFile
	 * @param tempFile
	 * @throws IOException
	 */
	
	public static void cutFile(File srcFile, File tempFile) throws IOException {
		//读取源地址文件
		FileInputStream fis = new FileInputStream(srcFile);
		FileOutputStream fos = null;
		//是否为文件,不是就创建
		if(!tempFile.isFile()){
			tempFile.mkdirs();
		}
	
		byte[] b = new byte[100];
		int len =0;
		int count = 0;
		while((len=fis.read(b)) != -1){
			int num = count++;
			//写入暂存地址目录中
			fos = new FileOutputStream(new File(tempFile, num+".part"));
			fos.write(b, 0, len);
			
		}
		fos.flush();
		fos.close();
		fis.close();
		
		System.out.println("分割完成!");
	}
	/**
	 * 合并文件
	 * @param dirFile 
	 * @param tempFile
	 * @param fileName
	 * @throws IOException
	 */
	public static void unionFile(File dirFile, File tempFile, String fileName) throws IOException {
		//判断目标地址是否存在,不存在则创建
		if(!dirFile.isFile()){
			dirFile.mkdirs();
		}
		List<FileInputStream> list = new ArrayList<FileInputStream>();
		//获取暂存地址中的文件
		File[] files = tempFile.listFiles();
		
		for (int i = 0; i < files.length; i++) {
			//用FileInputStream读取放入list集合
			list.add(new FileInputStream(new File(tempFile, i+".part")));
		}
		//使用 Enumeration(列举) 将文件全部列举出来
		Enumeration<FileInputStream> eum = Collections.enumeration(list);
		//SequenceInputStream合并流 合并文件
		SequenceInputStream sis = new SequenceInputStream(eum);
		FileOutputStream fos = new FileOutputStream(new File(dirFile, fileName));
		byte[] by = new byte[100];
		int len;
		while((len=sis.read(by)) != -1){
			fos.write(by, 0, len);
		}
		fos.flush();
		fos.close();
		sis.close();
		System.out.println("合并完成!");
	}
}
</span>

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/121286.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • 去噪自动编码器

    去噪自动编码器降噪自动编码器是一种用于图像去噪无监督的反馈神经网络原理如下图所示训练代码如下fromkeras.layersimportInput,Conv2D,MaxPooling2D,UpSampling2D,ZeroPadding2Dfromkeras.modelsimportModelfromkeras.callbacksimportTensorBoardfromkeras.datasetsimportmnistimportnumpyasnp(x_trai

  • python报错no module named_pycharm报错no module named

    python报错no module named_pycharm报错no module namedpycharm在运行时出现“ModuleNotFoundError:Nomodulenamed‘pygame’”错误的解决方法例如:(出现这样子的错误,再出错的地方点击installpygame后,代码还是会出现上面的错误,这时候,我手动安装之后代码就能正常运行了。)手动安装pygame:通过文件—设置—项目解释器(File-setting-Projectinterpreter),点击“+”,搜索pygame,点击左下角的安装即可。如下图所示:右侧下方点击“+”:在搜索框

  • 如何利用 Webshell 诊断 EDAS Serverless 应用

    如何利用 Webshell 诊断 EDAS Serverless 应用

  • Taiko taiko

    Taiko taikoTaikotaikoDescription拆拆超级喜欢太鼓达人(赛后大家可自行百度规则),玩久了也对积分规则产生了兴趣,理论上连击数越多,分数增加的越快,而且还配合着击打准确度有相应的计算规则,拆拆觉得这些规则太复杂了,于是把规则自行简化了下:对于一段击打序列,我们假设Y为打中,N为未打中(没有良可之分了)我们视连续的n次击中为n连击 相应的分数为1+2+3

    2022年10月22日
  • java中线程池参数设置

    java中线程池参数设置本文主要介绍线程池是解决了哪些问题以及线程池中的corePoolSize(核心线程数),queueCapacity(等待队列的长度),maximumPoolSize(最大核心线程数)。本文不会对线程池各个参数介绍,假定你已经了解了线程池各个参数的含义。1为什么要有线程池呢?当前实际应用中,经常会遇到单个请求处理时间短但请求量巨大但问题,简单说就是qps很高,平响时间很短的情况。…

  • 新的历程-近两个月的工作总结

    新的历程-近两个月的工作总结

    2021年11月15日

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号