如何在Spring应用程序侦听器（SessionConnectedEvent）中发送消息

Question

我在Spring消息中使用Stomp over SockJS。我正在尝试在连接新用户时向所有登录用户发送消息。首先，这是我的听众：

@Component
public class SessionConnectedListener implements ApplicationListener<SessionConnectedEvent> {

    private static final Logger log = LoggerFactory.getLogger(SessionConnectedListener.class);

    @Autowired
    private SimpMessagingTemplate template;

    @Override
    public void onApplicationEvent(SessionConnectedEvent event) {
        log.info(event.toString());

        // Not sure if it's sending...?
        template.convertAndSend("/topic/login", "New user logged in");
    }

}

我的WebSocket配置

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer {

    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        registry.addEndpoint("chat").withSockJS();
    }

    @Override
    public void configureMessageBroker(MessageBrokerRegistry config) {
        config.enableSimpleBroker("/topic", "/queue");
        config.setApplicationDestinationPrefixes("/app");
    }

}

我的JS配置

var socket = new SockJS('/chat');
stompClient = Stomp.over(socket);

stompClient.connect({}}, function(frame) {

    // ... other working subscriptions

    stompClient.subscribe("/topic/login", function(message) {
        console.log(message.body);
    });

});

我在这里的问题是，我的template.convert和发送（）在应用程序监听器中不工作。但是，如果我把它放在一个带有@Message映射注释的Controller方法中，它将工作，并且我将有一个控制台日志客户端。

所以我的问题是：template.convert和发送（）可以在应用程序监听器中工作吗？如果有，如何？还是我错过了什么？

谢谢你的帮助！

附：我的日志。信息（event.toString（））；在ApplicationListener中工作，因此我知道我正在进入onApplicationEvent（）方法。

Answer 1

好的。虽然很奇怪，但我把我的监听器放在了下面的包里：

包my.company.listener

但是由于我在应用程序上下文中的配置，convertAndSend（）方法无法工作。

@ComponentScan（basePackages={“my.company”}，excludeFilters=@ComponentScan.Filter（type=FilterType.REGEX，pattern={“my.company.web.*}））

然而，当我将我的监听器（用@Component注释）移动到web子包时，它工作了！

打包我的。公司网状物听众

Answer 2

在ApplicationListener中使用模板发送消息应该可以正常工作。请查看这个SpringWebSocket聊天示例。