本文主要和大家介紹HTML5 WebSocket實(shí)現(xiàn)點(diǎn)對點(diǎn)聊天的示例代碼的相關(guān)資料,小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧，希望能幫助到大家。

因?yàn)槭悄M的，這里給出的是兩個JSP頁面A和B，里面分別向session里放了兩個名字小明和小化，注意，這里的session是HttpSession session，之前多人聊天里的session是javax.websocket.Session;不一樣的。

這里想一下， 使用HttpSession session控制聊天的用戶，好處怎樣，自己猜~~~

這里沒有使用注解，傳統(tǒng)的web.xml配置方式，首先在系統(tǒng)啟動的時候調(diào)用InitServlet方法

html' target='_blank'>public class InitServlet extends HttpServlet { private static final long serialVersionUID = -3163557381361759907L;  private static HashMap String,MessageInbound socketList;  public void init(ServletConfig config) throws ServletException {  InitServlet.socketList = new HashMap String,MessageInbound  super.init(config);  System.out.println( 初始化聊天容器  public static HashMap String,MessageInbound getSocketList() {  return InitServlet.socketList; }

這里你可以跟自己的系統(tǒng)結(jié)合，對應(yīng)的web配置代碼如下：

 ?xml version= 1.0 encoding= UTF-8 ?  web-app version= 3.0 xmlns= http://java.sun.com/xml/ns/javaee  xmlns:xsi= http://www.w3.org/2001/XMLSchema-instance  xsi:schemaLocation= http://java.sun.com/xml/ns/javaee  http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd  servlet  servlet-name websocket /servlet-name  servlet-class socket.MyWebSocketServlet /servlet-class  /servlet  servlet-mapping  servlet-name websocket /servlet-name  url-pattern *.do /url-pattern  /servlet-mapping  servlet  servlet-name initServlet /servlet-name  servlet-class socket.InitServlet /servlet-class  load-on-startup 1 /load-on-startup !--方法執(zhí)行的級別--  /servlet  welcome-file-list  welcome-file index.jsp /welcome-file  /welcome-file-list  /web-app 

這就是最普通的前臺像后臺發(fā)送請求的過程，也是很容易嵌入到自己的系統(tǒng)里

MyWebSocketServlet：

