Java如何制作一个webSocket网页聊天室（附代码）
本篇文章给大家带来的内容是关于Java如何制作一个webSocket网页聊天室（附代码），有一定的参考价值，有需要的朋友可以参考一下，希望对你有所帮助。
一、什么是webSocket
WebSocket 是一种网络通信协议，是持久化协议。RFC6455 定义了它的通信标准。
WebSocket 是 HTML5 开始提供的一种在单个 TCP 连接上进行全双工通讯的协议。
二、为什么要使用webSocket
传统的web通信是使用的http技术，http协议是无状态的、无连接的、单向的应用层协议。一次请求只能对应一个响应，通信请求只能由客户端发出，服务端对请求做出响应。所以服务端发出响应是非常被动的，这种被动的响应注定了服务端无法及时的给客户端主动推送响应，如果服务端有连续的状态变化的时候，客户端获取是很困难的。通过频繁使用了异步ajax去不断地获取请求去实现长轮询，这样做是特别消耗性能，而且效率低下。（不停的握手，或者长时间保持live)。
而webSocket允许服务器和客户端之间建立全双工通信，只要建立一次连接，就能一直保持连接状态。一旦建立一次连接，就能双方互相通信，不需要多次握手。
三、实现WEB聊天室
添加pom.xml，引入jar包
<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>
<script type="text/javascript" src="./static/jquery-3.2.0.min.js"></script>
<!-- 最新版本的 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 文件 -->
<script src="https://cdn.bootcss.com/bootstrap/3.3.7/js/bootstrap.min.js" integrity="sha384-Tc5IQib027qvyjSMfHjOMaLkfuWVxZxUPnCJA7l2mCWNIpG9mGCD8wGNIcPD7Txa" crossorigin="anonymous"></script>
</head>
<body>
<div>
<div><span>聊天室</span>
<button class="btn btn-warning" onclick="doClose();">退出聊天</button>
</div>
<div><textarea class="form-control" style="width: 40%;" rows="3" id="contentInp"></textarea></div><hr/>
<div><button class="btn btn-danger" onclick="doClear();">清空会话框</button></div>
<div id="content">开始聊天<br/></div>
</div>
</body>
<script 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.onerror = 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();
}
</script>
</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.OnError;
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
*/
@OnError
public void onError(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;
}
}以上是Java如何制作一个webSocket网页聊天室（附代码）的详细内容。更多信息请关注PHP中文网其他相关文章！
热AI工具
Undresser.AI Undress
人工智能驱动的应用程序，用于创建逼真的裸体照片
AI Clothes Remover
用于从照片中去除衣服的在线人工智能工具。
Undress AI Tool
免费脱衣服图片
Clothoff.io
AI脱衣机
Video Face Swap
使用我们完全免费的人工智能换脸工具轻松在任何视频中换脸！
热门文章
热工具
记事本++7.3.1
好用且免费的代码编辑器
SublimeText3汉化版
中文版，非常好用
禅工作室 13.0.1
功能强大的PHP集成开发环境
Dreamweaver CS6
视觉化网页开发工具
SublimeText3 Mac版
神级代码编辑软件(SublimeText3)
golang WebSocket与JSON的结合：实现数据传输和解析
Dec 17, 2023 pm 03:06 PM
golangWebSocket与JSON的结合：实现数据传输和解析在现代的Web开发中，实时数据传输变得越来越重要。WebSocket是一种用于实现双向通信的协议，与传统的HTTP请求-响应模型不同，WebSocket允许服务器向客户端主动推送数据。而JSON（JavaScriptObjectNotation）是一种用于数据交换的轻量级格式，它简洁易读
WebSocket与JavaScript：实现实时监控系统的关键技术
Dec 17, 2023 pm 05:30 PM
WebSocket与JavaScript：实现实时监控系统的关键技术引言：随着互联网技术的快速发展，实时监控系统在各个领域中得到了广泛的应用。而实现实时监控的关键技术之一就是WebSocket与JavaScript的结合使用。本文将介绍WebSocket与JavaScript在实时监控系统中的应用，并给出代码示例，详细解释其实现原理。一、WebSocket技
如何使用PHP和WebSocket实现实时通信
Dec 17, 2023 pm 10:24 PM
随着互联网技术的不断发展，实时通信已经成为了日常生活中不可缺少的一部分。利用WebSockets技术可以实现高效、低延迟的实时通信，而PHP作为互联网领域使用最广泛的开发语言之一，也提供了相应的WebSocket支持。本文将为大家介绍如何使用PHP和WebSocket实现实时通信，并提供具体的代码示例。一、什么是WebSocketWebSocket是一种在单
如何使用WebSocket和JavaScript实现在线语音识别系统
Dec 17, 2023 pm 02:54 PM
如何使用WebSocket和JavaScript实现在线语音识别系统引言：随着科技的不断发展，语音识别技术已经成为了人工智能领域的重要组成部分。而基于WebSocket和JavaScript实现的在线语音识别系统，具备了低延迟、实时性和跨平台的特点，成为了一种被广泛应用的解决方案。本文将介绍如何使用WebSocket和JavaScript来实现在线语音识别系
Java和WebSocket的结合：如何实现实时视频流播放
Dec 17, 2023 pm 05:50 PM
随着互联网技术的不断发展，实时视频流已经成为了互联网领域的一个重要应用。要实现实时视频流播放，其中的关键技术包括WebSocket和Java。本文将介绍如何结合使用WebSocket和Java实现实时视频流播放，并提供相关的代码示例。一、什么是WebSocketWebSocket是一种在单个TCP连接上进行全双工通信的协议，它在Web
PHP和WebSocket: 实现实时数据传输的最佳实践方法
Dec 18, 2023 pm 02:10 PM
PHP和WebSocket：实现实时数据传输的最佳实践方法引言：在Web应用程序开发中，实时数据传输是一项非常重要的技术需求。传统的HTTP协议是一种请求-响应模式的协议，不能有效地实现实时数据传输。为了满足实时数据传输的需求，WebSocket协议应运而生。WebSocket是一种全双工通信协议，它提供了一种在单个TCP连接上进行全双工通信的方式。相比于H
如何利用Java和WebSocket实现实时股票行情推送
Dec 17, 2023 pm 09:15 PM
如何利用Java和WebSocket实现实时股票行情推送引言：随着互联网的快速发展，股票行情实时推送成为了投资者关注的焦点之一。传统的股票行情推送方式存在延迟较高、刷新速度慢等问题，对于投资者来说，无法及时获得最新的股票行情信息可能会导致投资决策的误差。而基于Java和WebSocket的实时股票行情推送可以有效解决这一问题，使投资者能够第一时间获取到最新的
SSE 与 WebSocket
Apr 17, 2024 pm 02:18 PM
在本文中，我们将比较服务器发送事件（SSE）和 WebSocket，两者都是用于传递数据的可靠方法。我们将在八个方面对它们进行分析，包括通信方向、底层协议、安全、易用性、性能、消息结构、易用性和测试工具。这些方面的比较总结如下：类别服务器发送事件 (SSE)WebSocket通信方向单向双向底层协议HTTPWebSocket 协议安全与 HTTP 相同存在安全漏洞易用性设置简单设置复杂性能消息发送速度快受消息处理和连接管理影响消息结构纯文本文本或二进制易用性广泛可用对 WebSocket 集成有
