package com.estate.expert.admin.test;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
import javax.websocket.*;
|
import java.io.IOException;
|
import java.net.URI;
|
import java.util.concurrent.Future;
|
|
/**
|
* @ClassName WebsocketTest
|
* @Description
|
* @Author daisy
|
* @Date 2024/1/2
|
**/
|
@Slf4j
|
@ClientEndpoint
|
public class WebsocketTest {
|
|
@OnOpen
|
public void onOpen(Session session) {
|
// 在建立连接时执行的逻辑
|
log.info("onOpen");
|
String subscriptionMessage = "{\"event\":\"subscribe\",\"topic\":\"PERP_NEAR_USDC@bbo\", \"id\":\"clientId555\"}";
|
Future<Void> result = session.getAsyncRemote().sendText(subscriptionMessage);
|
log.info("result: {}", result.isDone());
|
|
}
|
|
@OnMessage
|
public void onMessage(String message) {
|
// 处理接收到消息
|
log.info("onMessage: {}", message);
|
}
|
|
public static void main(String[] args) throws Exception {
|
WebSocketContainer container = ContainerProvider.getWebSocketContainer();
|
String accountId = "0xd1123119d6242281a07fff98e3d4fa0e0869d2eb6922ad7e13329ffa8cad902a";
|
String uri = "wss://testnet-ws-evm.orderly.org/ws/stream/" + accountId; // 替换成实际的WebSocket服务器URL
|
container.connectToServer(WebsocketTest.class, URI.create(uri));
|
while (true) {
|
Thread.sleep(60 * 60 * 1000);
|
}
|
}
|
}
|
