Java Websocket Client в качестве сервлета (App Engine) - PullRequest
0 голосов
/ 12 февраля 2019

Я пытаюсь установить соединение WebSocket в моем сервлете.Я получаю некоторые сообщения обратного вызова с сервера, но только очень немногие.Я вызываю Thread.sleep (30000), поэтому сервлет должен ждать новых сообщений 30 секунд, но, похоже, по какой-то причине он не ждет.

Это код в моем сервлете:

try {
    // open websocket
    final WebsocketClientEndpoint clientEndPoint = new WebsocketClientEndpoint(new URI("wss://www.bitmex.com/realtime"));

    // add listener
    clientEndPoint.addMessageHandler(new WebsocketClientEndpoint.MessageHandler() {
        public void handleMessage(String message) {


            System.out.println(message);

            logger.info("WEBSOCKET MSG: "+message);

        }
    });

    // send message to websocket
    clientEndPoint.sendMessage("{\"op\": \"subscribe\", \"args\": \"trade\"}");

    // wait 30 seconds for messages from websocket
    Thread.sleep(30000);

} catch (InterruptedException ex) {
    System.err.println("InterruptedException exception: " + ex.getMessage());
} catch (URISyntaxException ex) {
    System.err.println("URISyntaxException exception: " + ex.getMessage());
}

А это мой код WebsocketClientEndpoint:

import java.net.URI;
import javax.websocket.ClientEndpoint;
import javax.websocket.CloseReason;
import javax.websocket.ContainerProvider;
import javax.websocket.OnClose;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.WebSocketContainer;

@ClientEndpoint
public class WebsocketClientEndpoint {

    Session userSession = null;
    private MessageHandler messageHandler;

    public WebsocketClientEndpoint(URI endpointURI) {
        try {
            WebSocketContainer container = ContainerProvider.getWebSocketContainer();
            container.connectToServer(this, endpointURI);


        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }

    /**
     * Callback hook for Connection open events.
     *
     * @param userSession the userSession which is opened.
     */
    @OnOpen
    public void onOpen(Session userSession) {
        System.out.println("opening websocket");
        this.userSession = userSession;
    }

    /**
     * Callback hook for Connection close events.
     *
     * @param userSession the userSession which is getting closed.
     * @param reason the reason for connection close
     */
    @OnClose
    public void onClose(Session userSession, CloseReason reason) {
        System.out.println("closing websocket");
        this.userSession = null;
    }

    /**
     * Callback hook for Message Events. This method will be invoked when a client send a message.
     *
     * @param message The text message
     */
    @OnMessage
    public void onMessage(String message) {
        if (this.messageHandler != null) {
            this.messageHandler.handleMessage(message);
        }
    }

    public void addMessageHandler(MessageHandler msgHandler) {
        this.messageHandler = msgHandler;
    }

    public void sendMessage(String message) {
        this.userSession.getAsyncRemote().sendText(message);
    }

    public static interface MessageHandler {

        public void handleMessage(String message);
    }
}

Какой правильный способ сделать это?Или это может быть проблема с App Engine (стандартная среда)?

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...