這篇文章帶給大家的內容是關於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中文網其他相關文章！