public class MyWebSocketServlet extends WebSocketServlet { public String getUser(HttpServletRequest request){ String userName = (String) request.getSession().getAttribute( user  if(userName==null){ return null; return userName;  protected StreamInbound createWebSocketInbound(String arg0, HttpServletRequest request) { System.out.println( 用戶 + request.getSession().getAttribute( user ) + 登錄  return new MyMessageInbound(this.getUser(request)); }

MyMessageInbound繼承MessageInbound

package socket;import java.io.IOException;import java.nio.ByteBuffer;import java.nio.CharBuffer;import java.util.HashMap;import org.apache.catalina.websocket.MessageInbound;import org.apache.catalina.websocket.WsOutbound;import util.MessageUtil;public class MyMessageInbound extends MessageInbound { private String name; public MyMessageInbound() { super(); public MyMessageInbound(String name) { super(); this.name = name; @Override  protected void onBinaryMessage(ByteBuffer arg0) throws IOException {  @Override  protected void onTextMessage(CharBuffer msg) throws IOException {  //用戶所發(fā)消息處理后的map HashMap String,String messageMap = MessageUtil.getMessage(msg); //處理消息類 //上線用戶集合類map HashMap String, MessageInbound userMsgMap = InitServlet.getSocketList(); String fromName = messageMap.get( fromName //消息來自人 的userId String toName = messageMap.get( toName //消息發(fā)往人的 userId //獲取該用戶 MessageInbound messageInbound = userMsgMap.get(toName); //在倉庫中取出發(fā)往人的MessageInbound MessageInbound messageFromInbound = userMsgMap.get(fromName); if(messageInbound!=null messageFromInbound!=null){ //如果發(fā)往人 存在進(jìn)行操作 WsOutbound outbound = messageInbound.getWsOutbound();  WsOutbound outFromBound = messageFromInbound.getWsOutbound(); String content = messageMap.get( content //獲取消息內(nèi)容 String msgContentString = fromName + 說: + content; //構(gòu)造發(fā)送的消息 //發(fā)出去內(nèi)容 CharBuffer toMsg = CharBuffer.wrap(msgContentString.toCharArray()); CharBuffer fromMsg = CharBuffer.wrap(msgContentString.toCharArray()); outFromBound.writeTextMessage(fromMsg); outbound.writeTextMessage(toMsg); // outFromBound.flush(); outbound.flush(); @Override  protected void onClose(int status) {  InitServlet.getSocketList().remove(this);  super.onClose(status);  @Override protected void onOpen(WsOutbound outbound) {  super.onOpen(outbound);  //登錄的用戶注冊進(jìn)去 if(name!=null){ InitServlet.getSocketList().put(name, this);//存放客服ID與用戶 @Override public int getReadTimeout() { return 0;}

在onTextMessage中處理前臺發(fā)出的信息，并封裝信息傳給目標(biāo)

還有一個messageutil

package util;import java.nio.CharBuffer;import java.util.HashMap;public class MessageUtil { public static HashMap String,String getMessage(CharBuffer msg) { HashMap String,String map = new HashMap String,String  String msgString = msg.toString(); String m[] = msgString.split( ,  map.put( fromName , m[0]); map.put( toName , m[1]); map.put( content , m[2]); return map;}

當(dāng)然了，前臺也要按照規(guī)定的格式傳信息

 %@ page language= java contentType= text/html; charset=UTF-8  pageEncoding= UTF-8 %  !DOCTYPE html  html  head  meta http-equiv= Content-Type content= text/html; charset=UTF-8  title Index /title  script type= text/javascript src= js/jquery-1.7.2.min.js /script  %session.setAttribute( user , 小化 %  script type= text/javascript var ws = null;function startWebSocket() { if ( WebSocket in window) ws = new WebSocket( ws://localhost:8080/WebSocketUser/websocket.do  else if ( MozWebSocket in window) ws = new MozWebSocket( ws://localhost:8080/WebSocketUser/websocket.do  else alert( not support 
 function setMessageInnerHTML(innerHTML){ document.getElementById( message ).innerHTML += innerHTML + br/  ws.onclose = function(evt) { //alert( close  document.getElementById( denglu ).innerHTML= 離線  ws.onopen = function(evt) { //alert( open  document.getElementById( denglu ).innerHTML= 在線  document.getElementById( userName ).innerHTML= 小化 function sendMsg() { var fromName = 小化  var toName = document.getElementById( name ).value; //發(fā)給誰 var content = document.getElementById( writeMsg ).value; //發(fā)送內(nèi)容 ws.send(fromName+ , +toName+ , +content);//注意格式 /script  /head  body onload= startWebSocket();  p 聊天功能實(shí)現(xiàn) /p 登錄狀態(tài)： span id= denglu >
這是A.jsp頁面，B同上
通過以上代碼，就可以實(shí)現(xiàn)一個點(diǎn)對點(diǎn)的聊天功能，如果做的大，可以做成一個web版的聊天系統(tǒng)，包括聊天室和單人聊天，都說websocket不支持二進(jìn)制的傳輸，但是看到個大流說了這樣的話
不過現(xiàn)在做下來 感覺使用二進(jìn)制的意義不是很大。很久以前就一直困混，怎么都說JS不支持二進(jìn)制，發(fā)現(xiàn)其實(shí)只是一堆坑貨對這個沒研究。。（用的是filereader）
相關(guān)推薦：
HTML5仿微信聊天界面和朋友圈代碼
vue組件父子間通信實(shí)現(xiàn)聊天室實(shí)例詳解
node.js 用socket實(shí)現(xiàn)聊天實(shí)例分享
以上就是HTML5 WebSocket點(diǎn)對點(diǎn)聊天實(shí)現(xiàn)方法的詳細(xì)內(nèi)容，其它編程語言        
鄭重聲明：本文版權(quán)歸原作者所有，轉(zhuǎn)載文章僅為傳播更多信息之目的，如作者信息標(biāo)記有誤，請第一時間聯(lián)系我們修改或刪除，多謝。