springboot之websocket

　　一、WebSocket协议是基于TCP的一种新的网络协议。它实现了浏览器与服务器全双工(full-duplex)通信——允许服务器主动发送信息给客户端。

　　二、长久以来, 创建实现客户端和用户端之间双工通讯的web app都会造成HTTP轮询的滥用: 客户端向主机不断发送不同的HTTP呼叫来进行询问。

　　　　这会导致一系列的问题：

　　　　1.服务器被迫为每个客户端使用许多不同的底层TCP连接：一个用于向客户端发送信息，其它用于接收每个传入消息。

　　　　2.有些协议有很高的开销，每一个客户端和服务器之间都有HTTP头。

　　　　3.客户端脚本被迫维护从传出连接到传入连接的映射来追踪回复。

　　　　一个更简单的解决方案是使用单个TCP连接双向通信。 这就是WebSocket协议所提供的功能。 结合WebSocket API ，WebSocket协议提供了一个用来替代HTTP轮询实现网页到远程主机的双向通信的方法。

　　　　它的最大特点就是，服务器可以主动向客户端推送信息，客户端也可以主动向服务器发送信息，是真正的双向平等对话，属于服务器推送技术的一种。

 　　三、特点：　　

　　（1）建立在 TCP 协议之上，服务器端的实现比较容易。

　　（2）与 HTTP 协议有着良好的兼容性。默认端口也是80和443，并且握手阶段采用 HTTP 协议，因此握手时不容易屏蔽，能通过各种 HTTP 代理服务器。

　　（3）数据格式比较轻量，性能开销小，通信高效。

　　（4）可以发送文本，也可以发送二进制数据。

　　（5）没有同源限制，客户端可以与任意服务器通信。

　　（6）协议标识符是ws（如果加密，则为wss），服务器网址就是 URL。

　　四、实例：

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.pinnet</groupId>
    <artifactId>springboot-websocket</artifactId>
    <version>1.0-SNAPSHOT</version>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
        <version>1.5.9.RELEASE</version>
    </parent>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
            <version>1.5.9.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-websocket</artifactId>
            <version>1.5.9.RELEASE</version>
        </dependency>
    </dependencies>
</project>

　　2）websocket配置

package com.pinnet.config;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.socket.server.standard.ServerEndpointExporter;

@Configuration
public class WebSocketConfig {

    //加入配置，目的使用注解连接websocket
    @Bean
    public ServerEndpointExporter serverEndpointExporter() {
        return new ServerEndpointExporter();
    }
}

　　3）websocket的连接处理服务

package com.pinnet.controller;

import org.springframework.stereotype.Component;

import javax.websocket.OnClose;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.server.ServerEndpoint;
import java.io.IOException;
import java.util.List;
import java.util.concurrent.CopyOnWriteArrayList;

@Component
//websocket的连接名称
@ServerEndpoint(value = "/webSocket")
public class WebSocketServer {
    private Session session;
    private List<WebSocketServer> webSocketServers = new CopyOnWriteArrayList<WebSocketServer>();

    //打开连接时的操作
    @OnOpen
    public void onOpen(Session session) {
        this.session = session;
        webSocketServers.add(this);
    }

    //关闭连接时的操作
    @OnClose
    public void onClose() {
        webSocketServers.remove(this);
    }

    //接手消息时的操作
    @OnMessage
    public void onMessage(String message) {
        for (WebSocketServer webSocketServer: webSocketServers) {
            try {
                sendMessage(webSocketServer, message);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }

    //发送消息
    public void sendMessage(WebSocketServer webSocketServer,String message) throws IOException {
        webSocketServer.session.getBasicRemote().sendText(message);
    }
}

　　4）顺便谢了一个测试的js，可以直接在浏览器console里面执行测试

var websocket = null;
    if ('WebSocket' in window) {
        websocket = new WebSocket('ws://localhost/webSocket');
    } else {
        alert('该浏览器不支持websocket');
    }
    
    websocket.onopen = function (event) {
        console.log('websocket建立连接');
        websocket.send("websocket发送消息"); 
    }
    
    websocket.onclose = function (event) {
        console.log('websocket关闭连接');
    }
    
    websocket.onmessage = function (event) {
        console.log('websocket收到消息：' + event.data);
    }

　　五、springboot的简单用法就是这样的，当然实际的用法，需要进行封装，具体的处理以及使用都要，一定的框架支持。

　　六、源码下载：https://pan.baidu.com/s/1cHF_UIFb2cMTcmDM4UlzlA