当前位置: 开发笔记 > 运维 > 正文

Java多线程实现聊天客户端和服务器

作者：9527 | 来源：互联网 | 2021-09-03 09:16

这篇文章主要为大家详细介绍了Java多线程聊天客户端和服务器实现代码,具有一定的参考价值，感兴趣的小伙伴们可以参考一下

本文实例为大家分享了java聊天室代码，供大家参考，具体内容如下

主要涉及知识

·Java中GUI程序的编写，包括事件监听机制。
·Java的网络通信编程，ServerSocket，Socket类的使用。
·Java中多线程的编程，Thread类，Runnable接口的使用。

源代码

客户端

package project1; 
 
import java.awt.*; 
import java.awt.event.*; 
import java.io.*; 
import java.net.*; 
 
import javax.swing.*; 
 
public class Client { 
 private JFrame clientFrame; 
 private JLabel IPLabel; 
 private JLabel PortLabel; 
 private JLabel sayLabel; 
 private JLabel nicknameLabel; 
 private JTextField IPText; 
 private JTextField PortText; 
 private JTextField nicknameText; 
 private JTextField sayText; 
 private JButton connectButton; 
 private JButton nicknameButton; 
 private JButton sayButton; 
 private JPanel jPanelNorth; 
 private JPanel jPanelSouth0; 
 private JPanel jPanelSouth1; 
 private JPanel jPanelSouth2; 
 private JTextArea clientTextArea; 
 private JScrollPane scroller; 
 private BufferedReader reader; 
 private PrintWriter writer; 
 private String nickname; 
 
 public static void main(String args[]) { 
  Client aClient = new Client(); 
  aClient.startUp(); 
 } 
 
 // 初始化组件 
 public Client() { 
  nickname = "客户端"; 
 
  clientFrame = new JFrame(); 
  jPanelNorth = new JPanel(); 
  IPLabel = new JLabel("服务器IP", JLabel.LEFT); 
  IPText = new JTextField(10); 
  PortLabel = new JLabel("服务器端口", JLabel.LEFT); 
  PortText = new JTextField(10); 
  cOnnectButton= new JButton("连接"); 
  clientTextArea = new JTextArea(); 
  scroller = new JScrollPane(clientTextArea); 
  jPanelSouth0 = new JPanel(); 
  jPanelSouth1 = new JPanel(); 
  jPanelSouth2 = new JPanel(); 
  nicknameLabel = new JLabel("昵称", JLabel.LEFT); 
  nicknameText = new JTextField(nickname, 30); 
  nicknameButton = new JButton("确认"); 
  sayLabel = new JLabel("消息", JLabel.LEFT); 
  sayText = new JTextField(30); 
  sayButton = new JButton("确认"); 
 } 
 
 // 构建GUI 
 private void buildGUI() { 
  // 窗口的设置 
  clientFrame.setTitle("客户端"); 
  clientFrame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); 
  clientFrame.setSize(550, 550); 
 
  // 北区的组件 
  jPanelNorth.add(IPLabel); 
  jPanelNorth.add(IPText); 
  jPanelNorth.add(PortLabel); 
  jPanelNorth.add(PortText); 
  jPanelNorth.add(connectButton); 
  clientFrame.getContentPane().add(BorderLayout.NORTH, jPanelNorth); 
 
  // 中间的组件 
  clientTextArea.setFocusable(false); 
  scroller.setVerticalScrollBarPolicy(ScrollPaneConstants.VERTICAL_SCROLLBAR_ALWAYS); 
  scroller.setHorizontalScrollBarPolicy(ScrollPaneConstants.HORIZONTAL_SCROLLBAR_NEVER); 
  clientFrame.getContentPane().add(BorderLayout.CENTER, scroller); 
 
