diff --git a/src/org/redkale/boot/NodeHttpServer.java b/src/org/redkale/boot/NodeHttpServer.java index 8404a875d..82b8efdfc 100644 --- a/src/org/redkale/boot/NodeHttpServer.java +++ b/src/org/redkale/boot/NodeHttpServer.java @@ -123,7 +123,9 @@ public class NodeHttpServer extends NodeServer { protected void loadHttpServlet(final AnyValue servletsConf, final ClassFilter filter) throws Exception { final StringBuilder sb = logger.isLoggable(Level.INFO) ? new StringBuilder() : null; - final String prefix = servletsConf == null ? "" : servletsConf.getValue("path", ""); + String prefix0 = servletsConf == null ? "" : servletsConf.getValue("path", ""); + if (!prefix0.isEmpty() && prefix0.charAt(prefix0.length() - 1) == '/') prefix0 = prefix0.substring(0, prefix0.length() - 1); + final String prefix = prefix0; final String threadName = "[" + Thread.currentThread().getName() + "] "; List> list = new ArrayList(filter.getFilterEntrys()); list.sort((FilterEntry o1, FilterEntry o2) -> { //必须保证WebSocketServlet优先加载, 因为要确保其他的HttpServlet可以注入本地模式的WebSocketNode diff --git a/src/org/redkale/net/http/WebSocket.java b/src/org/redkale/net/http/WebSocket.java index cf7c15b06..0e5e92d11 100644 --- a/src/org/redkale/net/http/WebSocket.java +++ b/src/org/redkale/net/http/WebSocket.java @@ -518,6 +518,10 @@ public abstract class WebSocket { public void onClose(int code, String reason) { } + public long getLastSendTime() { + return this._runner == null ? 0 : this._runner.lastSendTime; + } + /** * 显式地关闭WebSocket */ diff --git a/src/org/redkale/net/http/WebSocketRunner.java b/src/org/redkale/net/http/WebSocketRunner.java index a9ecfbd96..a87a9a3bc 100644 --- a/src/org/redkale/net/http/WebSocketRunner.java +++ b/src/org/redkale/net/http/WebSocketRunner.java @@ -49,7 +49,7 @@ public class WebSocketRunner implements Runnable { private final boolean wsbinary; - private long lastSendTime; + protected long lastSendTime; public WebSocketRunner(Context context, WebSocket webSocket, AsyncConnection channel, final boolean wsbinary) { this.context = context;