使用webSocket与spring怎么实现一个应用

本篇文章给大家分享的是有关使用webSocket与spring怎么实现一个应用，小编觉得挺实用的，因此分享给大家学习，希望大家阅读完这篇文章后可以有所收获，话不多说，跟着小编一起来看看吧。

创新互联-专业网站定制、快速模板网站建设、高性价比禹王台网站开发、企业建站全套包干低至880元,成熟完善的模板库,直接使用。一站式禹王台网站制作公司更省心,省钱,快速模板网站建设找我们，业务覆盖禹王台地区。费用合理售后完善，十年实体公司更值得信赖。

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"

以及引入的功能 

1. http://www.springframework.org/schema/websocket

2. 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 {		//接收到消息后，响应消息，处理文本消息
		TextMessage returnMessage=new TextMessage("服务端返回报文:"+message.getPayload());	
                session.sendMessage(returnMessage);//服务器将前端请求信息传回浏览器
                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执行一次任务
		
		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 {//连接关闭后
		
			logger.info("连接已关闭");
			timer.cancel();

		   logger.info("连接关闭后处理方法");
		super.afterConnectionClosed(session, status);
	}
	
	//内部类实现数据获取
	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) {//系统将当前建立连接后的session传递给内部类的session，达到session共享
			super();
			this.session = session;
		}
 
 
		@Override
		public void run() {//启动多线程
		    int i=0;
			String taskCommand="定时执行任务"+ ++i;
			TextMessage textMessage = new TextMessage(taskCommand);
			try {
				
					handleTextMessage(session, textMessage);//定时调用handleTextMessage方法，向前端发送信息

		} 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("创建握手后...");
		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.服务注册

注解模式：

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

说明: 网上有很多文章配置中添加了一个注解@EnableWebMvc和继承了WebMvcConfigurerAdapter,其中@EnableWebMVC注解用来开启Web MVC的配置支持.相当于DispatcherServlet context内使用元素,WebMvcConfigurerAdapter配置类其实是Spring内部的一种配置方式,采用JavaBean的形式来代替传统的xml配置文件形式进行针对框架个性化定制.
XML配置模式：

6.页面

">






//加载websocket数据
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() 方法发送数据
           ws.send("发送数据");
           alert("数据发送中...");
        };
         
        ws.onmessage = function (evt){ 
           var received_msg = evt.data;
         
           console.log(received_msg);
        };
         
        ws.onclose = function(){ 
           // 关闭 websocket
           alert("连接已关闭..."); 
        };
     }
}


  
         运行 WebSocket