spring学习笔记（八）webSocket

知识储备

什么是stomp？
- 我们可以类比TCP与Http协议，我们知道Http协议是基于TCP协议的，Http协议解决了 web 浏览器发起请求以及 web 服务器响应请求的细节，我们在编码时候只要关注我们要发送或接受的信息就行了，不需要关注那些细节
- 直接使用 WebSocket（SockJS）就很类似于使用 TCP 套接字来编写 web 应用；因为没有高层协议，因此就需要我们定义应用间所发送消息的语义，还需要确保连接的两端都能遵循这些语义；
- 同 HTTP 在 TCP 套接字上添加请求-响应模型层一样，STOMP 在 WebSocket 之上提供了一个基于帧的线路格式层，用来定义消息语义；

STOMP帧格式

基本格式

COMMAND

header1:value1

header2:value2

Body^@

// 发送消息

SEND    -- 命令类型：发送

destination:/queue/trade   -- 头信息：标明了目的地

content-type:application/json  -- 头信息：标明数据交换格式

content-length:44  -- 用来表示负载内容的 大小；

{"action":"BUY","ticker":"MMM","shares",44}^@ -- 帧内容

项目代码

后台代码如下，主要的分析我都写在注释里了

package com.study.spring.websocket.config;

import org.springframework.context.annotation.Configuration;

import org.springframework.messaging.converter.MessageConverter;

import org.springframework.messaging.handler.invocation.HandlerMethodArgumentResolver;

import org.springframework.messaging.handler.invocation.HandlerMethodReturnValueHandler;

import org.springframework.messaging.simp.config.ChannelRegistration;

import org.springframework.messaging.simp.config.MessageBrokerRegistry;

import org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker;

import org.springframework.web.socket.config.annotation.StompEndpointRegistry;

import org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer;

import org.springframework.web.socket.config.annotation.WebSocketTransportRegistration;

import java.util.List;

/**

 * @author dmz

 * @date Create in 12:37 2019/3/30

 */

@Configuration

/**

 * 通过这个注解，开启使用STOMP来传输基于message broker

 * 的小心，这时的控制器支持@MessageMapping，就像@RequestMapping

 */

@EnableWebSocketMessageBroker

public class Config implements WebSocketMessageBrokerConfigurer {

    /**

     * 注册STOMP端点,映射指定的url

     * 端点的作用——客户端在订阅或发布消息 到目的地址前，要连接该端点

     *

     * @param registry

     */

    @Override

    public void registerStompEndpoints(StompEndpointRegistry registry) {

        registry.addEndpoint("/stomp").

                /**

                 * 设置允许所有域名访问

                 */

                        setAllowedOrigins("*").

                /**

                 * 许多浏览器不支持 WebSocket 协议；

                 * SockJS 是 WebSocket 技术的一种模拟。SockJS 会 尽可能对应 WebSocket API，

                 * 但如果 WebSocket 技术 不可用的话，就会选择另外的 通信方式协议；

                 */

                        withSockJS();

    }

    /**

     * 配置消息代理

     * 如果不重载它的话，将会自动配置一个简单的内存消息代理，用它来处理以"/topic"为前缀的消息

     *

     * @param registry

     */

    @Override

    public void configureMessageBroker(MessageBrokerRegistry registry) {

        registry.enableSimpleBroker("/topic", "/queue");

        registry.setApplicationDestinationPrefixes("/app");

        //基于RabbitMQ 的STOMP消息代理

//        registry.enableStompBrokerRelay("/queue", "/topic")

//                .setRelayHost(host)

//                .setRelayPort(port)

//                .setClientLogin(userName)

//                .setClientPasscode(password);

    }

    @Override

    public void configureWebSocketTransport(WebSocketTransportRegistration registry) {

    }

    @Override

    public void configureClientInboundChannel(ChannelRegistration registration) {

    }

    @Override

    public void configureClientOutboundChannel(ChannelRegistration registration) {

    }

    @Override

    public void addArgumentResolvers(List<HandlerMethodArgumentResolver> argumentResolvers) {

    }

    @Override

    public void addReturnValueHandlers(List<HandlerMethodReturnValueHandler> returnValueHandlers) {

    }

    @Override

    public boolean configureMessageConverters(List<MessageConverter> messageConverters) {

        return false;

    }

}

package com.study.spring.websocket.controller;

import org.springframework.messaging.handler.annotation.MessageMapping;

import org.springframework.messaging.handler.annotation.SendTo;

import org.springframework.web.bind.annotation.RestController;

/**

 * @author dmz

 * @date Create in 12:37 2019/3/30

 */

@RestController

public class Controller {

    /**

     * 类似于我们的@requestMapping

     */

    @MessageMapping("/test")

    /**

     * 客户端通过app/test访问后，

     * 服务端会将数据发送到消息代理中

     */

    @SendTo("/topic/d1")

    public String test(String name) {

        return "hello webSocket," + name;

    }

}

package com.study.spring.websocket;

import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication

public class WebsocketApplication {

    public static void main(String[] args) {

        SpringApplication.run(WebsocketApplication.class, args);

    }

}

前端项目地址：https://github.com/daimingzhi/h5/tree/master/webSocket

巴特西

spring学习笔记（八）webSocket

知识储备

项目代码

最新文章

热门文章