!7

// from https://github.com/BitgetLimited/v3-bitget-api-sdk/blob/master/bitget-java-sdk-api/src/test/java/com/bitget/openapi/ws/BitgetWsClientTest.java

lib 1400587 // BitGet Java SDK

import com.bitget.openapi.ws.*;

import com.alibaba.fastjson.JSON;

import com.alibaba.fastjson.JSONObject;

import com.bitget.openapi.dto.request.ws.SubscribeReq;

import org.junit.Before;

import org.junit.Test;

public static final String PUSH_URL = "wss://ws.bitget.com/mix/v1/stream";

public static String API_KEY = "";

public static String SECRET_KEY = "";

public static String PASS_PHRASE = "";

p {

  API_KEY = args[0];

  SECRET_KEY = args[1];

  PASS_PHRASE = args[2];

    BitgetWsClient client = BitgetWsHandle.builder()

                            .pushUrl(PUSH_URL)

                            .apiKey(API_KEY)

                            .secretKey(SECRET_KEY)

                            .passPhrase(PASS_PHRASE)

                            .isLogin(true)

                            //默认监听处理，如订阅时指定监听，默认不再接收该channel订阅信息

                            .listener(response -> {

                                JSONObject json = JSONObject.parseObject(response);

                                System.out.println("def:" + json);

                            //失败消息的逻辑处理,如:订阅失败

                            }).errorListener(response -> {

                                JSONObject json = JSONObject.parseObject(response);

                                System.out.println("error:" + json);

                            }).build();

    List<SubscribeReq> list = new ArrayList<SubscribeReq>() {{

        add(SubscribeReq.builder().instType("mc").channel("ticker").instId("BTCUSD").build());

        add(SubscribeReq.builder().instType("SP").channel("candle1W").instId("BTCUSDT").build());

    }};

    client.subscribe(list);

    List<SubscribeReq> list2 = new ArrayList<SubscribeReq>() {{

        add(SubscribeReq.builder().instType("UMCBL").channel("account").instId("default").build());

    }};

    client.subscribe(list2, response -> {

        JSONObject json = JSONObject.parseObject(response);

        System.out.println("appoint:" + json);

    });

}