Java Websocket開(kāi)發(fā)指南：如何實(shí)現(xiàn)客戶端與伺服器端的即時(shí)通信，需要具體程式碼範(fàn)例

#隨著Web應(yīng)用程式的不斷發(fā)展，即時(shí)通訊已成為項(xiàng)目中必不可少的一部分。在傳統(tǒng)的HTTP協(xié)定中，客戶端會(huì)向伺服器發(fā)送請(qǐng)求，只有在收到回應(yīng)之後才能得到數(shù)據(jù)，這導(dǎo)致客戶端需要不斷地輪詢（polling）伺服器以獲取最新數(shù)據(jù)，這樣會(huì)導(dǎo)致效能和效率問(wèn)題。而WebSocket則是為了解決這些問(wèn)題而生的。

WebSocket是HTML5中的一種新協(xié)定。它能夠提供雙向通訊的功能，並且減少了客戶端輪詢的工作?？蛻舳丝梢灾苯酉蛩欧靼l(fā)送訊息，而無(wú)需等待伺服器的回應(yīng)。這使得開(kāi)發(fā)即時(shí)應(yīng)用變得更加容易和高效。

Java作為一種廣泛應(yīng)用於網(wǎng)頁(yè)應(yīng)用程式開(kāi)發(fā)的語(yǔ)言，也提供了輕鬆實(shí)現(xiàn)Websocket的方式。下面將介紹如何在Java中使用Websocket。

第一步，需要匯入Java的WebSocket API。你可以從Maven中央函式庫(kù)或使用Java EE 7框架中的javax.websocket套件中的API。

下面是使用Java EE 7中的javax.websocket套件中的API實(shí)作Websocket的範(fàn)例：

1. 建立ServerEndpoint註解類別

#使用@WebSocket標(biāo)註創(chuàng)建類，以便告訴Java伺服器這個(gè)類可以將這個(gè)會(huì)話作為一個(gè)WebSocket endpoint，並提供了URI，將這個(gè)地址和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程式的入口。在上面的範(fàn)例中，我們使用了@ServerEndpoint註解來(lái)配合Endpoint類，將類別對(duì)應(yīng)到指定的URI。

@OnOpen, @OnMessage和@OnClose註解是基於事件的，用於指定方法在WebSocket連接打開(kāi)，訊息接收和連接關(guān)閉時(shí)被呼叫。

所取得的訊息字串將會(huì)直接傳遞給onMessage回呼方法?，F(xiàn)在，我們已經(jīng)在WebSocket server端定義了endpoints。

2. 建立client端範(fàn)例

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來(lái)判斷客戶端是否連接到伺服器。

在onOpen()回呼方法中，我們已經(jīng)連接到了伺服器，並發(fā)送訊息。

注意：在這個(gè)範(fàn)例中，透過(guò)使用session.getBasicRemote().sendText(“Hello”); 方法發(fā)送訊息。在WebSocket API中，還有另一個(gè)用於發(fā)送訊息的方法，即session.getAsyncRemote().sendText("Hello");，區(qū)別在於getBasicRemote()的方式是阻塞的，而getAsyncRemote()的方式是非阻塞的。如果我們想非同步發(fā)送訊息，可以使用getAsyncRemote()。

3. 建立測(cè)試類並執(zhí)行應(yīng)用程式

建置測(cè)試類，為伺服器端和用戶端服務(wù)，確保連線的正常建立。你需要啟動(dòng)應(yīng)用程序，並讓正在運(yùn)行的應(yīng)用程式與WebSocket伺服器互動(dòng)。如果一切正常，應(yīng)該會(huì)看到一些訊息列印在開(kāi)發(fā)工具的控制臺(tái)上。

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();
    }
}

這個(gè)測(cè)試程式碼將啟動(dòng)WebSocket客戶端，並嘗試連線到localhost:8080上的WebSocket伺服器。我們將使用CountDownLatch物件等待成功的連線以及一些附加資訊。

執(zhí)行測(cè)試時(shí)，我們可以透過(guò)網(wǎng)頁(yè)瀏覽器鍵入http://localhost:8080/websocket並開(kāi)啟JavaScript控制臺(tái)，查看並透過(guò)JavaScript WebSocket物件向WebSocket用戶端傳送訊息。

總結(jié)：

使用WebSocket進(jìn)行即時(shí)通訊遠(yuǎn)比使用傳統(tǒng)的HTTP週期性輪詢來(lái)得更有效率。在Java語(yǔ)言中，你可以使用WebSocket API來(lái)實(shí)作Websocket。本文提供了一個(gè)WebSocket server和client的Java範(fàn)例程式以及具體的程式碼實(shí)作範(fàn)例，希望對(duì)讀者有幫助。

以上是Java Websocket開(kāi)發(fā)指南：如何實(shí)現(xiàn)客戶端與伺服器端的即時(shí)通訊的詳細(xì)內(nèi)容。更多資訊請(qǐng)關(guān)注PHP中文網(wǎng)其他相關(guān)文章！