欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

J2SE基础-IO-字节流(位流)-多目标源输出流自定义扩展 博客分类: 1015-J2SE基础-IO J2SE基础IO字节流多目标源输出OutputStream扩展 

程序员文章站 2024-03-25 14:52:04
...
J2SE基础-IO-字节流(位流)-多目标源输出流自定义扩展

前一章节(J2SE基础-IO-字节流(位流))对字节流(位流)进行了说明,对于输入字节流InputStream/输出字节流OutputStream,我们可以根据业务的实际情况进行自定义的实现。

以下制作了一个多目标源输出流的扩展,作为前一章节的补充。

package com.core.common.file.stream;

import java.io.IOException;
import java.io.OutputStream;
import java.util.List;

import com.core.common.log.Log;

/**
 * 文件名称: MultiOutputStream.java
 * 类名: MultiOutputStream
 * 日期: 2012-12-22
 *
 * 功能描述:多目的源输出流,该对象同时将一个输入流写入多个输出流
 */
public class MultiOutputStream extends OutputStream {

	/** 多目的源输出流的保存对象*/
	private List<OutputStream> outputStreamList = null;

	/**
	 * 构造方法
	 * 功能描述:初始化多目的源输出流
	 *
	 * @param outputStreamList
	 * @throws IOException
	 */
	public MultiOutputStream(final List<OutputStream> outputStreamList) throws IOException {
		if(outputStreamList == null || outputStreamList.isEmpty()) {
			final String msg = "多源输出流对象为null,不能进行初始化操作,请检查!";
			Log.logDebug(msg);
			throw new IOException(msg);
		}
		int outputStreamListSize = outputStreamList.size();
		for (int i = outputStreamListSize - 1; 0 < i; i--) {
			OutputStream outputStream = outputStreamList.get(i);
			if(outputStream == null) {
				outputStreamList.remove(i);
				Log.logDebug("多源输出流对象中发现第[{}]个是null,该输出源已从输出列表中删除,请检查!", i);
			}
		}
		this.outputStreamList = outputStreamList;
	}

	/**
	 * 重写write方法
	 * 重载方法(non-Javadoc)
	 * @see java.io.OutputStream#write(int)
	 */
	@Override
	public void write(final int b) throws IOException {
		if(this.outputStreamList != null) {
			for (OutputStream outputStream : this.outputStreamList) {
				outputStream.write(b);
			}
		}
	}

	/**
	 * 重写write方法
	 * 重载方法(non-Javadoc)
	 * @see java.io.OutputStream#write(byte[], int, int)
	 */
	@Override
	public void write(final byte[] data, final int offset, final int length) throws IOException {
		if(this.outputStreamList != null) {
			for (OutputStream outputStream : this.outputStreamList) {
				outputStream.write(data, offset, length);
			}
		}
	}

	/**
	 * 重写flush方法
	 * 重载方法(non-Javadoc)
	 * @see java.io.OutputStream#flush()
	 */
	@Override
	public void flush() throws IOException {
		if(this.outputStreamList != null) {
			for (OutputStream outputStream : this.outputStreamList) {
				outputStream.flush();
			}
		}
	}

	/**
	 * 重写close方法
	 * 重载方法(non-Javadoc)
	 * @see java.io.OutputStream#close()
	 */
	@Override
	public void close() throws IOException {
		if(this.outputStreamList != null) {
			for (OutputStream outputStream : this.outputStreamList) {
				outputStream.close();
			}
		}
	}
}


以上扩展出MultiOutputStream对象,该对象继承于OutputStream,重写了其中的write/flush/close方法,主要思想是传入一个多源输出流,按照多目标源逐一进行write/flush/close,以下是使用本对象的例子:


	/**
	 * 方法名称: copyToMultiOutput
	 * 功能描述: 将输入流拷贝至多输出源
	 *
	 * @version 1.0
	 *
	 * @param inputStream InputStream 输入流
	 * @param outputStream OutputStream 多目的源输出流
	 * @throws IOException
	 *
	 * @update [日期YYYY-MM-DD] [更改人姓名] [变更描述]
	 */
	public void copyToMultiOutput(final InputStream inputStream,
		final List<OutputStream> outputStreamList) throws IOException {

		MultiOutputStream multiOut = new MultiOutputStream(outputStreamList);
		copy(inputStream, multiOut);
	}

	/**
	 * 方法名称: copy
	 * 功能描述: 该方法实现输出源输出
	 *
	 * @version 1.0
	 *
	 * @param inputStream InputStream 输入流
	 * @param outputStream OutputStream 多目的源输出流
	 * @throws IOException
	 *
	 * @update [日期YYYY-MM-DD] [更改人姓名] [变更描述]
	 */
	private static void copy(final InputStream inputStream, final OutputStream outputStream) throws IOException {
		if(inputStream == null) {
			throw new IOException("没有输入流,拷贝操作停止!");
		}
		if(outputStream == null) {
			throw new IOException("没有输出源,拷贝操作停止!");
		}
		// 缓冲流
		BufferedInputStream bin = new BufferedInputStream(inputStream);
		BufferedOutputStream bout = new BufferedOutputStream(outputStream);
		while (true) {
			int datum = bin.read();
			if(datum == -1) {
				break;
			}
			bout.write(datum);
		}
		// 刷新缓冲区
		bout.flush();
		bout.close();
		return;
	}


以上是一个扩展OutputStream的例子,如有不正之处,欢迎指正,谢谢!
  • J2SE基础-IO-字节流(位流)-多目标源输出流自定义扩展
            
    
    博客分类: 1015-J2SE基础-IO J2SE基础IO字节流多目标源输出OutputStream扩展 
  • 大小: 44.6 KB
  • J2SE基础-IO-字节流(位流)-多目标源输出流自定义扩展
            
    
    博客分类: 1015-J2SE基础-IO J2SE基础IO字节流多目标源输出OutputStream扩展 
  • 大小: 35.3 KB