springboot+websocket的多种实现方式

pom配置&＃xff1a;
    xsi:schemaLocation&＃61;"http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    4.0.0
    com.hc.websocket
    mywebsocket
    0.0.1-SNAPSHOT
    
        org.springframework.boot
        spring-boot-starter-parent
        1.5.4.RELEASE
    
    
        
            org.springframework.boot
            spring-boot-starter-websocket
            1.3.5.RELEASE
        
    

主函数&＃xff1a;
&＃64;Configuration
&＃64;EnableWebSocket
&＃64;SpringBootApplication
public class SampleTomcatWebSocketApplication implements WebSocketConfigurer{

    &＃64;Override
    public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
        registry.addHandler(echoWebSocketHandler(), "/echo").withSockJS();
        registry.addHandler(snakeWebSocketHandler(), "/snake").withSockJS();
    }

    &＃64;Bean
    public EchoService echoService() {
        return new DefaultEchoService("Did you say \"%s\"?");
    }

    &＃64;Bean
    public GreetingService greetingService() {
        return new SimpleGreetingService();
    }

    &＃64;Bean
    public WebSocketHandler echoWebSocketHandler() {
        return new EchoWebSocketHandler(echoService());
    }

    &＃64;Bean
    public WebSocketHandler snakeWebSocketHandler() {
        return new PerConnectionWebSocketHandler(SnakeWebSocketHandler.class);
    }

    &＃64;Bean
    public ReverseWebSocketEndpoint reverseWebSocketEndpoint() {
        return new ReverseWebSocketEndpoint();
    }
    
    &＃64;Bean
    public MyWebSocket myWebSocketEndpoint() {
        return new MyWebSocket();
    }

    &＃64;Bean
    public ServerEndpointExporter serverEndpointExporter() {
        return new ServerEndpointExporter();
    }

    public static void main(String[] args) {
        SpringApplication.run(SampleTomcatWebSocketApplication.class, args);
    }

}

--------------------------------------------------------------------------------------------------------
java服务方式&＃xff1a;

&＃64;ServerEndpoint(value &＃61; "/websocket")
public class MyWebSocket {
    //静态变量&＃xff0c;用来记录当前在线连接数。应该把它设计成线程安全的。
    private static int onlineCount &＃61; 0;

    //concurrent包的线程安全Set&＃xff0c;用来存放每个客户端对应的MyWebSocket对象。
    private static CopyOnWriteArraySet webSocketSet &＃61; new CopyOnWriteArraySet();

    //与某个客户端的连接会话&＃xff0c;需要通过它来给客户端发送数据
    private Session session;

    /**
     * 连接建立成功调用的方法*/
    &＃64;OnOpen
    public void onOpen(Session session) {
        String topken &＃61; session.getQueryString();
        this.session &＃61; session;
        webSocketSet.add(this);     //加入set中
        addOnlineCount();           //在线数加1
        System.out.println("有新连接加入&＃xff01;当前在线人数为" &＃43; getOnlineCount());
        try {
            sendMessage("有新连接加入&＃xff01;当前在线人数为" &＃43; getOnlineCount());
        } catch (IOException e) {
            System.out.println("IO异常");
        }
    }

    /**
     * 连接关闭调用的方法
     */
    &＃64;OnClose
    public void onClose() {
        webSocketSet.remove(this);  //从set中删除
        subOnlineCount();           //在线数减1
        System.out.println("有一连接关闭&＃xff01;当前在线人数为" &＃43; getOnlineCount());
    }

    /**
     * 收到客户端消息后调用的方法
     *
     * &＃64;param message 客户端发送过来的消息*/
    &＃64;OnMessage
    public void onMessage(String message, Session session) {
        System.out.println("来自客户端的消息:" &＃43; message);

        //群发消息
        for (MyWebSocket item : webSocketSet) {
            try {
                item.sendMessage(message);
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

    /**
     * 发生错误时调用
     */
    &＃64;OnError
    public void onError(Session session, Throwable error) {
        System.out.println("发生错误");
        error.printStackTrace();
    }

    public void sendMessage(String message) throws IOException {
        this.session.getBasicRemote().sendText(message);
        //this.session.getAsyncRemote().sendText(message);
    }

    /**
     * 群发自定义消息
     * */
    public static void sendInfo(String message) throws IOException {
        for (MyWebSocket item : webSocketSet) {
            try {
                item.sendMessage(message);
            } catch (IOException e) {
                continue;
            }
        }
    }

    public static synchronized int getOnlineCount() {
        return onlineCount;
    }

    public static synchronized void addOnlineCount() {
        MyWebSocket.onlineCount&＃43;&＃43;;
    }

    public static synchronized void subOnlineCount() {
        MyWebSocket.onlineCount--;
    }
}
-----------------------------------------------------------------------------------------------------------
类spring mvc注解方式

&＃64;Configuration
&＃64;EnableWebSocketMessageBroker
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer  {    
    &＃64;Override    
    public void registerStompEndpoints(StompEndpointRegistry registry) {        
        registry.addEndpoint("/sockets").withSockJS();       
    }    
    
    &＃64;Override
    public void configureMessageBroker(MessageBrokerRegistry registry) {  
        registry.enableSimpleBroker("/topic");      
        registry.setApplicationDestinationPrefixes("/app"); 
    }
}

&＃64;Controller
public class WebsocketController {
    &＃64;Resource
    private SimpMessagingTemplate simpMessagingTemplate;
    
    &＃64;MessageMapping("/hello")
    public void helloworld(){
        System.out.println("xxxxxx");
        simpMessagingTemplate.convertAndSend("xxxxx");
//        return "xxxxx";
    }
}

------------------------------------------------------------------------------------------------------------
前端分3种方式&＃xff1a;sockjs,sockejs&＃43;stomp,websocket

sockejs方式&＃xff1a;

function connect() {
            var target &＃61; document.getElementById(&＃39;target&＃39;).value;
            ws &＃61; new SockJS(target);
            ws.onopen &＃61; function () {
                setConnected(true);
                log(&＃39;Info: WebSocket connection opened.&＃39;);
            };
            ws.onmessage &＃61; function (event) {
                log(&＃39;Received: &＃39; &＃43; event.data);
            };
            ws.onclose &＃61; function () {
                setConnected(false);
                log(&＃39;Info: WebSocket connection closed.&＃39;);
            };
        }
------------------------------------------------------------------------------------------------------------
sockejs&＃43;stomp方式&＃xff1a;

// 开启socket连接
    function connect() {        
        var socket &＃61; new SockJS(&＃39;/sockets&＃39;);        
        stompClient &＃61; Stomp.over(socket);        
        stompClient.connect({}, function (frame) {            
             setConnected(true);            
        });    
    }    
    // 断开socket连接
    function disconnect() {        
        if (stompClient !&＃61; null) {            
            stompClient.disconnect();        
        }        
        setConnected(false);        
        console.log("Disconnected");    
    }    
    // 向‘/app/change-notice’服务端发送消息
    function sendName() {        
        var value &＃61; document.getElementById(&＃39;name&＃39;).value;            
        stompClient.send("/app/hello", {}, value);    
    }
------------------------------------------------------------------------------------------------------------
websocket方式&＃xff1a;

//判断当前浏览器是否支持WebSocket
    if(&＃39;WebSocket&＃39; in window){
        websocket &＃61; new WebSocket("ws://localhost:8080/websocket?xx&＃61;aa");
    }
    else{
        alert(&＃39;Not support websocket&＃39;)
    }

//发送消息
    function send(){
        var message &＃61; document.getElementById(&＃39;text&＃39;).value;
        websocket.send(message);
    }