亚洲激情专区-91九色丨porny丨老师-久久久久久久女国产乱让韩-国产精品午夜小视频观看

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

使用java怎么實現一個多人聊天室功能

發布時間:2021-05-14 17:47:14 來源:億速云 閱讀:254 作者:Leah 欄目:編程語言

這篇文章將為大家詳細講解有關使用java怎么實現一個多人聊天室功能,文章內容質量較高,因此小編分享給大家做個參考,希望大家閱讀完這篇文章后對相關知識有一定的了解。

server.java

//server.java
package Socket;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;
import java.util.Scanner;
public class server implements Runnable {// 服務端
  static List<Socket> socketList=new ArrayList<Socket>();
// 讀取 In
  static Socket socket = null;
  static ServerSocket serverSocket = null;
  public server() {// 構造方法
    try {
      serverSocket = new ServerSocket(9999);
    } catch (IOException e) {
      e.printStackTrace();
    }
  }
  public static void main(String[] args) {
    Scanner input = new Scanner(System.in);
    System.out.println("************服務端*************");
    server t = new server();
    int count = 0;
    while (true) {     
      try {
//       System.out.println("端口9999等待被連接......");
        socket = serverSocket.accept();
        count++;
        System.out.println("第" + count + "個客戶已連接");
        socketList.add(socket);
      } catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
      }
      Print p = new Print(socket);
      Thread read = new Thread(t);
      Thread print = new Thread(p);
      read.start();
      print.start();
    }
  }
  @Override
  public void run() {
    // 重寫run方法
    try {
      Thread.sleep(1000);
      BufferedReader in = new BufferedReader(new InputStreamReader(socket
          .getInputStream()));
      while (true) {
        String jieshou = in.readLine();
        System.out.println( jieshou);
        for (int i = 0; i < socketList.size(); i++) {
          Socket socket=socketList.get(i);
          PrintWriter out = new PrintWriter(socket.getOutputStream());
          if (socket!=this.socket) {
            out.println(jieshou);
          }else{
            out.println("(你)"+jieshou);
          }
          out.flush();
        }
      }
    } catch (Exception e) {

      e.printStackTrace();
    }
  }
}
class Print implements Runnable {
  static List<Socket> socketList=new ArrayList<Socket>();
  Scanner input = new Scanner(System.in);
  public Print(Socket s) {// 構造方法
    try {
      socketList.add(s);
    } catch (Exception e) {
      e.printStackTrace();
    }
  }
  @Override
  public void run() {
    try {
      Thread.sleep(1000);
      while (true) {
        String msg = input.next();
      for (int i = 0; i < socketList.size(); i++) {
        Socket socket=socketList.get(i);
        PrintWriter out = new PrintWriter(socket.getOutputStream());
        // System.out.println("對客戶端說:");
        out.println("服務端說:"+msg);
        out.flush();
      }
      }
    } catch (Exception e) {
      // TODO: handle exception
      e.printStackTrace();
    }
  }
}

client.java

//client.java
package Socket;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Scanner;
public class client implements Runnable {// 客戶端
  static Socket socket = null;
  Scanner input = new Scanner(System.in);
  static String name=null;
  public static void main(String[] args) {
    int x=(int)(Math.random()*100);
    client.name="client"+x;
    System.out.println("************客戶端"+x+"*************");
    try {
      socket = new Socket("127.0.0.1", 9999);
      System.out.println("已經連上服務器了");
    } catch (Exception e) {
      e.printStackTrace();
    }
    client t = new client();
    Read r = new Read(socket);
    Thread print = new Thread(t);
    Thread read = new Thread(r);
    print.start();
    read.start();
  }
  @Override
  public void run() {
    try {
      Thread.sleep(1000);     
      PrintWriter out = new PrintWriter(socket.getOutputStream());
      while (true) {
        String msg = input.next();
        out.println(name+"說:"+msg);
        out.flush();
      }
    } catch (Exception e) {
      e.printStackTrace();
    }
  }
}
class Read implements Runnable {
  static Socket socket = null;
  public Read(Socket socket) {
    this.socket = socket;
  }
  @Override
  public void run() {
    try {
      Thread.sleep(1000);
      BufferedReader in = new BufferedReader(new InputStreamReader(socket
          .getInputStream()));
      while (true) {
        System.out.println( in.readLine());
      }
    } catch (Exception e) {
      e.printStackTrace();
    }
  }
}

測試數據一:

服務端程序運行截圖:

使用java怎么實現一個多人聊天室功能

客戶端1程序運行截圖:

使用java怎么實現一個多人聊天室功能 

客戶端2程序運行截圖:

使用java怎么實現一個多人聊天室功能 

由測試數據一可以看出:程序可以實現多人聊天,并且效果和性能還算可以。而且每個客戶端連接進服務器時,都會隨機產生一個隨機數作為自身的標志,避免通話過程中,分辨不清彼此,而導致交流效果不好。

測試數據二:

服務端運行截圖:

使用java怎么實現一個多人聊天室功能 

使用java怎么實現一個多人聊天室功能 

客戶端1程序運行截圖:

使用java怎么實現一個多人聊天室功能

使用java怎么實現一個多人聊天室功能

客戶端2程序運行截圖:

使用java怎么實現一個多人聊天室功能

客戶端3程序運行截圖:

使用java怎么實現一個多人聊天室功能

客戶端4程序運行截圖:

使用java怎么實現一個多人聊天室功能

客戶端5程序運行截圖:

使用java怎么實現一個多人聊天室功能

客戶端6程序運行截圖:

使用java怎么實現一個多人聊天室功能

客戶端7程序運行截圖:

使用java怎么實現一個多人聊天室功能

 客戶端8程序運行截圖:

使用java怎么實現一個多人聊天室功能

客戶端9程序運行截圖:

使用java怎么實現一個多人聊天室功能

客戶端10程序運行截圖:

使用java怎么實現一個多人聊天室功能

Java有哪些集合類

Java中的集合主要分為四類:1、List列表:有序的,可重復的;2、Queue隊列:有序,可重復的;3、Set集合:不可重復;4、Map映射:無序,鍵唯一,值不唯一。

關于使用java怎么實現一個多人聊天室功能就分享到這里了,希望以上內容可以對大家有一定的幫助,可以學到更多知識。如果覺得文章不錯,可以把它分享出去讓更多的人看到。

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

方山县| 唐山市| 五大连池市| 新昌县| 卫辉市| 塔河县| 元阳县| 金溪县| 镇安县| 拉萨市| 澳门| 宁化县| 石景山区| 黔西县| 大厂| 略阳县| 晴隆县| 固原市| 互助| 安阳县| 东乡县| 孝感市| 昌邑市| 仪陇县| 綦江县| 九江市| 德惠市| 合水县| 衡山县| 阿巴嘎旗| 法库县| 陇川县| 商河县| 延庆县| 平潭县| 汽车| 梁平县| 周至县| 泰兴市| 和静县| 襄垣县|