Java项目如何实现一个在线实时聊天室功能？

本文共计803个文字，预计阅读时间需要4分钟。

Java练习项目——在线聊天室，话不多说，先上源码：server端：import java.io.*;import java.net.*;import java.util.*;

public class ChatServer { boolean stated=false; ServerSocket ss=null; // 创建集合，存储子线程 List threads=new ArrayList();}

Java练习项目——在线聊天室

话不多说，先上源码：

server端：

import java.io.*; import java.net.*; import java.util.*; public class ChatServer { boolean stated = false; ServerSocket ss = null; //创建集合，存储子线程 List<Client> clients = new ArrayList<>(); public static void main(String[] args){ new ChatServer().start(); } public void start() { try { ss = new ServerSocket(8888); stated = true; }catch (BindException e) { System.out.println("running ..."); System.exit(0); }catch (IOException e){ e.printStackTrace(); } try { //stated = true; while (stated) { Socket s = ss.accept(); Client c = new Client(s); System.out.println("a client connecied!"); new Thread(c).start(); clients.add(c); //dis.close(); } }catch (IOException e){ e.printStackTrace(); //System.out.println("closed!"); }finally { try { ss.close(); } catch (IOException e) { // TODO 自动生成的 catch 块 e.printStackTrace(); } } } class Client implements Runnable { private Socket s; private DataInputStream dis = null; private boolean bConnected = false; private DataOutputStream dos = null; public Client(Socket s) { this.s = s; try { dis = new DataInputStream(s.getInputStream()); dos = new DataOutputStream(s.getOutputStream()); bConnected = true; } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } public void send(String str) { try { dos.writeUTF(str); } catch (IOException e) { clients.remove(this); System.out.println("对方退出了，list去除！"); } } public void run() { try { while(bConnected) { String str = dis.readUTF(); System.out.println(str); //将接受的数据发送给客户端 for (int i=0;i<clients.size();i++) { Client c = clients.get(i); c.send(str); } } } catch (EOFException e) { System.out.println("Client closed!"); } catch (IOException e) { e.printStackTrace(); } finally { try { if(dis != null) dis.close(); if(dos != null) dos.close(); if(s != null) s.close(); } catch (IOException e1) { e1.printStackTrace(); } } } } }

client端：

//导入Java包 import java.awt.*; import java.awt.event.*; import java.io.*; import java.net.*; public class ChatClient extends Frame{ boolean bConnected = false; //创建成员变量 DataOutputStream dos = null; DataInputStream dis = null; //创建socket成员变量 Socket s = null; //TextField单行文本框 TextField tfText = new TextField(); // TextArea多行文本框 TextArea taContent = new TextArea(); //成员变量 Thread tRecv = new Thread(new RecvThread()); public static void main(String[] args) { //创建对象并调用方法 ChatClient q = new ChatClient(); q.launchFrame(); } //创建窗体方法 public void launchFrame() { //调整窗口大小 setLocation(400,300); this.setSize(300,300); //在窗口的北（上）方，南（下）方添加文本框 add(tfText, BorderLayout.SOUTH); add(taContent, BorderLayout.NORTH); //隐藏多余窗口区域 pack(); this.addWindowListener(new WindowAdapter(){ //重写WindowAdapter()类的windowClosing方法 //实现点击关闭终止程序 @Override public void windowClosing(WindowEvent e) { disconnect(); System.exit(0); } }); //调用Button类中的addActionListener方法 tfText.addActionListener(new TextListener()); setVisible(true); connect(); tRecv.start(); } //创建客户端连接服务器方法 public void connect() { //使用try/catch语句防止错误异常抛出 try { s = new Socket("127.0.0.1",8888); dis = new DataInputStream(s.getInputStream()); dos = new DataOutputStream(s.getOutputStream()); System.out.println("connected!"); bConnected = true; } catch (UnknownHostException e) { //找不到主机异常 e.printStackTrace(); } catch (IOException e) { //输入错误，连接错误 //e.printStackTrace(); System.out.println("输入错误，连接失败"); } } //添加清理方法，关闭套接字时将内存等清理 public void disconnect() { try { dos.close(); dis.close(); s.close(); } catch (IOException e) { // TODO 自动生成的 catch 块 e.printStackTrace(); } } //创建继承于ActionListener的类 private class TextListener implements ActionListener{ //重写actionPerformed方法 public void actionPerformed(ActionEvent e) { String str = tfText.getText().trim(); //taContent.setText(str); tfText.setText(""); try { dos.writeUTF(str); dos.flush(); //dos.close(); } catch (IOException e1) { e1.printStackTrace(); } } } private class RecvThread implements Runnable { public void run() { try { while (bConnected) { String str = dis.readUTF(); //System.out.println(str); taContent.setText(taContent.getText() + str + "\n"); } }catch (SocketException e) { System.out.println("退出了，bye!"); }catch (IOException e) { e.printStackTrace(); } } } }

PS：该练习可实现类似在线聊天系统的小功能，本人的第一个的练习，还有很多不足之处，请各位大佬指教。