WebSocket是HTML5引入的一種新型協議，用於在客戶端和伺服器之間建立長連接。它與HTTP一樣可以在標準的Web連接埠上運行，也能穿越防火牆和代理伺服器，並且已經大量使用於即時通訊和推播通知等場景。
Java作為一門強大的程式語言，也提供了各種WebSocket相關的API和函式庫，本文將介紹如何使用Java開發Websocket應用程序，並提供具體的程式碼範例。
一、WebSocket API簡介
Java EE 7提供了JSR-356 Java API for WebSocket，該API包含了WebSocket的客戶端和伺服器端相關的介面。你可以使用Java EE 7的容器（如GlassFish、Tomcat等）或第三方函式庫（如Jetty、Tyrus等）來實作WebSocket功能。
Java WebSocket API的核心介面和類別如下：
- Session：表示WebSocket連線會話，透過它可以傳送和接收訊息。
- Endpoint：表示WebSocket的端點，實作了WebSocket的核心邏輯，包括連線、訊息傳輸、錯誤處理等。
- MessageHandler：表示WebSocket的訊息處理器，用於接收和處理各種類型的訊息。
使用Java WebSocket API可以很方便地實作WebSocket應用程序，接下來我們將介紹具體範例。
二、WebSocket應用程式範例
本文將從以下幾個面向介紹WebSocket應用程式的實作：
- 伺服器端的WebSocket端點實作
- 客戶端的WebSocket實作
- 伺服器端廣播訊息的實作
#2.1 伺服器端的WebSocket端點實作
在伺服器端實作WebSocket應用程序，我們需要建立一個WebSocket端點。簡單的端點程式碼如下：
import javax.websocket.OnMessage;
import javax.websocket.Session;
import javax.websocket.server.ServerEndpoint;
import java.io.IOException;
@ServerEndpoint(value = "/chat")
public class ChatEndpoint {
@OnMessage
public void onMessage(Session session, String message) throws IOException {
// 处理收到的消息
session.getBasicRemote().sendText("You said: " + message);
}
}登入後複製
透過@ServerEndpoint註解指定端點的URI路徑，這裡是"/chat"。在端點中，實作了@OnMessage註解，用於接收和處理客戶端發送的訊息。在該方法中，我們可以對接收到的訊息進行處理，並給客戶端發送回應訊息。
2.2 客戶端的WebSocket實作
客戶端透過Java實作WebSocket可以使用javax.websocket客戶端API，以下給出一個簡單的Java WebSocket客戶端範例：
import javax.websocket.ClientEndpoint;
import javax.websocket.OnMessage;
import javax.websocket.Session;
import java.net.URI;
import java.net.URISyntaxException;
import java.util.concurrent.CountDownLatch;
@ClientEndpoint
public class ChatClientEndpoint {
private CountDownLatch latch;
public ChatClientEndpoint(CountDownLatch latch) {
this.latch = latch;
}
@OnMessage
public void onMessage(Session session, String message) {
System.out.println("Received message: " + message);
latch.countDown();
}
public static void main(String[] args) throws Exception {
final int messageCount = 5;
final CountDownLatch latch = new CountDownLatch(messageCount);
URI uri = new URI("ws://localhost:8080/chat");
ChatClientEndpoint client = new ChatClientEndpoint(latch);
WebSocketContainer container = ContainerProvider.getWebSocketContainer();
container.connectToServer(client, uri);
for (int i = 0; i < messageCount; i++) {
String message = "Hello " + i;
client.sendMessage(message);
System.out.println("Sent message: " + message);
}
latch.await();
container.close();
}
public void sendMessage(String message) {
try {
session.getBasicRemote().sendText(message);
} catch (IOException e) {
e.printStackTrace();
}
}
}登入後複製
在客戶端程式碼中，我們使用@ClientEndpoint來註解標記客戶端的WebSocket端點。在main方法中，我們使用WebSocketContainer連接到伺服器端，並傳送5個訊息。當接收到伺服器端回應後，會呼叫onMessage方法進行處理，同時藉助CountDownLatch實作程式的同步等待。
2.3 伺服器端廣播訊息的實作
WebSocket應用程式中，有時需要伺服器端向所有用戶端廣播訊息。以下是一個簡單的範例：
import javax.websocket.OnMessage;
import javax.websocket.Session;
import javax.websocket.server.ServerEndpoint;
import java.util.Collections;
import java.util.HashSet;
import java.util.Set;
@ServerEndpoint(value = "/chat")
public class ChatEndpoint {
private static Set<Session> sessions = Collections.synchronizedSet(new HashSet<Session>());
@OnMessage
public void onMessage(Session session, String message) throws IOException {
// 处理收到的消息
broadcast("User " + session.getId() + " said: " + message);
}
private void broadcast(String message) throws IOException {
for (Session session : sessions) {
if (session.isOpen()) {
session.getBasicRemote().sendText(message);
}
}
}
@OnOpen
public void onOpen(Session session) {
sessions.add(session);
}
@OnClose
public void onClose(Session session) {
sessions.remove(session);
}
}登入後複製
在該程式碼中，我們維護了所有WebSocket會話的清單sessions，在@OnOpen方法中新增新的會話，@OnClose方法中移除會話。同時，在broadcast方法中向所有WebSocket會話發送廣播訊息。
三、總結
WebSocket是一種非常強大的新型協議，可以讓程式建立即時通訊和即時推送功能。 Java對WebSocket也提供了豐富的API和函式庫支援。本文介紹如何使用Java開發WebSocket應用程序，並給出了具體的程式碼範例。希望本文能對Java開發WebSocket應用程式有所幫助。
以上是如何使用Java開發Websocket應用程式的詳細內容。更多資訊請關注PHP中文網其他相關文章！
