devbox
知新_RL
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

使用websocket-多人实时通讯_websocket 单服务端向多个客户端通信同时通信

作者：知新_RL | 2024-07-29 11:58:27

赞

踩

websocket 单服务端向多个客户端通信同时通信

HTML 

  1. <!DOCTYPE html>
  2. <html lang="en">
  3.  
  4. <head>
  5.     <meta charset="UTF-8">
  6.     <meta http-equiv="X-UA-Compatible" content="IE=edge">
  7.     <meta name="viewport" content="width=device-width, initial-scale=1.0">
  8.     <title>使用websocket-多人实时通讯</title>
  9. </head>
  10.  
  11. <body>
  12.     <div style="width: 600px;height: 240px;overflow-y: auto;border: 1px solid #ddd;" id="show"></div>
  13.     <input type="text" size="80" id="msg" name="msg" />
  14.     <input type="button" value="发送" onclick="sendMsg()">
  15.     <script>
  16.         //创建websocket对象
  17.         var websocket = new WebSocket('ws://IP:3000');
  18.         //当WebSocket 建立网络连接时触发该函数
  19.         websocket.onopen = function() {
  20.             //为onmessage事件绑定监听器，接收消息
  21.             websocket.onmessage = function(event) {
  22.                 //接收并显示消息
  23.                 document.getElementById('show').innerHTML += event.data + "<br/>";
  24.             }
  25.         }
  26.  
  27.         var sendMsg = function() {
  28.             var inputEle = document.getElementById('msg');
  29.             //发送消息
  30.             websocket.send(inputEle.value);
  31.             //清空单行文本框
  32.             inputEle.value = '';
  33.         }
  34.  
  35.         //为onmessage事件绑定监听器，接收消息
  36.         websocket.onmessage = function(event) {
  37.             //接收消息
  38.             alert('收到的消息是：' + event.data);
  39.         }
  40.     </script>
  41. </body>
  42.  
  43. </html>

