Spring stomp client for web sockets for Android

Question

Can someone please let me know how to connect to spring stomp network socket from android client.

WebSocketConfig.java

import org.springframework.context.annotation.Configuration;
import org.springframework.messaging.simp.config.MessageBrokerRegistry;
import org.springframework.web.socket.config.annotation.AbstractWebSocketMessageBrokerConfigurer;
import org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker;
import org.springframework.web.socket.config.annotation.StompEndpointRegistry;

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer {

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

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

}

PushMessageNotifier.java

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.messaging.simp.SimpMessagingTemplate;
import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.stereotype.Service;    

@Service
@EnableAsync
public class PushMessageNotifier {

    private SimpMessagingTemplate simpMessagingTemplate;

    @Autowired
    public PushMessageNotifier(SimpMessagingTemplate simpMessagingTemplate) {
        this.simpMessagingTemplate = simpMessagingTemplate;
    }

    @Async
    public Boolean pushToUI(TicketView ticketView) {
        Boolean result = false;
        if (null != ticketView) {
            this.simpMessagingTemplate.convertAndSend("/pushticket/ticket", ticketView);
            result = true;
        }
        return result;
    }

}

Please tell me how can I connect to this socket from an Android application? Even I have no idea which android client I need to use to connect to this socket and theme. thanks in advance

Answer 1

I experienced the same problem. I found that spring provides a standard socket library for web sockets, which I used to test my server side code.

@LocalServerPort
private int port;

private SockJsClient sockJsClient;

private WebSocketStompClient stompClient;

private final WebSocketHttpHeaders headers = new WebSocketHttpHeaders();

@Before
public void setup() {
    List<Transport> transports = new ArrayList<>();
    transports.add(new WebSocketTransport(new StandardWebSocketClient()));
    this.sockJsClient = new SockJsClient(transports);

    this.stompClient = new WebSocketStompClient(sockJsClient);
    this.stompClient.setMessageConverter(new MappingJackson2MessageConverter());
}

@Test
public void getGreeting() throws Exception {

    final CountDownLatch latch = new CountDownLatch(1);
    final AtomicReference<Throwable> failure = new AtomicReference<>();

    StompSessionHandler handler = new TestSessionHandler(failure) {

        @Override
        public void afterConnected(final StompSession session, StompHeaders connectedHeaders) {
            session.subscribe("/user/testuser1/reply", new StompFrameHandler() {
                @Override
                public Type getPayloadType(StompHeaders headers) {
                    return Greeting.class;
                }

                @Override
                public void handleFrame(StompHeaders headers, Object payload) {
                    MessageSendDTO greeting = (MessageSendDTO) payload;
                    try {
                        System.out.println("#################### "+greeting.getWriter());
                        assertEquals("testuser1", greeting.getWriter());
                    } catch (Throwable t) {
                        failure.set(t);
                    } finally {
                        session.disconnect();
                        latch.countDown();
                    }
                }
            });
            try {

                MessageSendDTO dto= new MessageSendDTO();
                dto.setWriter("testuser1");
                dto.setReceiver("testuser2");
                dto.setMessageBody("TESTING ");

                GsonBuilder builder = new GsonBuilder();
                Gson gson = builder.create();

               //session.send("/app/newMessage", new HelloMessage("Spring"));
                session.send("/app/newMessage", dto);
            } catch (Throwable t) {
                failure.set(t);
                latch.countDown();
            }
        }
    };

    this.stompClient.connect("ws://localhost:8080/newMessage", this.headers, handler, this.port);

    if (latch.await(20, TimeUnit.SECONDS)) {
        if (failure.get() != null) {
            throw new AssertionError("", failure.get());
        }
    }
    else {
        fail("Greeting not received");
    }

. , .

Answer 2

, , Google , ...

• https://github.com/NaikSoftware/StompProtocolAndroid
• : : SockJS , URL-, http://server-host:8080/stompEndpoint Android ws://server-host:8080/stompEndpoint/websocket. 1) http ws 2) /websocket Android- URL