基于TCP协议的文件传输

/**
 * @author 郑云飞
 * 日期：2010年08月18日1:26
 * 内容：基于TCP协议的文件传输
 * 服务器端程序
 */
package socketFile;
import java.io.*;
import java.net.*;
public class Server extends Thread
{
   File fi;
   DataOutputStream ps ;
   String filePath;
    BufferedReader in;
    public void run()
    {
      Socket s=null;
      try
      {
        ServerSocket ss = new ServerSocket(8888);
        System.out.println("服务器启动");
          while (true)
        {
          boolean isExist=true;//循环的标志
          s = ss.accept();//一直出于阻塞状态,直到有客户连接
          while(isExist)
          {
            isExist=false;
            System.out.println("与客户端成功建立连接");
              in=new BufferedReader(new InputStreamReader(s.getInputStream()));//从客户端获取信息
               filePath=in.readLine();//将从客户端读取到的信息赋给变量filePath
               fi= new File(filePath);//用刚才的字符串变量创建一个文件
               boolean flag=fi.exists();//判断文件是否存在
             ps=new DataOutputStream(s.getOutputStream());
             ps.writeBoolean(flag);//将文件是否存在的标志写入流ps中,发送给客户端
             ps.flush();//刷新缓冲流
             if(flag==false)
             {
               isExist=true;
             }
             else
             {
               System.out.println("文件长度:" + (long) fi.length());
                  DataInputStream fis = new DataInputStream(new BufferedInputStream(new FileInputStream(filePath)));

                  // 将文件名及长度传给客户端。
                  ps.writeUTF(fi.getName());
                  ps.flush();
                  ps.writeLong((long) fi.length());
                  ps.flush();
                  int bufferSize = 8192;
                  byte[] buf = new byte[bufferSize];
                  int read = 0;
                  while ((read = fis.read(buf))!=-1)
                  {
                    ps.write(buf, 0, read);
                  }
                  ps.flush();
                  // 注意关闭socket链接哦，不然客户端会等待server的数据过来，
                  // 直到socket超时，导致数据不完整。
                  fis.close();
                  s.close();
                  System.out.println("文件传输完成");
             }

          }

          }

      } 
      catch (Exception e)
      {
        e.printStackTrace();
      }
    }
  public static void main(String[] args)
  {
    new Server().start();
  }
}

/**
 * @author 郑云飞
 * 日期：2010年08月18日1:26
 * 内容：基于TCP协议的文件传输
 * 客户端程序
 */
package socketFile;
import java.io.*;
import java.net.Socket;
public class Client
{
  public static void main(String arg[])
  {
    Socket cs;

        DataInputStream dis;
    try
    {
          cs = new Socket("localhost", 8888);
          String savePath = "F:/";
          System.out.print("连接服务器成功!" + "");
          boolean fileFlag=true;//判断是否循环输入的标志,如果文件路径存在,返回true,否则返回false
          while(fileFlag)
           { 
                  fileFlag=false;
                System.out.println("请选择要下载的东西:");
                BufferedReader br=new BufferedReader(new InputStreamReader(System.in));//从键盘输入文件的路径
                String filePath=br.readLine();//将从键盘输入的文件路径赋给变量filePath
                //将从键盘输入的文件路径写入到pw中，返回给服务器端
                PrintWriter pw=new PrintWriter(new BufferedWriter(new OutputStreamWriter(cs.getOutputStream())),true);
                pw.println(filePath);//将文件的路径写入流pw中,返回给服务器端
                  dis=new DataInputStream(cs.getInputStream());
                  boolean isExist=dis.readBoolean();//读取服务器端返回来的文件是否存在的标志
                 if(isExist==false)
                 {
                   fileFlag=true;
                 }
                 else
                 {
                         dis = new DataInputStream(new BufferedInputStream(cs.getInputStream()));
                        // 本地保存路径，文件名会自动从服务器端继承而来。
                        long passedlen = 0;
                        long len = 0;
                        savePath += dis.readUTF();//读取文件的保存路径
                        DataOutputStream fileout = new DataOutputStream(new BufferedOutputStream(new BufferedOutputStream(new FileOutputStream(savePath))));
                        len = dis.readLong();//读取文件的长度
                        System.out.println("文件的长度为:" + len + "");
                        System.out.println("开始接收文件!" + "");
                        int bufferSize = 8192;
                        byte[] buf = new byte[bufferSize];
                        int read = 0;
                        while ((read = dis.read(buf))!=-1)
                        {
                          passedlen += read;
                          // 下面进度条本为图形界面的prograssBar做的，这里如果是打文件，
                          // 可能会重复打印出一些相同的百分比
                          System.out.println("文件接收了" + (passedlen * 100 / len) + "%");
                          fileout.write(buf, 0, read);
                        }
                        //注意必须关闭文件输出流,否则接收到的数据为空
                        if(fileout!=null)
                        {
                          fileout.close();
                        }
                        System.out.println("接收完成，文件存为" + savePath + "");
                 }
           }
    } 
    catch (Exception ex)
    {
      System.out.print("连接服务器失败!" + "");
    }
  }
}