java聊天室源码(二代)

JAVA聊天室（二代）代码仅为原来的一半！性能进一步提升，性能允许的基础上可连接无数客户端，改进了下线CPU占有暴增情况，实现指定人员聊天功能。。

来源：管天阳的日志

登录桌面

登录后用户列表可以显示

可指定人员单独聊天

上线客户端提醒

退出时列表可显示，每个客户端的用户项也将消失。。

下面是代码:

1.服务器：

package com.zzk;

import java.awt.BorderLayout;

import java.awt.Frame;

import java.awt.Image;

import java.awt.MenuItem;

import java.awt.PopupMenu;

import java.awt.SystemTray;

import java.awt.TrayIcon;

import java.awt.event.ActionEvent;

import java.awt.event.ActionListener;

import java.awt.event.MouseAdapter;

import java.awt.event.MouseEvent;

import java.awt.event.WindowAdapter;

import java.awt.event.WindowEvent;

import java.io.IOException;

import java.io.ObjectInputStream;

import java.io.PrintWriter;

import https://www.doczj.com/doc/429001041.html,.ServerSocket;

import https://www.doczj.com/doc/429001041.html,.Socket;

import https://www.doczj.com/doc/429001041.html,.URL;

import java.util.Hashtable;

import java.util.Iterator;

import java.util.Set;

import java.util.Vector;

import javax.swing.ImageIcon;

import javax.swing.JFrame;

import javax.swing.JScrollPane;

import javax.swing.JTextArea;

public class ChatServerFrame extends JFrame {

private JTextArea ta_info;

private ServerSocket server; // 声明ServerSocket对象

private Socket socket; // 声明Socket对象socket

private Hashtable map = new Hashtable();// 用于存储连接到服务器的用户和客户端套接字对象

public void createSocket() {

try {

server = new ServerSocket(1982);// 创建服务器套接字对象while (true) {

ta_info.append("等待新客户连接......\n");

socket = server.accept();// 获得套接字对象

ta_info.append("客户端连接成功。" + socket + "\n");

new ServerThread(socket).start();// 创建并启动线程对象

}

} catch (IOException e) {

e.printStackTrace();

}

}

class ServerThread extends Thread {

Socket socket;

public ServerThread(Socket socket) {

this.socket = socket;

}

public void run() {

try {

ObjectInputStream ins = new ObjectInputStream(socket

.getInputStream());

while (true) {

Vector v = null;

try {

v = (Vector) ins.readObject();

} catch (ClassNotFoundException e) {

e.printStackTrace();

}

if (v != null && v.size() > 0) {

for (int i = 0; i < v.size(); i++) {

String info = (String) v.get(i);// 读取信息

String key = "";

if (info.startsWith("用户：")) {// 添加登录用户到客户端列表

key = info.substring(3, info.length());// 获得用户名并作为键使用map.put(key, socket);// 添加键值对

Set set = map.keySet();// 获得集合中所有键的Set视图Iterator keyIt = set.iterator();// 获得所有键的迭代器while (keyIt.hasNext()) {

String receiveKey = keyIt.next();// 获得表示接收信息的键Socket s = map.get(receiveKey);// 获得与该键对应的套接字对象

PrintWriter out = new PrintWriter(s

.getOutputStream(), true);// 创建输出流对象

Iterator keyIt1 = set.iterator();// 获得所有键的迭代器

while (keyIt1.hasNext()) {

String receiveKey1 = keyIt1.next();// 获得键，用于向客户端添加用户列表

out.println(receiveKey1);// 发送信息

out.flush();// 刷新输出缓冲区

}

}

} else if (info.startsWith("退出：")) {

key = info.substring(3);// 获得退出用户的键

map.remove(key);// 删除键值对

Set set = map.keySet();// 获得集合中所有键的Set视图

Iterator keyIt = set.iterator();// 获得所有键的迭代器

while (keyIt.hasNext()) {

String receiveKey = keyIt.next();// 获得表示接收信息的键

Socket s = map.get(receiveKey);// 获得与该键对应的套接字对象

PrintWriter out = new PrintWriter(s

.getOutputStream(), true);// 创建输出流对象

out.println("退出：" + key);// 发送信息

out.flush();// 刷新输出缓冲区

}

} else {// 转发接收的消息

key = info.substring(info.indexOf("：发送给：") + 5,

info.indexOf("：的信息是："));// 获得接收方的key值,即接收方的用户名（因为substring起始索引包括，结尾索引不包括所以要+5）

String sendUser = info.substring(0, info

.indexOf("：发送给："));// 获得发送方的key值,即发送方的用户名

Set set = map.keySet();// 获得集合中所有键的Set视图

Iterator keyIt = set.iterator();// 获得所有键的迭代器

while (keyIt.hasNext()) {

String receiveKey = keyIt.next();// 获得表示接收信息的键

if (key.equals(receiveKey) && !sendUser.equals(receiveKey)) {// 与接受用户相同，但不是发送用户Socket s = map.get(receiveKey);// 获得与该键对应的套接字对象

PrintWriter out = new PrintWriter(s.getOutputStream(), true);// 创建输出流对象

out.println("MSG:" + info);// 发送信息

out.flush();// 刷新输出缓冲区

}

}

}

}

}

}

} catch (IOException e) {

ta_info.append(socket + "已经退出。\n");

}

}

}

