Welcome 微信登录

首页 / 操作系统 / Linux / Java简易聊天室

支持多人向服务器端发送消息并由服务器发送至各个客户端服务器端代码：[java]
  1. /* 
  2. *   @topic:服务器端 
  3. */  
  4. import java.io.*;  
  5. import java.net.*;  
  6. import java.util.List;  
  7. import java.util.ArrayList;  
  8. import java.util.concurrent.ExecutorService;  
  9. import java.util.concurrent.Executors;  
  10. public class Server{  
  11.     //服务器端口   
  12.     private static final int SERVERPORT = 8889 ;  
  13.     //客户端连接   
  14.     private static List<Socket> mClientList = new ArrayList<Socket>（）;  
  15.     //线程池   
  16.     private ExecutorService mExecutorService;  
  17.     //ServerSocket对象   
  18.     private ServerSocket mServerSocket;  
  19.     public static void main（String[] args）{  
  20.         //System.out.println（"Hello Landor！"）;   
  21.         new Server（）;  
  22.     }  
  23.   
  24.     public Server（）{  
  25.         try{  
  26.             //设置服务器端口   
  27.             mServerSocket = new ServerSocket（SERVERPORT）;  
  28.             //创建一个线程池   
  29.             mExecutorService = Executors.newCachedThreadPool（）;  
  30.             System.out.println（"wait client :"）;  
  31.             //用来临时保存客户端连接的Socket对象   
  32.             Socket client = null;  
  33.             while（true）{  
  34.                 //接收客户连接并添加到List中   
  35.                 client = mServerSocket.accept（）;  
  36.                 mClientList.add（client）;  
  37.                 //开启一个客户端线程   
  38.                 mExecutorService.execute（new ThreadServer（client））;  
  39.             }  
  40.         }catch（IOException e）{  
  41.             e.printStackTrace（）;  
  42.         }  
  43.     }  
  44.     //每个客户端单独开启一个线程   
  45.     static class ThreadServer implements Runnable{  
  46.         private Socket mSocket;  
  47.         private BufferedReader mBufferedReader;  
  48.         private PrintWriter mPrintWriter;  
  49.         private String mStrMSG;  
  50.   
  51.         public ThreadServer（Socket socket） throws IOException{  
  52.             this.mSocket = socket;  
  53.             mBufferedReader = new BufferedReader（new InputStreamReader（  
  54.                 socket.getInputStream（）））;  
  55.             mStrMSG = "user: "+this.mSocket.getInetAddress（）+" come total:"  
  56.                     + mClientList.size（）;  
  57.             sendMessage（）;  
  58.         }  
  59.   
  60.         public void run（）{  
  61.             try{  
  62.                 while（（mStrMSG = mBufferedReader.readLine（））！=null）{  
  63.                     if（mStrMSG.trim（）.equals（"exit"））{  
  64.                         //当一个客户端退出时   
  65.                         mClientList.remove（mSocket）;  
  66.                         mBufferedReader.close（）;  
  67.                         mPrintWriter.close（）;  
  68.                         mStrMSG = "user:" + this.mSocket.getInetAddress（）  
  69.                                 + " exit total:" + mClientList.size（）;  
  70.                         mSocket.close（）;  
  71.                         sendMessage（）;  
  72.                         break;  
  73.                     }else{  
  74.                         mStrMSG = mSocket.getInetAddress（） + ":" + mStrMSG;  
  75.                         sendMessage（）;  
  76.                     }  
  77.                 }  
  78.             }catch（IOException e）{  
  79.                 e.printStackTrace（）;  
  80.             }  
  81.         }  
  82.   
  83.         //发送消息给所有客户端   
  84.         private void sendMessage（） throws IOException {  
  85.             System.out.println（mStrMSG）;  
  86.             for（Socket client : mClientList）{  
  87.                 mPrintWriter = new PrintWriter（client.getOutputStream（）,true）;  
  88.                 mPrintWriter.println（mStrMSG）;  
  89.             }  
  90.         }  
  91.     }  
  92. }  
客户端：[java]
  1. import java.io.BufferedReader;  
  2. import java.io.InputStreamReader;  
  3. import java.io.PrintWriter;  
  4. import java.net.Socket;  
  5. import java.util.concurrent.ExecutorService;  
  6. import java.util.concurrent.Executors;  
  7. /* 
  8. *   @topic:客户端 
  9. */  
  10. public class Client{  
  11.     private static final int PORT = 8889;  
  12.     private static ExecutorService exec = Executors.newCachedThreadPool（）;  
  13.   
  14.     public static void main（String[] args） throws Exception{  
  15.         //System.out.println（"Hello Landor！"）;   
  16.         new Client（）;  
  17.     }  
  18.   
  19.     public Client（）{  
  20.         try{  
  21.             Socket socket = new Socket（"localhost",PORT）;  
  22.             exec.execute（new Sender（socket））;  
  23.             BufferedReader br = new BufferedReader（new InputStreamReader（socket.getInputStream（）））;  
  24.             String msg;  
  25.             while（（msg = br.readLine（））！=null）{  
  26.                 System.out.println（msg）;  
  27.             }  
  28.         }catch（Exception e）{  
  29.             e.printStackTrace（）;  
  30.         }  
  31.     }  
  32.   
  33.     //客户端线程获取控制台输入消息   
  34.     static class Sender implements Runnable{  
  35.         private Socket socket;  
  36.           
  37.         public Sender（Socket socket）{  
  38.             this.socket = socket;  
  39.         }  
  40.   
  41.         public void run（）{  
  42.             try{  
  43.                 BufferedReader br = new BufferedReader（new InputStreamReader（System.in））;  
  44.                 PrintWriter pw = new PrintWriter（socket.getOutputStream（）, true）;  
  45.                 while（true）{  
  46.                     String msg = br.readLine（）;  
  47.                     pw.println（msg）;  
  48.                     if （msg.trim（）.equals（"exit"）） {  
  49.                         pw.close（）;  
  50.                         br.close（）;  
  51.                         exec.shutdownNow（）;  
  52.                         break;  
  53.                     }  
  54.                 }  
  55.             }catch（Exception e）{  
  56.                 e.printStackTrace（）;  
  57.             }  
  58.         }  
  59.     }  
  60. }  
版权所有©石家庄振强科技有限公司2024 冀ICP备08103738号-5 网站地图