一、分析

发送了一条消息用户B在聊天框看到了消息接着用户B回复消息......

底层实现主机A

程序如果客户端不主动发起请求服务器就无法主动给客户端发送响应~

HTTP

协议实现消息推送需要进行“轮询”反复询问服务器是否收到请求成本太高

WebSocket

这种级别的通信方式——一旦连接建立完成客户端或服务器都可以主动向对方发送数据。

1.2.2、原理解析

表示是否要对数据载荷进行掩码操作。

从客户端向服务端发送数据时需要对数据进行掩码操作从服务端向客户端发送数据时不需要对数据进行掩码操作。

掩码算法主要是为了安全考虑的避免缓冲区溢出攻击。

Payload

length数据载荷的长度单位是字节。

为7位或716位或164位。

payload

data:

dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-web/artifactId/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-websocket/artifactId/dependency2.1.2、继承TextWebSocketHandler

这里我们先创建一个类自定义名为

afterConnectionEstablishe客户端与服务器成功建立连接以后会调用此方法。

handleTextMessage客户端通过

WebSocket

方法发送给服务器数据时会调用此方法。

handleTransportError客户端与服务器连接异常时会调用此方法。

afterConnectionClosed客户端与服务器断开连接时会调用此方法。

WebSocket

org.springframework.stereotype.Component;

import

org.springframework.web.socket.CloseStatus;

import

org.springframework.web.socket.TextMessage;

import

org.springframework.web.socket.WebSocketSession;

import

org.springframework.web.socket.handler.TextWebSocketHandler;Component

public

afterConnectionEstablished(WebSocketSession

session)

{System.out.println(连接成功);}Overrideprotected

void

handleTextMessage(WebSocketSession

session,

message.getPayload());//收到消息后向客户端反馈信息(这里反馈相同数据)session.sendMessage(message);}Overridepublic

void

handleTransportError(WebSocketSession

session,

{System.out.println(连接异常);}Overridepublic

void

afterConnectionClosed(WebSocketSession

session,

{System.out.println(连接关闭);}}2.1.3、实现

WebSocketConfigurer

第一步创建一个类自定义类名为WebSocketConfig实现

WebSocketConfigurer接口这个接口下只需要实现一个方法

registerWebSocketHandlers这个类就是用来注册添加

WebSocket

这个类以及注册路由这个路由就将客户端与服务器联系起来了前端创建

WebSocket

addHander方法添加注册这个类基于这个类才能进一步的找到

TestAPI

org.springframework.beans.factory.annotation.Autowired;

import

org.springframework.context.annotation.Configuration;

import

org.springframework.web.socket.config.annotation.EnableWebSocket;

import

org.springframework.web.socket.config.annotation.WebSocketConfigurer;

import

org.springframework.web.socket.config.annotation.WebSocketHandlerRegistry;Configuration

EnableWebSocket

registerWebSocketHandlers(WebSocketHandlerRegistry

{webSocketHandlerRegistry.addHandler(testAPI,

/test);}

onopen客户端与服务器建立连接后会调用该方法。

onmessage客户端收到服务器响应后会触发该方法。

onerror客户端与服务器连接异常时会触发该请求。

conclose客户端与服务器断开连接时会触发该请求。

HTTP

initial-scale1.0titleDocument/title

/head

WebSocket(ws://127.0.0.1:8080/test);websocket.onopen

function()

{console.log(建立连接);}websocket.onmessage

function(e)

{console.log(连接异常);}websocket.onclose

function()

document.querySelector(#message);//点击按钮发送请求let

button

document.querySelector(#submit);button.onclick

function()

input.value);websocket.send(input.value);}/script/body

/html