Frühjahr: Nachricht senden, um websocket-clients

Baue ich ein webchat mit Spring Boot, RabbitMQ und WebSocket als POC, aber ich bin stucked ein letzter Punkt: WebSockets

Ich möchte meine ws-clients die Verbindung zu einem bestimmten Endpunkt, wie /room/{id} und wenn eine neue Nachricht eintrifft, möchte ich den server zum senden der Antwort an den Kunden, aber ich suchte nach etwas ähnliches, und hat nicht gefunden.

Derzeit, wenn die Nachricht eintrifft, ich verarbeite es mit RabbitMQ, wie 

container.setMessageListener(new MessageListenerAdapter(){
            @Override
            public void onMessage(org.springframework.amqp.core.Message message, Channel channel) throws Exception {
                log.info(message);
                log.info("Got: "+ new String(message.getBody()));
            }
        });

was ich möchte ist, statt log , soll ich senden Sie es an den client, zum Beispiel: websocketManager.sendMessage(new String(message.getBody()))

InformationsquelleAutor Luiz E. | 2015-11-28
  1. 8

    Ok, ich denke ich habe es, für alle, die es noch braucht, hier ist die Antwort:

    erste, Sie brauchen, um hinzuzufügen, WS Abhängigkeiten der pom.xml

    <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-websocket</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-messaging</artifactId>
</dependency>

    erstellen eines WS-Endpunkt

    @Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer {

    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        //the endpoint for websocket connections
        registry.addEndpoint("/stomp").withSockJS();
    }

    @Override
    public void configureMessageBroker(MessageBrokerRegistry config) {
        config.enableSimpleBroker("/");

        //use the /app prefix for others
        config.setApplicationDestinationPrefixes("/app");
    }

}

    Hinweis: ich bin mit STOMP, damit die clients verbinden sollen, wie dies

    <script type="text/javascript">
    $(document).ready(function() {
        var messageList = $("#messages");
        //defined a connection to a new socket endpoint
        var socket = new SockJS('/stomp');
        var stompClient = Stomp.over(socket);
        stompClient.connect({ }, function(frame) {
            //subscribe to the /topic/message endpoint
            stompClient.subscribe("/room.2", function(data) {
                var message = data.body;
                messageList.append("<li>" + message + "</li>");
            });

        });
    });
</script>

    Dann können Sie einfach den Draht der ws messenger auf Ihre Komponenten mit 

    @Autowired
private SimpMessagingTemplate webSocket;

    und senden Sie die Nachricht mit 

    webSocket.convertAndSend(channel, new String(message.getBody()));
    • wo hat der "Kanal" kommen aus als Ihr Ziel argument convertAndSend?
    • Kanal ist ein string. es ist der "Raum" ich bin das senden der Nachricht, so etwas wie "/room.".concat(message.getRoom().getUid().toString())
    InformationsquelleAutor Luiz E.
Schreibe einen Kommentar