filesender.java

java局域网聊天室

package chatnew;
import java.net.*;
import java.io.*;
import java.awt.List;
/**
 * <p>Title: </p>
 *
 * <p>Description: </p>
 *
 * <p>Copyright: Copyright (c) 2005</p>
 *
 * <p>Company: </p>
 *
 * @author not attributable
 * @version 1.0
 */
public class FileSender extends Thread {
    String descNickname;
    String descIP;
    int port=9998;
    String fileName;

    List chatContentList;
    public FileSender(String nickname,String fileName,List chatContentList) {
        this.descNickname=nickname;
        this.fileName=fileName;
        this.chatContentList=chatContentList;
    }
    public void run(){
        try {
//            DatagramSocket ds = new DatagramSocket();
                Socket s=new Socket(InetAddress.getByName(this.descIP),this.port);
            BufferedInputStream bis = new BufferedInputStream(new
                    FileInputStream(fileName));
            BufferedOutputStream bos=new BufferedOutputStream(s.getOutputStream());
            byte[] buff = new byte[1024];
            int i = 0;
            while ((i = bis.read(buff, 0, buff.length)) != -1) {
//                DatagramPacket dp = new DatagramPacket(buff, i,
//                        InetAddress.getByName(this.descIP), this.port);
//                ds.send(dp);
                    bos.write(buff,0,i);
                    bos.flush();
            }
            bis.close();
//            ds.close();
            s.close();
            this.chatContentList.add("文件已发送完毕！");
            chatContentList.select(chatContentList.getItemCount() - 1);
        } catch (Exception ex) {
            ex.printStackTrace();
        }


    }
    public void setDescIP(String ip){
        this.descIP=ip;
    }
}