前言

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();    }}
1

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 {    //定义一个同步阻塞队列状态码    public static SynchronousQueue