Spring Boot WebSocket

spring websocket in the clint

WebSocketStompClient WebSocketClient SockJsClient security SimpUserRegistry

user1 name:revo password:revo user2 name:ashraf password:revo

open test/revox/RevoxApplicationTests

@Test
public void Main() throws InterruptedException, ExecutionException {
    List<Transport> transports = new ArrayList<>();
    StandardWebSocketClient standardWebSocketClient = new StandardWebSocketClient();
    transports.add(new WebSocketTransport(standardWebSocketClient));
    SockJsClient sockJsClient = new SockJsClient(transports);
    WebSocketStompClient stompClient = new WebSocketStompClient(sockJsClient);
    String stompUrl = "ws://localhost:8080/hello";
    stompClient.setMessageConverter(new MappingJackson2MessageConverter());
    String plainCreds = "revo:revo";
    String base64Creds = new String(Base64.getEncoder().encode(plainCreds.getBytes()));
    HttpHeaders httpHeaders = new HttpHeaders();
    httpHeaders.add("Authorization", "Basic " + base64Creds);
    WebSocketHttpHeaders headers = new WebSocketHttpHeaders(httpHeaders);

    ListenableFuture<StompSession> connect = stompClient.connect(stompUrl,headers, new StompSessionHandlerAdapter() {
    });

    connect.addCallback(new ListenableFutureCallback<StompSession>() {
        @Override
        public void onFailure(Throwable ex) {
        }

        @Override
        public void onSuccess(StompSession result) {
            result.subscribe("/user/topic/greetings", new StompSessionHandlerAdapter() {
                @Override
                public Type getPayloadType(StompHeaders headers) {
                    return ConversationMessage.class;
                }

                @Override
                public void handleFrame(StompHeaders headers, Object payload) {
                    ConversationMessage message = (ConversationMessage) payload;
                    System.out.println(message.getContent());
                }
            });
        }
    });


    connect.addCallback(new ListenableFutureCallback<StompSession>() {
        @Override
        public void onFailure(Throwable ex) {
        }

        @Override
        public void onSuccess(StompSession result) {
            StompHeaders stompHeaders = new StompHeaders();
            stompHeaders.setDestination("/app/hello");
            ConversationMessage payload = new ConversationMessage();
            payload.setContent("ddddddd");
            result.send(stompHeaders, payload);
        }
    });
    Thread.sleep(4000);
}

see RevoWebSocket for revo impl

    RevoWebSocket revoWebSocket = new RevoWebSocket("localhost:8080/hello", "revo", "revo");
    revoWebSocket.Connect();
    if (revoWebSocket.isConnected()) {
        revoWebSocket.subscribe("/user/topic/greetings", new RevoStompHandler<>(Message.class, m ->
                System.out.println(m.getContent())
        ));
        revoWebSocket.send("/app/hello", new Message("lovex"));
        Thread.sleep(100);
    }
}