2

我的目标是为客户端订阅服务器事件 SSE。客户端将使用 WebSocket 协议，因此我使用：spring.rsocket.server.transport: websocket

阻塞 IO 栈的模拟：

@Configuration
@EnableWebSocketMessageBroker
class WebSocketConfiguration: WebSocketMessageBrokerConfigurer {

    override fun configureMessageBroker(registry: MessageBrokerRegistry) {
        registry.enableSimpleBroker("/topic")

        registry.setApplicationDestinationPrefixes("/app")
    }

    override fun registerStompEndpoints(registry: StompEndpointRegistry) {
        registry.addEndpoint("/websocket")
                .setAllowedOrigins("*")
                .withSockJS();
    }
}

用法：

@Service
class MessagingService(private val simpMessagingTemplate: SimpMessagingTemplate) {

    private val logger = KotlinLogging.logger {}

    fun notify(baseEvent: BaseEvent) {
        logger.debug { "Sending an event $baseEvent" }
        simpMessagingTemplate.convertAndSend("/topic/events", baseEvent)
    }
}

客户端代码：

function connect() {
    var socket = new SockJS('/websocket');
    stompClient = Stomp.over(socket);
    stompClient.connect({}, function (frame) {
        setConnected(true);
        console.log('Connected: ' + frame);
        stompClient.subscribe('/topic/events', function (event) {
            console.log('Handled message from ws: ' + event)
            showGreeting(JSON.parse(event.body));
        });
    });
}

simpMessagingTemplate将事件推送到连接的客户端。

我想用反应器实现同样的效果，spring-boot-starter-rsocket 它也可以在客户端-服务器级别与 WebSocket 一起使用。

Rsocketrequest-stream适合，但在这种情况下，我需要服务器上的永恒通量流，因为我不知道事件何时会到来。我不知道该怎么做

4

0 回答 0