详细解析WebSocket+spring示例demo（已使用sockJs库）

xmlns="http://xmlns.j***cp.org/xml/ns/javaee"

xmlns:xsi="http://www.**w*3.org/2001/XMLSchema-instance"

xsi:schemaLocation="http://xmlns.j***cp.org/xml/ns/javaee http://xmlns.j***cp.org/xml/ns/javaee/web-app_3_1.xsd">

用来测试WebSocket基础上推送的功能

encodingFilter

org.springframework.web.filter.CharacterEncodingFilter

true

encoding

UTF-8

forceEncoding

true

encodingFilter

/*

org.springframework.web.context.ContextLoaderListener

org.springframework.web.util.IntrospectorCleanupListener

dispatcher

org.springframework.web.servlet.DispatcherServlet

contextConfigLocation

classpath:dispatcher-servlet.xml

1

true

dispatcher

/

30

testSocket.jsp

xmlns:xsi="http://www.**w*3.org/2001/XMLSchema-instance"

xmlns:beans="http://www.spring*fram*ewo*rk.org/schema/beans"

xmlns:context="http://www.spr*i*ngframewo*rk.org/schema/context"

xsi:schemaLocation="http://www.spri**ngfra*mework.org/schema/mvc http://www.spri**ngfra*mework.org/schema/mvc/spring-mvc.xsd

http://www.spring*fram*ewo*rk.org/schema/beans http://www.spring*fram*ewo*rk.org/schema/beans/spring-beans.xsd

http://www.spr*i*ngframewo*rk.org/schema/context http://www.spr*i*ngframewo*rk.org/schema/context/spring-context.xsd">

packagezyy.sockjs.config;

importjava.util.Map;

importorg.springframework.http.server.ServerHttpRequest;

importorg.springframework.http.server.ServerHttpResponse;

importorg.springframework.stereotype.Component;

importorg.springframework.web.socket.WebSocketHandler;

importorg.springframework.web.socket.server.support.HttpSessionHandshakeInterceptor;

@Component

publicclassHandshakeInterceptorextendsHttpSessionHandshakeInterceptor {

@Override

publicbooleanbeforeHandshake(ServerHttpRequest request,

ServerHttpResponse response, WebSocketHandler wsHandler,

Map attributes)throwsException {

System.out.println("Before Handshake");

returnsuper.beforeHandshake(request,response,wsHandler,attributes);

}

@Override

publicvoidafterHandshake(ServerHttpRequest request,

ServerHttpResponse response, WebSocketHandler wsHandler,

Exception ex) {

System.out.println("After Handshake");

super.afterHandshake(request,response,wsHandler,ex);

}

}

packagezyy.sockjs.config;

importorg.springframework.stereotype.Component;

importorg.springframework.web.socket.TextMessage;

importorg.springframework.web.socket.WebSocketSession;

importorg.springframework.web.socket.handler.TextWebSocketHandler;

@Component

publicclassInfoSocketEndPointextendsTextWebSocketHandler {

publicInfoSocketEndPoint() {

}

@Override

protectedvoidhandleTextMessage(WebSocketSession session,

TextMessage message)throwsException {

super.handleTextMessage(session, message);

TextMessage returnMessage =newTextMessage(message.getPayload()

+" received at server");

session.sendMessage(returnMessage);

}

}

packagezyy.sockjs.config;

importorg.springframework.stereotype.Component;

importorg.springframework.web.socket.CloseStatus;

importorg.springframework.web.socket.TextMessage;

importorg.springframework.web.socket.WebSocketHandler;

importorg.springframework.web.socket.WebSocketMessage;

importorg.springframework.web.socket.WebSocketSession;

/**

*

* @author dayu

*/

@Component

publicclassSystemWebSocketHandlerimplementsWebSocketHandler {

@Override

publicvoidafterConnectionEstablished(WebSocketSession session)throwsException {

System.out.println("connect to the websocket success......");

session.sendMessage(newTextMessage("Server:connected OK!"));

}

@Override

publicvoidhandleMessage(WebSocketSession wss, WebSocketMessage> wsm)throwsException {

TextMessage returnMessage =newTextMessage(wsm.getPayload()

+" received at server");

wss.sendMessage(returnMessage);

}

@Override

publicvoidhandleTransportError(WebSocketSession wss, Throwable thrwbl)throwsException {

if(wss.isOpen()){

wss.close();

}

System.out.println("websocket connection closed......");

}

@Override

publicvoidafterConnectionClosed(WebSocketSession wss, CloseStatus cs)throwsException {

System.out.println("websocket connection closed......");

}

@Override

publicbooleansupportsPartialMessages() {

returnfalse;

}

}

