java实现websocket实时推送数据
时间: 2023-08-11 11:57:27 浏览: 139
要实现Java中的WebSocket实时推送数据,可以使用Java WebSocket API,以下是一个简单的示例:
1. 创建一个WebSocket服务器类:
```java
import javax.websocket.*;
import javax.websocket.server.ServerEndpoint;
@ServerEndpoint("/websocket")
public class WebSocketServer {
@OnOpen
public void onOpen(Session session) {
// 连接建立时触发
System.out.println("WebSocket连接已建立");
}
@OnMessage
public void onMessage(String message, Session session) {
// 接收到客户端消息时触发
System.out.println("收到消息:" + message);
}
@OnClose
public void onClose(Session session, CloseReason reason) {
// 连接关闭时触发
System.out.println("WebSocket连接已关闭");
}
@OnError
public void onError(Session session, Throwable throwable) {
// 发生错误时触发
System.out.println("WebSocket发生错误");
}
}
```
2. 配置WebSocket容器,例如使用Tomcat作为容器,在web.xml文件中添加以下配置:
```xml
<websocket-endpoint>
<endpoint-class>your.package.name.WebSocketServer</endpoint-class>
</websocket-endpoint>
```
3. 创建一个WebSocket客户端类:
```java
import javax.websocket.*;
import java.net.URI;
@ClientEndpoint
public class WebSocketClient {
@OnOpen
public void onOpen(Session session) {
// 连接建立时触发
System.out.println("WebSocket连接已建立");
}
@OnMessage
public void onMessage(String message, Session session) {
// 接收到服务器消息时触发
System
阅读全文