public static void main(String args[]) {

ChatServerFrame frame = new ChatServerFrame();

frame.setVisible(true);

frame.createSocket();

}

/**

* Create the frame

*/

public ChatServerFrame() {

super();

addWindowListener(new WindowAdapter() {

public void windowIconified(final WindowEvent e) {

setVisible(false);

}

});

setTitle("聊天室服务器端");

setBounds(100, 100, 385, 266);

final JScrollPane scrollPane = new JScrollPane();

getContentPane().add(scrollPane, BorderLayout.CENTER);

ta_info = new JTextArea();

scrollPane.setViewportView(ta_info);

//托盘

if (SystemTray.isSupported()){ // 判断是否支持系统托盘

URL url=ChatServerFrame.class.getResource("server.png"); // 获取图片所在的URL ImageIcon icon = new ImageIcon(url); // 实例化图像对象

Image image=icon.getImage(); // 获得Image对象

TrayIcon trayIcon=new TrayIcon(image); // 创建托盘图标

trayIcon.addMouseListener(new MouseAdapter(){ // 为托盘添加鼠标适配器

public void mouseClicked(MouseEvent e){ // 鼠标事件

if (e.getClickCount()==2){ // 判断是否双击了鼠标

showFrame(); // 调用方法显示窗体

}

}

});

trayIcon.setToolTip("系统托盘"); // 添加工具提示文本

PopupMenu popupMenu=new PopupMenu(); // 创建弹出菜单

MenuItem exit=new MenuItem("退出"); // 创建菜单项

exit.addActionListener(new ActionListener() { // 添加事件监听器

public void actionPerformed(final ActionEvent arg0) {

System.exit(0); // 退出系统

}

});

popupMenu.add(exit); // 为弹出菜单添加菜单项

trayIcon.setPopupMenu(popupMenu); // 为托盘图标加弹出菜弹

SystemTray systemTray=SystemTray.getSystemTray(); // 获得系统托盘对象

try{

systemTray.add(trayIcon); // 为系统托盘加托盘图标

}catch(Exception e){

e.printStackTrace();

}

}

}

public void showFrame(){

this.setVisible(true); // 显示窗体

this.setState(Frame.NORMAL);

}

}

//////////////////////////////////////////////////////////////////////////////////////////////////////////////////////// /////////

2.客户端：

package com.zzk;

import java.awt.BorderLayout;

import java.awt.Dimension;

import java.awt.EventQueue;

import java.awt.Font;

import java.awt.Frame;

import java.awt.Image;

import java.awt.MenuItem;

import java.awt.PopupMenu;

import java.awt.SystemTray;

import java.awt.TrayIcon;

import java.awt.event.ActionEvent;

import java.awt.event.ActionListener;

import java.awt.event.MouseAdapter;

import java.awt.event.MouseEvent;

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.ObjectOutputStream;

import https://www.doczj.com/doc/429001041.html,.Socket;

import https://www.doczj.com/doc/429001041.html,.URL;

import https://www.doczj.com/doc/429001041.html,.UnknownHostException;

import java.text.DateFormat;

import java.util.Date;

import java.util.Vector;

import javax.swing.DefaultComboBoxModel;

import javax.swing.ImageIcon;

import javax.swing.JButton;

import javax.swing.JFrame;

import javax.swing.JLabel;

import javax.swing.JList;

import javax.swing.JOptionPane;

import javax.swing.JPanel;

import javax.swing.JScrollPane;

import javax.swing.JSplitPane;

import javax.swing.JTextArea;

import javax.swing.JTextField;

