【发布时间】:2019-09-21 05:15:20
【问题描述】:
我正在使用 Glassfish 服务器来托管使用 javax.websocket 的基本 Web Socket 服务器。
这是服务器代码:
import javax.websocket.*;
import javax.websocket.server.ServerEndpoint;
import java.io.IOException;
@ServerEndpoint("/websocket/server")
public class WebSocketServer {
@OnOpen
public void onOpen(Session session) {
System.out.println(String.format("Connection Established::%s", session.getId()));
RemoteEndpoint.Basic remoteEndpoint = session.getBasicRemote();
session.addMessageHandler(new ServerMessageHandler(remoteEndpoint));
}
@OnClose
public void onClose(Session session) {
System.out.println(String.format("Connection closed::%s", session.getId()));
}
@OnError
public void onError(Throwable t) {
System.out.println(t.toString());
}
@OnMessage
public void onMessage(Session session, String message) {
System.out.println(String.format("Received message::%s - sessionId::%s", message, session.getId()));
}
private class ServerMessageHandler implements MessageHandler.Whole<String> {
private RemoteEndpoint.Basic _remoteEndpoint;
ServerMessageHandler(RemoteEndpoint.Basic remoteEndpoint) {
this._remoteEndpoint = remoteEndpoint;
}
public void onMessage(String message) {
try {
_remoteEndpoint.sendText(message);
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
这是运行服务器的控制台应用程序:
import org.glassfish.tyrus.server.Server;
import javax.websocket.DeploymentException;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
public class Main {
public static void main(String[] args) {
runServer();
}
private static void runServer() {
Server server = null;
try {
server = new Server("localhost", 8080, "/websocket", null, WebSocketServer.class);
BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
server.start();
System.out.println("Please press a key to stop the server.");
reader.readLine();
} catch (IOException e) {
throw new RuntimeException(e);
} catch (DeploymentException e) {
throw new RuntimeException(e);
} finally {
if (server != null) {
server.stop();
}
}
}
}
我的问题是,当我运行此控制台应用程序并运行 Websocket 服务器时,我可以测试我的端点以验证它是否正常工作甚至调试到服务器代码(onOpen、onClose 等)的最佳方法是什么。我试图使用 Postman 访问 ws:\localhost:8080\websocket\server,但这不起作用。我对 Web Sockets 完全陌生,因此由于缺乏技术经验和知识,我的想法可能是错误的。
谢谢。
【问题讨论】:
标签: java websocket glassfish endpoint