Java Websocket開發(fā)指南：如何實現(xiàn)客戶端與服務(wù)器端的實時通信，需要具體代碼示例

隨著Web應(yīng)用程序的不斷發(fā)展，實時通信已成為項目中必不可少的一部分。在傳統(tǒng)的HTTP協(xié)議中，客戶端向服務(wù)器發(fā)送請求，只有在收到響應(yīng)之后才能得到數(shù)據(jù)，這導致客戶端需要不斷地輪詢（polling）服務(wù)器以獲取最新數(shù)據(jù)，這樣會導致性能和效率問題。而WebSocket則是為了解決這些問題而生的。

WebSocket是HTML5中的一種新協(xié)議。它能夠提供雙向通信的功能，并且減少了客戶端輪詢的工作?？蛻舳丝梢灾苯酉蚍?wù)器發(fā)送消息，而無需等待服務(wù)器的響應(yīng)。這使得開發(fā)實時應(yīng)用變得更加容易和高效。

Java作為一種廣泛應(yīng)用于Web應(yīng)用程序開發(fā)的語言，也提供了輕松實現(xiàn)Websocket的方式。下面將介紹如何在Java中使用Websocket。

立即學習“Java免費學習筆記（深入）”；

第一步，需要導入Java的WebSocket API。你可以從Maven中央庫或者使用Java EE 7框架中的javax.websocket包中的API。

下面是一個使用Java EE 7中的javax.websocket包中的API實現(xiàn)Websocket的示例：

1. 創(chuàng)建ServerEndpoint注釋類

使用@WebSocket標注創(chuàng)建類，以便告訴Java服務(wù)器這個類可以將這個會話作為一個WebSocket endpoint，并提供了URI，將這個地址和WebSocket endpoint相匹配。

import javax.websocket.*;
import javax.websocket.server.ServerEndpoint;
 
@ServerEndpoint(value = "/websocket")
public class WebSocketExample {
     
    @OnOpen
    public void onOpen(){
        System.out.println("Connection opened");
    }
     
    @OnClose
    public void onClose(){
        System.out.println("Connection closed");
    }
     
    @OnMessage
    public void onMessage(String message){
        System.out.println("Message received: " + message);
    }
}

使用WebSocketExample類作為我們WebSocket程序的入口。在上面的例子中，我們使用了@ServerEndpoint注釋配合Endpoint類，將類映射到指定的URI。

@OnOpen, @OnMessage和@OnClose注釋是基于事件的，用于指定方法在WebSocket連接打開，消息接收和連接關(guān)閉時被調(diào)用。

獲取的消息字符串將被直接傳遞給onMessage回調(diào)方法。現(xiàn)在，我們已經(jīng)在WebSocket server端定義了endpoints。

2. 創(chuàng)建client端示例

public class WebSocketClientExample extends Endpoint {
 
    public static CountDownLatch latch;
 
    @Override
    public void onOpen(final Session session, EndpointConfig config) {
        System.out.println("Connected");
 
        try {
            session.getBasicRemote().sendText("Hello");
        } catch (IOException ex) {
        }
    }
 
    @Override
    public void onError(final Session session, Throwable t) {
        t.printStackTrace();
    }
}

我們的WebSocket客戶端可以使用javax.websocket.Endpoint作為基類，這是WebSocket API的一部分。

我們將使用CountDownLatch來判斷客戶端是否連接到服務(wù)器。

在onOpen()回調(diào)方法中，我們已經(jīng)連接到了服務(wù)器，并發(fā)送消息。

注意：在這個示例中，通過使用session.getBasicRemote().sendText(“Hello”); 方法發(fā)送消息。在WebSocket API中，還有另一個用于發(fā)送消息的方法，即session.getAsyncRemote().sendText("Hello");，區(qū)別在于getBasicRemote()的方式是阻塞的，而getAsyncRemote()的方式是非阻塞的。如果我們想異步發(fā)送消息，可以使用getAsyncRemote()。

3. 創(chuàng)建測試類并運行應(yīng)用程序

構(gòu)建測試類，為服務(wù)器端和客戶端服務(wù)，確保連接的正常建立。你需要啟動應(yīng)用程序，并讓正在運行的應(yīng)用程序與WebSocket服務(wù)器交互。如果一切正常，應(yīng)該看到一些消息打印在開發(fā)工具的控制臺上。

import javax.websocket.*;
import java.net.URI;
import java.util.concurrent.CountDownLatch;
 
public class AppRunner {
 
    public static void main(String[] args) throws Exception {
        WebSocketContainer container = ContainerProvider.getWebSocketContainer();
 
        CountDownLatch latch = new CountDownLatch(1);
 
        container.connectToServer(new WebSocketExample(), new URI("ws://localhost:8080/websocket"));
 
        latch.await();
    }
}

這個測試代碼將啟動WebSocket客戶端，并嘗試連接到localhost:8080上的WebSocket服務(wù)器。我們將使用CountDownLatch對象等待成功的連接以及一些附加信息。

運行測試時，我們可以通過Web瀏覽器鍵入http://localhost:8080/websocket并打開JavaScript控制臺，查看并通過JavaScript WebSocket對象向WebSocket客戶端發(fā)送消息。

總結(jié)：

使用WebSocket進行實時通信遠比使用傳統(tǒng)的HTTP周期性輪詢來得更高效。在Java語言中，你可以使用WebSocket API來實現(xiàn)Websocket。本文提供了一個WebSocket server和client的Java示例程序以及具體的代碼實現(xiàn)示例，希望對讀者有所幫助。

以上就是Java Websocket開發(fā)指南：如何實現(xiàn)客戶端與服務(wù)器端的實時通信的詳細內(nèi)容，更多請關(guān)注php中文網(wǎng)其它相關(guān)文章！