Socket-based Chatroom

基于JAVA Socket的网络聊天室

完整内容及代码 github

主要特点

1. 连接mysql，具有用户的注册和登陆验证功能，端口号：9611

• 存储用户的账户名和密码，以及昵称和salt值。
• 密码存储的格式应该是以hash摘要的形式储存，为了避免hash冲突，同时储存salt值，提升安全性。
• 密码的验证方式应该为：
  1. 用户输入账号密码。
  2. 客户端基于账号向服务器段请求salt值。
  3. 客户端收到salt生成hash digest=hash(password+salt);
  4. 将生成的hash digest和账号一起到服务器数据库验证。

2. 进入聊天室, 端口号：9806

• 所有传输的信息加密：基于SSL
• 服务器端：
  1. 监听阻塞 listen()
  2. 建立SSLSocket连接后加入SSLSocketList accept() -> SSLSocketList()
     • 验证证书及密钥
  3. 新建接受线程 New ReceiveThread(Socket) -> ReceiveThread.Start()
  4. 广播消息：ReceiveThread() -> for each(SendThread())
• 客户端：
  1. 发送SSLSocket请求
     • 包括证书和密钥
  2. 新建两个线程：
     • 接收线程: ReceiveThread.start()

       private static class ReceiceThread implements Runnable {
           Socket socket;
           public ReceiceThread(Socket socket) {
               this.socket=socket;
           }
           @Override
           public void run() {
               try{
                   InputStream inputStream=socket.getInputStream();
                   InputStreamReader isr=new InputStreamReader(inputStream);
                   BufferedReader br =new BufferedReader(isr);
                   while(true){
                       String receiveMessage=br.readLine();
                       if(receiveMessage==null){
                           socket.shutdownInput();
                           socket.close();
                           break;
                       }
                       System.out.println(receiveMessage);
                   }
               }
               catch (Exception e){
                   e.printStackTrace();
               }
           }
       }

     • 发送线程: SendThread.start()

       private static class SendThread implements Runnable {
           Socket socket;
           public SendThread(Socket socket) {
               this.socket=socket;
           }
       
           @Override
           public void run() {
               try {
                   OutputStream outputStream=socket.getOutputStream();
                   OutputStreamWriter osw=new OutputStreamWriter(outputStream);
                   PrintWriter pw=new PrintWriter(osw,true);
                   Scanner scanner=new Scanner(System.in);
                   String join_text="【"+nickname+" join the chatroom】";
                   pw.println(join_text);
                   while(true){
                       String message=scanner.nextLine();
                       if(message.equals("\\quit")){//退出聊天程序
                           String leave_text="【"+nickname+" left the chatroom】";
                           pw.println(leave_text);
                           chatFlag=false;
                           socket.shutdownOutput();
                           break;
                       }
                       String text_temp="【"+nickname+"】"+" : "+message;
                       pw.println(text_temp);
                   }
               } catch (IOException e) {
                   e.printStackTrace();
               }
           }
       }

3.下传及下载文件功能，端口号：8888&9999