本篇文章給大家分享的是有關(guān)使用webSocket與spring怎么實(shí)現(xiàn)一個應(yīng)用，小編覺得挺實(shí)用的，因此分享給大家學(xué)習(xí)，希望大家閱讀完這篇文章后可以有所收獲，話不多說，跟著小編一起來看看吧。
創(chuàng)新互聯(lián)-專業(yè)網(wǎng)站定制、快速模板網(wǎng)站建設(shè)、高性價比禹王臺網(wǎng)站開發(fā)、企業(yè)建站全套包干低至880元,成熟完善的模板庫,直接使用。一站式禹王臺網(wǎng)站制作公司更省心,省錢,快速模板網(wǎng)站建設(shè)找我們，業(yè)務(wù)覆蓋禹王臺地區(qū)。費(fèi)用合理售后完善，十年實(shí)體公司更值得信賴。
1.spring-websocket依賴包
4.0.2.RELEASE
org.springframework
spring-websocket
${spring.version}
org.springframework
spring-messaging
${spring.version}
2 sping配置文件
其中命名空間
xmlns:websocket="http://www.springframework.org/schema/websocket"
以及引入的功能
http://www.springframework.org/schema/websocket
http://www.springframework.org/schema/websocket/spring-websocket-4.0.xsd
3.繼承TextWebSocketHandler
package com.gaofei.controller;
import java.util.Timer;
import java.util.TimerTask;
import org.apache.log4j.Logger;
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;
public class WebsocketEndPoint extends TextWebSocketHandler {
private Timer timer;
private Logger logger=Logger.getLogger(WebsocketEndPoint.class);
@Override
protected void handleTextMessage(WebSocketSession session,//session中攜帶http請求報文信息
TextMessage message) throws Exception { //接收到消息后，響應(yīng)消息，處理文本消息
TextMessage returnMessage=new TextMessage("服務(wù)端返回報文:"+message.getPayload());
session.sendMessage(returnMessage);//服務(wù)器將前端請求信息傳回瀏覽器
super.handleTextMessage(session, message);
}
@Override
public void afterConnectionEstablished(WebSocketSession session)
throws Exception {//握手成功后，啟動一個定時器timer
logger.info("連接建立后處理方法");
timer=new Timer(true);
LoadDataTask task=new LoadDataTask(session);
timer.schedule(task,1000,1000);//1s執(zhí)行一次任務(wù)
super.afterConnectionEstablished(session);
}
@Override
public void handleTransportError(WebSocketSession session,
Throwable exception) throws Exception {
logger.info("拋出異常時處理方法");
super.handleTransportError(session, exception);
}
@Override
public void afterConnectionClosed(WebSocketSession session,
CloseStatus status) throws Exception {//連接關(guān)閉后
logger.info("連接已關(guān)閉");
timer.cancel();
logger.info("連接關(guān)閉后處理方法");
super.afterConnectionClosed(session, status);
}
//內(nèi)部類實(shí)現(xiàn)數(shù)據(jù)獲取
class LoadDataTask extends TimerTask{
private WebSocketSession session;
public WebSocketSession getSession() {
return session;
}
public void setSession(WebSocketSession session) {
this.session = session;
}
public LoadDataTask() {
super();
}
public LoadDataTask(WebSocketSession session) {//系統(tǒng)將當(dāng)前建立連接后的session傳遞給內(nèi)部類的session，達(dá)到session共享
super();
this.session = session;
}
@Override
public void run() {//啟動多線程
int i=0;
String taskCommand="定時執(zhí)行任務(wù)"+ ++i;
TextMessage textMessage = new TextMessage(taskCommand);
try {
handleTextMessage(session, textMessage);//定時調(diào)用handleTextMessage方法，向前端發(fā)送信息
} catch (Exception e) {
e.printStackTrace();
logger.error(e.getMessage(),e);
}
}
}
}4.繼承HttpSessionHandshakeInterceptor
package com.gaofei.controller;
import java.util.Map;
import org.apache.log4j.Logger;
import org.springframework.http.server.ServerHttpRequest;
import org.springframework.http.server.ServerHttpResponse;
import org.springframework.web.socket.WebSocketHandler;
import org.springframework.web.socket.server.HandshakeInterceptor;
import org.springframework.web.socket.server.support.HttpSessionHandshakeInterceptor;
/**
* 攔截器（握手）
*/
public class HandInterceptor extends HttpSessionHandshakeInterceptor {
private Logger logger=Logger.getLogger(HandshakeInterceptor.class);
@Override
public void afterHandshake(ServerHttpRequest request,
ServerHttpResponse response, WebSocketHandler wsHandler,
Exception ex) {
logger.info("創(chuàng)建握手后...");
super.afterHandshake(request, response, wsHandler, ex);
}
@Override
public boolean beforeHandshake(ServerHttpRequest arg0,
ServerHttpResponse arg1, WebSocketHandler arg2,
Map arg3) throws Exception {
logger.info("握手完成前...");
return super.beforeHandshake(arg0, arg1, arg2, arg3);
}
}5.服務(wù)注冊
注解模式：
package com.gaofei.controller;
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
public class WebSocketConfig implements WebSocketConfigurer {
@Override
public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
//支持websocket
registry.addHandler(new WebsocketEndPoint(),"/websocket/socketServer.do").addInterceptors(new HandInterceptor());
//支持sockjs
registry.addHandler(new WebsocketEndPoint(),"/sockjs/socketServer.do").addInterceptors(new HandInterceptor()).withSockJS();
}
}注：該類需要放在SpringMVC掃描路徑下
@Configuration 指明該類為Spring配置類
@EnableWebSocket 聲明該類支持WebSocket
說明: 網(wǎng)上有很多文章配置中添加了一個注解@EnableWebMvc和繼承了WebMvcConfigurerAdapter,其中@EnableWebMVC注解用來開啟Web MVC的配置支持.相當(dāng)于DispatcherServlet context內(nèi)使用元素,WebMvcConfigurerAdapter配置類其實(shí)是Spring內(nèi)部的一種配置方式,采用JavaBean的形式來代替?zhèn)鹘y(tǒng)的xml配置文件形式進(jìn)行針對框架個性化定制.
XML配置模式：
6.頁面
">
WebSocket
//加載websocket數(shù)據(jù)
function WebSocketTest(){
if ("WebSocket" in window){
alert("您的瀏覽器支持 WebSocket!");
// 打開一個 web socket
var ws = new WebSocket("ws://localhost:8080/webSocketServer/websocket/socketServer.do");
ws.onopen = function(){
// Web Socket 已連接上，使用 send() 方法發(fā)送數(shù)據(jù)
ws.send("發(fā)送數(shù)據(jù)");
alert("數(shù)據(jù)發(fā)送中...");
};
ws.onmessage = function (evt){
var received_msg = evt.data;
console.log(received_msg);
};
ws.onclose = function(){
// 關(guān)閉 websocket
alert("連接已關(guān)閉...");
};
}
}
運(yùn)行 WebSocket
以上就是使用webSocket與spring怎么實(shí)現(xiàn)一個應(yīng)用，小編相信有部分知識點(diǎn)可能是我們?nèi)粘９ぷ鲿姷交蛴玫降?。希望你能通過這篇文章學(xué)到更多知識。更多詳情敬請關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。
重慶分公司
重慶分公司
