如何接收来自Vert的websocket消息.x服务器的Javascript

我正在尝试创建一个http服务器，包括与Vert的websockets。使用Java编写客户端，而不使用vertex .js。我避免使用Vert。因为它应该保持基于浏览器的(像browserfy这样的工具没有成功地转换Vert的commonjs标准)。

在完成服务器和客户机的测试代码之后，我尝试了向服务器发送消息、获取其数据并使用任意响应进行应答的简单示例。服务器接收到消息并能够读取其内容。但是，客户机只接收到一条消息，而没有获得假定的内容。客户端无法将websocket接收到的事件数据转换为字符串(根本没有字符串数据?)使用indexof.js来确定事件数据的字节大小，在多次更改服务器发送的内容后，结果是34字节的恒定大小。我尝试在服务器端使用writeMessage以及write-method来将数据发送到客户机-websocket。结果保持不变。

为什么我的客户端只接收恒定大小的websocket数据，如何使其工作?

谢谢你的建议!

编辑:

用writeFrame代替write和writeMessage的方法。使用writeFrame可以发送二进制数据，也可以发送纯文本。以这种方式将文本从基于java的服务器发送到基于javascript的客户端可以正常工作。我仍然不知道如何在客户端处理二进制消息，但它仍然是有益的。虽然文本消息可以工作，但它们仍然具有相同的大小(34字节)。我认为收到的数据对象的大小会有所不同，但似乎，它只是一个对象，在某个地方指向实际数据。

------------------------------------------------

客户端代码是在Java servlet和websockets(成功)测试期间编写的:

var wsUri = "ws://" + document.location.host + document.location.pathname + "chat";
var websocket = new WebSocket(wsUri);
websocket.onerror = function(evt) { onError(evt) };
websocket.onopen = function (evt) { onOpen(evt) };
function onError (evt)
{
    debugMessage('<span style="color: red;">ERROR:</span> ' + evt.data);
}
function onOpen (evt)
{
//    debugMessage("Connected to " + wsUri);
    debugMessage("GOTCHA!");
}
websocket.onmessage = function (evt) { onMessage(evt) };
function onMessage (evt)
{
    debugMessage(evt.toString());
    debugMessage(evt.data.toString());
    debugMessage(sizeof(evt.data));
}
function sendMessage (msg)
{
    websocket.send(msg);
}
function sendDebugMessage ()
{
    websocket.send("Hiho Wursty!");
    debugMessage("Did send Wursty-message.");
}

服务器端是根据官方版本。x文档以及另一个在线教程:

server = vertx.createHttpServer();
server.requestHandler(request -> {
    handleRequest(request);
});
server.websocketHandler(ws -> {
    print("Websocket-handshake...");
    print("path = " + ws.path());
    print("uri = " + ws.uri());
    print("localAdress = " + ws.localAddress().toString());
    print("remoteAddress = " + ws.remoteAddress());
    print(ws.toString());
    if (!ws.path().equals("/chat")) {
        ws.reject();
    } else {
        SharedData sd = vertx.sharedData();
        LocalMap<String, String> wsChatSessions =
                sd.getLocalMap("ws.chat.sessions");
        wsChatSessions.put(ws.textHandlerID(), ws.toString());
        ws.closeHandler(ch -> {
            print("Closing ws-connection to client " + ws.textHandlerID());
            wsChatSessions.remove(ws.textHandlerID());
        });
        ws.handler(new Handler<Buffer>(){
            @Override
            public void handle(final Buffer data) {
                String msg = data.getString(0, data.length());
                print("Message from ws-client " + ws.textHandlerID() 
                        + ": " + msg);
                Buffer resp = Buffer.buffer();
                resp.appendString("O Ding Dong asd asda sdasd a"
                        + "asdasd asd asdasda sdas dasd adads asd as"
                        + "as dasd asd asd asd asdasd asdasdasd "
                        + "asdasd asd asd asd asd asda sdasd asd !");
                ws.writeMessage(resp);
                ws.write(resp);
            }
        });
    }
});
server.listen(port, res -> {
    if (res.succeeded()){
        print("Listening...");
    } else{
        print("Failed to bind! -> Server is not listening"
            + " to incoming client connections.");
    }
});

我只收到0字节大小的消息的原因相对简单:在Javascript-websocket中，可以定义websocket从服务器接收的(二进制)数据的类型，即binaryType。默认设置为"blob"。在我的例子中，我假设接收数组缓冲区。设置相应的选项使websocket按预期传递数据:

websocket.binaryType = "arraybuffer";

要使用它，仍然需要从arraybuffer创建一个数组。在我的例子中，我创建了一个无符号8位整数数组:

var dataBytes = new Uint8Array(evt.data);

相关内容

最新更新

热门标签：