  // 南区的组件 
  jPanelSouth1.add(nicknameLabel); 
  jPanelSouth1.add(nicknameText); 
  jPanelSouth1.add(nicknameButton); 
  jPanelSouth2.add(sayLabel); 
  jPanelSouth2.add(sayText); 
  jPanelSouth2.add(sayButton); 
  jPanelSouth0.setLayout(new BoxLayout(jPanelSouth0, BoxLayout.Y_AXIS)); 
  jPanelSouth0.add(jPanelSouth1); 
  jPanelSouth0.add(jPanelSouth2); 
  clientFrame.getContentPane().add(BorderLayout.SOUTH, jPanelSouth0); 
 
  // 设置窗口可见 
  clientFrame.setVisible(true); 
 } 
 
 // 客户端运行 
 public void startUp() { 
  buildGUI(); 
 
  // 接收服务器消息的线程 
  Runnable incomingReader = new Runnable() { 
   @Override 
   public void run() { 
    String message; 
    try { 
     while ((message = reader.readLine()) != null) { 
      clientTextArea.append(message + "\n"); 
     } 
    } catch (Exception ex) { 
     ex.printStackTrace(); 
    } 
   } 
  }; 
 
  // 监听Connect按钮，实现服务器的连接 
  connectButton.addActionListener(new ActionListener() { 
   @Override 
   public void actionPerformed(ActionEvent e) { 
    String aServerIP = IPText.getText(); 
    String aServerPort = PortText.getText(); 
 
    if (aServerIP.equals("") || aServerPort.equals("")) { 
     JOptionPane.showMessageDialog(clientFrame, "请输入 完整的 IP和端口！"); 
    } else { 
     try { 
      @SuppressWarnings("resource") 
      Socket clientSocket = new Socket(aServerIP, Integer.parseInt(aServerPort)); 
      InputStreamReader streamReader = new InputStreamReader(clientSocket.getInputStream()); 
      reader = new BufferedReader(streamReader); 
      writer = new PrintWriter(clientSocket.getOutputStream()); 
 
      clientTextArea.append("服务器已连接...\n"); 
 
      Thread readerThread = new Thread(incomingReader); 
      readerThread.start(); 
     } catch (Exception ex) { 
      JOptionPane.showMessageDialog(clientFrame, "连接不上服务器!\n请确认 IP 和 端口 输入正确。"); 
     } 
    } 
   } 
  }); 
 
  // 监听nickname，设置昵称 
  ActionListener nicknameListener = new ActionListener() { 
   @Override 
   public void actionPerformed(ActionEvent e) { 
    String aText = nicknameText.getText(); 
    if (!aText.equals("")) { 
     nickname = aText; 
    } 
   } 
  }; 
  nicknameButton.addActionListener(nicknameListener); 
  nicknameText.addActionListener(nicknameListener); 
  nicknameText.addFocusListener(new FocusListener() { 
   @Override 
   public void focusGained(FocusEvent e) { 
   } 
 
   @Override 
   public void focusLost(FocusEvent e) { 
    String aText = nicknameText.getText(); 
    if (!aText.equals("")) { 
     nickname = aText; 
    } 
   } 
  }); 
 
  // 发送消息到服务器 
  ActionListener SayListener = new ActionListener() { 
   @Override 
   public void actionPerformed(ActionEvent e) { 
    String aText = sayText.getText(); 
    if (aText.equals("")) { 
     JOptionPane.showMessageDialog(clientFrame, "内容不能为空！"); 
    } else { 
     try { 
      writer.println(nickname + "：" + aText); 
      writer.flush(); 
     } catch (Exception ex) { 
      ex.printStackTrace(); 
     } 
     sayText.setText(""); 
    } 
   } 
  }; 
  sayButton.addActionListener(SayListener); 
  sayText.addActionListener(SayListener); 
 
 } 
 
}

服务器

package project1; 
 
import java.awt.*; 
import java.awt.event.*; 
import java.io.*; 
import java.net.*; 
import java.util.ArrayList; 
import java.util.Iterator; 
import javax.swing.*; 
 