Java

  1. package com.company;
  2.  
  3. import java.io.*;
  4. import java.net.*;
  5. import java.nio.charset.Charset;
  6. import java.security.MessageDigest;
  7. import java.util.regex.*;
  8. import java.util.*;
  9. import sun.misc.BASE64Encoder;
  10. /**
  11.  * Description:
  12.  * <br/>网站: <a href="http://www.crazyit.org">疯狂Java联盟</a>
  13.  * <br/>Copyright (C), 2001-2012, Yeeku.H.Lee
  14.  * <br/>This program is protected by copyright laws.
  15.  * <br/>Program Name:
  16.  * <br/>Date:
  17.  * @author Yeeku.H.Lee kongyeeku@163.com
  18.  * @version 1.0
  19.  */
  20. public class ChatServer
  21. {
  22.     // 记录所有的客户端Soccket
  23.     public static List<Socket> clientSockets
  24.             = new ArrayList<Socket>();
  25.     public ChatServer()throws IOException
  26.     {
  27.         // 创建ServerSocket，准备接受客户端连接
  28.         ServerSocket ss = new ServerSocket(3000);
  29.         while(true)
  30.         {
  31.             // 接收到客户端连接
  32.             Socket socket = ss.accept();
  33.             // 将客户端Socket添加到clientSockets集合中
  34.             clientSockets.add(socket);
  35.             // 启动线程
  36.             new ServerThread(socket).start();
  37.         }
  38.     }
  39.     public static void main(String[] args)
  40.             throws Exception
  41.     {
  42.         new ChatServer();
  43.     }
  44. }
  45. class ServerThread extends Thread
  46. {
  47.     private Socket socket;
  48.     public ServerThread(Socket socket)
  49.     {
  50.         this.socket = socket;
  51.     }
  52.     public void run()
  53.     {
  54.         try
  55.         {
  56.             // 得到Socket对应的输入流
  57.             InputStream in = socket.getInputStream();
  58.             // 得到Socket对应的输出流
  59.             OutputStream out = socket.getOutputStream();
  60.             byte[] buff = new byte[1024];
  61.             String req = "";
  62.             // 读取数据，此时建立与WebSocket的"握手"。
  63.             int count = in.read(buff);
  64.             // 如果读取的数据长度大于0
  65.             if(count > 0)
  66.             {
  67.                 // 将读取的数据转化为字符串
  68.                 req = new String(buff , 0 , count);
  69.                 System.out.println("握手请求：" + req);
  70.                 // 获取WebSocket的key
  71.                 String secKey = getSecWebSocketKey(req);
  72.                 System.out.println("secKey = " + secKey);
  73.                 String response = "HTTP/1.1 101 Switching Protocols\r\nUpgrade: "
  74.                         + "websocket\r\nConnection: Upgrade\r\nSec-WebSocket-Accept: "
  75.                         + getSecWebSocketAccept(secKey) + "\r\n\r\n";
  76.                 System.out.println("secAccept = " + getSecWebSocketAccept(secKey));
  77.                 out.write(response.getBytes());
  78.             }
  79.             int hasRead = 0;
  80.             // 不断读取WebSocket发送过来的数据
  81.             while((hasRead = in.read(buff)) > 0)
  82.             {
  83.                 System.out.println("接收的字节数：" + hasRead);
  84. 				/*
  85. 					因为WebSocket发送过来的数据遵循了一定的协议格式，
  86. 					其中第3个～第6个字节是数据掩码。
  87. 					从第7个字节开始才是真正的有效数据。
  88. 					因此程序使用第3个～第6个字节对后面的数据进行了处理
  89. 				*/
  90.                 for (int i = 0 ; i < hasRead - 6 ; i++ )
  91.                 {
  92.                     buff[i + 6] = (byte) (buff[i % 4 + 2] ^ buff[i + 6]);
  93.                 }
  94.                 // 获得从浏览器发送过来的数据
  95.                 String pushMsg = new String(buff
  96.                         , 6 , hasRead - 6 , "UTF-8");
  97.                 // 遍历Socket集合，依次向每个Socket发送数据
  98.                 for (Iterator<Socket> it = ChatServer.clientSockets.iterator()
  99.                      ; it.hasNext() ;)
  100.                 {
  101.                     try
  102.                     {
  103.                         Socket s = it.next();
  104.                         // 发送数据时，第一个字节必须与读到的第一个字节相同
  105.                         byte[] pushHead = new byte[2];
  106.                         pushHead[0] = buff[0];
  107.                         // 发送数据时，第二个字节记录发送数据的长度
  108.                         pushHead[1] = (byte) pushMsg.getBytes("UTF-8").length;
  109.                         // 发送前两个字节
  110.                         s.getOutputStream().write(pushHead);
  111.                         // 发送有效数据
  112.                         s.getOutputStream().write(pushMsg.getBytes("UTF-8"));
  113.                     }
  114.                     catch (SocketException ex)
  115.                     {
  116.                         // 如果捕捉到异常，表明该Socket已经关闭
  117.                         // 将该Socket从Socket集合中删除
  118.                         it.remove();
  119.                     }
  120.                 }
  121.             }
  122.         }
  123.         catch (Exception e)
  124.         {
  125.             e.printStackTrace();
  126.         }
  127.         finally
  128.         {
  129.             try
  130.             {
  131.                 // 关闭Socket
  132.                 socket.close();
  133.             }
  134.             catch (IOException ex)
  135.             {
  136.                 ex.printStackTrace();
  137.             }
  138.         }
  139.     }
  140.     // 获取WebSocket请求的SecKey
  141.     private String getSecWebSocketKey(String req)
  142.     {
  143.         //构建正则表达式，获取Sec-WebSocket-Key: 后面的内容
  144.         Pattern p = Pattern.compile("^(Sec-WebSocket-Key:).+",
  145.                 Pattern.CASE_INSENSITIVE | Pattern.MULTILINE);
  146.         Matcher m = p.matcher(req);
  147.         if (m.find())
  148.         {
  149.             // 提取Sec-WebSocket-Key
  150.             String foundstring = m.group();
  151.             return foundstring.split(":")[1].trim();
  152.         }
  153.         else
  154.         {
  155.             return null;
  156.         }
  157.     }
  158.     // 根据WebSocket请求的SecKey计算SecAccept
  159.     private String getSecWebSocketAccept(String key)
  160.             throws Exception
  161.     {
  162.         String guid = "258EAFA5-E914-47DA-95CA-C5AB0DC85B11";
  163.         key += guid;
  164.         MessageDigest md = MessageDigest.getInstance("SHA-1");
  165.         md.update(key.getBytes("ISO-8859-1") , 0 , key.length());
  166.         byte[] sha1Hash = md.digest();
  167.         BASE64Encoder encoder = new BASE64Encoder();
  168.         return encoder.encode(sha1Hash);
  169.     }
  170. }

使用方式1

Tomcat启动

1. 把项目部署到webapp目录

2. 打开D:\ITData\tomcat\tomcat-8.0\bin -> startup.bat

3. 访问http://localhost:8080/webapp下的项目/...html

使用方式2：使用vscode-ip访问可以实现同区域网段聊天

参考：

websocket实现聊天室

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/知新_RL/article/detail/898636
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。