Java WebSocket客戶端

方式一 使用Java-WebSocket

1.依賴

<dependency>
    <groupId>org.java-websocket</groupId>
    <artifactId>Java-WebSocket</artifactId>
    <version>1.5.3</version>
</dependency>

2.代碼

import org.java_websocket.client.WebSocketClient;
import org.java_websocket.handshake.ServerHandshake;

import java.net.URI;
import java.net.URISyntaxException;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

/**
 * @author zhong
 */
public class MyWebSocketClient extends WebSocketClient {

    public MyWebSocketClient(URI serverUri) {
        super(serverUri);
    }

    @Override
    public void onOpen(ServerHandshake data) {
        System.out.println("WebSocket連接已打開。");
    }

    @Override
    public void onMessage(String message) {
        System.out.println("收到消息: " + message);
    }

    @Override
    public void onClose(int code, String reason, boolean remote) {
        System.out.println("WebSocket連接已關(guān)閉。");
    }

    @Override
    public void onError(Exception ex) {
        System.err.println("WebSocket連接發(fā)生錯誤：" + ex.getMessage());
    }

    /**
     * 連接定時檢查
     */
    public void startReconnectTask(long delay,
                                   TimeUnit unit) {
        System.out.println("WebSocket 心跳檢查");
        // 以下為定時器,建議使用自定義線程池，或交給框架處理（spring）
        ScheduledExecutorService executorService = Executors.newSingleThreadScheduledExecutor();
        executorService.scheduleWithFixedDelay(() -> {
            // 檢查邏輯：判斷當(dāng)前連接是否連通
            if (!this.isOpen()) {
                System.out.println("WebSocket 開始重連......");
                // 重置連接
                this.reconnect();
                // 以下為錯誤示范
                //this.close();
                //this.connect();
            }
        }, 0, delay, unit);
    }
	// 測試
    public static void main(String[] args) throws URISyntaxException {
        // 服務(wù)地址
        URI uri = new URI("ws:服務(wù)地址");
        // 創(chuàng)建客戶端
        MyWebSocketClient myWebSocketClient = new MyWebSocketClient(uri);
        // 建立連接
        myWebSocketClient.connect();
        // 開啟 定時檢查
        myWebSocketClient.startReconnectTask(5, TimeUnit.SECONDS);
    }
}

方式二 spring-boot-starter-websocket

1.依賴

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-test</artifactId>
    <scope>test</scope>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-websocket</artifactId>
</dependency>

2.代碼

2.1 自定義 websocket handler

public class ClientWebSocketHandler implements WebSocketHandler {
    public static final Logger logger = LoggerFactory.getLogger(ClientWebSocketHandler.class);

    @Override
    public void afterConnectionEstablished(WebSocketSession session) throws Exception {
        logger.info("客戶端連接成功:{}", session.getId());
    }

    @Override
    public void handleMessage(WebSocketSession session, WebSocketMessage<?> message) throws Exception {
        logger.info("客戶端接受到消息:{}", message.getPayload());
    }

    @Override
    public void handleTransportError(WebSocketSession session, Throwable exception) throws Exception {
        logger.info("客戶端發(fā)送錯誤:{}", exception.getMessage());
    }

    @Override
    public void afterConnectionClosed(WebSocketSession session, CloseStatus closeStatus) throws Exception {
        logger.info("客戶端關(guān)閉連接:{}", closeStatus.getCode());
    }

    @Override
    public boolean supportsPartialMessages() {
        return false;
    }
}

2.2 將websocket handler加入容器

@Configuration
public class WebSocketClientConfig {
    @Bean
    public WebSocketClient webSocketClient() {
        return new StandardWebSocketClient();
    }

    @Bean
    public ClientWebSocketHandler clientWebSocketHandler() {
        return new ClientWebSocketHandler();
    }

    @Bean
    public WebSocketConnectionManager connectionManager() {
        WebSocketConnectionManager connectionManager = new WebSocketConnectionManager(
                webSocketClient(),
                clientWebSocketHandler(),
                "連接地址"
        );
        connectionManager.setAutoStartup(true);
        return connectionManager;
    }
}

2.3 定時器監(jiān)控

@EnableScheduling
@SpringBootApplication
public class WebsocketClientApplication {
    @Resource
    private WebSocketConnectionManager connectionManager;

    public static void main(String[] args) {
        SpringApplication.run(WebsocketClientApplication.class, args);
    }
    @Scheduled(fixedRate = 5000)
    public void reconnectTask() {
        System.out.println("心跳檢查");
        if(!connectionManager.isConnected()){
            System.out.println("重新連接.....");
            connectionManager.stop();
            connectionManager.start();
        }
    }

}

文章來源地址http://www.zghlxwxcb.cn/news/detail-596371.html

到了這里，關(guān)于Java WebSocket客戶端的文章就介紹完了。如果您還想了解更多內(nèi)容，請?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！