input.java

来自「软件体系结构 KWIC三种风格的java实现」· Java 代码 · 共 48 行

package PipeKwic;

import java.io.BufferedReader;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileReader;
import java.io.IOException;

/**
 * 按行读取数据，传递给下一模块
 */
public class Input extends Filter {

	private FileReader fr;
	
	
	public Input(File fInput, Pipe output) {
		super(null, output);
		try {
			fr = new FileReader(fInput);
		} catch (FileNotFoundException e) {
			e.printStackTrace();
		}
	}

	/**
	 * 按行从输入文件fr中读取数据，并将数据写到输出管道output中
	 */
	@Override
	protected void transform() {
		BufferedReader br = new BufferedReader(fr);
		try {
			String line;
			while((line = br.readLine()) != null) {

				output.write(line + '\n'); //加入换行是以便下个模块的处理
			}
			br.close();
			fr.close();
			output.closeWriter();
		} catch (IOException e) {
			e.printStackTrace();
		}
	}

}