Spring Chapter4 WebSocket 胡乱翻译 一个例子

Posted zhsmtp

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Spring Chapter4 WebSocket 胡乱翻译 一个例子相关的知识,希望对你有一定的参考价值。

因为没有基础,不知道从哪里入手。

文档里的例子,https://github.com/rstoyanchev/spring-websocket-portfolio,这个除了WebSocket,还整了Security的东西(坑,版本更新导致默认的passwordEncoder不能用了,不然login一直不成功)

自己写了个乞丐版,体验一下到底怎么运行起来的。

要做啥

客户端:html,请求建立连接,显示接收到的消息

服务端:SpringBoot的WebSocket starter,每隔0.5秒发送一个数字

实现

客户端:

<!DOCTYPE html>
<html>

<head>
    <meta http-equiv="content-type" content="text/html;charset=utf-8">
    <title>Test WebSocket</title>
    <script>
        var ws = new WebSocket("ws://localhost:8080/myHandler");
        
        ws.onopen = function () {
            var ele=document.getElementById(wsStatus);
            ele.innerHTML="WebSocket状态:已连接";
        };
        // 接收服务端数据时触发事件
        ws.onmessage = function (evt) {
            var received_msg = evt.data;
            console.info(received_msg);
            var ele=document.getElementById(countId);
            ele.innerHTML="接收到:"+received_msg;
        };

        // 断开 web socket 连接成功触发事件
        ws.onclose = function () {
            var ele=document.getElementById(wsStatus);
            ele.innerHTML="WebSocket状态:已断开";
        };
    </script>
</head>

<body>
    <div>
        <h2 id="wsStatus">WebSocket状态:</h2>
    </div>
    <div > 
        <h2 id="countId">接收到:</h2>
    </div>
</body>

</html>

 

服务端:

1. 从start.spring.io上生成一个初始的Gradle项目,依赖项加入WebSocket。

2. 根据4.2.1, 添加一个handler,每500ms发送一个数字。

package com.fzh.sbootwebsocket.handlers;

import org.springframework.web.socket.TextMessage;
import org.springframework.web.socket.WebSocketSession;
import org.springframework.web.socket.handler.TextWebSocketHandler;

public class MyHandler extends TextWebSocketHandler{
    @Override
    public void handleTextMessage(WebSocketSession session, TextMessage message){
        System.out.println("session:"+session.getId()+", Message: "+message.getPayload());
    }

    @Override
    public void afterConnectionEstablished(WebSocketSession session) throws Exception {
        
        for(int i=0;i<100;i++){
            TextMessage message = new TextMessage(String.valueOf(i));
            session.sendMessage(message);
            Thread.sleep(500);
        }
        
    }
}

3. 将handler配置到路径/myHandler。注意,setAllowedOrigins("*")这个一定要加上,要不然客户端没有响应。

package com.fzh.sbootwebsocket.config;

import com.fzh.sbootwebsocket.handlers.MyHandler;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.socket.WebSocketHandler;
import org.springframework.web.socket.config.annotation.EnableWebSocket;
import org.springframework.web.socket.config.annotation.WebSocketConfigurer;
import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistry;

@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {

    @Override
    public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
        registry.addHandler(myHandler(), "/myHandler").setAllowedOrigins("*");
    }
    
    @Bean
    public WebSocketHandler myHandler(){
        return new MyHandler();
    }
    
}

4. 命令行输入: ./gradlew bootRun

5. 用浏览器打开最开始编辑好的网页,当当当当当!

技术分享图片

 

以上是关于Spring Chapter4 WebSocket 胡乱翻译 一个例子的主要内容,如果未能解决你的问题,请参考以下文章

spring chapter4 用SPRING BOOT创建一个项目

如何在Spring中配置Websocket

java WebSocket的实现以及Spring WebSocket

Spring 4.0 WebSocket 示例应用程序:无法建立 websocket 连接

spring-webSocket

Spring 4 WebSocket 配置端口