package com.lanqiao.demo2; 
import java.io.BufferedInputStream; 
import java.io.FileInputStream; 
import java.io.IOException; 
import java.io.OutputStream; 
import java.net.ServerSocket; 
import java.net.Socket; 
/** 
 * @author 
 * @version 創(chuàng)建時間：2017年6月12日 上午8:47:37 
 * 類說明:服務(wù)端上傳一個txt類型的文件 
 * 注意：服務(wù)端是一直不關(guān)閉的 
 */ 
public class TestServer { 
  // 這個路徑是我電腦上的一個記事本文件 
  private static final String PATH = "D:\\JavaFile_Test\\test\\網(wǎng)上JDK環(huán)境變量配置.txt"; 
  public static void main(String[] args) { 
    int count = 0; 
    OutputStream os = null; 
    ServerSocket severscoket = null; 
    Socket s1 = null; 
    BufferedInputStream bis =null; 
    int len=0; 
    try { 
      // 創(chuàng)建 Socket 服務(wù) 
      severscoket = new ServerSocket(8888); 
      while (true) { 
        // 阻塞 
        s1 = severscoket.accept(); 
        //服務(wù)端被連接的次數(shù) 
        count++; 
        System.out.println("---服務(wù)端開啟 " + count + " 次---"); 
        // 服務(wù)端寫入文件 
        os = s1.getOutputStream(); 
        //創(chuàng)建一個BufferedInputStream對象讀取我電腦上的文件 
        bis = new BufferedInputStream(new FileInputStream(PATH)); 
        //每次寫入512個字節(jié) 
        byte[] b = new byte[512]; 
        while ((len = bis.read(b)) != -1) { 
          os.write(b, 0, len); 
        } 
        s1.shutdownOutput(); 
        os.flush(); 
      } 
    } catch (IOException e) { 
      // TODO 自動生成的 catch 塊 
      e.printStackTrace(); 
    } finally { 
      try { 
        if (os != null) 
          os.close(); 
      } catch (IOException e) { 
        // TODO 自動生成的 catch 塊 
        e.printStackTrace(); 
      } 
    } 
  } 
} 
package com.lanqiao.demo2; 
import java.io.BufferedInputStream; 
import java.io.IOException; 
import java.net.Socket; 
/** 
 * @author 
 * @version 創(chuàng)建時間：2017年6月12日 上午9:04:36 
 * 類說明:客戶端打印出從服務(wù)端下載的txt內(nèi)容 
 */ 
public class TestClient { 
  public static void main(String[] args) { 
    BufferedInputStream bis = null; 
    Socket socket = null; 
    int len=0; 
    try { 
      // 通過IP地址和端口號創(chuàng)建一個Socket對象 
      socket = new Socket("127.0.0.1", 8888); 
      // 客戶端讀取文件 
      bis = new BufferedInputStream(socket.getInputStream()); 
      // 每次讀512個字節(jié) 
      byte[] b = new byte[512]; 
      //當(dāng)讀取的字節(jié)不為空 循環(huán)打印下載的內(nèi)容 
      while ((len = bis.read(b)) != -1) { 
        System.out.println(new String(b, 0, len)); 
      } 
    } catch (IOException e) { 
      // TODO 自動生成的 catch 塊 
      e.printStackTrace(); 
    } finally { 
      //關(guān)閉客戶端的輸入流對象 和 Socket對象 
      try { 
        if(bis!=null) bis.close(); 
        if(socket!=null) socket.close(); 
      } catch (IOException e) { 
        // TODO 自動生成的 catch 塊 
        e.printStackTrace(); 
      } 
    } 
  } 
}