package test.concurrent.socket; 
 
import java.io.*; 
import java.net.InetAddress; 
import java.net.ServerSocket; 
import java.net.Socket; 
 
/** 
 * Created by dong on 15-6-22. 
 * 基于TCP協(xié)議的Socket通信，實(shí)現(xiàn)用戶登錄 
 * 服務(wù)器端 
 */ 
public class Server { 
 
  public static void main(String[] args) { 
 
    try { 
      //1、創(chuàng)建一個(gè)服務(wù)器端Socket,即ServerSocket, 指定綁定的端口，并監(jiān)聽(tīng)此端口 
      ServerSocket serverSocket = new ServerSocket(8888); 
      Socket socket = null; 
      //記錄客戶端的數(shù)量 
      int count = 0; 
      System.out.println("***服務(wù)器即將啟動(dòng)，等待客戶端的鏈接***"); 
      //循環(huán)監(jiān)聽(tīng)等待客戶端的鏈接 
      while (true){ 
        //調(diào)用accept()方法開(kāi)始監(jiān)聽(tīng)，等待客戶端的鏈接 
        socket = serverSocket.accept(); 
        //創(chuàng)建一個(gè)新的線程 
        ServerThread serverThread = new ServerThread(socket); 
        //啟動(dòng)線程 
        serverThread.start(); 
 
        count++; //統(tǒng)計(jì)客戶端的數(shù)量 
        System.out.println("客戶端的數(shù)量: " + count); 
        InetAddress address = socket.getInetAddress(); 
        System.out.println("當(dāng)前客戶端的IP ： " + address.getHostAddress()); 
      } 
 
    } catch (IOException e) { 
      e.printStackTrace(); 
    } 
  } 
} 

package test.concurrent.socket; 
 
import java.io.*; 
import java.net.Socket; 
 
/** 
 * Created by dong on 15-6-22. 
 * 服務(wù)器端線程處理類 
 */ 
public class ServerThread extends Thread { 
 
  //和本線程相關(guān)的Socket 
  Socket socket = null; 
  public ServerThread(Socket socket){ 
    this.socket = socket; 
  } 
 
  //線程執(zhí)行的操作，響應(yīng)客戶端的請(qǐng)求 
  public void run(){ 
 
    InputStream is = null; 
    InputStreamReader isr = null; 
    BufferedReader br = null; 
 
    OutputStream os = null; 
    PrintWriter pw = null; 
    try { 
 
      //獲取一個(gè)輸入流，并讀取客戶端的信息 
      is = socket.getInputStream(); 
      isr = new InputStreamReader(is); //將字節(jié)流轉(zhuǎn)化為字符流 
      br = new BufferedReader(isr); //添加緩沖 
      String info = null; 
      //循環(huán)讀取數(shù)據(jù) 
      while ((info = br.readLine()) != null){ 
        System.out.println("我是服務(wù)器，客戶端說(shuō): " +info); 
      } 
 
      socket.shutdownInput(); //關(guān)閉輸入流 
 
      //獲取輸出流，響應(yīng)客戶端的請(qǐng)求 
      os = socket.getOutputStream(); 
      pw = new PrintWriter(os); //包裝為打印流 
      pw.write("歡迎你"); 
      pw.flush(); //將緩存輸出 
 
 
    } catch (IOException e) { 
      e.printStackTrace(); 
    }finally { 
 
 
        try { 
          //關(guān)閉資源 
          if (pw != null) 
            pw.close(); 
          if (os != null) 
            os.close(); 
          if (is != null) 
            is.close(); 
          if (isr != null) 
            isr.close(); 
          if (br != null) 
            br.close(); 
          if (socket != null) 
            socket.close(); 
        } catch (IOException e) { 
          e.printStackTrace(); 
 
        } 
 
    } 
 
 
 
  } 
} 

package test.concurrent.socket; 
 
import java.io.*; 
import java.net.Socket; 
 
/** 
 * Created by dong on 15-6-22. 
 * 客戶端 
 */ 
public class Client { 
 
  public static void main(String[] args) { 
 
    try { 
      //1、創(chuàng)建客戶端Socket，指定服務(wù)器端口號(hào)和地址 
      Socket socket = new Socket("localhost",8888); 
      //2、獲取輸出流,向服務(wù)器發(fā)送信息 
      OutputStream os = socket.getOutputStream(); //字節(jié)輸出流 
      PrintWriter pw = new PrintWriter(os); //將輸出流包裝為打印流 
      pw.write("用戶名:tom; 密碼：456"); 
      pw.flush(); 
      socket.shutdownOutput(); //關(guān)閉輸出流 
 
      InputStream is = socket.getInputStream(); 
      InputStreamReader isr = new InputStreamReader(is); 
      BufferedReader br = new BufferedReader(isr); 
 
      String info = null; 
      //循環(huán)讀取 
      while ((info = br.readLine()) != null){ 
        System.out.println("我是客戶端:服務(wù)器說(shuō):" + info); 
      } 
 
      br.close(); 
      is.close(); 
      isr.close(); 
 
 
      pw.close(); 
      os.close(); 
      socket.close(); 
    } catch (IOException e) { 
      e.printStackTrace(); 
    } 
  } 
}