在内部订阅spring-websocket消息

Question

我使用spring-websocket将消息推送到浏览器客户端。

我的设置与the portfolio example中的设置几乎相同，并且我使用MessageSendingOperations发送消息

MessageSendingOperations<String> messagingTemplate = //...;
this.messagingTemplate.convertAndSend("/topic/data/1", message);

这个可以完美地工作。

但我也希望能够在内部订阅相同的消息。

MessageReceivingOperations看起来几乎像是要使用的工具，但它似乎只支持拉取消息。我更喜欢将消息推送到我的服务中。

SubscribableChannel.subscribe()看起来也很有前途，但是我怎么才能找到正确的通道呢？

我真的希望能够像这样的东西

messagingTemplate.subscribe("/topic/data/*", 
                            new MessageHandler<String>{
                                public void handleMessage(String s){
                                  // process message
                                }
                            });

Answer 1

以下方法适用于我，但如果有更直接的方法就更好了：

public interface MessageHandler<T> {
    public void handleMessage(T message);
}

@Autowired
private AbstractSubscribableChannel brokerChannel;

private PathMatcher pathMatcher = new AntPathMatcher();

private <T> void subscribe(final String topic, final Handler<T> handler, final Class<T> messageClass){
    brokerChannel.subscribe(new MessageHandler() {
        @Override
        public void handleMessage(Message<?> message) throws MessagingException {
            SimpMessageHeaderAccessor headers = SimpMessageHeaderAccessor.wrap(message);
            final String destination = headers.getDestination();
            if(pathMatcher.match(topic, destination)) {
                final T messageObject = (T) messageConverter.fromMessage(message, messageClass);
                handler.handleMessage(messageObject);
            }
        }
    });
}