时将聊天消息保存到mysql

服务端为当前客户端创建一个线程此线程接收当前客户端的消息并转发给所有客户端或私发给某个客户端同时将聊天消息保存到mysql

!!!

com.alibaba.druid.pool.DruidDataSource;/**用druid连接池来连接数据库的工具类*/public

class

ds.setUrl(jdbc:mysql://localhost:3306/test?characterEncodingutf8useSSLfalseserverTimezoneAsia/ShanghairewriteBatchedStatementstrue);

ds.setUsername(root);//给DruidDataSource

ds设置数据库用户名

ds.setPassword(root);//给DruidDataSource

ds设置数据库密码

ds.setInitialSize(10);//给DruidDataSource

ds初始容量

ds.setMaxActive(20);//给DruidDataSource

ds最大连接数

3.2.将druid-1.1.20.jar和mysql-connector-java-8.0.23.jar粘贴到chat4.lib软件包中:

在druid-1.1.20.jar上点右键然后按下图方式点击add

library

在mysql-connector-java-8.0.23.jar上点右键然后按下图方式点击add

library

chatinfo(content,from_user,to_user)

VALUES

connection.prepareStatement(sql);

ps.executeUpdate();

在Server里的ClientHandler类的run方法中循环读取客户端消息的循环中添加调用saveMessage()方法的一行代码。

用于将群聊消息保存到mysql。

在Server里的ClientHandler类的sendMessageToOne()方法中添加调用saveMessage()方法的一行代码。

如下图

运行效果

运行效果和上一版本chat3一样不过多出了将聊天数据保存到mysql的功能。

zhaoyq