Invia messaggio a tutti i clienti tramite SimpMessagingTemplate in ServletContextListener

Question

sto usando il framework Spring e ho un controller websocket di lavoro che assomiglia a questo:

@Controller 
public class GreetingController { 

    @MessageMapping("/hello") 
    @SendTo("/topic/greetings") 
    public Greeting greeting(HelloMessage message) throws InterruptedException { 
     return new Greeting("Hello, " + message.getName() + "!"); 
    } 
} 

Ho anche questa configurazione:

@Configuration 
@EnableWebSocketMessageBroker 
public class HelloWebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer { 

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

    public void registerStompEndpoints(StompEndpointRegistry registry) { 
     registry.addEndpoint("/hello").withSockJS(); 
    } 
} 

Questa parte funziona alla grande! Posso inviare e ricevere messaggi con successo tra due o più browser utilizzando Stomp.js. Ecco la parte che non funziona. Ho implementato uno ServletContextListener che contiene un oggetto personalizzato che, per motivi di semplicità, ho chiamato "notifier". Il notificatore ascolta determinati eventi che si verificano sul lato server. Quindi chiama il metodo 'notify', che dovrebbe inviare dettagli sull'evento a tutti i client. Tuttavia, non funziona.

@WebListener 
public class MessageListener implements ServletContextListener, Notifiable { 

    private Notifier notifier; 

    @Autowired 
    private SimpMessagingTemplate messageSender; 


    public MessageListener() { 
     notifier = new Notifier(this); 
    } 

    public void contextInitialized(ServletContextEvent contextEvent) { 
     WebApplicationContextUtils 
     .getRequiredWebApplicationContext(contextEvent.getServletContext()) 
     .getAutowireCapableBeanFactory() 
     .autowireBean(this); 

     notifier.start(); 
    } 

    public void contextDestroyed(ServletContextEvent contextEvent) { 
     notifier.stop(); 
    } 

    public void notify(NotifyEvent event) { 
     messageSender.convertAndSend("/topic/greetings", new Greeting("Hello, " + event.subject + "!")); 
    } 
} 

non ottengo un'eccezione. Lo SimpMessagingTemplate è stato iniettato con successo da Spring, quindi non è nullo. Sono stato in grado di inserire il codice Spring e ho capito che lo subscriptionRegistrySimpleBrokerMessageHandler è vuoto quando si utilizza lo SimpMessagingTemplate. Quindi deve essere un'istanza separata da quella utilizzata dai controller. Come posso ottenere lo stesso subscriptionRegistry utilizzato dai controller?

Answer 1

La soluzione era quella di utilizzare la classe di primavera ApplicationListener invece di un ServletContextListener, e per ascoltare appositamente per il ContextRefreshedEvent.

Questo è il mio esempio di lavoro:

@Component 
public class MessagingApplicationListener implements ApplicationListener<ContextRefreshedEvent>, Notifiable { 
    private final NotifierFactor notifierFactory; 
    private final MessageSendingOperations<String> messagingTemplate; 
    private Notifier notifier; 

    @Autowired 
    public MessagingApplicationListener(NotifierFactor notifierFactory, MessageSendingOperations<String> messagingTemplate) { 
     this.notifierFactory = notifierFactory; 
     this.messagingTemplate = messagingTemplate; 
    } 

    @Override 
    public void onApplicationEvent(ContextRefreshedEvent event) { 
     if (notifier == null) { 
      notifier = notifierFactory.create(this); 
      notifier.start(); 
     } 
    } 

    public void notify(NotifyEvent event) { 
     messagingTemplate.convertAndSend("/topic/greetings", new Greeting("Hello, " + event.subject + "!")); 
    } 

    @PreDestroy 
    private void stopNotifier() { 
     if (notifier != null) { 
      notifier.stop(); 
     } 
    } 
}