0

我正在尝试使用 Coinigy websocket api 来获取实时交易流。

但我收到一个错误：

{"rid":2,"error":"您已连接，但此套接字尚未经过身份验证。请发出带有凭据有效负载的 auth 事件。"} {"data":{"pingTimeout":20000,"id":" BltoRYWc7k1dYgeRAHm0","isAuthenticated":false},"rid":1}

我正在使用的代码如下

import com.neovisionaries.ws.client.WebSocketException;
import com.neovisionaries.ws.client.WebSocketFrame;
import io.github.sac.*;

import java.util.List;
import java.util.Map;

import org.codehaus.jettison.json.JSONException;
import org.codehaus.jettison.json.JSONObject;


public class Main {

    public static String url="wss://sc-02.coinigy.com/socketcluster/";

    public static void main(String arg[]) throws JSONException {

        Socket socket = new Socket(url);
        JSONObject obj = new JSONObject();
        obj.put("apiKey", "abd");
        obj.put("apiSecret", "efg");
        socket.setListener(new BasicListener() {

            public void onConnected(Socket socket,Map<String, List<String>> headers) {
                System.out.println("Connected to endpoint");
                socket.emit("auth", obj, new Ack() {
                    @Override
                    public void call(String eventName, Object error, Object data) {
                        System.out.println("Got message for :"+eventName+" error is :"+error+" data is :"+data);
                    }
                });
            }

            public void onDisconnected(Socket socket,WebSocketFrame serverCloseFrame, WebSocketFrame clientCloseFrame, boolean closedByServer) {
                System.out.println("Disconnected from end-point");
            }

            public void onConnectError(Socket socket,WebSocketException exception) {
                System.out.println("Got connect error "+ exception);
            }

            public void onSetAuthToken(String token, Socket socket) {
                System.out.println("Set auth token got called");
                socket.setAuthToken(token);
            }

            public void onAuthentication(Socket socket,Boolean status) {
                if (status) {
                    System.out.println("socket is authenticated");
                } else {
                    System.out.println("Authentication is required (optional)");
                }
            }

        });


       socket.setReconnection(new ReconnectStrategy().setDelay(3000).setMaxAttempts(10)); //Connect after each 2 seconds for 30 times

        socket.connect();

        Socket.Channel channel = socket.createChannel("xyz");
        channel.subscribe(new Ack() {
            @Override
            public void call(String channelName, Object error, Object data) {
                if (error==null){
                    System.out.println("Subscribed to channel "+channelName+" successfully");
                }
            }
        });

        channel.onMessage(new Emitter.Listener() {
            @Override
            public void call(String channelName, Object data) {

                System.out.println("Got message for channel "+channelName+" data is "+data);
            }
        });

        channel.unsubscribe(new Ack() {
            @Override
            public void call(String name, Object error, Object data) {
                System.out.println("Unsubscribed successfully");
            }
        });
        channel.unsubscribe();
    }
}
4

1 回答 1

0

如果您使用套接字集群库，您只能这样进行身份验证。否则，您需要使用他们更复杂且未记录的协议。这里有一段文档：https ://github.com/SocketCluster/socketcluster/blob/master/socketcluster-protocol.md

于 2018-01-12T09:55:41.830 回答