packagezyy.sockjs.config;

importorg.springframework.context.annotation.Bean;

importorg.springframework.context.annotation.Configuration;

importorg.springframework.web.servlet.config.annotation.EnableWebMvc;

importorg.springframework.web.servlet.config.annotation.WebMvcConfigurerAdapter;

importorg.springframework.web.socket.WebSocketHandler;

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

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

importorg.springframework.web.socket.config.annotation.WebSocketHandlerRegistry;

@Configuration

@EnableWebMvc

@EnableWebSocket

publicclassWebSocketConfigextendsWebMvcConfigurerAdapterimplements

WebSocketConfigurer {

publicWebSocketConfig() {

}

@Override

publicvoidregisterWebSocketHandlers(WebSocketHandlerRegistry registry) {

registry.addHandler(systemWebSocketHandler(),"/websck").addInterceptors(newHandshakeInterceptor());

System.out.println("registed!");

registry.addHandler(systemWebSocketHandler(),"/sockjs/websck/info").addInterceptors(newHandshakeInterceptor())

.withSockJS();

}

@Bean

publicWebSocketHandler systemWebSocketHandler() {

returnnewSystemWebSocketHandler();

}

}

#connect-container {

float: left;

width: 400px

}

#connect-container div {

padding: 5px;

}

#console-container {

float: left;

margin-left: 15px;

width: 400px;

}

#console {

border:1px solid #CCCCCC;

border-right-color:#33333333;

border-bottom-color:#999999;

height: 170px;

overflow-y: scroll;

padding: 5px;

width: 100%;

}

#console p {

padding: 0;

margin: 0;

}

var ws = null;

var url = null;

var transports = [];

function setConnected(connected) {

document.getElementById('connect').disabled = connected;

document.getElementById('disconnect').disabled = !connected;

document.getElementById('echo').disabled = !connected;

}

function connect() {

if (!url) {

log('Select whether to use W3C WebSocket or SockJS');

return;

}

//ws = (url.indexOf('sockjs') != -1) ?new SockJS(url, undefined, {protocols_whitelist: transports}) : new WebSocket(url);

if ('WebSocket'in window) {

ws= new WebSocket("ws://localhost:8080/SpringSocketJs/websck");

}else {

ws = new SockJS("http://*lo*calhost*:8080/SpringSocketJs/sockjs/websck/info");

}

//websocket = new SockJS("http://loc*alhost:**8084/SpringWebSocketPush/sockjs/websck");

ws.onopen = function () {

setConnected(true);

//log('Info: connection opened.');

};

ws.onmessage = function (event) {

log('Received:' + event.data);

};

ws.onclose = function (event) {

setConnected(false);

log('Info: connection closed.');

log(event);

};

}

function disconnect() {

if (ws != null) {

ws.close();

ws = null;

}

setConnected(false);

}

function echo() {

if (ws != null) {

var message = document.getElementById('message').value;

log('Sent:' + message);

ws.send(message);

} else {

alert('connection not established, please connect.');

}

}

function updateUrl(urlPath) {

if (urlPath.indexOf('sockjs') != -1) {

url = urlPath;

document.getElementById('sockJsTransportSelect').style.visibility ='visible';

}

else {

if (window.location.protocol =='http:') {

url = 'ws://' + window.location.host + urlPath;

}else{

url = 'wss://' + window.location.host + urlPath;

}

document.getElementById('sockJsTransportSelect').style.visibility ='hidden';

}

}

function updateTransport(transport) {

transports = (transport == 'all') ? [] : [transport];

}

function log(message) {

var console = document.getElementById('console');

var p = document.createElement('p');

p.style.wordWrap = 'break-word';

p.appendChild(document.createTextNode(message));

console.appendChild(p);

while (console.childNodes.length > 25) {

console.removeChild(console.firstChild);

}

console.scrollTop = console.scrollHeight;

}

Seems your browser doesn't supportJavascript!Websockets

rely on Javascript being enabled. Please enable

Javascript and reloadthispage!