基於Java語言訂閱免費的外匯API、指數API教學

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

    

      @ClientEndpoint
public class WebSocketSubscriber {

    

      // WebSocket服務器的地址
private static final String WEBSOCKET_SERVER_URL = "wss://api.itick.org/sws";

// 用於鑒權
private static final String AUTH_MESSAGE = "{\n" +
"  \"ac\":\"auth\",\n" +
"  \"params\":\"you_apikey\"\n" +
"}";

// 用於訂閱的消息格式，這裡假設訂閱一個名為 "your_channel" 的頻道
private static final String SUBSCRIBE_MESSAGE = "{\n" +
"  \"ac\":\"subscribe\",\n" +
"  \"params\":\"AM.LPL,AM.LPL\",\n" +
"  \"types\":\"depth,quote\"\n" +
"}";

    

      public static void main(String[] args) {
try {
// 創建WebSocket容器
WebSocketContainer container = ContainerProvider.getContainer();

// 連接到WebSocket服務器並獲取會話
Session session = container.connectToServer(WebSocketSubscriber.class, new URI(WEBSOCKET_SERVER_URL));

// 發送鑒權消息
session.getBasicRemote().sendText(AUTH_MESSAGE);

// 發送訂閱消息
session.getBasicRemote().sendText(SUBSCRIBE_MESSAGE);

} catch (URISyntaxException | IOException e) {
e.printStackTrace();
}
}

    

      @OnOpen
public void onOpen(Session session) {
System.out.println("WebSocket連接已打開");
}

@OnMessage
public void onMessage(Session session, String message) {
System.out.println("收到消息: " + message);
// 這裡可以根據收到的消息內容進行進一步的處理，比如解析JSON數據等
}

@OnError
public void onError(Session session, Throwable error) {
System.out.println("WebSocket錯誤: " + error.getMessage());
}

@OnClose
public void onClose(Session session, CloseReason closeReason) {
System.out.println("WebSocket連接已關閉，原因: " + closeReason.getReasonPhrase());
}