zoukankan      html  css  js  c++  java
  • 序列流 SequenceInputStream

     SequenceInputStream:序列流,对多个流进行合并。

    SequenceInputStream 表示其他输入流的逻辑串联。它从输入流的有序集合开始,并从第一个输入流开始读取,直到到达文件末尾,接着从第二个输入流读取,依次类推,直到到达包含的最后一个输入流的文件末尾为止。

    序列流的使用:

    可以将多个流串联到一起  ,然后就通过串联一个一来读取流中的数据。

         --- SequenceInputStream   只能操作输入流。

    方式二和方式三即为SequenceInputStream的用法:

    package com.beiwo.io;
    
    import java.io.File;
    import java.io.FileInputStream;
    import java.io.FileOutputStream;
    import java.io.SequenceInputStream;
    import java.util.ArrayList;
    import java.util.Enumeration;
    import java.util.List;
    import java.util.Vector;
    
    public class demo6 {
      /**
      * 
      */
    public static void main(String[] args) throws Exception { // TODO 自动生成的方法存根 testMerge1(); testMerge2(); testMerge3(); } // 方式三:可以同时操作多个文件夹 public static void testMerge3() throws Exception { // 获取目标文件、 File file1 = new File("C:\Users\cdlx2016\Desktop\2\1.txt"); File file2 = new File("C:\Users\cdlx2016\Desktop\2\2.txt"); File file3 = new File("C:\Users\cdlx2016\Desktop\2\3.txt"); File file4 = new File("C:\Users\cdlx2016\Desktop\2\4.txt"); // 如果没有目标文件就创建 if (!file1.exists()) { file1.createNewFile(); } if (!file2.exists()) { file2.createNewFile(); } if (!file3.exists()) { file3.createNewFile(); } if (!file4.exists()) { file4.createNewFile(); } // 建立通道 FileInputStream fileInputStream1 = new FileInputStream(file1); FileInputStream fileInputStream2 = new FileInputStream(file2); FileInputStream fileInputStream3 = new FileInputStream(file3); FileOutputStream fileOutputStream = new FileOutputStream(file4); // 创建一个vector集合对象 Vector<FileInputStream> vector = new Vector<FileInputStream>(); // 添加 vector.add(fileInputStream1); vector.add(fileInputStream2); vector.add(fileInputStream3); // 获取迭代器 Enumeration<FileInputStream> enumeration = vector.elements(); // 通过序列化将三个流串起来 SequenceInputStream sequenceInputStream = new SequenceInputStream(enumeration); // 创建字节数组 byte[] b = new byte[1024]; // 读取数据 int length = 0; while ((length = sequenceInputStream.read(b)) != -1) { // 写入数据 fileOutputStream.write(b, 0, length); } // 关闭流 fileOutputStream.close(); sequenceInputStream.close(); } // 方式二:简化方式一的操作 public static void testMerge2() throws Exception { // 获取目标文件、 File file1 = new File("C:\Users\cdlx2016\Desktop\2\1.txt"); File file2 = new File("C:\Users\cdlx2016\Desktop\2\2.txt"); File file3 = new File("C:\Users\cdlx2016\Desktop\2\3.txt"); // 如果没有目标文件就创建 if (!file1.exists()) { file1.createNewFile(); } if (!file2.exists()) { file2.createNewFile(); } if (!file3.exists()) { file3.createNewFile(); } // 建立通道 FileInputStream fileInputStream1 = new FileInputStream(file1); FileInputStream fileInputStream2 = new FileInputStream(file2); FileOutputStream fileOutputStream = new FileOutputStream(file3); // 建立序列流 SequenceInputStream sequenceInputStream = new SequenceInputStream(fileInputStream1, fileInputStream2); byte[] b = new byte[1024]; // 读取数据 int length = 0; while ((length = sequenceInputStream.read(b)) != -1) { // 写入数据 fileOutputStream.write(b, 0, length); } // 关闭流 fileOutputStream.close(); sequenceInputStream.close(); } // 方法一:操作太复杂了 public static void testMerge1() throws Exception { // 获取目标文件、 File file1 = new File("C:\Users\cdlx2016\Desktop\2\1.txt"); File file2 = new File("C:\Users\cdlx2016\Desktop\2\2.txt"); File file3 = new File("C:\Users\cdlx2016\Desktop\2\3.txt"); // 如果没有目标文件就创建 if (!file1.exists()) { file1.createNewFile(); } if (!file2.exists()) { file2.createNewFile(); } if (!file3.exists()) { file3.createNewFile(); } // 建立通道 FileInputStream fileInputStream1 = new FileInputStream(file1); FileInputStream fileInputStream2 = new FileInputStream(file2); FileOutputStream fileOutputStream = new FileOutputStream(file3); // 用集合来存输入流 List<FileInputStream> list = new ArrayList<FileInputStream>(); // 添加元素 list.add(fileInputStream1); list.add(fileInputStream2); // 边读边写数据 byte[] b = new byte[1024]; int length = 0; for (int i = 0; i < list.size(); i++) { while ((length = list.get(i).read(b)) != -1) { // 写入数据 fileOutputStream.write(b, 0, length); } } // 关闭流 先开后关 fileOutputStream.close(); fileInputStream2.close(); fileInputStream1.close(); } }
  • 相关阅读:
    python 一个二维数组和一个整数,判断数组中是否含有该整数
    DDD 全称 “Domain-Driven Design”,领域驱动设计
    pytest + allure 生成测试报告
    AttributeError: module 'pytest' has no attribute 'allure'
    BDD的概念
    在im4java中使用GraphicsMagick
    缓存穿透与缓存雪崩
    Linux安装ImageMagick与JMagick完成过程及配置
    Windows/Linux下引用jar包,并用javac/java编译运行
    在CentOS4上安装JMagick
  • 原文地址:https://www.cnblogs.com/Liang-Haishan216/p/6148451.html
Copyright © 2011-2022 走看看