首先websocket后臺需要在web服務器運行，所以先搭建一個web項目。websocket需要依賴其他的jar包，引入依賴

javaxjavaee-api7.0provided

新建一個類，該類建立一個服務端點 ServerEndpoint

importjavax.websocket.*;importjavax.websocket.server.PathParam;importjavax.websocket.server.ServerEndpoint;importjava.io.IOException;importjava.util.concurrent.ConcurrentHashMap;

/***@authorRice*@create2020/06/24 15:56*/@ServerEndpoint("/ws/{sid}")

public classWSServer {

privateSession session;private staticConcurrentHashMap ss= newConcurrentHashMap();private intoln;

@OnOpenpublic voidonOpen(Session session,@PathParam("sid") String sid){

oln++;this.session= session;ss.put(sid,session);}

@OnMessagepublic voidonMessage(String message ,Session session,@PathParam("sid") String sid ) throwsIOException {

Msg msg = Msg.getInstance(message);msg.setUser(sid);if(msg.getTid()==1){

privateChat(msg);return ;}

}

@OnClosepublic voidonClose(@PathParam("sid") String sid){

oln--;ss.remove(sid);}

@OnErrorpublic voidonError(Session session ,Throwable error){

System.out.println(error);}

private voidprivateChat(Msg msg) throwsIOException {

if(ss.containsKey(msg.getTsid())){

Session ts = ss.get(msg.getTsid());ts.getBasicRemote().sendText(Msg.forwordMSg(msg));}else{

this.session.getBasicRemote().sendText("對方不在線");}

}

}

前端(客戶端點)：

ws = new WebSocket("ws://localhost:8080/wws/ws/"+_this.luser)

ws.onmessage=function(event){

let rm = JSON.parse(event.data);

if(!_this.msgs[rm.user]){

_this.$set(_this.msgs,rm.user,new Array());

}

_this.msgs[rm.user].push(rm.user+": "+rm.msg);

}

當客戶端點調用new Websocket時，會發起和服務端的連接。當websocekt的readystate變為1時，會觸發后端onopen事件，此時一般會將建立連接的session加入到管理的Map中，記錄session的名字和session.以此方便進行消息的轉發。

當客戶端readystate=1(連接成功),客戶端可以進行發消息，關閉連接。當客戶端調用websocket.send(String msg)，后臺會觸發onMessage方法并且把消息以及發消息的session傳入到該方法中進行處理。通常客戶端發送的消息需要自行規定數據報格式，如JSON，給后臺進行解析。

客戶端點同樣的需要進行onmessage方法的處理，當服務端往客戶端session發送消息，同樣會觸發客戶端的onmessage方法。以此達到即時溝通

總結

以上是生活随笔為你收集整理的java js websocket_js+java websocket记录的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。