src/main/java/com/zx/maintain/util/OutHandler.java

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

package com.zx.maintain.util;

import java.io.BufferedReader;
import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class OutHandler extends Thread {
	
	private static final Logger logger = LoggerFactory.getLogger(OutHandler.class);
	
	// 控制线程状态
	volatile boolean status = true;

	BufferedReader br = null;

	String type = null;
	
	String file_name = null;

	public OutHandler(InputStream is, String type, String file_name) {
		br = new BufferedReader(new InputStreamReader(is));
		this.type = type;
		this.file_name = file_name;
	}

	/**
	 * 重写线程销毁方法，安全的关闭线程
	 */
	@Override
	public void destroy() {
		status = false;
		boolean b = deleteFile(file_name);
		logger.info(b==true ? "文件" + file_name + "删除成功" : "文件" + file_name + "不存在" );
	}

	/**
	 * 执行输出线程
	 */
	@Override
	public void run() {
		String msg = null;
		try {
			while (status) {
				if ((msg = br.readLine()) != null) {
//					System.out.println(type + "消息：" + msg);
				}else{
					destroy();
				}
			}
		} catch (IOException e) {
			e.printStackTrace();
		}
	}