用 Java 写了一个类 QQ 界面聊天小项目,可在线聊天!
作者: AC路上
原文:https://blog.csdn.net/weixin_44048140/article/details/109612049
1.功能实现
1.修改功能(密码、昵称、个性签名)
2.添加好友、删除好友
3.单聊功能
4.判断好友是否在线
2.模块划分

3.使用的知识
netty
swing
集合等同步阻塞队列synchronousQueue
数据库MySQL中的CRUD
C3p0连接池
JSON字符串
4.部分代码实现
1.nettyController.java
接收到来自客户端的消息,与dao层进行交互 dao层与之数据库进行交互
修改密码添加好友
从添加好友逻辑实现上我走了很多的弯路频繁的访问数据库,这是一件很不好的事情
package chat.Project.controller;
import chat.Project.bean.information;
import chat.Project.constant.EnMsgType;
import chat.Project.dao.*;
import chat.utils.CacheUtil;
import chat.utils.JsonUtils;
import com.fasterxml.jackson.databind.node.ObjectNode;
import io.netty.channel.Channel;
import java.util.ArrayList;
import java.util.Iterator;
public class NettyController {
private static UserDao userDao = new UserDaoImpl();
private static informationDao informationDao = new informationDaoImpl();
private static friendDao friendDao = new friendDaoImpl();
public static String processing(String message, Channel channel){
//解析客户端发送的消息
ObjectNode jsonNodes = JsonUtils.getObjectNode(message);
String msgtype = jsonNodes.get("msgtype").asText();
if (EnMsgType.EN_MSG_LOGIN.toString().equals(msgtype)){
//登录操作
return loginOperation(jsonNodes,channel);
}else if (EnMsgType.EN_MSG_MODIFY_SIGNATURE.toString().equals(msgtype)){
//修改签名
return modifySignature(jsonNodes);
}else if (EnMsgType.EN_MSG_MODIFY_NICKNAME.toString().equals(msgtype)){
//修改昵称
return modifyNickname(jsonNodes);
}else if (EnMsgType.EN_MSG_GETINFORMATION.toString().equals(msgtype)){
//获取登录信息
return getInformation(jsonNodes);
}else if (EnMsgType.EN_MSG_VERIFY_PASSWORD.toString().equals(msgtype)){
//进行修改密码
return verifyPasswd(jsonNodes);
}else if (EnMsgType.EN_MSG_CHAT.toString().equals(msgtype)){
//单聊模式
return SingleChat(jsonNodes);
}else if (EnMsgType.EN_MSG_GET_ID.toString().equals(msgtype)){
//获取id
return getId(jsonNodes);
}else if (EnMsgType.EN_MSG_GET_FRIEND.toString().equals(msgtype)){
//获取好友列表
return getFriend(jsonNodes);
}else if (EnMsgType.EN_MSG_ADD_FRIEND.toString().equals(msgtype)){
//添加好友
return addFriends(jsonNodes);
}else if (EnMsgType.EN_MSG_DEL_FRIEND.toString().equals(msgtype)){
//删除好友
return delFriend(jsonNodes);
}else if (EnMsgType.EN_MSG_ACTIVE_STATE.toString().equals(msgtype)){
//判断好友的在线状态
return friendIsActive(jsonNodes);
}
return "";
}
//判断好友在线状态
private static String friendIsActive(ObjectNode jsonNodes) {
int friendId = jsonNodes.get("friendId").asInt();
ObjectNode objectNode = JsonUtils.getObjectNode();
objectNode.put("msgtype",EnMsgType.EN_MSG_ACK.toString());
objectNode.put("srctype",EnMsgType.EN_MSG_ACTIVE_STATE.toString());
//客户端保证用户独立存在且是好友
Channel channel = CacheUtil.get(friendId);
//判断用户是否在线
if (channel == null){
//用户不在线
objectNode.put("code",200);
}else {
//用户在线
objectNode.put("code",300);
}
return objectNode.toString();
}
//添加好友
private static String delFriend(ObjectNode jsonNodes) {
Integer friendId = jsonNodes.get("friendId").asInt();
int userId = jsonNodes.get("id").asInt();
String localName = jsonNodes.get("localName").asText();
//封装发回客户端的JSON
ObjectNode objectNode = JsonUtils.getObjectNode();
objectNode.put("msgtype",EnMsgType.EN_MSG_ACK.toString());
objectNode.put("srctype",EnMsgType.EN_MSG_DEL_FRIEND.toString());
objectNode.put("code",200);
//验证是否存在当前好友
information information = informationDao.getInformation(friendId);
String friendName = information.getNickname();
//查询自己是否有该好友
boolean exist = friendDao.isExist(friendName,userId);
if (exist){
//存在当前好友进行删除操作
friendDao.delFriend(userId,friendName);
friendDao.delFriend(friendId,localName);
objectNode.put("code",300);
}
return objectNode.toString();
}
//添加好友
private static String addFriends(ObjectNode jsonNodes) {
Integer friendId = jsonNodes.get("friendId").asInt();
int userId = jsonNodes.get("id").asInt();
String localName = jsonNodes.get("localName").asText();
//验证是否有ID
boolean exists = userDao.verifyExistFriend(friendId);
ObjectNode objectNode = JsonUtils.getObjectNode();
objectNode.put("msgtype",EnMsgType.EN_MSG_ACK.toString());
objectNode.put("srctype",EnMsgType.EN_MSG_ADD_FRIEND.toString());
objectNode.put("code",200);
if(exists){
//表示存在此id
objectNode.put("code",300);
//获取好友昵称
information information = informationDao.getInformation(friendId);
String friendNickname = information.getNickname();
//进行添加好友的操作 两个对应的信息都应该添加
friendDao.addFriends(userId,localName,friendNickname);
friendDao.addFriends(friendId,friendNickname,localName);
}
return objectNode.toString();
}
//获取好友列表
private static String getFriend(ObjectNode jsonNodes) {
int uid = jsonNodes.get("uid").asInt();
//返回ArrayLis集合
ArrayList friends = friendDao.getFriends(uid);
//封装JSON
ObjectNode objectNode = JsonUtils.getObjectNode();
objectNode.put("msgtype",EnMsgType.EN_MSG_ACK.toString());
objectNode.put("srctype",EnMsgType.EN_MSG_GET_FRIEND.toString());
//写回friend集合
Iterator iterator = friends.iterator();
int i = 0;
while (iterator.hasNext()){
objectNode.put("res"+i,iterator.next());
i++;
}
//记录好友个数
objectNode.put("count",i);
return objectNode.toString();
}
//获取id
private static String getId(ObjectNode jsonNodes) {
String nickname = jsonNodes.get("nickname").asText();
information information = informationDao.nicknameGetId(nickname);
//联系人的id
int uid = information.getUid();
//封装JSON
ObjectNode objectNode = JsonUtils.getObjectNode();
objectNode.put("msgtype",EnMsgType.EN_MSG_ACK.toString());
objectNode.put("srctype",EnMsgType.EN_MSG_GET_ID.toString());
objectNode.put("uid",uid);
return objectNode.toString();
}
//单聊模式
private static String SingleChat(ObjectNode jsonNodes) {
int id = jsonNodes.get("id").asInt();
//根据id在friend表获取登录用户名
//封装JSON数据服务端转发数据
ObjectNode objectNode = JsonUtils.getObjectNode();
objectNode.put("msgtype",EnMsgType.EN_MSG_ACK.toString());
objectNode.put("srctype",EnMsgType.EN_MSG_CHAT.toString());
//客户端保证用户独立存在且是好友
Channel channel = CacheUtil.get(id);
//判断用户是否在线
if (channel == null){
//用户不在线
objectNode.put("code",200);
}else{
//用户在线
objectNode.put("code",300);
//消息转发
channel.writeAndFlush(jsonNodes.toString());
}
return objectNode.toString();
}
//修改密码
private static String verifyPasswd(ObjectNode jsonNodes) {
int id = jsonNodes.get("id").asInt();
String oldPasswd = jsonNodes.get("oldPasswd").asText();
String newPasswd = jsonNodes.get("newPasswd").asText();
boolean exits = userDao.verifyPassword(oldPasswd, id);
ObjectNode objectNode = JsonUtils.getObjectNode();
objectNode.put("msgtype",EnMsgType.EN_MSG_VERIFY_PASSWORD.toString());
objectNode.put("code",200);
if (exits){
//验证成功
userDao.modifyPasswd(newPasswd,id);
objectNode.put("code",300);
}
return objectNode.toString();
}
//获取信息
private static String getInformation(ObjectNode jsonNodes) {
int id = jsonNodes.get("id").asInt();
information information = informationDao.getInformation(id);
//封装JSON发回客户端
ObjectNode objectNode = JsonUtils.getObjectNode();
objectNode.put("msgtype",EnMsgType.EN_MSG_ACK.toString());
objectNode.put("srctype",EnMsgType.EN_MSG_GETINFORMATION.toString());
objectNode.put("Nickname",information.getNickname());
objectNode.put("Signature",information.getSignature());
return objectNode.toString();
}
//修改昵称
private static String modifyNickname(ObjectNode jsonNodes) {
int id = jsonNodes.get("id").asInt();
String nickname = jsonNodes.get("nickname").asText();
//进行存储
informationDao.storeNickname(nickname,id);
return "";
}
//修改签名
private static String modifySignature(ObjectNode jsonNodes) {
int id = jsonNodes.get("id").asInt();
String signature = jsonNodes.get("signature").asText();
//进行存储
informationDao.storeSignature(signature,id);
return "";
}
//登录操作
private static String loginOperation(ObjectNode objectNode,Channel channel) {
int id = objectNode.get("id").asInt();
String passwd = objectNode.get("passwd").asText();
//进行数据库查询
boolean exits = userDao.getInformation(id, passwd);
ObjectNode jsonNodes = JsonUtils.getObjectNode();
jsonNodes.put("msgtype",EnMsgType.EN_MSG_ACK.toString());
jsonNodes.put("srctype",EnMsgType.EN_MSG_LOGIN.toString());
jsonNodes.put("code",300);
//返回状态码
if (exits){
jsonNodes.put("code",200);
//添加用户的在线信息
CacheUtil.put(id,channel);
}
return jsonNodes.toString();
}
}
2.ClientHandler.java
客户端接受来自服务端返回的消息 根据返回的状态码来判断是否操作成功
package chat.Project.netty;
import chat.Frame.chat.ChatFrame;
import chat.Frame.chat.linkmen;
import chat.Frame.chat.login;
import chat.Project.constant.EnMsgType;
import chat.util.JsonUtils;
import com.fasterxml.jackson.databind.node.ObjectNode;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import java.util.concurrent.SynchronousQueue;
public class ClientHandler extends SimpleChannelInboundHandler<String> {
//定义一个同步阻塞队列状态码
public static SynchronousQueue