Как получить потоковые данные из dolphindb с помощью java api? - PullRequest
0 голосов
/ 22 февраля 2020

Я выполняю тестирование потоковых данных в кластере dolphindb, в узле данных есть потоковая таблица, я подписал потоковые данные на java api, но данные не получены. я использую ThreadedClient для подписки на streamTable и без исключений, кто-нибудь может помочь?

мой java код

public static void main(String args[]) throws SocketException {

    ThreadedClient client = new ThreadedClient(8849); //the subPort set to 8849
    try {
        client.subscribe("192.168.1.42", 8848, "trades", "action1", new SampleMessageHandler());
    } catch (IOException e) {
        e.printStackTrace();
    }
}

public class SampleMessageHandler implements MessageHandler {
    @Override
    public void doEvent(IMessage msg) {
        System.out.println(msg.getValue(0)); 
    }
}

...