目的

通过之前学习了Java语言中的网络编程，今天就来实现QQ内部的相应聊天功能（群聊、登录功能、群聊）

相关技术、及其使用

QQ图片20190822184802.jpg

1、通过创建一个接口对客户端和发服务器端进行进行相应的规范
客户端的需求可以再发送的字符里面体现
1、登录 u+姓名 u+
2、返回结果 成功1 失败-1
3、私聊 p+姓名 ♥ 聊天内容 p+
4、群聊 a+聊天内容 a+
5、发文件 f+
6、发语音 v+

public interface ChatProtocol {
    //登录
    String LOGIN_FLAG = "u+";
    //私聊
    String PRIVATE_FLAG = "p+";
    //群聊
    String PUBLIC_FLAG = "a+";

    //分隔符
    String SPLIT_FLAG = "♥";

    //成功与否的状态
    String SUCCESS = "1";
    String FAILUER = "-1";

}

2、创建服务器端和服务器端的子线程
这个功能的代码在之前就有讲解，所以，在此就不详细讲解：
创建服务器端：

public class Server {
    //用于保存每一个用户对应的姓名和socket
    public static UserManager manager = new UserManager();

    public static void main(String [] agrs){
        //创建ServerSocket

        try {
            ServerSocket ss = new ServerSocket(8888);
            //监听所有来连接的客户端
            while (true){
                Socket socket = ss.accept();

                //让子线程处理这个socket

            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

其次，创建子线程继承于Thread并实现Thread里面的run方法

class ServerThread extends Thread{
    private Socket socket;

    public ServerThread(Socket socket){
        this.socket = socket;
    }
    @Override
    public void run() {
        BufferedReader br = null;
        PrintStream ps = null;
        try {
            //得到对应的输入流对象
            br = new BufferedReader(new InputStreamReader(socket.getInputStream()));

            //得到对应的输出流对象
            ps = new PrintStream(socket.getOutputStream());

            String line = null;
            while ((line = br.readLine()) != null){
                //判断是不是登录
                if(line.startsWith(ChatProtocol.LOGIN_FLAG) &&line.endsWith(ChatProtocol.LOGIN_FLAG)){
                    //获取名字
                    String  name = line.substring(2,line.length()-2);

                    //判断这个用户是否已经登录
                    if(Server.manager.isLogined(name)){
                        //登录过了 发送结果给客户端
                        ps.println(ChatProtocol.FAILUER);
                    }else {
                        //没有登录
                        // 保存当前登录的用户信息
                        Server.manager.save(name,socket);

                        //发送结果给客户端
                        ps.println(ChatProtocol.SUCCESS);
                    }
                }
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

在子线程socket里面需要注意的一点就是，从终端获取到名字过后需要判断是否该用户已经登录同时实现接口ChatProtocol

3、创建客户端
创建客户端的相关步骤和之前的都差不多，但是，这次在客户端里面需要对登录进行相关处理：

try {
            Socket socket = new Socket("10.129.14.97",8888);
            //接收终端的输入流
            br = new BufferedReader(new InputStreamReader(System.in));
            //接收服务器端的输出流
            ps = new PrintStream(socket.getOutputStream());
            //接收服务器端的输入流
            brSever = new BufferedReader( new InputStreamReader(socket.getInputStream()));

            //登录
            while (true){
                //接收终端输入信息
                /*
                BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
                String line = br.readLine();
                */
                String line =  JOptionPane.showInputDialog("请输入用户名：");
                //拼接登录格式
                String loginStr = ChatProtocol.LOGIN_FLAG +line +ChatProtocol.LOGIN_FLAG;

                ps.println(loginStr);

                String result = brSever.readLine();

                //判断登录结果
                if(result.equals(ChatProtocol.SUCCESS)){
                    break;
                }else{
                    System.out.println("用户名已存在，请重新登录");
                }
            }

            //登录成功
            //开启线程处理服务器端的输入
            new ClientThread(socket).start();

            //接收终端输入 发送给服务器端
            String line ;
            while ((line = br.readLine()) != null){
                ps.println(line);
            }

        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

4、最后创建一个UserManager定义一些方法对客户端里面相关功能进行实现

public class UserManager{
    //保存所有用户信息
    private Map<String, Socket> users = new HashMap<>();

    //判断用户是否已经登录
    public boolean isLogined(String name){
        //遍历数组
       for(String key:users.keySet()){
           if(key.equals(name)){
               return true;
           }
       }
       return false;
    }

    //保存当前登陆的用户信息
    public void save(String name, Socket socket){
        users.put(name,socket);
    }
    //通过用户名找到对应的socket
    public Socket socketByName(String name){
      return users.get(name);
    }
    //通过socket对象找到对应的名称
    public String nameBySocket(Socket socket){
        for(String key :users.keySet()){
            //取出这个key 对应的socket
            if(socket == users.get(key)){
                return key;
            }
        }
        return null;
    }
    /*
        获取所有人的socket对象
     */
    public Collection<Socket> allUsers(){
        return users.values();
    }
}

PS

今天讲的这个demo是对昨天网络编程相关知识的复习和进一步延伸。今天，课堂上用到了Map集合和HashMap里面的toString方法，一下子没想起来，然后上完课后，自己跟着思路重新写demo的时候才想起来Map集合的相关用法，所以，感觉现在几乎又把之前学的那些知识个忘掉了，学了这个忘了那个。