import javax.websocket.OnMessage;
import javax.websocket.Session;
import javax.websocket.server.ServerEndpoint;
import java.io.IOException;
// 定义一个WebSocket服务器端点,路径为"/websocket"
@ServerEndpoint("/websocket")
public class WebSocketServer {
// 当客户端发送消息时触发此方法
@OnMessage
public void onMessage(String message, Session session) {
System.out.println("Received message: " + message);
// 回复客户端消息
try {
session.getBasicRemote().sendText("Echo: " + message);
} catch (IOException e) {
e.printStackTrace();
}
}
}
@ServerEndpoint("/websocket"):这是一个注解,用于定义一个WebSocket服务器端点。路径为/websocket,表示客户端可以通过这个路径连接到服务器。
@OnMessage:当客户端通过WebSocket发送消息时,会触发这个方法。参数String message是接收到的消息内容,Session session表示与客户端的会话。
session.getBasicRemote().sendText():用于向客户端发送文本消息。这里我们简单地将客户端发送的消息加上前缀"Echo: "再发回给客户端。
异常处理:如果发送消息时发生IO异常,我们会捕获并打印堆栈信息。
这个示例展示了如何创建一个简单的Java WebSocket服务器端点,并处理来自客户端的消息。
上一篇:java list转数组
下一篇:java int转string
Laravel PHP 深圳智简公司。版权所有©2023-2043 LaravelPHP 粤ICP备2021048745号-3
Laravel 中文站