Spring web套接字消息传递-订阅并发送初始消息

Question

使用用于web套接字消息传递的Stomp broker中继，我可以订阅目标/topic/mydest。这将创建一个代理订阅，并接收系统中的某些内容为此代理目标触发的所有消息，这将在系统中发生某些事件时发生。

我可以订阅一个目标/app/mydest，将调用带有@subscribebemapping（“mydest”）的控制器方法，并且返回值仅在该套接字上作为消息发送回。据我所知，这是唯一的消息，将永远发送此订阅。

有没有一种方法可以将其合并到一个订阅中，即为某个/topic目的地创建一个代理订阅，并触发一些直接将消息发送回订阅方的代码？

用例：当系统中发生错误时，将带有当前错误计数的消息发送到/topic/mydest。当一个新客户订阅时，我只想向他发送最后一次已知的错误计数。其他人此时不感兴趣，因为人数没有变化。

我目前的解决方案是同时订阅/app/my的和/topic/my的，并在客户端上使用相同的消息处理程序。但它确实是一个合乎逻辑的订阅，而且它有点容易出错，因为客户端需要记住订阅两者。

我在这种情况下的问题：是否会有/app/订阅的进一步消息？有什么可以触发的吗？除此之外，如何向订阅者发送主题的初始信息，而不向现有订阅者发送冗余消息？

按照要求，这是我的WebSocket配置类。

@Configuration
@EnableWebSocketMessageBroker
public class WebsocketConfiguration extends AbstractWebSocketMessageBrokerConfigurer {
    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        registry.addEndpoint("/ws").setAllowedOrigins("*").withSockJS();
    }

    @Override
    public void configureMessageBroker(MessageBrokerRegistry registry) {
        registry.enableStompBrokerRelay("/queue/", "/topic/", "/exchange/");
        registry.setApplicationDestinationPrefixes("/app");
    }
}

Answer 1

您可以侦听会话订阅事件并发送初始消息

@Component
@RequiredArgsConstructor
public class WebSocketEventListener {

private static final Logger logger = LoggerFactory.getLogger(WebSocketEventListener.class);
private final SimpMessagingTemplate simpMessagingTemplate;


@EventListener
public void handleSessionSubscribeEvent(SessionSubscribeEvent event) {
    logger.info("Subscribed to session: " + event);
    Principal user = event.getUser();
    if (user instanceof UsernamePasswordAuthenticationToken) {
        UsernamePasswordAuthenticationToken token = (UsernamePasswordAuthenticationToken) user;
        if (token.getPrincipal() instanceof UserDetails) {
            UserDetails userDetails = (UserDetails) token.getPrincipal();
            simpMessagingTemplate.convertAndSendToUser(userDetails.getUsername(), "/queue/notify", "Hello");
        }
    }
}

}

Answer 2

可以使用Application ationListener和SessionSubcribe事件。示例：

@Component
public class SubscribeListener implements ApplicationListener<SessionSubscribeEvent> {

    private final SimpMessagingTemplate messagingTemplate;

    @Autowired
    public SubscribeListener(SimpMessagingTemplate messagingTemplate) {
        this.messagingTemplate = messagingTemplate;
    }

    @Override
    public void onApplicationEvent(SessionSubscribeEvent event) {
        messagingTemplate.convertAndSendToUser(event.getUser().getName(), "/topic/mydest", "Last known error count");
    }
}