多個(gè)客戶端--多人聊天+私聊

2019-07-09 22:34 更新

在多人聊天室的基礎(chǔ)上增加了私聊功能。 實(shí)現(xiàn)方法：在Send類中添加name區(qū)別客戶端，用于客戶端；在MyChannel中添加name區(qū)別客戶端連接，用于服務(wù)端。 1.服務(wù)端

  1. import java.io.DataInputStream;
  2. import java.io.DataOutputStream;
  3. import java.io.IOException;
  4. import java.net.ServerSocket;
  5. import java.net.Socket;
  6. import java.util.ArrayList;
  7. import java.util.List;
  10. /**
  11.  * 創(chuàng)建服務(wù)器
  12.  * 發(fā)送數(shù)據(jù)：輸出流
  13.  * 接收數(shù)據(jù)：輸入流
  14.  */
  15. public class MyServer {
  16.     //存放服務(wù)端與客戶端的連接
  17.     private List<MyChannel> all = new ArrayList<>();
  18.     public static void main(String[] args) throws IOException {
  19.         new MyServer().start();
  20.     }
  21.     public void start() throws IOException {
  22.         ServerSocket server = new ServerSocket(8888);
  23.         while(true) {
  24.             Socket socket = server.accept();
  25.             MyChannel myChannel = new MyChannel(socket);
  26.             all.add(myChannel);
  27.             new Thread(myChannel).start();
  28.         }
  29.     }
  30.     /**
  31.      * 一個(gè)客戶端一條道路，
  32.      * 一個(gè)客戶端一個(gè)線程。
  33.      * 1.輸入流
  34.      * 2.輸出流
  35.      * 3.接收數(shù)據(jù)
  36.      * 4.發(fā)送數(shù)據(jù)
  37.      * 成員內(nèi)部類，靜態(tài)方法不能訪問。
  38.      */
  39.     class MyChannel implements Runnable{
  40.         //輸入流
  41.         private DataInputStream dis;
  42.         //輸出流
  43.         private DataOutputStream dos;
  44.         //控制線程的標(biāo)識(shí)符
  45.         private boolean isRunning = true;
  46.         //名稱  給每個(gè)連接命名，區(qū)別客戶端  不考慮重名
  47.         private String name;
  48.         //初始化建立管道
  49.         public MyChannel(Socket socket) {
  50.             try {
  51.                 dis = new DataInputStream(socket.getInputStream());
  52.                 dos = new DataOutputStream(socket.getOutputStream());
  54.                 
  55.                 name = dis.readUTF();
  57.                 
  58.                 send("歡迎您進(jìn)入聊天室！");//發(fā)送給自己客戶端
  59.                 sendOthers(name + "進(jìn)入了聊天室！", true); //發(fā)給其他的客戶端
  60.             } catch (IOException e) {
  61.                 e.printStackTrace();
  62.                 CloseUtil.closeAll(dis, dos);
  63.                 all.remove(this);
  64.                 isRunning = false;
  65.             }
  66.         }
  67.         //讀取數(shù)據(jù)
  68.         private String receive() {
  69.             String msg = "";
  70.             try {
  71.                 msg = dis.readUTF();
  72.             } catch (IOException e) {
  73.                 e.printStackTrace();
  74.                 CloseUtil.closeAll(dis, dos);
  75.                 all.remove(this);
  76.                 isRunning = false;
  77.             }
  78.             return msg;
  79.         }
  80.         //發(fā)送給this數(shù)據(jù)
  81.         private void send(String msg) {
  82.             if(msg == null || msg.equals("")) {
  83.                 return;
  84.             }
  85.             try {
  86.                 dos.writeUTF(msg);
  87.                 dos.flush();
  88.             } catch (IOException e) {
  89.                 e.printStackTrace();
  90.                 CloseUtil.closeAll(dis, dos);
  91.                 all.remove(this);
  92.                 isRunning = false;
  93.             }
  94.         }
  95.         //發(fā)送給其他客戶端
  96.         private void sendOthers(String msg, boolean isSysMsg) {
  97.             //是否為私聊
  98.             if(msg.startsWith("@") && msg.indexOf(":") != -1) {//向一個(gè)特定的人發(fā)消息，格式為@xxx:message
  99.                 //獲取name
  100.                 String name = msg.substring(1, msg.indexOf(":"));
  101.                 //獲取內(nèi)容
  102.                 String content = msg.substring(msg.indexOf(":") + 1);
  103.                 for(MyChannel other:all) {
  104.                     if(other.name.equals(name)) {
  105.                         other.send(this.name + "對(duì)您悄悄地說：" + content);
  106.                     }
  107.                 }
  108.             } else {//向全體發(fā)消息
  109.                 //遍歷容器
  110.                 for(MyChannel other : all) {
  111.                     if(other == this) {
  112.                         continue;
  113.                     }
  114.                     if(isSysMsg) {//是系統(tǒng)消息
  115.                         //發(fā)送給其他客戶端
  116.                         other.send("系統(tǒng)信息：" + msg);
  117.                     } else {//不是系統(tǒng)消息
  118.                         //發(fā)送給其他客戶端
  119.                         other.send(name + "對(duì)所有人說：" + msg);
  120.                     }
  122.                     
  123.                 }
  124.             }
  125.         }
  126.         @Override
  127.         public void run() {
  128.             while(isRunning) {
  129.                 sendOthers(receive(), false);
  130.             }
  131.         }
  132.     }
  133. }

