- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我正在尝试创建类似node-websockify的东西,它基本上是一个简单的代理服务器,用于将数据从novnc服务器传输到novnc客户端,我正在使用提到的here方法
我在将 ByteBuffer 发送到远程客户端时发生奇怪的错误。正如之前所说,客户端是一个 noVNC 客户端,node-websockify 和 tightvnc 完美运行
import org.eclipse.jetty.websocket.server.WebSocketHandler;
org.eclipse.jetty.server.Server serverr = new org.eclipse.jetty.server.Server(8090);
WebSocketHandler wsh = new WebSockify();
serverr.setHandler(wsh);
serverr.start();
serverr.join();
import java.io.BufferedInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.Socket;
import java.net.URL;
import java.net.URLConnection;
import java.nio.ByteBuffer;
import org.eclipse.jetty.server.Request;
import org.eclipse.jetty.websocket.api.Session;
import org.eclipse.jetty.websocket.api.annotations.OnWebSocketConnect;
import org.eclipse.jetty.websocket.api.annotations.OnWebSocketError;
import org.eclipse.jetty.websocket.api.annotations.OnWebSocketFrame;
import org.eclipse.jetty.websocket.api.annotations.WebSocket;
import org.eclipse.jetty.websocket.api.extensions.Frame;
import org.eclipse.jetty.websocket.client.WebSocketClient;
import org.eclipse.jetty.websocket.server.WebSocketHandler;
import org.eclipse.jetty.websocket.servlet.WebSocketServletFactory;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
@WebSocket
public class WebSockify extends WebSocketHandler {
private static String authorizationHeader = "";
Socket vncSocket;
int vncPort = 5900;
String vncPassword = "1234560";
@Override
public void configure(WebSocketServletFactory webSocketServletFactory) {
webSocketServletFactory.register(WebSockify.class);
}
public void handle(String target, Request baseRequest, HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException {
System.out.println("Received handle " + target);
try {
if (this.getWebSocketFactory().isUpgradeRequest(request, response)) {
System.out.println("Adding header");
response.addHeader("Sec-WebSocket-Protocol", "binary");
if (this.getWebSocketFactory().acceptWebSocket(request, response)) {
System.out.println("websocket accepted");
baseRequest.setHandled(true);
return;
}
System.out.println("websocket not accepted");
if (response.isCommitted()) {
System.out.println("response commited.");
return;
}
}
} catch (Exception e) {
System.err.println(e.getMessage());
} finally {
super.handle(target, baseRequest, request, response);
}
}
@OnWebSocketConnect
public void onConnect(final Session session) throws IOException, InterruptedException {
System.out.println("Connect: " + session.getRemoteAddress().getAddress());
System.out.println(session.getUpgradeRequest().getRequestURI());
System.out.println("session open ? " + session.isOpen());
vncSocket = new Socket("127.0.0.1", vncPort);
Thread readThread = new Thread(new Runnable() {
public void run() {
try {
System.out.println("session open ? " + session.isOpen());
byte[] b = new byte[1500];
int readBytes;
while (true) {
readBytes = vncSocket.getInputStream().read(b);
System.out.println("session open ? " + session.isOpen());
System.out.println("read bytes " + readBytes + ", " + new String(b));
if (readBytes == -1) {
break;
}
if (readBytes > 0) {
System.out.println("session open ? " + session.isOpen());
ByteBuffer bb = ByteBuffer.wrap(b, 0, readBytes);
session.getRemote().sendBytes(bb);
}
}
} catch (IOException e) {
e.printStackTrace();
System.err.println(e);
}
}
});
readThread.start();
}
@OnWebSocketFrame
public void onFrame(Frame f) throws IOException {
System.out.printf("Frame: %d\n", f.getPayloadLength());
byte[] data = new byte[f.getPayloadLength()];
f.getPayload().get(data);
vncSocket.getOutputStream().write(data);
}
@OnWebSocketError
public void onError(Throwable cause) {
System.err.println(cause.getMessage());
}
}
错误和控制台输出是
session 开放?正确
线程“Thread-8”org.eclipse.jetty.websocket.api.WebSocketException 中出现异常:RemoteEndpoint 不可用,当前状态 [CLOSED],期待 [OPEN 或 CONNECTED] 在 org.eclipse.jetty.websocket.common.WebSocketSession.getRemote(WebSocketSession.java:308) 在 com.hossein.main.WebSockify$1.run(WebSockify.java:91) 在 java.lang.Thread.run(来源未知)
看起来 session.open()
返回 true,但下一行 session.getRemote().sendBytes()
会导致错误。你能帮我找出原因吗?
发现了一些东西,当我在线程内使用 session 时会出现问题,我的意思是如果我不创建新线程session.getRemote().sendBytes()
工作正常。
最佳答案
与线程无关,实际上是客户端和服务器之间握手错误造成的
public void handle(String target, Request baseRequest, HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException {
System.out.println("Received handle " + target);
try {
if (this.getWebSocketFactory().isUpgradeRequest(request, response)) {
System.out.println("Adding header");
// NO NEED, the client already put this header in the request
//so no need to be added again
//response.addHeader("Sec-WebSocket-Protocol", "binary");
if (this.getWebSocketFactory().acceptWebSocket(request, response)) {
System.out.println("websocket accepted");
baseRequest.setHandled(true);
return;
}
System.out.println("websocket not accepted");
if (response.isCommitted()) {
System.out.println("response commited.");
return;
}
}
} catch (Exception e) {
System.err.println(e.getMessage());
} finally {
// has to be removed, because this cause an Upgrade header to be added with is already existed and causes .
//super.handle(target, baseRequest, request, response);
}
}
关于java - WebSocket RemoteEndpoint 不可用将数据发送回客户端的问题,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/62403293/
如何检测当前网络中计算机是否已连接/可用。 当然,它有多种用途,但我主要关心的是我的应用程序使用位于特定计算机中的资源,如果这些资源不可用,它甚至不会尝试连接,而是使用本地资源。 最佳答案 您可以尝试
雅虎建议load scripts at the bottom of an HTML pages出于性能原因。我使用遵守规则的 HTML5 Boilerplate。 这种方法的问题是 jQuery 也是
我有一个场景,我需要只向管理员而不是普通用户展示一个组件。 说, // This component should be rendered for public users.
我有一个数组,比方说 ["a","b","c"],我想把它变成一个对象,它以数组值作为键和一个默认值我可以设置。因此,如果默认值为 true,我希望我的输出为 {a:true, b:true, c:t
我假设在函数中创建一个新的 PS-Drive 会使该驱动器只能在该函数中访问。 如何通过从该函数可访问的 MAIN 调用函数来创建 PS 驱动器? $temproraryPSDriveName =
您会推荐哪些 .net 控制库作为企业必备的? 可以免费/非免费 至少应该包含一个真正强大的Datagrid Ajax 功能 有没有可用的比较? 最佳答案 我用过 Telerik ASP.NET控制之
假设我有一些像这样的 html: Hello World Javascript代码: var fooBar = document.getElementById('fooBar'); fooBar.
开始实现 camera plugin 时出现以下错误在我的 flutter 应用程序上: [VERBOSE-2:dart_error.cc(16)] Unhandled exception:
我想知道应该在哪里正确放置 countA,因为我希望将计数添加到所做的每个按钮中。开头的“count”变量用于制作新按钮,“countA”是我试图声明的计数,但它无法编译。这是我的代码片段:我的问题再
在python帮助文档中我经常看到带有函数名和命名参数的签名行,然后你会看到**kwarg(关键字参数)。 list? 打印到帮助文档字符串: Init signature: list(self, /
我是 UWP 的新手,想知道“Flyout”、“ContextFlyout”和“Popup”之间的区别。另外,我想知道“AppBar”和“CommandBar”之间的区别。我相信这些是容纳菜单或菜单项
我想显示可用的 Wifi 设备列表。这是我的代码,我不明白这里有什么错误: wifi = (WifiManager) getSystemService(Context.WIFI_SERVICE); i
这是我的代码: Random = function(name) { this.name = name; this.addSomething = function(a, b) {
我希望我的按钮持续动画直到用户触摸它,这是代码 func animate() { UIView.animateWithDuration(1, animations: { () -> Void
我正在为我正在参加的类(class)制作一个 HTTP 服务器作为项目,一周来我一直在尝试寻找解决方案。我有一个 DataInputStream,我需要等待客户端向我发送 http 请求,由于连接保持
我想创建一个 bash 脚本来检查我的 Linux 服务器中的哪些端口已关闭且未在特定范围(端口范围 (3000-3010))中使用。 打印输出只需1个端口,如果将输出保存为变量或保存在同一个文件中,
我写了一个我认为是最小的自定义设备来测试我对 QOM 和 QEMU 的总体理解。以下是省略注释的相关代码。不幸的是,当我启动 guest 并将我的设备名称作为命令行参数传递时,它无法找到我的设备并退出
调用Opencv函数时,通常会提供一个常量给函数调用,如: im_hsv = cv2.cvtColor(im, cv2.COLOR_BGR2HSV) 虽然我找不到对所有可用常量的引用。 Opencv
C++ 于 1998 年正式标准化,但我们能在多久以前找到一个名为 string 的类,它看起来像 C++2003 中的 std::string预标准 C++ 实现? 我问是因为 CString 作为
是否有一个官方的(或可能没有)git 命令列表,--porcelain 选项可用?或者我应该在 the porcelain commands list 中手动查看它们中的每一个吗? ? 我已经设法用谷
我是一名优秀的程序员,十分优秀!