项目介绍：

Java聊天室是期末设计，阿里巴巴druid+mysql+多线程+GUI+mvn项目+java Socket

服务端模块：踢出聊天室：管理员可以踢出发言不当的用户。只有当开启服务端的时候，客户端才能起到作用。

客户端模块：注册：用户可以注册账户，通过输入的账户密码往数据库添加数据；

新建窗口：用于开启新的客户端；

一.代码设计

Server.java

package Chatroom;import java.awt.image.BufferedImage;
import java.io.*;
import java.net.*;
import java.util.*;
import java.awt.*;
import javax.imageio.ImageIO;
import javax.swing.*;
import javax.swing.border.TitledBorder;
import net.sf.json.JSONObject;//继承JFrame实现可视化
public class Server extends JFrame{//用户列表，用于存放连接上的用户信息ArrayList<User> user_list = new ArrayList<>();//用户名列表，用于显示已连接上的用户ArrayList<String> username_list = new ArrayList<>();//消息显示区域JTextArea show_area = new JTextArea();//用户名显示区域JTextArea show_user = new JTextArea(10, 10);//socket的数据输出流DataOutputStream outputStream = null;//socket的数据输入流DataInputStream inputStream = null;//从主函数里面开启服务端public static void main(String[] args) {new Server();}//构造函数public Server() {//设置流式布局setLayout(new BorderLayout());//VERTICAL_SCROLLBAR_AS_NEEDED设置垂直滚动条需要时出现//HORIZONTAL_SCROLLBAR_NEVER设置水平滚动条不出现//创建信息显示区的画布并添加到show_areaJScrollPane panel = new JScrollPane(show_area,ScrollPaneConstants.VERTICAL_SCROLLBAR_AS_NEEDED,ScrollPaneConstants.HORIZONTAL_SCROLLBAR_NEVER);//设置信息显示区标题panel.setBorder(new TitledBorder("信息显示区"));//布局到中央add(panel,BorderLayout.CENTER);//设置信息显示区为不可编辑show_area.setEditable(false);//创建用于显示用户的画布final JPanel panel_east = new JPanel();//添加流式布局panel_east.setLayout(new BorderLayout());//设置标题panel_east.setBorder(new TitledBorder("在线用户"));//在用户显示区添加show_uesrpanel_east.add(new JScrollPane(show_user), BorderLayout.CENTER);//设置用户显示区域为不可编辑show_user.setEditable(false);//将显示用户的画布添加到整体布局的右侧add(panel_east, BorderLayout.EAST);//创建关于踢下线用户的画布final JPanel panel_south = new JPanel();//创建标签JLabel label = new JLabel("输入要踢下线用户的ID");//创建输入框JTextField out_area = new JTextField(40);//创建踢下线按钮JButton out_btn = new JButton("踢下线");//依次添加进画布panel_south.add(label);panel_south.add(out_area);panel_south.add(out_btn);//将踢下线用户的画布添加到整体布局的下侧add(panel_south,BorderLayout.SOUTH);//设置踢下线按钮的监听out_btn.addActionListener(e -> {try {//用于存储踢下线用户的名字String out_username;//从输入框中获取踢下线用户名out_username = out_area.getText().trim();//用于判断盖用户是否被踢下线boolean is_out=false;//遍历用户列表依次判断for (int i = 0; i < user_list.size(); i++){//比较用户名，相同则踢下线if(user_list.get(i).getUsername().equals(out_username)){//获取被踢下线用户对象User out_user = user_list.get(i);//使用json封装将要传递的数据JSONObject data = new JSONObject();//封装全体用户名，广播至所有用户data.put("user_list", username_list);//广播的信息内容data.put("msg", out_user.getUsername() + "被管理员踢出\n");//服务端消息显示区显示相应信息show_area.append(out_user.getUsername() + "被你踢出\n");//依次遍历用户列表for (User value : user_list) {try {//获取每个用户列表的socket连接outputStream = new DataOutputStream(value.getSocket().getOutputStream());//传递信息outputStream.writeUTF(data.toString());} catch (IOException ex) {ex.printStackTrace();}}//将被踢用户移出用户列表user_list.remove(i);//将被踢用户移出用户名列表username_list.remove(out_user.getUsername());//刷新在线人数show_user.setText("当前在线人数 " + username_list.size() + " 人\n");//刷新在线用户for (String s : username_list) {show_user.append(s + "\n");}//判断踢出成功is_out=true;break;}}//根据是否踢出成功弹出相应提示if(is_out){JOptionPane.showMessageDialog(null,"踢下线成功","提示",JOptionPane.WARNING_MESSAGE);}if(!is_out){JOptionPane.showMessageDialog(null,"不存在用户","提示",JOptionPane.WARNING_MESSAGE);}//重置输入框out_area.setText("");} catch(Exception ex) {ex.printStackTrace();}});//设置该窗口名setTitle("服务器 ");//引入图片BufferedImage img;
//        try {
//            //根据图片名引入图片
//            img = ImageIO.read(Server.class.getResource("/a.jpg"));
//            //设置其为该窗体logo
//            setIconImage(img);
//        } catch (IOException exception) {
//            exception.printStackTrace();
//        }//设置窗体大小setSize(700, 700);//设置窗体位置可移动setLocationRelativeTo(null);//设置窗体关闭方式setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);//设置窗体可见setVisible(true);//socket连接相关代码try {//开启socket服务器，绑定端口11111ServerSocket serverSocket = new ServerSocket(11111);//信息显示区打印服务器启动时间show_area.append("服务器启动时间 " + new Date() + "\n");//持续接收连接while (true) {//接收连接Socket socket = serverSocket.accept();//创建用户对象User user = new User();//判断是否连接上if (socket != null) {//获取输入流inputStream = new DataInputStream(socket.getInputStream());//读取输入流String json = inputStream.readUTF();//创建信息对象JSONObject data = JSONObject.fromObject(json);//信息显示区打印用户上线show_area.append("用户 " + data.getString("username") + " 在" + new Date() + "登陆系统"+"\n");//创建新用户user = new User();//存储socket对象user.setSocket(socket);//获取输入流用户名user.setUsername(data.getString("username"));//添加进用户列表user_list.add(user);//添加进用户名列表username_list.add(data.getString("username"));//刷新在线人数show_user.setText("当前在线人数 " + username_list.size() + " 人\n");//刷新在线用户for (String s : username_list) {show_user.append(s + "\n");}}//封装信息对象JSONObject online = new JSONObject();//设置接收信息对象online.put("user_list", username_list);//设置信息内容online.put("msg", user.getUsername() + "上线了");//依次遍历，将信息广播给所有在线用户for (User value : user_list) {//获取输出流outputStream = new DataOutputStream(value.getSocket().getOutputStream());//给所有用户输出上线信息outputStream.writeUTF(online.toString());}//开启新线程，持续接收该socket信息new Thread(new ServerThread(socket)).start();}} catch (IOException ex) {ex.printStackTrace();}}//线程代码class ServerThread implements Runnable {//存放全局变量socketprivate final Socket socket;//构造函数，初始化socketpublic ServerThread(Socket socket) {this.socket = socket;}@Overridepublic void run() {try {//获取输入流DataInputStream inputStream = new DataInputStream(socket.getInputStream());//持续接收信息while (true) {//获取传递进来的信息String json = inputStream.readUTF();//封装成json格式JSONObject data = JSONObject.fromObject(json);//通过json里面的private判断是否私发boolean is_private = false;//私发处理for (int i = 0; i < user_list.size(); i++) {//找到私发对象if (user_list.get(i).getUsername().equals(data.getString("private"))) {//构建私发信息内容String msg = data.getString("time") +"\n" + data.getString("username")+ " 给你发了一条私密消息，其它用户看不到" + "\n"  + data.getString("msg");//用该方法指定对象发送信息send_msg(i, msg);//将发送成功反馈给原用户for (int j = 0; j < user_list.size(); j++) {//找到发信息用户if(user_list.get(j).getUsername().equals(data.getString("username"))){//构建反馈信息内容String msg2 = data.getString("time")+"\n你成功向"+user_list.get(i).getUsername()+"发送了一条私密消息\n" +data.getString("msg");//用该方法指定对象发送信息send_msg(j,msg2);}}//将该操作打印到服务器监视窗show_area.append(data.getString("username") +data.getString("time")+ "私发给"+ data.getString("private") + ":\n" + data.getString("msg") + "\n");//判断是私发is_private = true;break;}}//非私发的情况if (!is_private) {//构建信息内容String msg = data.getString("username") + " " + data.getString("time") + ":\n"+ data.getString("msg");//添加到服务器显示show_area.append(msg + "\n");//依次发给所有在线用户for (int i = 0; i < user_list.size(); ) {send_msg(i, msg);i++;}}}} catch (IOException e) {e.printStackTrace();}}//发送信息给指定用户的方法public void send_msg(int i, String msg) {//构建对象JSONObject data = new JSONObject();//封装信息data.put("user_list", username_list);data.put("msg", msg);//获取目标对象User user = user_list.get(i);try {//获取输出流outputStream = new DataOutputStream(user.getSocket().getOutputStream());//写信息outputStream.writeUTF(data.toString());} catch (IOException e) {//如果没有找到，则说明该用户已经下线User out_user = user_list.get(i);//重复删除操作user_list.remove(i);username_list.remove(out_user.getUsername());//重新构建信息JSONObject out = new JSONObject();out.put("user_list", username_list);out.put("msg", out_user.getUsername() + "下线了\n");//将其下线通知广播给所有用户for (User value : user_list) {try {outputStream = new DataOutputStream(value.getSocket().getOutputStream());outputStream.writeUTF(out.toString());} catch (IOException ex) {ex.printStackTrace();}}}}}}

Client.java

package Chatroom;import javax.imageio.ImageIO;
import javax.swing.*;
import java.awt.image.BufferedImage;
import java.io.IOException;public class Client extends JFrame{public static void main(String[] args) {new Client();}public Client(){setTitle("登陆界面");
//        BufferedImage img;
//        try {
//            img = ImageIO.read(Server.class.getResource("src/tag.jpg"));
//            setIconImage(img);
//        } catch (IOException exception) {
//            exception.printStackTrace();
//        }setLayout(null);setSize(500,500);setLocationRelativeTo(null);setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);setLayout(null);setResizable(false);JLabel username_label = new JLabel("用户名");username_label.setBounds(60,100,100,50);add(username_label);JLabel password_label = new JLabel("密码");password_label.setBounds(60,200,100,50);add(password_label);JTextField username_field = new JTextField();username_field.setBounds(110,100,300,50);add(username_field);JPasswordField password_field = new JPasswordField();password_field.setBounds(110,200,300,50);add(password_field);JButton login = new JButton("登陆");login.setBounds(35,300,100,50);add(login);JButton register = new JButton("注册");register.setBounds(180,300,100,50);add(register);JButton addwindow = new JButton("新建窗口");addwindow.setBounds(320,300,100,50);add(addwindow);setVisible(true);login.addActionListener(e -> {String username = username_field.getText();String password = String.valueOf(password_field.getPassword());if(username.length()!=0 && password.length()!=0){User user = new User();user.setUsername(username);user.setPassword(password);UserDao dao = new UserDao();User u = dao.login(user);if(u!=null){setVisible(false);new Chat(username);}else{JOptionPane.showMessageDialog(null,"登录失败，账号或密码错误","提示",JOptionPane.WARNING_MESSAGE);}}else {JOptionPane.showMessageDialog(null,"登录失败，账号或密码不能为空","提示",JOptionPane.WARNING_MESSAGE);}});register.addActionListener(e -> {setVisible(false);new Register();});addwindow.addActionListener(e -> {setVisible(true);new Client();});}}

Register.java

package Chatroom;import javax.imageio.ImageIO;
import javax.swing.*;
import java.awt.image.BufferedImage;
import java.io.IOException;public class Register extends JFrame {public Register(){setTitle("注册界面");BufferedImage img;
//        try {
//            img = ImageIO.read(Server.class.getResource("src/tag.jpg"));
//            this.setIconImage(img);
//        } catch (IOException exception) {
//            exception.printStackTrace();
//        }setLayout(null);setSize(500,500);setLocationRelativeTo(null);setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);setLayout(null);setResizable(false);JLabel username_label = new JLabel("用户名");username_label.setBounds(60,50,100,50);add(username_label);JLabel password_label = new JLabel("密码");password_label.setBounds(60,150,100,50);add(password_label);JLabel password_label2 = new JLabel("请再次输入密码");password_label2.setBounds(20,250,100,50);add(password_label2);JTextField username_field = new JTextField();username_field.setBounds(110,50,300,50);add(username_field);JPasswordField password_field = new JPasswordField();password_field.setBounds(110,150,300,50);add(password_field);JPasswordField password_field2 = new JPasswordField();password_field2.setBounds(110,250,300,50);add(password_field2);JButton register_success = new JButton("注册");register_success.setBounds(130,350,100,50);add(register_success);JButton back = new JButton("返回");back.setBounds(280,350,100,50);add(back);setVisible(true);register_success.addActionListener(e -> {String username = username_field.getText();String password = String.valueOf(password_field.getPassword());String password2 = String.valueOf(password_field2.getPassword());System.out.println(password);System.out.println(password2);if(username.length()==0 || password.length()==0){JOptionPane.showMessageDialog(null,"注册失败，账号或密码不能为空","提示",JOptionPane.WARNING_MESSAGE);}else if (!password.equals(password2)) {JOptionPane.showMessageDialog(null,"注册失败，前后密码不匹配","提示",JOptionPane.WARNING_MESSAGE);}else{System.out.println();System.out.println(password);User user = new User();user.setUsername(username);user.setPassword(password);UserDao dao = new UserDao();int flag = dao.register(user);if(flag!=0){JOptionPane.showMessageDialog(null,"注册成功，欢迎您登录","提示",JOptionPane.WARNING_MESSAGE);}else{//建表语句中设置了user为主键，重复则建表失败JOptionPane.showMessageDialog(null,"注册失败，账号已经存在","提示",JOptionPane.WARNING_MESSAGE);}}});back.addActionListener(e ->{setVisible(false);new Client();});}}

User.java

package Chatroom;import java.net.Socket;public class User {private String username;private String password;private Socket socket;public String getUsername() {return username;}public void setUsername(String username) {this.username = username;}public String getPassword() {return password;}public void setPassword(String password) {this.password = password;}public Socket getSocket() {return socket;}public void setSocket(Socket socket) {this.socket = socket;}
}

UserDao.java

package Chatroom;import org.springframework.dao.DataAccessException;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;public class UserDao {private final JdbcTemplate template = new JdbcTemplate(JDBCUtils.getDataSource());public User login(User login_user) {try {//编写sqlString sql = "select * from user where username = ? and password = ?";User user = template.queryForObject(sql,new BeanPropertyRowMapper<User>(User.class),login_user.getUsername(), login_user.getPassword());return user;} catch (DataAccessException e) {e.printStackTrace();return null;}}public int register(User register_user) {try {
//            String sql = "insert into user values (null ,?,?)";String sql = "insert into user values (?,?)";int count = template.update(sql,register_user.getUsername(),register_user.getPassword());return count;} catch (DataAccessException e) {e.printStackTrace();return 0;}}}

Chat.java

package Chatroom;import java.awt.event.KeyAdapter;
import java.awt.event.KeyEvent;
import java.awt.image.BufferedImage;
import java.io.*;
import java.net.*;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.awt.*;
import javax.imageio.ImageIO;
import javax.swing.*;
import javax.swing.border.TitledBorder;
import net.sf.json.JSONArray;
import net.sf.json.JSONObject;
public class Chat extends JFrame{JTextArea show_area = new JTextArea();JTextArea show_user = new JTextArea(10, 10);DataOutputStream outputStream;DataInputStream inputStream;String username;ArrayList<String> username_list = new ArrayList<>();boolean is_stop = false;public Chat(final String username) {this.username = username;final JPanel panel_south = new JPanel();panel_south.setLayout(new BorderLayout());panel_south.setBorder(new TitledBorder("写消息区，若私聊，在内容后添加（-用户名）"));JTextField send_area = new JTextField(40);send_area.setPreferredSize(new Dimension(450,50));panel_south.add(send_area, BorderLayout.CENTER);JButton send_btn = new JButton("发送");panel_south.add(send_btn,BorderLayout.EAST);add(panel_south, BorderLayout.SOUTH);send_area.addKeyListener(new KeyAdapter() {public void keyTyped(KeyEvent e) {if ((char) e.getKeyChar() == KeyEvent.VK_ENTER) {System.out.println("发送消息");SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");String time = sdf.format(new Date());String msg = send_area.getText().trim();if (!msg.equals("")) {String[] msg1 = msg.split("-");JSONObject data = new JSONObject();data.put("username", username);data.put("msg", msg1[0]+"\n");data.put("time", time);try {data.put("private", msg1[1]+"\n");} catch (ArrayIndexOutOfBoundsException e1) {data.put("private", "");}try {outputStream.writeUTF(data.toString());} catch (IOException ioException) {ioException.printStackTrace();}}send_area.setText("");}}});send_btn.addActionListener(e -> {try {if (is_stop) {show_area.append("你已被踢出，不能发送消息\n");JOptionPane.showMessageDialog(null,"你已被踢出，不能发送消息，进程已经关闭","提示",JOptionPane.WARNING_MESSAGE);System.exit(0);} else {SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");String time = sdf.format(new Date());String msg = send_area.getText().trim();if (!msg.equals("")) {String[] msg1 = msg.split("-");JSONObject data = new JSONObject();data.put("username", username);data.put("msg", msg1[0]);data.put("time", time);try {data.put("private", msg1[1]);} catch (ArrayIndexOutOfBoundsException e1) {data.put("private", "");}outputStream.writeUTF(data.toString());}}send_area.setText("");} catch (Exception ex) {ex.printStackTrace();}});JScrollPane panel = new JScrollPane(show_area,ScrollPaneConstants.VERTICAL_SCROLLBAR_AS_NEEDED,ScrollPaneConstants.HORIZONTAL_SCROLLBAR_NEVER);panel.setBorder(new TitledBorder("信息显示区"));add(panel,BorderLayout.CENTER);show_area.setEditable(false);final JPanel panel_east = new JPanel();panel_east.setLayout(new BorderLayout());panel_east.setBorder(new TitledBorder("在线用户"));panel_east.add(new JScrollPane(show_user), BorderLayout.CENTER);show_user.setEditable(false);add(panel_east, BorderLayout.EAST);setTitle("用户  " + username);BufferedImage img;
//        try {
//            img = ImageIO.read(Server.class.getResource("src/tag.jpg"));
//            this.setIconImage(img);
//        } catch (IOException exception) {
//            exception.printStackTrace();
//        }setSize(500, 500);setLocationRelativeTo(null);setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);setVisible(true);JSONObject data = new JSONObject();data.put("username", username);data.put("msg", null);try {Socket socket = new Socket("127.0.0.1", 11111);inputStream = new DataInputStream(socket.getInputStream());outputStream = new DataOutputStream(socket.getOutputStream());outputStream.writeUTF(data.toString());new Thread(new Read()).start();} catch (IOException e) {show_area.append("服务器无响应");JOptionPane.showMessageDialog(null,"服务器无响应","提示",JOptionPane.WARNING_MESSAGE);}}public class Read implements Runnable {@Overridepublic void run() {try {while (true) {String json = inputStream.readUTF();JSONObject data = JSONObject.fromObject(json);String msg = data.getString("msg");if (msg.contains("踢出") && msg.contains(username)) {is_stop = true;show_area.append(username + ",你已经被踢出群聊\n");JOptionPane.showMessageDialog(null,"你已经被踢出群聊","提示",JOptionPane.WARNING_MESSAGE);System.exit(0);} else {show_area.append(msg + "\n");show_area.selectAll();username_list.clear();JSONArray jsonArray = data.getJSONArray("user_list");for (Object o : jsonArray) {username_list.add(o.toString());}show_user.setText("当前在线人数： " + jsonArray.size() + " 人\n");for (String s : username_list) {show_user.append(s + "\n");}}}} catch (Exception e) {e.printStackTrace();}}}}

JDBCUtils

package Chatroom;import com.alibaba.druid.pool.DruidDataSourceFactory;
import javax.sql.DataSource;
import java.io.InputStream;
import java.util.Properties;public class JDBCUtils {private static DataSource ds;static {try {Properties pro = new Properties();InputStream is = JDBCUtils.class.getClassLoader().getResourceAsStream("druid.properties");pro.load(is);ds = DruidDataSourceFactory.createDataSource(pro);} catch (Exception exception) {exception.printStackTrace();}}public static DataSource getDataSource(){return ds;}}

druid.properties

# druid.properties文件的配置
driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://127.0.0.1:3306/plan
username=root
password=123123
# 初始化连接数量
initialSize=5
# 最大连接数
maxActive=10
# 最大超时时间
maxWait=3000