स्प्रिंग 4 वेबसॉकेट

Question

के साथ जावा से पुश संदेश मैं जावा से वेबस्केट क्लाइंट को संदेश धक्का देना चाहता हूं। मैंने सफलतापूर्वक जेएस क्लाइंट को सर्वर पर भेज दिया है और 2 जेएस क्लाइंट पर एक संदेश वापस प्राप्त किया है, इसलिए क्लाइंट साइड कोड ठीक काम करता है।

मेरी समस्या यह है कि जब मैं जावा ऐप में ईवेंट करता हूं तो मैं एक संदेश शुरू करना चाहता हूं। तो उदाहरण के लिए हर बार 10 ऑर्डर दिए गए हैं सभी सब्सक्राइब किए गए ग्राहकों को एक संदेश भेजें। क्या यह संभव है?

मेरे वर्तमान config:

<websocket:message-broker application-destination-prefix="/app"> 
    <websocket:stomp-endpoint path="/hello"> 
     <websocket:sockjs/> 
    </websocket:stomp-endpoint> 
    <websocket:simple-broker prefix="/topic"/> 
</websocket:message-broker> 

@Controller 
public class MessageController { 
    @MessageMapping("/hello") 
    @SendTo("/topic/greetings") 
    public Greeting greeting() throws Exception { 
     return new Greeting("Hello world"); 
    } 
} 

मैं चाहता क्या ऐसा करने में सक्षम होने के लिए कुछ इस तरह है:

public class OrderManager { 
    @Autowired MessageController messageController; 
    int orderCount = 0; 

    public void processOrder(Order o) { 
     orderCount++; 
     if(orderCount % 10 == 0) 
      messageController.greeting(); 
    } 
} 

और WebSocket करने के लिए सभी की सदस्यता ली ग्राहकों एक संदेश प्राप्त होता है।

Answer 1

आप SimpMessagingTemplate. का उपयोग कर सकते हैं यह स्वचालित रूप से पंजीकृत है। बस autowire इसे किसी भी स्प्रिंग बीन में आप चाहते हैं।

@Autowired 
private SimpMessagingTemplate template; 
... 
this.template.convertAndSend("/topic/greetings", text);