2.客戶端

  1. import java.io.BufferedReader;
  2. import java.io.IOException;
  3. import java.io.InputStreamReader;
  4. import java.net.Socket;
  5. /**
  6.  * 創(chuàng)建客戶端：發(fā)送數(shù)據(jù)+接收數(shù)據(jù)
  7.  * 發(fā)送數(shù)據(jù)：輸出流
  8.  * 接收數(shù)據(jù)：輸入流
  9.  * 輸出流和輸入流應(yīng)該彼此獨(dú)立，使用線程處理。
  10.  * 加入名稱。
  11.  */
  12. public class MyClient {
  13.     public static void main(String[] args) throws IOException {
  14.         //通過名稱判斷不同的客戶 端，存放在Send類中。
  15.         System.out.println("請(qǐng)輸入名稱：");
  16.         BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
  17.         String name = br.readLine();
  18.         if(name.equals("")) {
  19.             return;
  20.         }
  22.         
  23.         Socket client = new Socket("localhost", 8888);
  24.         //發(fā)送  控制臺(tái)輸入并發(fā)送到服務(wù)端
  25.         new Thread(new Send(client, name)).start();//一條路徑
  26.         //接收  接收服務(wù)端數(shù)據(jù)并打印
  27.         new Thread(new Receive(client)).start();//一條路徑
  28.     }
  29. }

發(fā)送數(shù)據(jù)線程

  1. import java.io.BufferedReader;
  2. import java.io.DataOutputStream;
  3. import java.io.IOException;
  4. import java.io.InputStreamReader;
  5. import java.net.Socket;
  8. /**
  9.  * 發(fā)送數(shù)據(jù)  線程
  10.  */
  11. public class Send implements Runnable{
  12.     //控制臺(tái)輸入流
  13.     private BufferedReader console;
  14.     //管道輸出流
  15.     private DataOutputStream dos;
  16.     //控制線程的標(biāo)識(shí)符
  17.     private boolean isRunning = true;
  18.     //名稱  不考慮重名
  19.     private String name;
  20.     //初始化建立管道
  21.     public Send(Socket socket, String name) {
  22.         try {
  23.             console = new BufferedReader(new InputStreamReader(System.in));
  24.             dos = new DataOutputStream(socket.getOutputStream());
  25.             this.name = name;
  26.             send(name);
  27.         } catch (IOException e) {
  28.             e.printStackTrace();
  29.             isRunning = false;
  30.             CloseUtil.closeAll(dos, console);
  31.         }
  32.     }
  34.     
  35.     /**
  36.      * 1.從控制臺(tái)接收數(shù)據(jù)
  37.      * 2.向服務(wù)端發(fā)送數(shù)據(jù)
  38.      */
  39.     //1.從控制臺(tái)接收數(shù)據(jù)
  40.     private String getMsgFromConsole() {
  41.         String msg = "";
  42.         try {
  43.             msg = console.readLine();
  44.         } catch (IOException e) {
  45.             e.printStackTrace();
  46.             isRunning = false;
  47.             CloseUtil.closeAll(dos, console);
  48.         }
  49.         return msg;
  50.     }
  51.     //2.向服務(wù)端發(fā)送數(shù)據(jù)
  52.     private void send(String msg) {
  53.         try {
  54.             if(msg != null && !msg.equals("")) {
  55.                 dos.writeUTF(msg);
  56.                 dos.flush();//強(qiáng)制刷新
  57.             }
  58.         } catch (IOException e) {
  59.             e.printStackTrace();
  60.             isRunning = false;
  61.             CloseUtil.closeAll(dos, console);
  62.         }
  63.     }
  64.     @Override
  65.     public void run() {
  66.         //線程體
  67.         while(isRunning) {
  68.             send(getMsgFromConsole());
  69.         }
  70.     }
  71. }

接收數(shù)據(jù)線程

  1. import java.io.DataInputStream;
  2. import java.io.IOException;
  3. import java.net.Socket;
  6. public class Receive implements Runnable{
  7.     //輸入流
  8.     private DataInputStream dis;
  9.     //線程標(biāo)識(shí)符
  10.     private boolean isRunning = true;
  11.     //初始化建立管道
  12.     public Receive(Socket socket) {
  13.         try {
  14.             dis = new DataInputStream(socket.getInputStream());
  15.         } catch (IOException e) {
  16.             e.printStackTrace();
  17.             isRunning = false;
  18.             CloseUtil.closeAll(dis);
  19.         }
  20.     }
  21.     /**
  22.      * 接收數(shù)據(jù)
  23.      */
  24.     private String receive() {
  25.         String msg = "";
  26.         try {
  27.             msg = dis.readUTF();
  28.         } catch (IOException e) {
  29.             e.printStackTrace();
  30.             isRunning = false;
  31.             CloseUtil.closeAll(dis);
  32.         }
  33.         return msg;
  34.     }
  36.     
  37.     @Override
  38.     public void run() {
  39.         //線程體
  40.         while(isRunning) {
  41.             System.out.println(receive());
  42.         }
  43.     }
  44. }

3.關(guān)閉流工具類

  1. import java.io.Closeable;
  2. import java.io.IOException;
  5. /**
  6.  * 關(guān)閉io流的工具
  7.  */
  8. public class CloseUtil {
  9.     public static void closeAll(Closeable... io) {
  10.         for(Closeable temp : io) {
  11.             try {
  12.                 if(temp != null) {
  13.                     temp.close();
  14.                 }
  15.             } catch (IOException e) {
  16.                 e.printStackTrace();
  17.             }
  18.         }
  19.     }
  20. }
以上內(nèi)容是否對(duì)您有幫助：
在線筆記
App下載
App下載

掃描二維碼

下載編程獅App

公眾號(hào)
微信公眾號(hào)

編程獅公眾號(hào)