以下是一个简单的Java实现WebSocket服务端的代码示例:
import javax.websocket.*;
import javax.websocket.server.ServerEndpoint;
@ServerEndpoint("/websocket")
public class WebSocketServer {
@OnOpen
public void onOpen(Session session) {
System.out.println("Client connected");
}
@OnMessage
public void onMessage(String message, Session session) {
System.out.println("Received message: " + message);
// 处理接收到的消息
// 向客户端发送消息
sendMessage(session, "Response from server");
}
@OnClose
public void onClose(Session session) {
System.out.println("Client disconnected");
}
@OnError
public void onError(Throwable error) {
System.out.println("Error occurred: " + error.getMessage());
}
private void sendMessage(Session session, String message) {
try {
session.getBasicRemote().sendText(message);
} catch (Exception e) {
e.printStackTrace();
}
}
}
这个示例使用了javax.websocket
包提供的注解和接口,通过@ServerEndpoint
注解来定义WebSocket服务端,并使用@OnOpen
、@OnMessage
、@OnClose
和@OnError
注解来定义对应的事件处理方法。你可以根据自己的需求在这些方法中编写相应的业务逻辑。
内容由零声教学AI助手提供,问题来源于学员提问