java多線程實現服務器端與多客戶端之間的通信

用java語言構建一個網絡服務器,實現客戶端和服務器之間通信,實現客戶端擁有獨立線程,互不干擾。

應用多線程來實現服務器與多線程之間的通信的基本步驟

1. 服務器端創建ServerSocket,循環調用accept()等待客戶端鏈接
2. 客戶端創建一個Socket並請求和服務器端鏈接
3. 服務器端接受客戶端請求，創建socekt與該客戶端建立專線鏈接
4. 建立鏈接的socket在一個單獨的線程上對話
5. 服務器繼續等待新的鏈接

服務器端Server.java

 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協議的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(); } } }

服務器端線程處理類ServerThread.java

 package test.concurrent.socket; import java.io.*; import java.net.Socket; /** * Created by dong on 15-6-22. * 服務器端線程處理類*/ 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(); //將緩存輸出} catch (IOException e) { e.printStackTrace(); }finally { try { //關閉資源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(); } } } }

客戶端Client.java

 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、創建客戶端Socket，指定服務器端口號和地址Socket socket = new Socket("localhost",8888); //2、獲取輸出流,向服務器發送信息OutputStream os = socket.getOutputStream(); //字節輸出流PrintWriter pw = new PrintWriter(os); //將輸出流包裝為打印流pw.write("用戶名:tom; 密碼：456"); pw.flush(); socket.shutdownOutput(); //關閉輸出流InputStream is = socket.getInputStream(); InputStreamReader isr = new InputStreamReader(is); BufferedReader br = new BufferedReader(isr); String info = null; //循環讀取while ((info = br.readLine()) != null){ System.out.println("我是客戶端:服務器說:" + info); } br.close(); is.close(); isr.close(); pw.close(); os.close(); socket.close(); } catch (IOException e) { e.printStackTrace(); } } }

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持武林網。