注意点：

1、Spring Framework从4.0版本开始支持websocket，示例代码使用的是4.1.3

2、SockJs是一个封装的WebSocket实现，可以支持低版本的IE浏览器。

3、SockJs+Spring-WebSocket时，由于SockJs与Spring WebSocket之间采用JSON通讯，需要引入jackson 2的相关jar包。

4、项目需要使用到Spring MVC。

具体代码实现（小例子）：

1、Spring WebSocket配置类

Java代码

1. package com.watcher.websocket.spring;
2. import org.springframework.context.annotation.Bean;
3. import org.springframework.context.annotation.Configuration;
4. import org.springframework.web.socket.config.annotation.EnableWebSocket;
5. import org.springframework.web.socket.config.annotation.WebSocketConfigurer;
6. import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistry;
7. @Configuration  //配置类
8. @EnableWebSocket  //声明支持websocket
9. public class WebSocketConfig implements WebSocketConfigurer{
10. @Override
11. public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
12. //注册websocket实现类，指定参数访问地址;allowed-origins="*" 允许跨域
13. registry.addHandler(myHandler(), "/ws").addInterceptors(myHandshake()).setAllowedOrigins("*");
14. //允许客户端使用SockJS
15. registry.addHandler(myHandler(), "/sockjs/ws").addInterceptors(myHandshake()).withSockJS();
16. }
17. @Bean
18. public MyHandler myHandler(){
19. return new MyHandler();
20. }
21. @Bean
22. public MyHandshakeInterceptor myHandshake(){
23. return new MyHandshakeInterceptor();
24. }
25. }

2、Handler类实现（用于处理具体的消息）

Java代码

1. package com.watcher.websocket.spring;
2. import org.springframework.web.socket.CloseStatus;
3. import org.springframework.web.socket.TextMessage;
4. import org.springframework.web.socket.WebSocketHandler;
5. import org.springframework.web.socket.WebSocketMessage;
6. import org.springframework.web.socket.WebSocketSession;
7. //extending either TextWebSocketHandler orBinaryWebSocketHandler
8. public class MyHandler implements WebSocketHandler {
9. @Override
10. public void afterConnectionClosed(WebSocketSession arg0, CloseStatus arg1) throws Exception {
11. // TODO Auto-generated method stub
12. System.out.println("Connection closed..."+arg0.getRemoteAddress().toString());
13. }
14. @Override
15. public void afterConnectionEstablished(WebSocketSession arg0) throws Exception {
16. // TODO Auto-generated method stub
17. System.out.println("Connection established..."+arg0.getRemoteAddress().toString());
18. }
19. @Override
20. public void handleMessage(WebSocketSession arg0, WebSocketMessage<?> arg1) throws Exception {
21. // TODO Auto-generated method stub
22. try {
23. System.out.println("Req: "+arg1.getPayload());
24. TextMessage returnMessage = new TextMessage(arg1.getPayload()
25. + " received at server");
26. arg0.sendMessage(returnMessage);
27. } catch (Exception e) {
28. e.printStackTrace();
29. }
30. }
31. @Override
32. public void handleTransportError(WebSocketSession arg0, Throwable arg1) throws Exception {
33. // TODO Auto-generated method stub
34. if(arg0.isOpen()){
35. arg0.close();
36. }
37. System.out.println(arg1.toString());
38. System.out.println("WS connection error,close...");
39. }
40. @Override
41. public boolean supportsPartialMessages() {
42. // TODO Auto-generated method stub
43. return false;
44. }
45. }

3、握手拦截器实现（拦截器...）

Java代码

1. package com.watcher.websocket.spring;
2. import java.util.Map;
3. import org.springframework.http.server.ServerHttpRequest;
4. import org.springframework.http.server.ServerHttpResponse;
5. import org.springframework.web.socket.WebSocketHandler;
6. import org.springframework.web.socket.server.support.HttpSessionHandshakeInterceptor;
7. /**
8. *
9. * 类描述：握手拦截器
10. * com.watcher.websocket.spring  MyHandshakeInterceptor
11. * Created by 78098 on 2016年11月15日.
12. * version 1.0
13. */
14. public class MyHandshakeInterceptor extends HttpSessionHandshakeInterceptor{
15. @Override
16. public void afterHandshake(ServerHttpRequest request, ServerHttpResponse response, WebSocketHandler wsHandler, Exception ex) {
17. // TODO Auto-generated method stub
18. System.out.println("After handshake "+request.getRemoteAddress().toString());
19. super.afterHandshake(request, response, wsHandler, ex);
20. }
21. @Override
22. public boolean beforeHandshake(ServerHttpRequest request, ServerHttpResponse response, WebSocketHandler handler, Map<String, Object> map) throws Exception {
23. // TODO Auto-generated method stub
24. System.out.println("Before handshake "+request.getRemoteAddress().toString());
25. return super.beforeHandshake(request, response, handler, map);
26. }
27. }

4、页面

Html代码

1. <!DOCTYPE html>
2. <html>
3. <head>
4. <meta charset="UTF-8">
5. <title>Insert title here</title>
6. <script type="text/javascript" src="./plugin/sockjs/sockjs-1.1.1.js"></script>
7. <script type="text/javascript">
8. var url = "192.168.120.37:8080/springMybatis";
9. var websocket = null;
10. if ('WebSocket' in window) {
11. websocket = new WebSocket("ws://" + url + "/ws");
12. } else {
13. websocket = new SockJS("http://" + url + "/sockjs/ws");
14. }
15. websocket.onopen = onOpen;
16. websocket.onmessage = onMessage;
17. websocket.onerror = onError;
18. websocket.onclose = onClose;
19. function onOpen(openEvent) {
20. document.getElementById("console").innerHTML = document.getElementById("console").innerHTML+ "OPEN<br/>";
21. }
22. function onMessage(event) {
23. document.getElementById("console").innerHTML = document.getElementById("console").innerHTML+ event.data+"<br/>";
24. }
25. function onError() {
26. }
27. function onClose() {
28. document.getElementById("console").innerHTML = document.getElementById("console").innerHTML+ "CLOSE<br/>";
29. }
30. function doSend() {
31. console.log(websocket.readyState);
32. if (websocket.readyState == SockJS.OPEN) {
33. var msg = document.getElementById("message").value;
34. websocket.send(msg);
35. } else {
36. alert("连接失败!");
37. }
38. }
39. function disconnect(){
40. if (websocket != null) {
41. websocket.close();
42. websocket = null;
43. }
44. }
45. function reconnect(){
46. if (websocket != null) {
47. websocket.close();
48. websocket = null;
49. }
50. if ('WebSocket' in window) {
51. websocket = new WebSocket("ws://" + url + "/ws");
52. } else {
53. websocket = new SockJS("http://" + url + "/sockjs/ws");
54. }
55. websocket.onopen = onOpen;
56. websocket.onmessage = onMessage;
57. websocket.onerror = onError;
58. websocket.onclose = onClose;
59. }
60. </script>
61. </head>
62. <body>
63. <div>
64. <button id="disconnect" οnclick="disconnect()">断开连接</button>
65. <button id="send" οnclick="doSend()">发送消息</button>
66. <button id="reconnect" οnclick="reconnect()">重新连接</button>
67. </div>
68. <div>
69. <textarea id="message" style="width: 350px">Here is a message!</textarea>
70. </div>
71. <div>日志信息：</div>
72. <p id="console" width="600px"></p>
73. </body>
74. </html>