servertext.java

一个用java开发的文件传输系统

package send;

import java.io.BufferedInputStream;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.net.ServerSocket;
import java.net.Socket;
import interfaces.MainInter;

public class ServerText {
    int port = 8821;
    public static String filePath,SocketMess,InfoMess;
    public  ServerText() {
        Socket s = null;
        
        try {
            ServerSocket ss = new ServerSocket(port);
            while (true) {
               // 选择进行传输的文件
                File fi = new File(filePath);
                s = ss.accept();
                MainInter.jlabel2.setText("建立socket链接");
                DataInputStream dis = new DataInputStream(new BufferedInputStream(s.getInputStream()));
                dis.readByte();

                DataInputStream fis = new DataInputStream(new BufferedInputStream(new FileInputStream(filePath)));
                DataOutputStream ps = new DataOutputStream(s.getOutputStream());
                //将文件名及长度传给客户端。这里要真正适用所有平台，例如中文名的处理，还需要加工，具体可以参见Think In Java 4th里有现成的代码。
                ps.writeUTF(fi.getName());
                ps.flush();
                ps.writeLong((long) fi.length());
                ps.flush();

                int bufferSize = 8192;
                byte[] buf = new byte[bufferSize];

                while (true) {
                    int read = 0;
                    if (fis != null) {
                        read = fis.read(buf);
                    }

                    if (read == -1) {
                        break;
                    }
                    ps.write(buf, 0, read);
                }
                ps.flush();
                // 注意关闭socket链接哦，不然客户端会等待server的数据过来，
                // 直到socket超时，导致数据不完整。                
                fis.close();
                s.close();                
                MainInter.jlabel3.setText("文件传输完成");
                ss.close();
            }

        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}