快捷導(dǎo)航

Java通過Socket實(shí)現(xiàn)簡單多人聊天室

更新時(shí)間：2021年04月07日 14:05:48 作者：haki

這篇文章主要為大家詳細(xì)介紹了Java通過Socket實(shí)現(xiàn)簡單多人聊天室，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下

本文實(shí)例為大家分享了Java通過Socket實(shí)現(xiàn)多人聊天室的具體代碼，供大家參考，具體內(nèi)容如下

Socket可以實(shí)現(xiàn)網(wǎng)絡(luò)上兩個(gè)程序通過雙向通道進(jìn)行數(shù)據(jù)的交換，此外它是Java中網(wǎng)絡(luò)TCP/IP協(xié)議的封裝，例如可以進(jìn)行網(wǎng)絡(luò)通信等等，下面我們就來簡單寫一下多人聊天室。

首先來分析一下要實(shí)現(xiàn)的流程

首先建立一個(gè)服務(wù)器端，構(gòu)建ServerSocket并綁定端口
創(chuàng)建socket客戶端，連接到指定ip以及其端口
然后使用accept阻塞接收socket發(fā)出的連接請求
獲取連接后的socket客戶端的輸入流和輸出流
根據(jù)輸入流和輸出流進(jìn)行兩者數(shù)據(jù)的通信

值得一提是：該Socket是同步阻塞的，因此在socket客戶端需要進(jìn)行創(chuàng)建一個(gè)線程，來分別進(jìn)行向服務(wù)器輸出，和接收服務(wù)器傳輸?shù)臄?shù)據(jù)。要解決同步阻塞這個(gè)問題可以去了解JAVA NIO。

Socket客戶端代碼如下:

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
 
public class Client{
 
 public static void main(String[] args) throws IOException {
 //創(chuàng)建連接指定Ip和端口的socket
 Socket socket = new Socket("127.0.0.1",5200);
 //獲取系統(tǒng)標(biāo)準(zhǔn)輸入流
 BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
 PrintWriter out = new PrintWriter(socket.getOutputStream());
 BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
 //創(chuàng)建一個(gè)線程用于讀取服務(wù)器的信息
 new Thread(new Runnable() {
  @Override
  public void run() {
  try {
   while (true){
   System.out.println(in.readLine());
   }
  } catch (IOException e) {
   e.printStackTrace();
  }
  }
 }).start();
 //寫信息給客戶端
 String line = reader.readLine();
 while (!"end".equalsIgnoreCase(line)){
  //將從鍵盤獲取的信息給到服務(wù)器
  out.println(line);
  out.flush();
  //顯示輸入的信息
  line = reader.readLine();
 }
 out.close();
 in.close();
 socket.close();
 
 }
}

由于要接收多個(gè)客戶端的請求，因此服務(wù)端需要多個(gè)線程進(jìn)行分別來接收客戶端的請求。

Socket服務(wù)端代碼如下：

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.List;
import java.util.Vector;
 
public class Servers {
 //將接收到的socket變成一個(gè)集合
 protected static List<Socket> sockets = new Vector<>();
 
 public static void main(String[] args) throws IOException {
 //創(chuàng)建服務(wù)端
 ServerSocket server = new ServerSocket(5200);
 boolean flag = true;
 //接受客戶端請求
 while (flag){
  try {
  //阻塞等待客戶端的連接
  Socket accept = server.accept();
  synchronized (sockets){
  sockets.add(accept);
  }
  //多個(gè)服務(wù)器線程進(jìn)行對客戶端的響應(yīng)
  Thread thread = new Thread(new ServerThead(accept));
  thread.start();
  //捕獲異常。
  }catch (Exception e){
  flag = false;
  e.printStackTrace();
  }
 }
 //關(guān)閉服務(wù)器
 server.close();
 }
 
}

Server線程代碼如下：

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
 
/**
 * 服務(wù)器線程，主要來處理多個(gè)客戶端的請求
 */
public class ServerThead extends Servers implements Runnable{
 
 Socket socket;
 String socketName;
 
 public ServerThead(Socket socket){
 this.socket = socket;
 }
 @Override
 public void run() {
 try {
  BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
  //設(shè)置該客戶端的端點(diǎn)地址
  socketName = socket.getRemoteSocketAddress().toString();
  System.out.println("Client@"+socketName+"已加入聊天");
  print("Client@"+socketName+"已加入聊天");
  boolean flag = true;
  while (flag)
  {
  //阻塞，等待該客戶端的輸出流
  String line = reader.readLine();
  //若客戶端退出，則退出連接。
  if (line == null){
   flag = false;
   continue;
  }
  String msg = "Client@"+socketName+":"+line;
  System.out.println(msg);
  //向在線客戶端輸出信息
  print(msg);
  }
 
  closeConnect();
 } catch (IOException e) {
  try {
  closeConnect();
  } catch (IOException e1) {
  e1.printStackTrace();
  }
 }
 }
 /**
 * 向所有在線客戶端socket轉(zhuǎn)發(fā)消息
 * @param msg
 * @throws IOException
 */
 private void print(String msg) throws IOException {
 PrintWriter out = null;
 synchronized (sockets){
 for (Socket sc : sockets){
  out = new PrintWriter(sc.getOutputStream());
  out.println(msg);
  out.flush();
 }
 }
 }
 /**
 * 關(guān)閉該socket的連接
 * @throws IOException
 */
 public void closeConnect() throws IOException {
 System.out.println("Client@"+socketName+"已退出聊天");
 print("Client@"+socketName+"已退出聊天");
 //移除沒連接上的客戶端
 synchronized (sockets){
  sockets.remove(socket);
 }
 socket.close();
 }
}

由于要接收多個(gè)客戶端的信息，并轉(zhuǎn)發(fā)到每一個(gè)已經(jīng)連接上的客戶端，因此創(chuàng)建了一個(gè)Vector集合來保存每一個(gè)客戶端Socket,由于是多個(gè)線程同時(shí)對這個(gè)Vector集合進(jìn)行操作，因此加上synchronized關(guān)鍵字保證同步安全。

先運(yùn)行服務(wù)器端，然后在運(yùn)行多個(gè)客戶端就可以進(jìn)行多人聊天了。

下面是運(yùn)行的結(jié)果。