public class Server { 
 private JFrame serverFrame; 
 private JLabel portLabel; 
 private JLabel sayLabel; 
 private JLabel nicknameLabel; 
 private JTextField portText; 
 private JTextField sayText; 
 private JTextField nicknameText; 
 private JButton startButton; 
 private JButton sayButton; 
 private JButton nicknameButton; 
 private JPanel jPanelNorth; 
 private JPanel jPanelSouth0; 
 private JPanel jPanelSouth1; 
 private JPanel jPanelSouth2; 
 private JScrollPane scroller; 
 private JTextArea serverTextArea; 
 private ArrayList clientOutputStreams; 
 private String nickname; 
 
 public static void main(String[] args) { 
  Server aServer = new Server(); 
  aServer.startUp(); 
 } 
 
 // 初始化组件 
 public Server() { 
  nickname = "服务器"; 
 
  serverFrame = new JFrame(); 
  jPanelNorth = new JPanel(); 
  portLabel = new JLabel("端口", JLabel.LEFT); 
  portText = new JTextField(30); 
  startButton = new JButton("开始"); 
  serverTextArea = new JTextArea(); 
  scroller = new JScrollPane(serverTextArea); 
  nicknameLabel = new JLabel("昵称", JLabel.LEFT); 
  nicknameText = new JTextField(nickname, 30); 
  nicknameButton = new JButton("确认"); 
  jPanelSouth0 = new JPanel(); 
  jPanelSouth1 = new JPanel(); 
  jPanelSouth2 = new JPanel(); 
  sayLabel = new JLabel("消息", JLabel.LEFT); 
  sayText = new JTextField(30); 
  sayButton = new JButton("确认"); 
 } 
 
 // 构建GUI 
 private void buildGUI() { 
  // 窗口的设置 
  serverFrame.setTitle("服务器"); 
  serverFrame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); 
  serverFrame.setSize(550, 550); 
 
  // 北区的组件 
  jPanelNorth.add(portLabel); 
  jPanelNorth.add(portText); 
  jPanelNorth.add(startButton); 
  serverFrame.getContentPane().add(BorderLayout.NORTH, jPanelNorth); 
 
  // 中间的组件 
  serverTextArea.setFocusable(false); 
  scroller.setVerticalScrollBarPolicy(ScrollPaneConstants.VERTICAL_SCROLLBAR_ALWAYS); 
  scroller.setHorizontalScrollBarPolicy(ScrollPaneConstants.HORIZONTAL_SCROLLBAR_NEVER); 
  serverFrame.getContentPane().add(BorderLayout.CENTER, scroller); 
 
  // 南区的组件 
  jPanelSouth1.add(nicknameLabel); 
  jPanelSouth1.add(nicknameText); 
  jPanelSouth1.add(nicknameButton); 
  jPanelSouth2.add(sayLabel); 
  jPanelSouth2.add(sayText); 
  jPanelSouth2.add(sayButton); 
  jPanelSouth0.setLayout(new BoxLayout(jPanelSouth0, BoxLayout.Y_AXIS)); 
  jPanelSouth0.add(jPanelSouth1); 
  jPanelSouth0.add(jPanelSouth2); 
  serverFrame.getContentPane().add(BorderLayout.SOUTH, jPanelSouth0); 
 
