spring-websocket的搭建

Apach Tomcat 8.0.3+MyEclipse+maven+JDK1.7

spring4.0以后加入了對websocket技術的支持，擼主目前的項目用的是SSM（springMVC+spring+MyBatis）框

架，所 以肯定要首選spring自帶的websocket

1 在maven的pom.xml中加入websocket所依賴的jar包

<dependency>  <groupId>com.fasterxml.jackson.core</groupId>  <artifactId>jackson-core</artifactId>  <version>2.4.0</version> </dependency> <dependency>  <groupId>com.fasterxml.jackson.core</groupId>  <artifactId>jackson-databind</artifactId>  <version>2.4.0</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-websocket</artifactId>//version須和spring mvc的version保持一致，否則會出現問題 <version>4.0.5.RELEASE</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-messaging</artifactId> <version>4.0.5.RELEASE</version> </dependency>
2 更新spring-mvc.xml中namespace.xsd的版本

 2.1<beans xmlns="http://www.springframework.org/schema/beans"  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  xmlns:websocket="http://www.springframework.org/schema/websocket"  xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd   http://www.springframework.org/schema/websocket http://www.springframework.org/schema/websocket/spring-websocket.xsd">

　　處理類和握手協議的spring配置(applicationContext.xml文件）

<bean id="websocket" class="com.xl.websocket.handler"/> <websocket:handlers> <websocket:mapping path="/websocket" handler="websocket"/> <websocket:handshake-interceptors> <bean class="com.xl.websocket.HandshakeInterceptor"/> </websocket:handshake-interceptors>
　　 <websocket:sockjs/> </websocket:handlers>
2.2webconfig
　　 　　 @Override
 　　　　public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
 　　　　　　 registry.addHandler(new HelloHandler(), "/hello").addInterceptors(new HandshakeInterceptor()).withSockJS().setHttpMessageCacheSize(20000);

　　　　}

3 創建握手（handshake）接口

public class HandshakeInterceptor extends HttpSessionHandshakeInterceptor {
 @Override
 public boolean beforeHandshake(ServerHttpRequest arg0,
   ServerHttpResponse arg1, WebSocketHandler arg2,
   Map<String, Object> arg3) throws Exception {
  
  System.out.println("---- Before Handshake ----");
  return super.beforeHandshake(arg0, arg1, arg2, arg3);
 }
 
 @Override
 public void afterHandshake(ServerHttpRequest request,
   ServerHttpResponse response, WebSocketHandler wsHandler,
   Exception ex) {
  
  System.out.println("---- After Handshake ----");
  super.afterHandshake(request, response, wsHandler, ex);
 }
}

4  創建websocket處理類

public class HelloHandler extends TextWebSocketHandler {
 
 public static List<WebSocketSession> users;
 static{
  users = new ArrayList<WebSocketSession>();
 }
 
 @Override
    public void handleTextMessage(WebSocketSession session, TextMessage message) {
        //接收到客戶端消息時調用
        System.out.println("text message: " + session.getId() + "-" + message.getPayload());
    }

    @Override
    public void afterConnectionEstablished(WebSocketSession session)
            throws Exception {
        // 與客戶端完成連接后調用
        System.out.println("afterConnectionEstablished");
        System.out.println("getId:" + session.getId());
        System.out.println("getLocalAddress:" + session.getLocalAddress().toString());
        System.out.println("getTextMessageSizeLimit:" + session.getTextMessageSizeLimit());
        System.out.println("getUri:" + session.getUri().toString());
        System.out.println("getPrincipal:" + session.getPrincipal());
        System.out.println(soslistService.getsss());
        session.sendMessage(new TextMessage("你好"));
       
        users.add(session);
    }

    @Override
    public void handleTransportError(WebSocketSession session,
            Throwable exception) throws Exception {
        // 消息傳輸出錯時調用
        System.out.println("handleTransportError");
    }

    @Override
    public void afterConnectionClosed(WebSocketSession session,
            CloseStatus closeStatus) throws Exception {
        // 一個客戶端連接斷開時關閉
        System.out.println("afterConnectionClosed");
    }

    @Override
    public boolean supportsPartialMessages() {
        // TODO Auto-generated method stub
        return false;
    }
}