filetransportthread.java

大家相信对QQ都再熟悉不过了

package NewQQ;

import java.io.*;

public class FileTransportThread extends Thread{
	String file;
	SingleFrame sf;
	ObjectOutputStream oos;
	public FileTransportThread(String file, SingleFrame sf, ObjectOutputStream oos) {
		this.file = file;
		this.sf = sf;
		this.oos = oos;
	}
	public void run(){
		try {
			byte[] data = new byte[1024];
			FileInputStream fis = new FileInputStream(new File(file));
			int len = fis.read(data);
			while(len>0){
				QQMessage filem = new QQMessage();
				filem.setSender(sf.me);
				filem.setRecver(sf.name);
				filem.setType(8);
				filem.setData(data);
				filem.setLen(len);
				oos.writeObject(filem);
				oos.flush();
				len = fis.read(data);
			}
			QQMessage filem = new QQMessage();
			filem.setSender(sf.me);
			filem.setRecver(sf.name);
			filem.setType(9);
			oos.writeObject(filem);
			oos.flush();
			fis.close();
			sf.jtextarea.append("文件发送完毕\n\n");
			file = "";
		} catch (Exception e) {
		}
	}
}