Websocket使用Spring網絡套接字向SockJS廣播不同的用戶

目前在我的應用程序中，每10秒鐘會發送一個消息與Spring網絡套接字。這就是我的Spring應用程序中向用戶廣播的消息。Websocket使用Spring網絡套接字向SockJS廣播不同的用戶

@Configuration 
@EnableWebSocketMessageBroker 
@EnableScheduling 
@Component 
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer { 

     @Autowired 
     private SimpMessagingTemplate template; 

     private TaskScheduler scheduler = new ConcurrentTaskScheduler(); 

     public WebSocketConfig() { 
      System.out.printf(" ---INIT----------"); 

    } 

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

    // @Override 
    public void configureMessageBroker(MessageBrokerRegistry config) { 

     config.enableSimpleBroker("/topic/", "/queue/"); 

     config.setApplicationDestinationPrefixes("/app"); 
    } 

    @PostConstruct 
    private void broadcastTimePeriodically() { 


     scheduler.scheduleAtFixedRate(new Runnable() { 
     public void run() { 
      try{ 
      template.convertAndSend("/topic/simplemessagesresponse", "{shares:true,price:100.00}"); 
      }catch(MessagingException e){ 
       System.err.println("!!!!!! websocket timer error :>"+e.toString()); 
      } 

     } 
     }, 10000); 
    } 

    @PreDestroy 
    private void destroyServices(){ 

    } 

    // @Override 
    public void configureClientInboundChannel(ChannelRegistration registration) { 

    } 
    // @Override 
    public void configureClientOutboundChannel(ChannelRegistration registration) { 
     registration.taskExecutor().corePoolSize(4).maxPoolSize(10); 
    } 

    //@Override 
    public boolean configureMessageConverters(List<MessageConverter> arg0) { 
     // TODO Auto-generated method stub 
     return true; 
    } 
    @Override 
    public void configureWebSocketTransport(WebSocketTransportRegistration arg0) { 
     // TODO Auto-generated method stub 

    } 
}

這是瀏覽器如何接收，

var socket = new SockJS(desz); 
stompClient = Stomp.over(socket); 

stompClient.connect('user', 'guest', function(frame) { 

    stompClient.subscribe("/topic/simplemessagesresponse", function(servermessage) { 
     var stompResponse = JSON.parse((servermessage.body)); 
     console.log('server msg: '+stompResponse); 
    }); 
});

我要廣播相同的消息給一些用戶，而另一組用戶定期有另一條消息。我應該如何修改我的上述代碼來實現這一目標？

來源

2014-10-10 Débora

您可以在調度run（）方法

this.simpMessagingTemplate.convertAndSend("/queue/" + userGroup.geName(), 
      messageMap.get(userGroup.geName()));

有這樣和客戶端，您可以訂閱特定URL 「隊列/ {groupName}」羣組

stompClient.subscribe("/queue/${groupName}", function(servermessage) { 
    var stompResponse = JSON.parse((servermessage.body)); 
    console.log('server msg: '+stompResponse); 
});

注意:(在客戶端示例變量'groupName'被髮送到從控制器查看並使用JSP在JSP中訪問）

來源

2015-06-29 06:04:06 Jebil

Websocket使用Spring網絡套接字向SockJS廣播不同的用戶

回答

相關問題