  // 设置窗口可见 
  serverFrame.setVisible(true); 
 } 
 
 // 服务器运行 
 public void startUp() { 
  buildGUI(); 
 
  // 监听Start按钮，建立端口 
  ActionListener startListener = new ActionListener() { 
   @Override 
   public void actionPerformed(ActionEvent e) { 
    clientOutputStreams = new ArrayList(); 
    String aPort = portText.getText(); 
 
    if (aPort.equals("")) { 
     JOptionPane.showMessageDialog(serverFrame, "请输入正确的端口号！"); 
    } else { 
     try { 
      // 等待客户端连接的线程 
      Runnable serverRunnable = new Runnable() { 
       @Override 
       public void run() { 
        ServerSocket serverSocket; 
        try { 
         serverSocket = new ServerSocket(Integer.parseInt(aPort)); 
         serverTextArea.append("正在等待客户端连接...\n"); 
         while (true) { 
          Socket clientSocket = serverSocket.accept(); 
          serverTextArea.append("客户端已连接...\n"); 
 
          PrintWriter writer = new PrintWriter(clientSocket.getOutputStream()); 
          clientOutputStreams.add(writer); 
 
          Thread t = new Thread(new ClientHandler(clientSocket)); 
          t.start(); 
         } 
        } catch (NumberFormatException | IOException e) { 
         e.printStackTrace(); 
        } 
       } 
      }; 
      Thread serverThread = new Thread(serverRunnable); 
      serverThread.start(); 
     } catch (Exception ex) { 
      ex.printStackTrace(); 
     } 
    } 
   } 
  }; 
  startButton.addActionListener(startListener); 
  portText.addActionListener(startListener); 
 
  // 监听nickname，设置昵称 
  ActionListener nicknameListener = new ActionListener() { 
   @Override 
   public void actionPerformed(ActionEvent e) { 
    String aText = nicknameText.getText(); 
    if (!aText.equals("")) { 
     nickname = aText; 
    } 
   } 
  }; 
  nicknameButton.addActionListener(nicknameListener); 
  nicknameText.addActionListener(nicknameListener); 
  nicknameText.addFocusListener(new FocusListener() { 
   @Override 
   public void focusGained(FocusEvent e) { 
   } 
 
   @Override 
   public void focusLost(FocusEvent e) { 
    String aText = nicknameText.getText(); 
    if (!aText.equals("")) { 
     nickname = aText; 
    } 
   } 
  }); 
 
  // 监听Say按钮，发送消息 
  ActionListener SayListener = new ActionListener() { 
   @Override 
   public void actionPerformed(ActionEvent e) { 
    String aText = sayText.getText(); 
    if (!aText.equals("")) { 
     aText = nickname + "：" + aText; 
     sendToEveryClient(aText); 
     serverTextArea.append(aText + "\n"); 
     sayText.setText(""); 
    } else { 
     JOptionPane.showMessageDialog(serverFrame, "内容不能为空！"); 
    } 
   } 
  }; 
  sayButton.addActionListener(SayListener); 
  sayText.addActionListener(SayListener); 
 } 
 
 // 多客户端的线程 
 public class ClientHandler implements Runnable { 
  BufferedReader bReader; 
  Socket aSocket; 
 
  public ClientHandler(Socket clientSocket) { 
   try { 
    aSocket = clientSocket; 
    InputStreamReader isReader = new InputStreamReader(aSocket.getInputStream()); 
    bReader = new BufferedReader(isReader); 
   } catch (Exception ex) { 
    ex.printStackTrace(); 
   } 
  } 
 
  @Override 
  public void run() { 
   String message; 
   try { 
    while ((message = bReader.readLine()) != null) { 
     sendToEveryClient(message); 
     serverTextArea.append(message + "\n"); 
    } 
   } catch (Exception ex) { 
    ex.printStackTrace(); 
   } 
  } 
 } 
 
 // 发送消息给所有客户端的方法 
 private void sendToEveryClient(String message) { 
  Iterator it = clientOutputStreams.iterator(); 
  while (it.hasNext()) { 
   try { 
    PrintWriter writer = (PrintWriter) it.next(); 
    writer.println(message); 
    writer.flush(); 
   } catch (Exception ex) { 
    ex.printStackTrace(); 
   } 
  } 
 } 
 
}

GUI运行截图：

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。

服务器

推荐阅读

linux
解决getallheaders函数导致的500错误及8种服务器性能优化策略

本文探讨了解决getallheaders函数引起的服务器500错误的方法，并介绍八种有效的服务器性能优化技术，包括内存数据库的应用、Spark RDD的使用、缓存策略的实施、SSD的引入、数据库优化、IO模型的选择、多核处理策略以及分布式部署方案。 ... [详细]

蜡笔小新 2024-12-03 18:26:35
路由器
利用 Linux 构建高效网络路由器

本文介绍了如何在 Linux 系统上构建网络路由器，特别关注于使用 Zebra 软件实现动态路由功能。通过具体的案例，展示了如何配置 RIP 和 OSPF 协议，以及如何利用多路由器查看工具（MRLG）监控网络状态。 ... [详细]

