Java Socket編程之TCP
阿新 • • 發佈:2017-07-30
null 即將 import tip rate 客戶端信息 連接建立 adl exce
基於TCP的Socket通信:
服務器端:
- 創建一個服務器端Socket,即ServerSocket,指定綁定的端口,並監聽此端口
- 調用accept()方法開始監聽,等待客戶端的連接
- 連接建立後,通過輸入流讀取客戶發送的請求信息
- 通過輸出流向客戶端發送響應信息
- 關閉相關資源
客戶端:
- 創建客戶端Socket,指定服務器地址和端口
- 連接建立後,通過輸出流,向服務器端發送信息
- 獲取輸入流,並讀取服務器端的響應信息
- 關閉資源
例:服務器端:
import java.io.BufferedReader; import java.io.IOException; import java.io.InputStream;import java.io.InputStreamReader; import java.io.OutputStream; import java.io.PrintWriter; import java.net.InetAddress; import java.net.ServerSocket; import java.net.Socket; public class Server { public static void main(String[] args) { try { //1.創建一個服務器端Socket,即ServerSocket,指定綁定的端口,並監聽此端口ServerSocket serverSocket=new ServerSocket(8888); Socket socket=null; //記錄客戶端的數量 int count=0; System.out.println("***服務器即將啟動,等待客戶端的連接***"); //循環監聽等待客戶端的連接 while(true){ //調用accept()方法開始監聽,等待客戶端的連接 socket=serverSocket.accept();//創建一個新的線程 ServerThread serverThread=new ServerThread(socket); //啟動線程 serverThread.start(); count++;//統計客戶端的數量 System.out.println("客戶端的數量:"+count); InetAddress address=socket.getInetAddress(); System.out.println("當前客戶端的IP:"+address.getHostAddress()); } } catch (IOException e) { e.printStackTrace(); } } }
客戶端:
import java.io.BufferedReader; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.io.OutputStream; import java.io.PrintWriter; import java.net.Socket; import java.net.UnknownHostException; public class Client { public static void main(String[] args) { try { //1.創建客戶端Socket,指定服務器地址和端口 Socket socket=new Socket("localhost", 8888); //2.獲取輸出流,向服務器端發送信息 OutputStream os=socket.getOutputStream();//字節輸出流 PrintWriter pw=new PrintWriter(os);//將輸出流包裝為打印流 pw.write("用戶名:alice;密碼:789"); pw.flush(); socket.shutdownOutput();//關閉輸出流 //3.獲取輸入流,並讀取服務器端的響應信息 InputStream is=socket.getInputStream(); BufferedReader br=new BufferedReader(new InputStreamReader(is)); String info=null; while((info=br.readLine())!=null){ System.out.println("我是客戶端,服務器說:"+info); } //4.關閉資源 br.close(); is.close(); pw.close(); os.close(); socket.close(); } catch (UnknownHostException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } } }
服務器線程處理類:
import java.io.BufferedReader; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.io.OutputStream; import java.io.PrintWriter; import java.net.Socket; public class ServerThread extends Thread { // 和本線程相關的Socket Socket socket = null; public ServerThread(Socket socket) { this.socket = socket; } //線程執行的操作,響應客戶端的請求 public void run(){ InputStream is=null; InputStreamReader isr=null; BufferedReader br=null; OutputStream os=null; PrintWriter pw=null; try { //獲取輸入流,並讀取客戶端信息 is = socket.getInputStream(); isr = new InputStreamReader(is); br = new BufferedReader(isr); String info=null; while((info=br.readLine())!=null){//循環讀取客戶端的信息 System.out.println("我是服務器,客戶端說:"+info); } socket.shutdownInput();//關閉輸入流 //獲取輸出流,響應客戶端的請求 os = socket.getOutputStream(); pw = new PrintWriter(os); pw.write("歡迎您!"); pw.flush();//調用flush()方法將緩沖輸出 } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); }finally{ //關閉資源 try { if(pw!=null) pw.close(); if(os!=null) os.close(); if(br!=null) br.close(); if(isr!=null) isr.close(); if(is!=null) is.close(); if(socket!=null) socket.close(); } catch (IOException e) { e.printStackTrace(); } } } }
使用TCP通信傳輸對象:
ObjectOutputStream oos=new ObjectOutputStream(os);
User user=new User(“admin”,”123”);//封裝為對象
oos.writeObject(user);//序列化
Tips:
優先級問題:serverthread.setPriority();//降低優先級,以防運行速度較慢
輸入輸出流問題:同一個Socket,關閉輸出流則會關閉與之關聯的Socket,所以不用關閉輸出流,最後關閉Socket即可。
Java Socket編程之TCP