Jetty开发指导:WebSocket介绍
时间: 2024-05-06 19:16:00 浏览: 12
WebSocket 是一种在单个 TCP 连接上进行全双工通信的协议。它使得浏览器和服务器之间的数据交换变得更加简单,更快速,更实时。
在传统的 HTTP 协议中,客户端发送请求到服务器后,服务器会响应一个完整的 HTML 页面或者一个数据 JSON,这种请求响应模式被称为“请求-响应模式”。
而 WebSocket 通过建立一条长连接,使得浏览器和服务器之间可以进行双向实时通信。客户端可以向服务器发送数据,服务器也可以主动向客户端发送数据,这种通信模式被称为“推送模式”。
Jetty 对 WebSocket 的支持非常好,它提供了完整的 WebSocket API,可以方便地实现 WebSocket 服务器和客户端。下面是一个简单的示例:
```java
import org.eclipse.jetty.server.Server;
import org.eclipse.jetty.websocket.api.Session;
import org.eclipse.jetty.websocket.api.annotations.*;
import org.eclipse.jetty.websocket.server.WebSocketHandler;
import org.eclipse.jetty.websocket.servlet.WebSocketServletFactory;
@WebSocket
public class MyWebSocketHandler {
@OnWebSocketConnect
public void onConnect(Session session) throws Exception {
System.out.println("Connected: " + session.getRemoteAddress().getHostName());
session.getRemote().sendString("Hello, world!");
}
@OnWebSocketClose
public void onClose(int statusCode, String reason) {
System.out.println("Closed: " + statusCode + ", " + reason);
}
@OnWebSocketMessage
public void onMessage(String message) {
System.out.println("Message received: " + message);
}
public static void main(String[] args) throws Exception {
Server server = new Server(8080);
WebSocketHandler wsHandler = new WebSocketHandler() {
@Override
public void configure(WebSocketServletFactory factory) {
factory.register(MyWebSocketHandler.class);
}
};
server.setHandler(wsHandler);
server.start();
server.join();
}
}
```
在这个示例中,我们定义了一个 WebSocket 处理器 `MyWebSocketHandler`,并通过 `@WebSocket` 注解标记了它。在 `onConnect` 方法中,我们打印了客户端的连接地址,并向客户端发送了一条消息。在 `onClose` 方法中,我们打印了客户端关闭连接的状态码和原因。在 `onMessage` 方法中,我们打印了客户端发送过来的消息。
最后,在 `main` 方法中,我们创建了一个 Jetty 服务器,并将 WebSocket 处理器注册到了 `WebSocketServletFactory` 中,然后启动了服务器。这样,当有客户端连接到服务器时,就会自动调用 `MyWebSocketHandler` 中对应的方法进行处理。
除了使用注解的方式,Jetty 还提供了一种基于接口的方式来实现 WebSocket 处理器,具体可以参考 Jetty 的官方文档。