devbox
羊村懒王
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

Java 多人聊天室_java多人聊天室

作者：羊村懒王 | 2024-02-17 02:27:32

赞

踩

java多人聊天室

Java实训做的多人聊天室，效果如图：

 功能：

  • 能够实现多个客户端之间的互相聊天，服务端来负责接收数据和转发数据。
  • 每个客户端可以自己设置和修改自己的名称，并传给服务器让其他客户端知道。
  • 当有客户端加入和退出时，群聊里每个客户端都有提示。（优化了异常检测，意外断开终止时也能不报错并提示用户xxx退出聊天室）
  • 当服务器异常断开或正常退出，客户端都可以提示并且程序不报错。
  • 服务端能够实时的显示在线的人数、  

关键技术： 

  • 集合（服务端并不是对一个客户端进行操作，是多个客户端之间来回通信充当转发数据的功能。服务端需要创建一个集合用来存放服务端连接对象。这样只要监听到客户端发送过来的数据，就可以遍历整个集合，转发给每一个客户端）
  • 多线程（客户端通过主线程来发送数据，还需要再启动一个线程来不断循环接收服务端转发过来的消息。服务端主线程使用while循环来不停的接收socket连接，然后为每个客户端的socket通道分配一个子线程接收）
  • 网络TCP传输的嵌套字socket（实现客户端和服务端之间的数据传输，选择TCP更安全可靠）
  • IO流（通道间的数据传输需要用到io流）