public class ChatClientFrame extends JFrame {

private JTextField tf_newUser;

private JList user_list;

private JTextArea ta_info;

private JTextField tf_send;

private ObjectOutputStream out;// 声明输出流对象

private boolean loginFlag = false;// 为true时表示已经登录，为false时表示未登录

public static void main(String args[]) {

EventQueue.invokeLater(new Runnable() {

public void run() {

try {

ChatClientFrame frame = new ChatClientFrame();

frame.setVisible(true);

frame.createClientSocket();// 调用方法创建套接字对象

} catch (Exception e) {

e.printStackTrace();

}

}

});

}

public void createClientSocket() {

try {

Socket socket = new Socket("localhost", 1982);// 创建套接字对象

out = new ObjectOutputStream(socket.getOutputStream());// 创建输出流对象new ClientThread(socket).start();// 创建并启动线程对象

} catch (UnknownHostException e) {

e.printStackTrace();

} catch (IOException e) {

e.printStackTrace();

}

}

class ClientThread extends Thread {

Socket socket;

public ClientThread(Socket socket) {

this.socket = socket;

}

public void run() {

try {

BufferedReader in = new BufferedReader(new InputStreamReader( socket.getInputStream()));// 创建输入流对象

DefaultComboBoxModel model = (DefaultComboBoxModel) user_list

.getModel();// 获得列表框的模型

while (true) {

String info = in.readLine().trim();// 读取信息

if (!info.startsWith("MSG:")) {// 接收到的不是消息

if (info.startsWith("退出：")) {// 接收到的是退出消息

model.removeElement(info.substring(3));// 从用户列表中移除用户

} else {// 接收到的是登录用户

boolean itemFlag = false;// 标记是否为列表框添加列表项，为true不添加，为false添加

for (int i = 0; i < model.getSize(); i++) {// 对用户列表进行遍历

if (info.equals((String) model.getElementAt(i))) {// 如果用户列表中存在该用户名

itemFlag = true;// 设置为true，表示不添加到用户列表

break;// 结束for循环

}

}

if (!itemFlag) {

model.addElement(info);// 将登录用户添加到用户列表

}

}

} else {// 如果获得的是消息，则在文本域中显示接收到的消息

DateFormat df = DateFormat.getDateInstance();// 获得DateFormat实例

String dateString = df.format(new Date()); // 格式化为日期

df = DateFormat.getTimeInstance(DateFormat.MEDIUM);// 获得DateFormat实例

String timeString = df.format(new Date()); // 格式化为时间

String sendUser = info.substring(4,info.indexOf("：发送给："));// 获得发送信息的用户

String receiveInfo = info.substring(info.indexOf("：的信息是：")+6);// 获得接收到的信息

ta_info.append(" "+sendUser + " " +dateString+" "+timeString+"\n "+receiveInfo+"\n");// 在文本域中显示信息

ta_info.setSelectionStart(ta_info.getText().length()-1);// 设置选择起始位置

ta_info.setSelectionEnd(ta_info.getText().length());// 设置选择的结束位置

tf_send.requestFocus();// 使发送信息文本框获得焦点

}

}

} catch (IOException e) {

e.printStackTrace();

}

}

}

private void send() {

if (!loginFlag) {

JOptionPane.showMessageDialog(null, "请先登录。");

return;// 如果用户没登录则返回

}

String sendUserName = tf_newUser.getText().trim();// 获得登录用户名

String info = tf_send.getText();// 获得输入的发送信息

if (info.equals("")) {

return;// 如果没输入信息则返回，即不发送

}

Vector v = new Vector();// 创建向量对象，用于存储发送的消息

Object[] receiveUserNames = user_list.getSelectedValues();// 获得选择的用户数组

if (receiveUserNames.length <= 0) {

return;// 如果没选择用户则返回

}

for (int i = 0; i < receiveUserNames.length; i++) {

String msg = sendUserName + "：发送给：" + (String) receiveUserNames[i]

+ "：的信息是：" + info;// 定义发送的信息

v.add(msg);// 将信息添加到向量

}

try {

out.writeObject(v);// 将向量写入输出流，完成信息的发送

out.flush();// 刷新输出缓冲区

} catch (IOException e) {

e.printStackTrace();

}

DateFormat df = DateFormat.getDateInstance();// 获得DateFormat实例

String dateString = df.format(new Date()); // 格式化为日期

df = DateFormat.getTimeInstance(DateFormat.MEDIUM);// 获得DateFormat实例

String timeString = df.format(new Date()); // 格式化为时间

String sendUser = tf_newUser.getText().trim();// 获得发送信息的用户

String receiveInfo = tf_send.getText().trim();// 显示发送的信息

ta_info.append(" "+sendUser + " " +dateString+" "+timeString+"\n "+receiveInfo+"\n");// 在文本域中显示信息

tf_send.setText(null);// 清空文本框

ta_info.setSelectionStart(ta_info.getText().length()-1);// 设置选择的起始位置

ta_info.setSelectionEnd(ta_info.getText().length());// 设置选择的结束位置

tf_send.requestFocus();// 使发送信息文本框获得焦点

}

/**

* Create the frame

*/

public ChatClientFrame() {

super();

setTitle("聊天室客户端");

setBounds(100, 100, 385, 288);

final JPanel panel = new JPanel();

getContentPane().add(panel, BorderLayout.SOUTH);

final JLabel label = new JLabel();

label.setText("输入聊天内容：");

panel.add(label);

tf_send = new JTextField();

tf_send.addActionListener(new ActionListener() {

public void actionPerformed(final ActionEvent e) {

send();// 调用方法发送信息

}

});

tf_send.setPreferredSize(new Dimension(180, 25));

panel.add(tf_send);

final JButton button = new JButton();

button.addActionListener(new ActionListener() {

public void actionPerformed(final ActionEvent e) {

send();// 调用方法发送信息

}

});

button.setText("发送");

panel.add(button);

final JSplitPane splitPane = new JSplitPane();

splitPane.setDividerLocation(100);

getContentPane().add(splitPane, BorderLayout.CENTER);

final JScrollPane scrollPane = new JScrollPane();

splitPane.setRightComponent(scrollPane);

ta_info = new JTextArea();

ta_info.setFont(new Font("", Font.BOLD, 14));

scrollPane.setViewportView(ta_info);

final JScrollPane scrollPane_1 = new JScrollPane();

splitPane.setLeftComponent(scrollPane_1);

user_list = new JList();

user_list.setModel(new DefaultComboBoxModel(new String[] { "" })); scrollPane_1.setViewportView(user_list);

final JPanel panel_1 = new JPanel();

getContentPane().add(panel_1, BorderLayout.NORTH);

final JLabel label_1 = new JLabel();

label_1.setText("用户名称：");

panel_1.add(label_1);

tf_newUser = new JTextField();

tf_newUser.setPreferredSize(new Dimension(140, 25));

panel_1.add(tf_newUser);

final JButton button_1 = new JButton();

button_1.addActionListener(new ActionListener() {

public void actionPerformed(final ActionEvent e) {

if (loginFlag) {// 已登录标记为true

JOptionPane.showMessageDialog(null, "在同一窗口只能登录一次。"); return;

}

String userName = tf_newUser.getText().trim();// 获得登录用户名Vector v = new Vector();// 定义向量，用于存储登录用户

v.add("用户：" + userName);// 添加登录用户

try {

out.writeObject(v);// 将用户向量发送到服务器

out.flush();// 刷新输出缓冲区

} catch (IOException ex) {

ex.printStackTrace();

}

tf_newUser.setEnabled(false);// 禁用用户文本框

loginFlag = true;// 将已登录标记设置为true

}

});

button_1.setText("登录");

panel_1.add(button_1);

final JButton button_2 = new JButton();

button_2.addActionListener(new ActionListener() {

public void actionPerformed(final ActionEvent e) {

String exitUser = tf_newUser.getText().trim();

Vector v = new Vector();

v.add("退出：" + exitUser);

try {

out.writeObject(v);

out.flush();// 刷新输出缓冲区

} catch (IOException ex) {

ex.printStackTrace();

}

System.exit(0); // 退出系统

}

});

button_2.setText("退出");

panel_1.add(button_2);

//托盘

if (SystemTray.isSupported()){ // 判断是否支持系统托盘

URL url=ChatClientFrame.class.getResource("client.png"); // 获取图片所在的URL ImageIcon icon = new ImageIcon(url); // 实例化图像对象

Image image=icon.getImage(); // 获得Image对象

TrayIcon trayIcon=new TrayIcon(image); // 创建托盘图标

trayIcon.addMouseListener(new MouseAdapter(){ // 为托盘添加鼠标适配器public void mouseClicked(MouseEvent e){ // 鼠标事件

if (e.getClickCount()==2){ // 判断是否双击了鼠标

showFrame(); // 调用方法显示窗体

}

}

});

trayIcon.setToolTip("系统托盘"); // 添加工具提示文本

PopupMenu popupMenu=new PopupMenu(); // 创建弹出菜单

MenuItem exit=new MenuItem("退出"); // 创建菜单项

exit.addActionListener(new ActionListener() { // 添加事件监听器

public void actionPerformed(final ActionEvent arg0) {

String exitUser = tf_newUser.getText().trim();

Vector v = new Vector();

v.add("退出：" + exitUser);

try {

out.writeObject(v);

out.flush();// 刷新输出缓冲区

} catch (IOException ex) {

ex.printStackTrace();

}

System.exit(0); // 退出系统

}

});

popupMenu.add(exit); // 为弹出菜单添加菜单项

trayIcon.setPopupMenu(popupMenu); // 为托盘图标加弹出菜弹

SystemTray systemTray=SystemTray.getSystemTray(); // 获得系统托盘对象try{

systemTray.add(trayIcon); // 为系统托盘加托盘图标

}catch(Exception e){

e.printStackTrace();

}

}

}

public void showFrame(){

this.setVisible(true); // 显示窗体

this.setState(Frame.NORMAL);

}

}

该段程序需要设置png图片，如有需要，请酌情加上自己的图标。。