tbupl.java

来自「java实现的ftp文件传输」· Java 代码 · 共 28 行

import java.io.BufferedOutputStream;
import org.apache.commons.net.ftp.FTPClient;

public class TBupl extends Thread{
	FTPClient ftpupl;
	WByte wbyte;
	BufferedOutputStream boutupl;
	String filename;
	TBupl(WByte wbyte,BufferedOutputStream boutupl,FTPClient ftpupl){
		this.wbyte = wbyte;
//		this.filename = filename;
		this.ftpupl = ftpupl;
		this.boutupl = boutupl;
	}

//	上传一个缓冲区的数据
	public void run(){	
		try{
			wbyte.flag_busy = 1;
			boutupl.write(wbyte.buf,0,wbyte.length);
			boutupl.flush();
			wbyte.flag_empty = 1;
			wbyte.flag_busy = 0;
		}catch(Exception e){
			System.out.println("error occur when buf1 is uploading.");
		}
	}
}