Websocket协议从版本8开始完全改变。现在从浏览器传入的消息是一种非常不同的格式,对我来说真的很复杂。
0 1 2 3
0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1
+-+-+-+-+-------+-+-------------+-------------------------------+
|F|R|R|R| opcode|M| Payload len | Extended payload length |
|I|S|S|S| (4) |A| (7) | (16/64) |
|N|V|V|V| |S| | (if payload len==126/127) |
| |1|2|3| |K| | |
+-+-+-+-+-------+-+-------------+ - - - - - - - - - - - - - - - +
| Extended payload length continued, if payload len == 127 |
+ - - - - - - - - - - - - - - - +-------------------------------+
| |Masking-key, if MASK set to 1 |
+-------------------------------+-------------------------------+
| Masking-key (continued) | Payload Data |
+-------------------------------- - - - - - - - - - - - - - - - +
: Payload Data continued ... :
+ - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - +
| Payload Data continued ... |
+---------------------------------------------------------------+
以下是我从https://datatracker.ietf.org/doc/html/draft-ietf-hybi-thewebsocketprotocol-17
找到的内容有人知道如何在c++或c#中实现服务器端读取吗?或者你有一个链接到一个已经工作的例子?
我知道这个服务器是正确的,但我需要一个代码:http://websocket.org/echo.html
这里有一个很棒的c++ WebSocket库,它支持hybi-17(最新版本),它的头文件只使用boost。它带有示例代码和文档:http://vinniefalco.github.io/
下面是一个向echo服务器发送消息的完整程序:
#include <beast/websocket.hpp>
#include <beast/buffers_debug.hpp>
#include <boost/asio.hpp>
#include <iostream>
#include <string>
int main()
{
// Normal boost::asio setup
std::string const host = "echo.websocket.org";
boost::asio::io_service ios;
boost::asio::ip::tcp::resolver r(ios);
boost::asio::ip::tcp::socket sock(ios);
boost::asio::connect(sock,
r.resolve(boost::asio::ip::tcp::resolver::query{host, "80"}));
using namespace beast::websocket;
// WebSocket connect and send message using beast
stream<boost::asio::ip::tcp::socket&> ws(sock);
ws.handshake(host, "/");
ws.write(boost::asio::buffer("Hello, world!"));
// Receive WebSocket message, print and close using beast
beast::streambuf sb;
opcode op;
ws.read(op, sb);
ws.close(close_code::normal);
std::cout <<
beast::debug::buffers_to_string(sb.data()) << "n";
}
我写了一个c++服务器。关于如何读取hybi-17消息,请参见WsProtocol80::Read()
。请注意,服务器使用自定义字符串和套接字类,因此重用将是非常重要的,但您应该能够轻松地跟踪正在读取/写入的数据。
对于代码的特定部分,请随意提问。
这个wiki帖子可能你也感兴趣。