服务端代码：

  1. import javax.swing.*;
  2. import java.awt.*;
  3. import java.awt.event.ActionEvent;
  4. import java.awt.event.ActionListener;
  5. import java.awt.event.WindowAdapter;
  6. import java.awt.event.WindowEvent;
  7. import java.io.*;
  8. import java.net.ServerSocket;
  9. import java.net.Socket;
  10. import java.net.SocketException;
  11. import java.util.ArrayList;
  12. import java.util.Iterator;
  13.  
  14. public class ServerChar extends JFrame {
  15.     private static final int PORT = 8888;
  16.     JTextArea jta = new JTextArea();
  17.     JScrollPane jsp = new JScrollPane(jta);
  18.     private JPanel south = new JPanel(); //面板
  19.     private JLabel jb = new JLabel();
  20.     private JButton stopBtn = new JButton("停止服务器");
  21.  
  22.     private boolean isStart = false;//服务器是否启动
  23.  
  24.     private ServerSocket serverSocket = null;
  25.  
  26.     private ArrayList<ClientConn> clientConn = new ArrayList<>();
  27.     private int peopleOnline = 0;
  28.  
  29.     public ServerChar(){
  30.         this.setTitle("服务端");
  31.         this.add(jsp, BorderLayout.CENTER);
  32.         jta.setEditable(false); //不能输入
  33.         south.add(jb);
  34.         jb.setText("聊天室在线人数: "+peopleOnline+"   ");
  35.         south.add(stopBtn);
  36.         this.add(south,BorderLayout.SOUTH);
  37.  
  38.         stopBtn.addActionListener(new ActionListener() {
  39.             @Override
  40.             public void actionPerformed(ActionEvent e) {
  41.                 isStart = false;
  42.                     try {
  43.                         if (serverSocket != null){
  44.                             serverSocket.close();
  45.                             isStart = false;
  46.                         }
  47.                     } catch (IOException ex) {
  48.                         ex.printStackTrace();
  49.                     }finally {
  50.                         System.exit(0);
  51.                     }
  52.             }
  53.         });
  54.  
  55.         this.addWindowListener(new WindowAdapter() {
  56.             @Override
  57.             public void windowClosing(WindowEvent e) {
  58.                 isStart = false;
  59.                 try {
  60.                     if (serverSocket != null){
  61.                         serverSocket.close();
  62.                         isStart = false;
  63.                     }
  64.                 } catch (IOException ex) {
  65.                     ex.printStackTrace();
  66.                 }finally {
  67.                     System.exit(0);
  68.                 }
  69.             }
  70.         });
  71.         this.setBounds(200,100,500,500);
  72.         this.setVisible(true);
  73.         startServer();
  74.     }
  75.  
  76.     //服务器启动的方法
  77.     public void startServer()  {
  78.         try{
  79.             try {
  80.                 serverSocket = new ServerSocket(PORT);
  81.                 isStart = true;
  82.                 jta.append("服务器已启动,等待客户端连接..."+System.lineSeparator());
  83.                 } catch (IOException e) {
  84.                     e.printStackTrace();
  85.                 }
  86.             while(isStart){
  87.                 Socket socket = serverSocket.accept();
  88.                 clientConn.add(new ClientConn(socket));
  89.                 jta.append("客户端"+"["+socket.getInetAddress()+"-"+socket.getPort()+"]"+"加入聊天室"+System.lineSeparator());
  90.                 jb.setText("聊天室在线人数: "+(++peopleOnline)+"   ");
  91.             }
  92.         }catch (SocketException e){
  93.             System.out.println("服务器中断");
  94.         }catch (IOException e){
  95.             e.printStackTrace();
  96.         }
  97.     }
  98.  
  99.     //这个对象属于服务器端的连接对象
  100.     class ClientConn implements Runnable{
  101.         Socket socket = null;
  102.         //构造器 传入socket
  103.         public ClientConn(Socket socket){
  104.             this.socket=socket;
  105.             (new Thread(this)).start();
  106.         }
  107.  
  108.         @Override//同时接收客户端信息
  109.         public void run() {
  110.             String name = socket.getInetAddress()+"-"+socket.getPort();
  111.             try {
  112.             DataInputStream dis = new DataInputStream(socket.getInputStream());
  113.             while (isStart){
  114.                 //读过来
  115.                 String str = dis.readUTF();
  116.                 if (str.startsWith("##")){
  117.                     name = str.substring("##".length(),str.length());
  118.                     jta.append("客户端"+"["+socket.getInetAddress()+"-"+socket.getPort()+"]"+"将名称设置为"+"["+name+"]"+System.lineSeparator());
  119.                     Iterator<ClientConn> it = clientConn.iterator();
  120.                     while(it.hasNext()) {
  121.                         ClientConn o = it.next();
  122.                         o.send(name+"加入了聊天室"+System.lineSeparator());
  123.                     }
  124.                 }else{
  125.                     jta.append("["+name+"]"+"说:"+str+System.lineSeparator());
  126.                     //发过去
  127.                     String strSend = "["+name+"]"+"说:"+str+System.lineSeparator();
  128.                     //要遍历所有的客户端来发送 遍历ccList 调用send方法
  129.                     Iterator<ClientConn> it = clientConn.iterator();
  130.                     while(it.hasNext()) {
  131.                         ClientConn o = it.next();
  132.                         o.send(strSend);
  133.                     }
  134.                 }
  135.                 }
  136.             } catch (SocketException e){
  137.                 jta.append("客户端"+"["+name+"]"+"下线了"+System.lineSeparator());
  138.                 Iterator<ClientConn> it = clientConn.iterator();
  139.                 while(it.hasNext()) {
  140.                     ClientConn o = it.next();
  141.                     o.send(name+"退出了聊天室"+System.lineSeparator());
  142.                 }
  143.                 jb.setText("聊天室在线人数: "+(--peopleOnline)+"   ");
  144.             } catch (IOException e) {
  145.             e.printStackTrace();
  146.             }
  147.     }
  148.  
  149.         //对每个连接发送信息的方法
  150.         public void send(String str){
  151.             try {
  152.                 DataOutputStream dos = new DataOutputStream(this.socket.getOutputStream());
  153.                 dos.writeUTF(str);
  154.                 dos.flush();
  155.             } catch (IOException e) {
  156.                 e.printStackTrace();
  157.             }
  158.         }
  159.     }
  160.  
  161.     public static void main(String[] args) {
  162.         new ServerChar();
  163.     }
  164.  
  165. }

 客户端代码： 

  1. import javax.swing.*;
  2. import java.awt.*;
  3. import java.awt.event.ActionEvent;
  4. import java.awt.event.ActionListener;
  5. import java.awt.event.KeyEvent;
  6. import java.awt.event.KeyListener;
  7. import java.io.DataInputStream;
  8. import java.io.DataOutputStream;
  9. import java.io.IOException;
  10. import java.net.Socket;
  11. import java.net.SocketException;
  12.  
  13. public class ClientChar extends JFrame implements KeyListener{
  14.     public static void main(String[] args) throws IOException {
  15.         new ClientChar().init();
  16.     }
  17.     //属性
  18.     private boolean isConn = false;
  19.     String name = "";
  20.  
  21.     private JTextArea jta;//文本域
  22.     private JScrollPane jsp;//滚动条
  23.     private JPanel jp;//面板
  24.     private JTextField jtf;//文本框
  25.     private JButton jb1;//发送信息
  26.     //通道
  27.     private Socket socket = null;
  28.     private static final String CONNSTR = "127.0.0.1";
  29.     private static final int CONNPORT = 8888;
  30.     //流
  31.     private DataOutputStream dos = null;
  32.  
  33.     //构造器
  34.     public ClientChar(){
  35.         //初始化组件
  36.         jta = new JTextArea();
  37.         jta.setEditable(false);//设置为不可编辑
  38.         jsp = new JScrollPane(jta); //让文本域实现滚动效果
  39.         //面板
  40.         jp = new JPanel();
  41.         jtf = new JTextField(15);
  42.         jb1 = new JButton("发送信息");
  43.     }
  44.  
  45.     public void init(){
  46.         //将文本框和按钮添加到面板中
  47.         jp.add(jtf);
  48.         jtf.addKeyListener(this);
  49.         jp.add(jb1);
  50.         jb1.addActionListener(new ActionListener() {
  51.             @Override
  52.             public void actionPerformed(ActionEvent e) {
  53.                 //获取文本框内容
  54.                 String text = jtf.getText();
  55.                 sendMessage(text);
  56.                 if (text.length()==0){
  57.                     return;
  58.                 }
  59.                 //拼接内容并发送
  60.                 jtf.setText("");
  61.             }
  62.         });
  63.  
  64.         //将滚动条与面板全部添加到窗口中
  65.         this.add(jsp, BorderLayout.CENTER);
  66.         this.add(jp, BorderLayout.SOUTH);
  67.  
  68.         //设置窗口
  69.         this.setBounds(700, 300, 300, 300);
  70.         this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
  71.         this.setVisible(true);
  72.  
  73.         try {
  74.             socket = new Socket(CONNSTR,CONNPORT);
  75.             isConn = true;
  76.             name = JOptionPane.showInputDialog(this.getContentPane(), "请输入你的用户名:");
  77.             dos = new DataOutputStream(socket.getOutputStream());
  78.             dos.writeUTF("##"+name);
  79.             dos.flush();
  80.         } catch (IOException e) {
  81.             e.printStackTrace();
  82.         }
  83.  
  84.         this.setTitle("聊天室-"+name);
  85.         //启动线程类接收
  86.         new Thread(new Receive()).start();
  87.  
  88.     }
  89.  
  90.     //发送信息到服务器的方法
  91.     private void sendMessage(String str) {
  92.         try {
  93.             if(jtf.getText().length()==0){
  94.                 return;
  95.             }
  96.             dos = new DataOutputStream(socket.getOutputStream());
  97.             dos.writeUTF(str);
  98.             dos.flush();
  99.         } catch (IOException e) {
  100.             e.printStackTrace();
  101.         }
  102.  
  103.     }
  104.     @Override
  105.     public void keyPressed(KeyEvent e) {
  106.         if (e.getKeyCode()==KeyEvent.VK_ENTER){
  107.             //回去输入框的内容
  108.             String text = jtf.getText();
  109.             //调用发送信息的方法
  110.             sendMessage(text);
  111.             //发送完后让输入框为空
  112.             jtf.setText("");
  113.         }
  114.     }
  115.  
  116.     //多线程的类，实现了Runnable接口 用来接收
  117.     class Receive implements Runnable{
  118.         @Override
  119.         public void run() {
  120.             try {
  121.                 while (isConn) {
  122.                     DataInputStream dis = new DataInputStream(socket.getInputStream());
  123.                     String str = dis.readUTF(); //从管道读出服务端转发的数据 放到文本框里面
  124.                     jta.append(str);
  125.                     }
  126.                 } catch (SocketException e) {
  127.                     System.out.println("服务器终止");
  128.                     jta.append("服务器终止"+System.lineSeparator());
  129.                 } catch (IOException e) {
  130.                     e.printStackTrace();
  131.                 }
  132.             }
  133.         }
  134.  
  135.     @Override
  136.     public void keyReleased(KeyEvent e) {
  137.  
  138.     }
  139.  
  140.     @Override
  141.     public void keyTyped(KeyEvent e) {
  142.  
  143.     }
  144. }

如果有帮助的话麻烦点赞收藏，谢谢。你的支持是对我最大的鼓励。

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/羊村懒王/article/detail/99161
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号