蜡笔小新 2024-12-03 17:33:54
路由器
PHP中的Content-Type含义及其功能解析

在PHP中，Content-Type头部信息用于定义资源的媒体类型（MIME类型），这对于确保客户端正确解析服务器响应至关重要。 ... [详细]

蜡笔小新 2024-12-03 11:59:01
tomcat
解析程序员与软件工程师的角色差异

本文深入探讨了程序员与软件工程师之间的主要区别，包括它们的职业定位、技能要求以及工作内容等方面的不同，旨在帮助读者更好地理解这两个角色的特点。 ... [详细]

蜡笔小新 2024-12-03 11:53:09
server
linux下ipvsadm命令,Linux命令：ipvsadm

ipvsadm命令简介：ipvsadm是LVS在应用层的管理命令，我们可以通过这个命令去管理LVS的配置。在fedora14、Linux6.0之后系统中 ... [详细]

蜡笔小新 2024-12-03 11:30:18
server
MySQL员工数据库管理指南

本文详细介绍了MySQL中关于员工数据库的基础知识、操作技巧以及常见问题的解决方案，适合初学者和有一定基础的用户阅读。 ... [详细]

蜡笔小新 2024-12-03 11:15:05
server
深入解析C/S与B/S架构的差异及其发展趋势

本文详细探讨了当前主流的两种系统架构——C/S（客户端/服务器）与B/S（浏览器/服务器）架构的特点、优缺点及未来的发展趋势。 ... [详细]

蜡笔小新 2024-12-03 11:04:55
server
开发笔记:新手DVWACSRF

开发笔记:新手DVWACSRF ... [详细]

蜡笔小新 2024-12-03 10:33:16
server
深入理解JavaScript中的Ajax与跨域解决方案

本文详细介绍了如何手动编写兼容IE的Ajax函数，以及探讨了跨域请求的实现方法和原理，包括JSONP和服务器端设置HTTP头部等技术。 ... [详细]

蜡笔小新 2024-12-03 09:41:30
server
php中Redis的应用消息传递的示例代码分享（图）

消息传递这一应用广泛存在于各个网站中，这个功能也是一个网站必不可少的。本文主要介绍了php中Redis的应用--消息传递。下面跟着小编一起来看下吧阅读目录1、摘要2、实现方法3、一 ... [详细]

蜡笔小新 2024-12-03 09:16:38
server
Java WebSocket 实时通信服务端实现

本文介绍了一个基于Java的WebSocket实时通信服务端代码示例，包括客户端连接管理、消息接收与分发等功能。 ... [详细]

蜡笔小新 2024-12-03 06:46:46
server
探索大数据与人工智能的未来潜力

在近期的百度大数据开放会议上，计算机科学领域的专家怀进鹏教授的演讲引发了广泛关注。尽管演讲内容高深复杂，但对于那些对计算机科学和人工智能领域有所了解的人来说，这场演讲无疑揭示了未来技术发展的无限可能性。 ... [详细]

蜡笔小新 2024-12-02 23:18:47
linux
Linux环境下MySQL主从复制机制详解与实践

本文详细介绍了MySQL在Linux环境下的主从复制技术，包括单向复制、双向复制、级联复制及异步复制等多种模式。主从复制架构中，一个主服务器（Master）可与一个或多个从服务器（Slave）建立连接，实现数据的实时同步。 ... [详细]

蜡笔小新 2024-12-02 23:08:49
server
php怎么重新发布网站(2023年最新分享)

php怎么重新发布网站(2023年最新分享) ... [详细]

蜡笔小新 2024-12-02 22:13:15
sudo
Redis 教程01 —— 如何安装 Redis

本文介绍了 Redis，这是一个由 Salvatore Sanfilippo 开发的键值存储系统。Redis 是一款开源且高性能的数据库，支持多种数据结构存储，并提供了丰富的功能和特性。 ... [详细]

蜡笔小新 2024-12-02 21:28:54

9527

这个家伙很懒，什么也没留下！

Tags | 热门标签

RankList | 热门文章