本篇文章给大家带来的内容是关于java如何制作一个websocket网页聊天室（附代码），有一定的参考价值，有需要的朋友可以参考一下，希望对你有所帮助。
一、什么是webSocket
WebSocket 是一种网络通信协议，是持久化协议。RFC6455 定义了它的通信标准。
WebSocket 是 HTML5 开始提供的一种在单个 TCP 连接上进行全双工通讯的协议。
二、为什么要使用webSocket
传统的web通信是使用的http技术，http协议是无状态的、无连接的、单向的应用层协议。一次请求只能对应一个响应，通信请求只能由客户端发出，服务端对请求做出响应。所以服务端发出响应是非常被动的，这种被动的响应注定了服务端无法及时的给客户端主动推送响应，如果服务端有连续的状态变化的时候，客户端获取是很困难的。通过频繁使用了异步ajax去不断地获取请求去实现长轮询，这样做是特别消耗性能，而且效率低下。（不停的握手，或者长时间保持live)。
而webSocket允许服务器和客户端之间建立全双工通信，只要建立一次连接，就能一直保持连接状态。一旦建立一次连接，就能双方互相通信，不需要多次握手。
三、实现WEB聊天室
添加pom.xml，引入jar包
立即学习“Java免费学习笔记（深入）”；
<dependency> <groupId>javax</groupId> <artifactId>javaee-api</artifactId> <version>7.0</version> <scope>provided</scope> </dependency>
2.建立html和js文件
<!DOCTYPE html><html><head><meta charset="UTF-8"><title>在线聊天室</title><ｓｃｒｉｐｔ type="text/javascript" src="./static/jquery-3.2.0.min.js"></ｓｃｒｉｐｔ><!-- 最新版本的 Bootstrap 核心 CSS 文件 --><link rel="stylesheet" href="https://cdn.bootcss.com/bootstrap/3.3.7/css/bootstrap.min.css" integrity="sha384-BVYiiSIFeK1dGmJRAkycuHAHRg32OmUcww7on3RYdg4Va+PmSTsz/K68vbdEjh4u" crossorigin="anonymous"><!-- 最新的 Bootstrap 核心 JavaScript 文件 --><ｓｃｒｉｐｔ src="https://cdn.bootcss.com/bootstrap/3.3.7/js/bootstrap.min.js" integrity="sha384-Tc5IQib027qvyjSMfHjOMaLkfuWVxZxUPnCJA7l2mCWNIpG9mGCD8wGNIcPD7Txa" crossorigin="anonymous"></ｓｃｒｉｐｔ></head><body> <p> <p><span>聊天室</span> <button class="btn btn-warning" onclick="doClose();">退出聊天</button> </p> <p><textarea class="form-control" style="width: 40%;" rows="3" id="contentInp"></textarea></p><hr/> <p><button class="btn btn-danger" onclick="doClear();">清空会话框</button></p> <p id="content">开始聊天<br/></p> </p></body><ｓｃｒｉｐｔ type="text/javascript"> var ws = new WebSocket("ws://localhost:8080/ws/websocket"); //controller层url $(function(){ $("#contentInp").keyup(function(evt){ if(evt.which == 13){ //enter键发送消息 var htm = $("#contentInp").val(); doSend(htm); $("textarea").empty(); } }); }) ws.onopen = function(){ appendHtm("连接成功！"); } // 从服务端接收到消息，将消息回显到聊天记录区 ws.onmessage = function(evt){ appendHtm(evt.data); } ws.ｏｎｅｒｒｏｒ = function(){ appendHtm("连接失败！"); } ws.onclose = function(){ appendHtm("连接关闭！"); } function appendHtm(htm){ ($("#content")[0]).innerHTML += htm +"<br/>" } // 注销登录 function doClose(){ ws.close(); } // 发送消息 function doSend(htm){ // ($("#content")[0]).innerHTML += htm +"<br/>" ws.send(htm); } function doClear(){ $("#content").empty(); }</ｓｃｒｉｐｔ></html>
3.后台java代码
package controller;import java.io.IOException;import java.util.concurrent.CopyOnWriteArraySet;import javax.net.ssl.SSLSession;import javax.websocket.OnClose;import javax.websocket.ｏｎｅｒｒｏｒ;import javax.websocket.OnMessage;import javax.websocket.OnOpen;import javax.websocket.Session;import javax.websocket.server.ServerEndpoint;@ServerEndpoint("/websocket")public class WebScoketServer { private static Integer onlineNum = 0; //当前在线人数，线程必须设计成安全的 private static CopyOnWriteArraySet<WebScoketServer> arraySet = new CopyOnWriteArraySet<WebScoketServer>(); //存放每一个客户的的WebScoketServer对象，线程安全 private Session session; /** * 连接成功 * @param session 会话信息 */ @OnOpen public void onOpen(Session session) { this.session =session; arraySet.add(this); this.addOnlineNum(); System.out.println("有一个新连接加入，当前在线 "+this.getOnLineNum()+" 人"); } /** * 连接关闭 */ @OnClose public void onClose() { arraySet.remove(this); this.subOnlineNum(); System.out.println("有一个连接断开，当前在线 "+this.getOnLineNum()+" 人"); } /** * 连接错误 * @param session * @param error */ @ｏｎｅｒｒｏｒ public void ｏｎｅｒｒｏｒ(Session session, Throwable error) { System.err.println("发生错误！"); error.printStackTrace(); } /** * 发送消息,不加注解，自己选择实现 * @param msg * @throws IOException */ public void onSend(String msg) throws IOException { this.session.getBasicRemote().sendText(msg); } /** * 收到客户端消息回调方法 * @param session * @param msg */ @OnMessage public void onMessage(Session session, String msg) { System.out.println("消息监控："+msg); for (WebScoketServer webScoketServer : arraySet) { try { webScoketServer.onSend(msg); } catch (IOException e) { e.printStackTrace(); continue; } } } /** * 增加一个在线人数 */ private synchronized void addOnlineNum() { onlineNum++; } /** * 减少一个在线人数 */ private synchronized void subOnlineNum() { onlineNum--; } private Integer getOnLineNum() { return onlineNum; }}
免责声明：本站内容仅用于学习参考，信息和图片素材来源于互联网，如内容侵权与违规，请联系我们进行删除，我们将在三个工作日内处理。联系邮箱：chuangshanghai#qq.com（把#换成@）