springboot之websocket

  1. 云栖社区>
  2. 博客>
  3. 正文

springboot之websocket

小不点丶 2018-05-30 21:39:00 浏览2022
展开阅读全文

  一、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

 

 

 

 

网友评论

登录后评论
0/500
评论
小不点丶
+ 关注