java實(shí)現(xiàn)多客戶(hù)聊天功能

更新時(shí)間：2021年08月27日 12:24:51 作者：最好的碩碩

這篇文章主要為大家詳細(xì)介紹了java實(shí)現(xiàn)多客戶(hù)聊天功能，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下

java 實(shí)現(xiàn)多客戶(hù)端聊天（TCP），供大家參考，具體內(nèi)容如下

1. 編程思想：

1）、要想實(shí)現(xiàn)多客戶(hù)端聊天，首先需要有多個(gè)客戶(hù)端，而這些客戶(hù)端需要隨時(shí)發(fā)送消息和接受消息，所以收發(fā)消息需要放入不同的線(xiàn)程中。

2）、多客戶(hù)聊天并不是多個(gè)客戶(hù)之間進(jìn)行兩兩通信，而是需要所有客戶(hù)端與服務(wù)端進(jìn)行交互，再由服務(wù)端統(tǒng)一下發(fā)信息到其他參與聊天的客戶(hù)端。

2. 代碼實(shí)現(xiàn)：

2.1 實(shí)現(xiàn)專(zhuān)用于接收消息的子線(xiàn)程ReceiveThread

將接收消息和發(fā)送消息分為兩個(gè)線(xiàn)程，其中將發(fā)送消息寫(xiě)入主線(xiàn)程中，開(kāi)啟新的線(xiàn)程用于接收消息。

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.Socket;

public class ReceiveThread extends Thread{

 private Socket socket; //私有的成員變量，套接字
 
 public ReceiveThread(Socket socket) {
  this.socket = socket;
 }

 @Override
 public void run() {
  BufferedReader br = null;//使用帶緩沖區(qū)的字符輸入流接收信息
  try {
   br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
  } catch (IOException e) {
   e.printStackTrace();
  }
  while(true){
   try {
    System.out.println(br.readLine());
   } catch (IOException e) {
    e.printStackTrace();
   }
  }
 }
}

2.2 客戶(hù)端代碼

import java.io.IOException;
import java.io.PrintStream;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Scanner;

public class Client {
 @SuppressWarnings("all")
 public static void main(String[] args) throws UnknownHostException, IOException {  
        //ip：需要連接的服務(wù)端所在的ip
        //端口：客戶(hù)端連接的端口必須和服務(wù)端端口一致
  Socket socket = new Socket("192.168.*.*",8080);
  Scanner scan = new Scanner(System.in);
  new ReceiveThread(socket).start();
  //發(fā)送給服務(wù)端信息
  while(true ){
   PrintStream ps = new PrintStream(socket.getOutputStream());
   ps.println("一號(hào)："+scan.next());  
  }
 }
}

注：

1）、客戶(hù)端代碼可以在局域網(wǎng)下的多臺(tái)電腦上運(yùn)行，只需要將ip地址改為服務(wù)端的ip，就能夠連接。

2）、如果想要使用同臺(tái)電腦完成一個(gè)服務(wù)端和兩個(gè)客戶(hù)端運(yùn)行，進(jìn)行測(cè)試多人聊天，可創(chuàng)建客戶(hù)端2，使用本機(jī)ip

Socket socket = new Socket("127.0.0.1",8080);
Scanner scan = new Scanner(System.in);
new ReceiveThread(socket).start();
//發(fā)送給服務(wù)端信息
while(true ){
    PrintStream ps = new PrintStream(socket.getOutputStream());
    ps.println("二號(hào)："+scan.next());  
}

2.3 服務(wù)端接收和轉(zhuǎn)發(fā)信息的線(xiàn)程ServerThread

服務(wù)端在每一個(gè)客戶(hù)端進(jìn)行連接時(shí)，都會(huì)產(chǎn)生一個(gè)線(xiàn)程，用于服務(wù)這個(gè)客戶(hù)，負(fù)責(zé)接收該客戶(hù)發(fā)送的信息，并轉(zhuǎn)發(fā)到參與多人聊天的其他客戶(hù)。

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.InetAddress;
import java.net.Socket;
import java.util.Map.Entry;
import java.util.Set;

public class ServerThread  extends Thread{

 private Socket socket;
 
 public ServerThread(Socket socket) {
  this.socket = socket;
 }
 @Override
 public void run() {
  BufferedReader br = null;
  String str=null;
  try {
   br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
  } catch (IOException e) {
   e.printStackTrace();
  }
  while(true){
   try {
    str=br.readLine();
                //在服務(wù)端輸出，可以監(jiān)測(cè)到所有人的聊天信息。
    System.out.println(str);
    
    //發(fā)送到其他客戶(hù)端
    Set<Entry<InetAddress, Socket>> entrySet = Server.map.entrySet();
    for (Entry<InetAddress, Socket> entry : entrySet) {
     InetAddress key = entry.getKey();
     Socket value = entry.getValue();
     if(socket.getInetAddress()!=key){
      PrintStream printStream = new PrintStream(value.getOutputStream());
      printStream.println(str);
     }
    }
    
   } catch (IOException e) {
    e.printStackTrace();
   }
  }
 }
}

2.4 服務(wù)端代碼

import java.io.IOException;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.concurrent.ConcurrentHashMap;

public class Server {
 @SuppressWarnings("all")
    
 public static ConcurrentHashMap<InetAddress, Socket> map =new ConcurrentHashMap<>();
 public static void main(String[] args) throws IOException, InterruptedException {

  //創(chuàng)建服務(wù)端的ServerSocket
  ServerSocket server = new ServerSocket(8080);
  while(true){
            //接收到客戶(hù)連接就創(chuàng)建一個(gè)對(duì)應(yīng)的套接字
   Socket socket = server.accept();
            //獲取該客戶(hù)的ip
   InetAddress inetAddress = socket.getInetAddress();
   //將該客戶(hù)的ip和套接字裝入map集合
   map.put(inetAddress, socket);
            //創(chuàng)建新的線(xiàn)程服務(wù)該客戶(hù)
   new ServerThread(socket).start();
  }  
 }
}

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: