Java基于Socket实现聊天群聊敏感词汇过滤功能

Posted 吹灭读书灯 一身都是月

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Java基于Socket实现聊天群聊敏感词汇过滤功能相关的知识,希望对你有一定的参考价值。

首先的话,这个代码主要是我很久以前写的,然后当时还有很多地方没有理解,现在再来看看这份代码,实在是觉得丑陋不堪,想改,但是是真的改都不好改了…
所以,写代码,规范真的很重要。

实现的功能:

  1. 用户私聊
  2. 群聊功能:进群退群,群发消息,查看群聊
  3. 查看自己的消息记录
  4. 通过文件流,设置敏感词汇过滤(这里还用到了字典树…)不过我还有点不熟练…
  5. 离线,退出登录

不足:
emmm,其实说到不足的地方实在是太多了。
首先功能并没有完全完善,尤其是群聊的功能(但是我觉得后面的功能实现了也意义不大了)
然后,写代码并不规范。
也没有用到Java面向对象的知识,只存放用户的昵称,没有设置密码什么的
还要设置个,当用户上线之后,再来发送缓存之中的数据。
数据没有保存起来,关闭程序之后,数据消失了…
最开始的时候,我还不怎么会使用集合,后面发现在集合中放List(其实就是对象嘛),可以存很多东西的…
总而言之就是,还是要多写代码的,同时要多学习知识啊!!!

开始上代码!

目录结构


我这里的话,把我这四个类都放在test1包下。

实在是,这里用到了很多if else…然后,我这里想调用对应的方法语句都是要先输入对应的中文前缀的,很麻烦…建议大家使用循环,然后每次提示用户输入对应的指令。

TCPServer

首先就是要先启动服务端,如果没有启动的话是会报错的!!!

package test1;

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
import java.nio.charset.StandardCharsets;
import java.util.*;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class TCPServer 

    public static void main(String[] args) 
        TCPServer server = new TCPServer();
        server.start();
    

    /**
     * 创建线程池来管理客户端的连接线程
     * 避免系统资源过度浪费
     */
    private ServerSocket serverSocket;
    private ExecutorService exec;
    /**
     * 存放用户昵称,打印流
     */
    private Map<String, PrintWriter> storeInfo;
    /**
     * 存放客户端之间私聊的信息
     */
    private Map<String, LinkedList<String>> storeMessages;
    /**
     * 用户没有上线的消息【我这里没有实现】
     */
    private Map<String, String> waitMessages;

    /**
     * 群 K:群名称,Value:人员的昵称集合
     */
    Map<String, LinkedList<String>> aGroup = new LinkedHashMap<>();

    public TCPServer() //构造器
        try 
            serverSocket = new ServerSocket(9999);
            storeInfo = new ConcurrentHashMap<String, PrintWriter>();
            exec = Executors.newCachedThreadPool();//创建线程池
            storeMessages = new ConcurrentHashMap<String, LinkedList<String>>();
         catch (IOException e) 
            e.printStackTrace();
        
    

    public void start() 
        try 
            while (true) 
                System.out.println("服务端等待客户端连接... ... ");
                Socket socket = serverSocket.accept();//出现一个客户才会accept()
                System.out.println("客户端:“" + socket.getInetAddress().getHostAddress() + "”连接成功! ");
                //启动一个线程,由线程来处理客户端的请求,这样可以再次监听下一个客户端的连接
                //每次都是一个服务端Socket跟一个客户端绑定。同时服务端开启监听客户端的请求输入流
                exec.execute(new ListenerClient(socket)); //通过线程池来分配线程      监听客户机    出现一个客户,就新建一个线程
            
         catch (Exception e) 
            e.printStackTrace();
        
    

    /**
     * 创建内部类来获取昵称
     * 监听客户端
     * 该线程体用来处理给定的某一个客户端的消息,循环接收客户端发送 的每一个字符串,并输出到控制台
     */
    class ListenerClient implements Runnable 
        private Socket socket;
        private String name;

        public ListenerClient(Socket socket) 
            this.socket = socket;
        

        /**
         * 管理昵称的方法
         */
        private String getName() throws Exception 
            //服务端的输入流读取客户端发送来的昵称输出流
            BufferedReader bReader = new BufferedReader(
                    new InputStreamReader(socket.getInputStream(), StandardCharsets.UTF_8));
            //服务端将昵称验证结果通过自身的输出流发送给客户端
            PrintWriter ipw = new PrintWriter(
                    new OutputStreamWriter(socket.getOutputStream(), StandardCharsets.UTF_8), true);
            //读取客户端发来的昵称
            while (true) 
                String nameString = bReader.readLine();
                if ((nameString.trim().length() == 0) || storeInfo.containsKey(nameString)) 
                    ipw.println("FAIL");//发送给客户端
                 else 
                    ipw.println("OK");
                    return nameString;
                
            
        

        /**
         * 监听方法
         * 通过客户端的Socket获取客户端的输出流,用来将消息发送给客户端
         */
        @Override
        public void run() 
            try 
                PrintWriter pw = new PrintWriter(
                        new OutputStreamWriter(socket.getOutputStream(), StandardCharsets.UTF_8), true);
                name = getName();
                putIn(name, pw, storeInfo);//将客户昵称和服务端所说的内容存入共享集合HashMap-storeInfo中
                Thread.sleep(100);
                // 服务端通知所有客户端,某用户上线(是群发的)
                sendToAll("[系统通知] “" + name + "”已上线");
                System.out.println("[系统通知] “" + name + "”已上线");
                /* 读取客户端
                 * 通过客户端的Socket获取输入流读取客户端发送来的信息
                 */
                BufferedReader bReader = new BufferedReader(
                        new InputStreamReader(socket.getInputStream(), StandardCharsets.UTF_8));

                String msgString = null;//用msgString来获取客户端的输入
                while ((msgString = bReader.readLine()) != null) 
                    LinkedList<String> msgList = storeMessages.get(name);
                    if (msgList == null) 
                        msgList = new LinkedList<String>();
                    
                    // 检验是否为私聊(格式:@昵称:内容)
                    if (msgString.startsWith("@")) 
                        int index = msgString.indexOf(":");//@deng:xxx(冒号后面为内容)
                        if (index == -1) 
                            index = msgString.indexOf(":");
                        
                        if (index >= 0) 
                            String theName = msgString.substring(1, index);//获取昵称
                            String info = msgString.substring(index + 1);//获取发送的内容
                            if (isBlank(info)) 
                                pw.println("[系统提示]:给好友发送的消息不能为空哦!");
                            
                            info = "“" + name + "”:" + info;
                            //将私聊信息发送出去
                            boolean b = sendToSomeone(theName, isIllegal(info));
                            if (!b) 
//返回给原来的用户:消息发送失败,找不到人
                                pw.println("[系统提示]:未找到指定用户“" + theName + "“,消息发送失败");
                            
                            msgList.add(msgString);
                            storeMessages.put(name, msgList);
                            continue;
                        
                     else if (msgString.startsWith("新建群:") || msgString.startsWith("新建群:")) 
                        creatGroup(msgString, name);
                        continue;
                     else if (msgString.contains("群邀请:") || msgString.contains("群邀请:")) 
                        groupInvite(msgString, name);
                        continue;
                     else if (msgString.startsWith("退群:") || msgString.startsWith("退群:")) 
                        String groupName = msgString.substring(3);
                        exitGroup(groupName, name);
                        continue;
                     else if (msgString.startsWith("我想进群:") || msgString.startsWith("我想进群:") ) 
                        String groupName = msgString.substring(5);
                        acceptGroup(groupName, name);
                        continue;
                     else if (msgString.contains("查看我加入的群聊")) 
                        pw.println("我加入的群聊有"+showMyGroups(name));
                        continue;
                     else if ("查看消息记录".equals(msgString)) 
                        printOnlineUser(name);
                        printAllMessages(name);
                        continue;
                     else if ("撤回最近一条消息".equals(msgString)) 
                        withdraw(name);
                        continue;
                     else if (msgString.startsWith("群发给")) //在群里发信息:群发给XXX:。。。1.判断是否在群XXX里   2.群发内容
                        int index = msgString.indexOf(':');
                        if (index == -1) 
                            index = msgString.indexOf(":");
                        
                        String theGroupName = msgString.substring(3, index);//群聊名称
                        String theMsg = msgString.substring(index + 1);//内容
                        sendToGroup(theGroupName, isIllegal(theMsg), name);
                        continue;
                    
                    if ("exit".equals(msgString)) //手动退出程序
                        remove(name);
                        sendToAll("[系统通知] “" + name + "”已经手动下线了。");// 通知所有客户端,某某客户已经下线
                    
                    //否则:(自己乱发消息) 遍历所有输出流,将该客户端发送的信息转发给所有客户端
                    System.out.println(name + ":" + isIllegal(msgString));
                    sendToSomeone(name, isIllegal(msgString));

                    msgList.add(msgString);
                    storeMessages.put(name, msgList);
                
             catch (Exception e) 
                // e.printStackTrace();
             finally 
                remove(name);
                sendToAll("[系统通知] “" + name + "”已经下线了。");// 通知所有客户端,某某客户已经下线
                if (socket != null) 
                    try 
                        socket.close();
                     catch (IOException e) 
                        e.printStackTrace();
                    
                
            
        
    

    private boolean isBlank(String msg) 
        return msg == null || "".equals(msg.trim());
    

    private void putIn(String name, PrintWriter value, Map<String, PrintWriter> store) 
        synchronized (this) 
            store.put(name, value);
        
    

    /**
     * 将给定的输出流从共享集合中删除
     */
    private synchronized void remove(String key) 
        storeInfo.remove(key);
        System.out.println("系统当前在线人数为:" + storeInfo.size());
    

    /**
     * 将给定的消息转发给所有客户端(群发)
     */
    private synchronized void sendToAll(String message) 
        for (PrintWriter everyone : storeInfo.values()) 
            everyone.println(message);
        
    

    /**
     * 群发信息
     *
     * @param groupName 群聊名称
     * @param message   群发的内容
     * @param username  发信息的人
     */
    private synchronized void sendToGroup(String groupName, String message, String username) 
        LinkedList<String> nickNameList = aGroup.get(groupName);
        if (nickNameList == null) 
            sendToSomeone(username, "未找到指定的群:" + groupName);
         else 
            for (String name : nickNameList) 
                sendToSomeone(name, "【"+groupName + "】群的“" + username + "”说" + message);
            
        
    


    /**
     * 将给定的消息转发给私聊的客户端
     */
    private synchronized boolean sendToSomeone(String name, String message) //每一个名字对应一个只给它发送信息的PrintWriter
        PrintWriter pw = storeInfo.get(name); //将对应客户端的聊天信息取出作为私聊内容发送出去(相当于只发给指定的name的)
        if (pw != null) 
            pw.println(message);
            return true;
        
        return false;
    

    private static final SensitiveFilter sensitiveFilter = new SensitiveFilter();

    /**
     * 检测从服务端读入的信息是否合法-->读取 不含敏感信息
     * 否侧把敏感词汇进行过滤
     */
    private synchronized String isIllegal(String message) 
        String msg = sensitiveFilter.filter(message);
        if (msg == null) 
            return "[系统提示]:消息为空,发送失败了";
        
        return msg;
    


    private synchronized void creatGroup(String msgString, String hostname) 
        String groupName = msgString.substring(4);
        //1.建立Map,添加群主及群聊名称
        LinkedList<String> nickNameList = new LinkedList<>();
        nickNameList.add(hostname);
        aGroup.put(groupName

以上是关于Java基于Socket实现聊天群聊敏感词汇过滤功能的主要内容,如果未能解决你的问题,请参考以下文章

node.js + socket.io 聊天群聊系统

基于Java NIO的多人在线聊天工具源码实现(登录,单聊,群聊)

java socket编程实现群聊(超详细)

java socket编程实现群聊(超详细)

Java编程实例-tcp聊天室代码实现

Java过滤敏感词语/词汇---DFA算法