Java SDK

<dependency>
    <groupId>io.itick</groupId>
    <artifactId>sdk</artifactId>
    <version>0.1.3</version>
</dependency>

implementation 'io.itick:sdk:0.1.3'

cd java
mvn clean install

import io.itick.sdk.Client;

public class Example {
    public static void main(String[] args) {
        String token = "your_api_token";
        Client client = new Client(token);
    }
}

// Get forex real-time trade
var tick = client.getForexTick("GB", "EURUSD");
System.out.println(tick);

// Get forex real-time quote
var quote = client.getForexQuote("GB", "EURUSD");
System.out.println(quote);

// Get forex real-time order book
var depth = client.getForexDepth("GB", "EURUSD");
System.out.println(depth);

// Get forex historical K-line
var kline = client.getForexKline("GB", "EURUSD", 2, 10, null);
for (var k : kline) {
    System.out.println(k);
}

// Get stock real-time trade
var tick = client.getStockTick("US", "AAPL");
System.out.println(tick);

// Get stock real-time quote
var quote = client.getStockQuote("US", "AAPL");
System.out.println(quote);

// Get stock real-time order book
var depth = client.getStockDepth("US", "AAPL");
System.out.println(depth);

// Get stock historical K-line
var kline = client.getStockKline("US", "AAPL", 2, 10, null);
for (var k : kline) {
    System.out.println(k);
}

// Get cryptocurrency real-time trade
var tick = client.getCryptoTick("BA", "BTCUSDT");
System.out.println(tick);

// Get cryptocurrency real-time quote
var quote = client.getCryptoQuote("BA", "BTCUSDT");
System.out.println(quote);

// Get cryptocurrency real-time order book
var depth = client.getCryptoDepth("BA", "BTCUSDT");
System.out.println(depth);

// Get cryptocurrency historical K-line
var kline = client.getCryptoKline("BA", "BTCUSDT", 2, 10, null);
for (var k : kline) {
    System.out.println(k);
}

// Set message handler
client.setMessageHandler(message -> {
    System.out.println("Received WebSocket message: " + message);
});

// Set error handler
client.setErrorHandler(error -> {
    System.err.println("WebSocket error: " + error.getMessage());
});

// Set open handler
client.setOpenHandler(() -> {
    System.out.println("WebSocket connected");
});

// Set close handler
client.setCloseHandler(() -> {
    System.out.println("WebSocket closed");
});

// Connect to forex WebSocket
client.connectForexWebSocket();

// Send subscription message
client.sendWebSocketMessage("{\"action\": \"subscribe\", \"codes\": [\"EURUSD\"]}");

// Wait to receive messages
Thread.sleep(5000);

// Check connection status
System.out.println("WebSocket connected: " + client.isWebSocketConnected());

// Close WebSocket
client.closeWebSocket();

// Connect to stock WebSocket
client.connectStockWebSocket();

// Connect to cryptocurrency WebSocket
client.connectCryptoWebSocket();

// Check if WebSocket is connected
boolean connected = client.isWebSocketConnected();

import io.itick.sdk.Client;

public class Main {
    public static void main(String[] args) {
        try {
            // Initialize client
            String token = "your_api_token";
            Client client = new Client(token);

            // Set WebSocket message handler
            client.setMessageHandler(message -> {
                System.out.println("Received WebSocket message: " + message);
            });

            // Set WebSocket error handler
            client.setErrorHandler(error -> {
                System.err.println("WebSocket error: " + error.getMessage());
            });

            // Test REST API
            System.out.println("Testing forex tick...");
            var tick = client.getForexTick("GB", "EURUSD");
            System.out.println(tick);

            // Test WebSocket
            System.out.println("\nTesting WebSocket...");
            client.connectForexWebSocket();

            // Send subscription message
            client.sendWebSocketMessage("{\"action\": \"subscribe\", \"codes\": [\"EURUSD\"]}");

            // Wait to receive messages
            Thread.sleep(5000);

            // Check connection status
            System.out.println("WebSocket connected: " + client.isWebSocketConnected());

            // Close WebSocket
            client.closeWebSocket();

        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}