websocket代码整理

yangys

2024-05-19 9e5da8899bc21bb5b6b0a3c267108caa00199291

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
package com.qianwen.core.websocket.config;
 
import java.util.List;
import javax.annotation.PostConstruct;
import com.qianwen.core.websocket.custom.SubscriptionSessionFilter;
import com.qianwen.core.websocket.handler.JsonMessageHandler;
import com.qianwen.core.websocket.holder.JsonMessageFilterHolder;
import com.qianwen.core.websocket.holder.JsonMessageHandlerHolder;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Import;
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.server.HandshakeInterceptor;
 
@Configuration
@Import({WebSocketHandlerConfig.class})
@EnableWebSocket
public class WebSocketAutoConfiguration {
    private final WebSocketProperties webSocketProperties;
    private final List<JsonMessageHandler> jsonMessageHandlerList;
    private final List<SubscriptionSessionFilter> jsonMessageFilterList;
 
    public WebSocketAutoConfiguration(final WebSocketProperties webSocketProperties, final List<JsonMessageHandler> jsonMessageHandlerList, final List<SubscriptionSessionFilter> jsonMessageFilterList) {
        this.webSocketProperties = webSocketProperties;
        this.jsonMessageHandlerList = jsonMessageHandlerList;
        this.jsonMessageFilterList = jsonMessageFilterList;
    }
 
    @ConditionalOnMissingBean
    @Bean
    public WebSocketConfigurer webSocketConfigurer(List<HandshakeInterceptor> handshakeInterceptor, WebSocketHandler webSocketHandler) {
        return registry -> {
            //普通websocket支持
            registry.addHandler(webSocketHandler, new String[]{this.webSocketProperties.getPath()}).setAllowedOrigins(new String[]{this.webSocketProperties.getAllowOrigins()}).addInterceptors((HandshakeInterceptor[]) handshakeInterceptor.toArray(new HandshakeInterceptor[0]));
            //提供降级为SockJS的支持
            registry.addHandler(webSocketHandler, new String[]{this.webSocketProperties.getSockJsPath()}).setAllowedOrigins(new String[]{this.webSocketProperties.getAllowOrigins()}).addInterceptors((HandshakeInterceptor[]) handshakeInterceptor.toArray(new HandshakeInterceptor[0])).withSockJS();
        };
    }
 
    @PostConstruct
    public void initJsonMessageHandlerHolder() {
        for (JsonMessageHandler jsonMessageHandler : this.jsonMessageHandlerList) {
            JsonMessageHandlerHolder.addHandler(jsonMessageHandler);
        }
        for (SubscriptionSessionFilter filter : this.jsonMessageFilterList) {
            JsonMessageFilterHolder.addFilter(filter);
        }
    }
}