读书人

转:Socket传递文件

发布时间: 2012-08-21 13:00:21 作者: rapoo

转:Socket传送文件

?

客户端:

Client.java

?

package lee.socket;    import java.io.BufferedInputStream;  import java.io.DataInputStream;  import java.io.DataOutputStream;  import java.io.File;  import java.io.FileInputStream;  import java.io.IOException;  import java.net.Socket;    public class Client {      static DataInputStream din = null;      static DataOutputStream dout = null;      static Socket s = null;        public static void main(String[] args) {          try {              s = new Socket("127.0.0.1", 2224);                File file = new File("d:/05.jpg"); // 定义文件              FileInputStream fis = new FileInputStream(file); // 定义文件输入流              din = new DataInputStream(new BufferedInputStream(fis)); // 用缓存流包装文件输入流(提高读取速度),然后再包装成数据输入流              dout = new DataOutputStream(s.getOutputStream());// 定义数据输出流                dout.writeUTF(String.valueOf(file.length())); // 发送文件长度                byte[] buffer = new byte[1024]; // 定义缓存              int len = 0;              while ((len = din.read(buffer)) != -1) {                  dout.write(buffer, 0, len); // 向服务器发送数据              }              dout.flush();            } catch (IOException e) {              System.out.println(e.toString());          } finally {              try {                  if (din != null) {                      din.close();                      din = null;                  }              } catch (Exception e) {                  e.printStackTrace();              }              try {                  if (dout != null) { // 最后一定要关闭输出流,不然数据发送不出去。导致一直连接着,不断开                      dout.close();                      dout = null;                  }              } catch (Exception e) {                  e.printStackTrace();              }              try {                  if (s != null) {                      s.close();                      s = null;                  }              } catch (Exception e) {                  e.printStackTrace();              }          }      }  }  

?Android和客户端基本一样。

?

?

服务端:

Server.java

?

?

package lee.socket;    import java.io.BufferedInputStream;  import java.io.BufferedOutputStream;  import java.io.DataInputStream;  import java.io.DataOutputStream;  import java.io.File;  import java.io.FileOutputStream;  import java.io.IOException;  import java.net.ServerSocket;  import java.net.Socket;    public class Server {      static DataInputStream din = null;      static DataOutputStream dout = null;      static Socket s = null;        public static void main(String[] args) {          new Thread() { // 开启子线程              public void run() {                  try {                      ServerSocket ss = new ServerSocket(2224); // 这个必须在while外,不然会循环连接端口,出错                      while (true) {                          System.out.println("--------等待用户连接--------------");                          s = ss.accept();                          System.out.println("--------用户连接上了--------------");                            din = new DataInputStream(new BufferedInputStream(s                                  .getInputStream()));// 使用缓存进行包装,提示读取速度                          System.out.println("文件长度:" + din.readUTF()); // 显示接收文件长度                            File file = new File("d:/01.jpg");                          FileOutputStream fos = new FileOutputStream(file);                          dout = new DataOutputStream(new BufferedOutputStream(                                  fos));                            byte[] buffer = new byte[1024];                          int len = 0;                          while ((len = din.read(buffer)) != -1) {                              dout.write(buffer, 0, len);                          }                          dout.flush();                          dout.close(); // 下面的finally要等到循环结束后才执行,如果不执行close,文件无法正常打开                            System.out.println("接受成功");                      }                    } catch (IOException e) {                      e.printStackTrace();                  } finally { // 等while循环结束后才会执行,                      try {                          if (dout != null) {                              dout.close();                              dout = null;                          }                      } catch (Exception e) {                          e.printStackTrace();                      }                      try {                          if (din != null) {                              din.close();                              din = null;                          }                      } catch (Exception e) {                          e.printStackTrace();                      }                      try {                          if (s != null) {                              s.close();                              s = null;                          }                      } catch (Exception e) {                          e.printStackTrace();                      }                  }              }          }.start();        }    }  

?

转自:http://shazhuzhu1.iteye.com/blog/965658

读书人网 >移动开发

热点推荐