{"id":1629,"date":"2018-08-31T19:36:50","date_gmt":"2018-08-31T11:36:50","guid":{"rendered":"https:\/\/damogame.cn:15443\/wordpress\/?p=1629"},"modified":"2018-08-31T19:36:50","modified_gmt":"2018-08-31T11:36:50","slug":"%e6%9c%8d%e5%8a%a1%e7%ab%af%e4%bd%bf%e7%94%a8c%e5%ae%9e%e7%8e%b0websocket%e5%8d%8f%e8%ae%ae%e8%a7%a3%e6%9e%90%e5%8f%8a%e9%80%9a%e4%bf%a1","status":"publish","type":"post","link":"https:\/\/i007.cc\/wordpress\/archives\/1629","title":{"rendered":"\u670d\u52a1\u7aef\u4f7f\u7528c++\u5b9e\u73b0websocket\u534f\u8bae\u89e3\u6790\u53ca\u901a\u4fe1"},"content":{"rendered":"
\n
\n
\n

\u670d\u52a1\u7aef\u4f7f\u7528c++\u5b9e\u73b0websocket\u534f\u8bae\u89e3\u6790\u53ca\u901a\u4fe1<\/h1>\n<\/div>\n
\n
2017\u5e7401\u670808\u65e5 16:30:54<\/span>\u00a0\u9605\u8bfb\u6570\uff1a20479<\/span>\u66f4\u591a<\/span><\/p>\n
\u4e2a\u4eba\u5206\u7c7b\uff1a<\/span>\u00a0c \/ c++<\/a><\/div>\n<\/div>\n
<\/div>\n<\/div>\n<\/div>\n<\/div>\n
\n
\n
\u7248\u6743\u58f0\u660e\uff1a\u672c\u6587\u4e3a\u535a\u4e3b\u539f\u521b\u6587\u7ae0\uff0c\u672a\u7ecf\u535a\u4e3b\u5141\u8bb8\u4e0d\u5f97\u8f6c\u8f7d\u3002 https:\/\/blog.csdn.net\/u013085897\/article\/details\/54234518<\/div>\n
\n

\u00a0 \u00a0 \u00a0 \u00a0WebSocket \u8bbe\u8ba1\u51fa\u6765\u7684\u76ee\u7684\u5c31\u662f\u8981\u4f7f\u5ba2\u6237\u7aef\u6d4f\u89c8\u5668\u5177\u5907\u50cf C\/S \u67b6\u6784\u4e0b\u684c\u9762\u7cfb\u7edf\u7684\u5b9e\u65f6\u901a\u8baf\u80fd\u529b\u3002 \u6d4f\u89c8\u5668\u901a\u8fc7 JavaScript \u5411\u670d\u52a1\u5668\u53d1\u51fa\u5efa\u7acb WebSocket \u8fde\u63a5\u7684\u8bf7\u6c42\uff0c\u8fde\u63a5\u5efa\u7acb\u4ee5\u540e\uff0c\u5ba2\u6237\u7aef\u548c\u670d\u52a1\u5668\u7aef\u5c31\u53ef\u4ee5\u901a\u8fc7 TCP \u8fde\u63a5\u76f4\u63a5\u4ea4\u6362\u6570\u636e\u3002\u56e0\u4e3a WebSocket \u8fde\u63a5\u672c\u8d28\u4e0a\u5c31\u662f\u4e00\u4e2a TCP \u8fde\u63a5\uff0c\u6240\u4ee5\u5728\u6570\u636e\u4f20\u8f93\u7684\u7a33\u5b9a\u6027\u548c\u6570\u636e\u4f20\u8f93\u91cf\u7684\u5927\u5c0f\u65b9\u9762\uff0c\u548c\u8f6e\u8be2\u4ee5\u53ca Comet \u6280\u672f\u6bd4\u8f83\uff0c\u5177\u6709\u5f88\u5927\u7684\u6027\u80fd\u4f18\u52bf\u3002\u4e0b\u9762\u662f\u4e00\u4e2a\u7b80\u5355 Web \u5e94\u7528\u5206\u522b\u7528\u8f6e\u8be2\u65b9\u5f0f\u548c WebSocket \u65b9\u5f0f\u6765\u5b9e\u73b0\uff0c\u4e0b\u9762\u662f\u6d4b\u8bd5\u7ed3\u679c\u56fe\uff1a<\/p>\n

\"\"<\/p>\n

\u00a0 \u00a0 \u00a0 \u00a0\u901a\u8fc7\u8fd9\u5f20\u56fe\u53ef\u4ee5\u6e05\u695a\u7684\u770b\u51fa\uff0c\u5728\u6d41\u91cf\u548c\u8d1f\u8f7d\u589e\u5927\u7684\u60c5\u51b5\u4e0b\uff0cWebSocket \u65b9\u6848\u76f8\u6bd4\u4f20\u7edf\u7684 Ajax \u8f6e\u8be2\u65b9\u6848\u6709\u6781\u5927\u7684\u6027\u80fd\u4f18\u52bf\u3002<\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0\u597d\u4e86\u4e0d\u8fc7\u591a\u4ecb\u7ecd\u00a0WebSocket\u00a0\u4e86\uff0c\u66f4\u591a\u4ecb\u7ecd\u5927\u5bb6\u53ef\u4ee5\u70b9\u51fb\u53c2\u8003\u8d44\u6599\u5f15\u7528\u7684\u94fe\u63a5\u67e5\u770b\uff0c\u8fd8\u662f\u56de\u5230\u89e3\u6790\u534f\u8bae\u53ca\u901a\u4fe1\u4e0a\u6765\u3002\u89e3\u6790\u534f\u8bae\u8fd9\u79cd\u4e8b\uff0c\u5c31\u5f97\u8010\u7740\u6027\u5b50\uff0c\u4e00\u4e2a\u5b57\u8282\u4e00\u4e2a\u5b57\u8282\u89e3\u6790\uff0c\u6309\u6b65\u9aa4\u4e00\u70b9\u4e00\u70b9\u5199\u7a0b\u5e8f\u3002\u4e0d\u8fc7\u8bfb\u61c2\u4e86\u6587\u6863\uff0c\u77e5\u9053\u4e86\u6bcf\u4e2a\u5b57\u8282\u7684\u5c5e\u6027\u610f\u4e49\u540e\uff0c\u89e3\u6790\u8d77\u6765\u8fd8\u662f\u633a\u7b80\u5355\u7684\u3002\u6309\u7167\u534f\u8bae\u8bf4\u660e\uff0c\u4e00\u65e6\u5b8c\u6210\u6570\u636e\u89e3\u7801\uff0c\u90a3\u4e48\u7f16\u7801\u5c31\u7a0d\u5fae\u5bb9\u6613\u4e00\u4e9b\uff0c\u5dee\u4e0d\u591a\u5c31\u662f\u89e3\u7801\u7684\u9006\u5411\u64cd\u4f5c\u4e86\u3002\u670d\u52a1\u7aef\u4f7f\u7528c++\u5b8c\u6210\u00a0WebSocket\u00a0\u901a\u4fe1\uff0c\u4e3b\u8981\u9700\u8981\u5b8c\u6210\u4ee5\u4e0b\u4e09\u65b9\u9762\u7f16\u7a0b\uff1a<\/div>\n

1.\u00a0\u670d\u52a1\u7aef\u4e0eh5\u5ba2\u6237\u7aef\u53d1\u8d77\u7684\u00a0WebSocket\u00a0\u8fde\u63a5\u63e1\u624b\uff1a<\/p>\n

<\/code><\/pre>\n
    \n
  1. \n
    \n
    <\/div>\n<\/div>\n
    \n
    int<\/span> wsHandshake<\/span>(string<\/span> &request, string<\/span> &response)<\/span><\/span><\/div>\n<\/div>\n<\/li>\n
  2. \n
    \n
    <\/div>\n<\/div>\n
    \n
    {<\/div>\n<\/div>\n<\/li>\n
  3. \n
    \n
    <\/div>\n<\/div>\n
    \n
    \/\/ \u89e3\u6790http\u8bf7\u6c42\u5934\u4fe1\u606f<\/span><\/div>\n<\/div>\n<\/li>\n
  4. \n
    \n
    <\/div>\n<\/div>\n
    \n
    int<\/span> ret = WS_STATUS_UNCONNECT;<\/div>\n<\/div>\n<\/li>\n
  5. \n
    \n
    <\/div>\n<\/div>\n
    \n
    std<\/span>::istringstream<\/span> stream<\/span>(request.c_str()<\/span>)<\/span>;<\/div>\n<\/div>\n<\/li>\n
  6. \n
    \n
    <\/div>\n<\/div>\n
    \n
    std<\/span>::string<\/span> reqType;<\/div>\n<\/div>\n<\/li>\n
  7. \n
    \n
    <\/div>\n<\/div>\n
    \n
    std<\/span>::getline(stream, reqType);<\/div>\n<\/div>\n<\/li>\n
  8. \n
    \n
    <\/div>\n<\/div>\n
    \n
    if<\/span> (reqType.substr(0<\/span>, 4<\/span>) != “GET “<\/span>)<\/div>\n<\/div>\n<\/li>\n
  9. \n
    \n
    <\/div>\n<\/div>\n
    \n
    {<\/div>\n<\/div>\n<\/li>\n
  10. \n
    \n
    <\/div>\n<\/div>\n
    \n
    return<\/span> ret;<\/div>\n<\/div>\n<\/li>\n
  11. \n
    \n
    <\/div>\n<\/div>\n
    \n
    }<\/div>\n<\/div>\n<\/li>\n
  12. \n
    \n
    <\/div>\n<\/div>\n
    \n
    <\/div>\n<\/div>\n<\/li>\n
  13. \n
    \n
    <\/div>\n<\/div>\n
    \n
    std<\/span>::string<\/span> header;<\/div>\n<\/div>\n<\/li>\n
  14. \n
    \n
    <\/div>\n<\/div>\n
    \n
    std<\/span>::string<\/span>::size_type pos = 0<\/span>;<\/div>\n<\/div>\n<\/li>\n
  15. \n
    \n
    <\/div>\n<\/div>\n
    \n
    std<\/span>::string<\/span> websocketKey;<\/div>\n<\/div>\n<\/li>\n
  16. \n
    \n
    <\/div>\n<\/div>\n
    \n
    while<\/span> (std<\/span>::getline(stream, header) && header != “\\r”<\/span>)<\/div>\n<\/div>\n<\/li>\n
  17. \n
    \n
    <\/div>\n<\/div>\n
    \n
    {<\/div>\n<\/div>\n<\/li>\n
  18. \n
    \n
    <\/div>\n<\/div>\n
    \n
    header.erase(header.end() – 1<\/span>);<\/div>\n<\/div>\n<\/li>\n
  19. \n
    \n
    <\/div>\n<\/div>\n
    \n
    pos = header.find(“: “<\/span>, 0<\/span>);<\/div>\n<\/div>\n<\/li>\n
  20. \n
    \n
    <\/div>\n<\/div>\n
    \n
    if<\/span> (pos != std<\/span>::string<\/span>::npos)<\/div>\n<\/div>\n<\/li>\n
  21. \n
    \n
    <\/div>\n<\/div>\n
    \n
    {<\/div>\n<\/div>\n<\/li>\n
  22. \n
    \n
    <\/div>\n<\/div>\n
    \n
    std<\/span>::string<\/span> key = header.substr(0<\/span>, pos);<\/div>\n<\/div>\n<\/li>\n
  23. \n
    \n
    <\/div>\n<\/div>\n
    \n
    std<\/span>::string<\/span> value = header.substr(pos + 2<\/span>);<\/div>\n<\/div>\n<\/li>\n
  24. \n
    \n
    <\/div>\n<\/div>\n
    \n
    if<\/span> (key == “Sec-WebSocket-Key”<\/span>)<\/div>\n<\/div>\n<\/li>\n
  25. \n
    \n
    <\/div>\n<\/div>\n
    \n
    {<\/div>\n<\/div>\n<\/li>\n
  26. \n
    \n
    <\/div>\n<\/div>\n
    \n
    ret = WS_STATUS_CONNECT;<\/div>\n<\/div>\n<\/li>\n
  27. \n
    \n
    <\/div>\n<\/div>\n
    \n
    websocketKey = value;<\/div>\n<\/div>\n<\/li>\n
  28. \n
    \n
    <\/div>\n<\/div>\n
    \n
    break<\/span>;<\/div>\n<\/div>\n<\/li>\n
  29. \n
    \n
    <\/div>\n<\/div>\n
    \n
    }<\/div>\n<\/div>\n<\/li>\n
  30. \n
    \n
    <\/div>\n<\/div>\n
    \n
    }<\/div>\n<\/div>\n<\/li>\n
  31. \n
    \n
    <\/div>\n<\/div>\n
    \n
    }<\/div>\n<\/div>\n<\/li>\n
  32. \n
    \n
    <\/div>\n<\/div>\n
    \n
    <\/div>\n<\/div>\n<\/li>\n
  33. \n
    \n
    <\/div>\n<\/div>\n
    \n
    if<\/span> (ret != WS_STATUS_CONNECT)<\/div>\n<\/div>\n<\/li>\n
  34. \n
    \n
    <\/div>\n<\/div>\n
    \n
    {<\/div>\n<\/div>\n<\/li>\n
  35. \n
    \n
    <\/div>\n<\/div>\n
    \n
    return<\/span> ret;<\/div>\n<\/div>\n<\/li>\n
  36. \n
    \n
    <\/div>\n<\/div>\n
    \n
    }<\/div>\n<\/div>\n<\/li>\n
  37. \n
    \n
    <\/div>\n<\/div>\n
    \n
    <\/div>\n<\/div>\n<\/li>\n
  38. \n
    \n
    <\/div>\n<\/div>\n
    \n
    \/\/ \u586b\u5145http\u54cd\u5e94\u5934\u4fe1\u606f<\/span><\/div>\n<\/div>\n<\/li>\n
  39. \n
    \n
    <\/div>\n<\/div>\n
    \n
    response = “HTTP\/1.1 101 Switching Protocols\\r\\n”<\/span>;<\/div>\n<\/div>\n<\/li>\n
  40. \n
    \n
    <\/div>\n<\/div>\n
    \n
    response += “Upgrade: websocket\\r\\n”<\/span>;<\/div>\n<\/div>\n<\/li>\n
  41. \n
    \n
    <\/div>\n<\/div>\n
    \n
    response += “Connection: upgrade\\r\\n”<\/span>;<\/div>\n<\/div>\n<\/li>\n
  42. \n
    \n
    <\/div>\n<\/div>\n
    \n
    response += “Sec-WebSocket-Accept: “<\/span>;<\/div>\n<\/div>\n<\/li>\n
  43. \n
    \n
    <\/div>\n<\/div>\n
    \n
    <\/div>\n<\/div>\n<\/li>\n
  44. \n
    \n
    <\/div>\n<\/div>\n
    \n
    const<\/span> std<\/span>::string<\/span> magicKey<\/span>(“258EAFA5-E914-47DA-95CA-C5AB0DC85B11”<\/span>)<\/span><\/span>;<\/div>\n<\/div>\n<\/li>\n
  45. \n
    \n
    <\/div>\n<\/div>\n
    \n
    std<\/span>::string<\/span> serverKey = websocketKey + magicKey;<\/div>\n<\/div>\n<\/li>\n
  46. \n
    \n
    <\/div>\n<\/div>\n
    \n
    <\/div>\n<\/div>\n<\/li>\n
  47. \n
    \n
    <\/div>\n<\/div>\n
    \n
    char<\/span> shaHash[32<\/span>];<\/div>\n<\/div>\n<\/li>\n
  48. \n
    \n
    <\/div>\n<\/div>\n
    \n
    memset<\/span>(shaHash, 0<\/span>, sizeof<\/span>(shaHash));<\/div>\n<\/div>\n<\/li>\n
  49. \n
    \n
    <\/div>\n<\/div>\n
    \n
    sha1::calc(serverKey.c_str(), serverKey.size(), (unsigned<\/span> char<\/span> *) shaHash);<\/div>\n<\/div>\n<\/li>\n
  50. \n
    \n
    <\/div>\n<\/div>\n
    \n
    serverKey = base64::base64_encode(std<\/span>::string<\/span>(shaHash)) + “\\r\\n\\r\\n”<\/span>;<\/div>\n<\/div>\n<\/li>\n
  51. \n
    \n
    <\/div>\n<\/div>\n
    \n
    string<\/span> strtmp<\/span>(serverKey.c_str()<\/span>)<\/span>;<\/div>\n<\/div>\n<\/li>\n
  52. \n
    \n
    <\/div>\n<\/div>\n
    \n
    response += strtmp;<\/div>\n<\/div>\n<\/li>\n
  53. \n
    \n
    <\/div>\n<\/div>\n
    \n
    <\/div>\n<\/div>\n<\/li>\n
  54. \n
    \n
    <\/div>\n<\/div>\n
    \n
    return<\/span> ret;<\/div>\n<\/div>\n<\/li>\n
  55. \n
    \n
    <\/div>\n<\/div>\n
    \n
    }<\/div>\n<\/div>\n<\/li>\n<\/ol>\n
    <\/code><\/pre>\n
    2.\u00a0\u5b8c\u6210\u63e1\u624b\u540e\u8fde\u63a5\u5c31\u5efa\u7acb\u4e86\u3002\u7136\u540e\u5c31\u662f\u63a5\u6536h5\u5ba2\u6237\u7aef\u901a\u8fc7\u00a0WebSocket\u00a0\u53d1\u8fc7\u6765\u7684\u6570\u636e\u5e27\u5e76\u89e3\u7801\uff1a<\/p>\n
    <\/code><\/pre>\n
      \n
    1. \n
      \n
      <\/div>\n<\/div>\n
      \n
      int<\/span> wsDecodeFrame<\/span>(string<\/span> inFrame, string<\/span> &outMessage)<\/span><\/span><\/div>\n<\/div>\n<\/li>\n
    2. \n
      \n
      <\/div>\n<\/div>\n
      \n
      {<\/div>\n<\/div>\n<\/li>\n
    3. \n
      \n
      <\/div>\n<\/div>\n
      \n
      int<\/span> ret = WS_OPENING_FRAME;<\/div>\n<\/div>\n<\/li>\n
    4. \n
      \n
      <\/div>\n<\/div>\n
      \n
      const<\/span> char<\/span> *frameData = inFrame.c_str();<\/div>\n<\/div>\n<\/li>\n
    5. \n
      \n
      <\/div>\n<\/div>\n
      \n
      const<\/span> int<\/span> frameLength = inFrame.size();<\/div>\n<\/div>\n<\/li>\n
    6. \n
      \n
      <\/div>\n<\/div>\n
      \n
      if<\/span> (frameLength < 2<\/span>)<\/div>\n<\/div>\n<\/li>\n
    7. \n
      \n
      <\/div>\n<\/div>\n
      \n
      {<\/div>\n<\/div>\n<\/li>\n
    8. \n
      \n
      <\/div>\n<\/div>\n
      \n
      ret = WS_ERROR_FRAME;<\/div>\n<\/div>\n<\/li>\n
    9. \n
      \n
      <\/div>\n<\/div>\n
      \n
      }<\/div>\n<\/div>\n<\/li>\n
    10. \n
      \n
      <\/div>\n<\/div>\n
      \n
      <\/div>\n<\/div>\n<\/li>\n
    11. \n
      \n
      <\/div>\n<\/div>\n
      \n
      \/\/ \u68c0\u67e5\u6269\u5c55\u4f4d\u5e76\u5ffd\u7565<\/span><\/div>\n<\/div>\n<\/li>\n
    12. \n
      \n
      <\/div>\n<\/div>\n
      \n
      if<\/span> ((frameData[0<\/span>] & 0x70<\/span>) != 0x0<\/span>)<\/div>\n<\/div>\n<\/li>\n
    13. \n
      \n
      <\/div>\n<\/div>\n
      \n
      {<\/div>\n<\/div>\n<\/li>\n
    14. \n
      \n
      <\/div>\n<\/div>\n
      \n
      ret = WS_ERROR_FRAME;<\/div>\n<\/div>\n<\/li>\n
    15. \n
      \n
      <\/div>\n<\/div>\n
      \n
      }<\/div>\n<\/div>\n<\/li>\n
    16. \n
      \n
      <\/div>\n<\/div>\n
      \n
      <\/div>\n<\/div>\n<\/li>\n
    17. \n
      \n
      <\/div>\n<\/div>\n
      \n
      \/\/ fin\u4f4d: \u4e3a1\u8868\u793a\u5df2\u63a5\u6536\u5b8c\u6574\u62a5\u6587, \u4e3a0\u8868\u793a\u7ee7\u7eed\u76d1\u542c\u540e\u7eed\u62a5\u6587<\/span><\/div>\n<\/div>\n<\/li>\n
    18. \n
      \n
      <\/div>\n<\/div>\n
      \n
      ret = (frameData[0<\/span>] & 0x80<\/span>);<\/div>\n<\/div>\n<\/li>\n
    19. \n
      \n
      <\/div>\n<\/div>\n
      \n
      if<\/span> ((frameData[0<\/span>] & 0x80<\/span>) != 0x80<\/span>)<\/div>\n<\/div>\n<\/li>\n
    20. \n
      \n
      <\/div>\n<\/div>\n
      \n
      {<\/div>\n<\/div>\n<\/li>\n
    21. \n
      \n
      <\/div>\n<\/div>\n
      \n
      ret = WS_ERROR_FRAME;<\/div>\n<\/div>\n<\/li>\n
    22. \n
      \n
      <\/div>\n<\/div>\n
      \n
      }<\/div>\n<\/div>\n<\/li>\n
    23. \n
      \n
      <\/div>\n<\/div>\n
      \n
      <\/div>\n<\/div>\n<\/li>\n
    24. \n
      \n
      <\/div>\n<\/div>\n
      \n
      \/\/ mask\u4f4d, \u4e3a1\u8868\u793a\u6570\u636e\u88ab\u52a0\u5bc6<\/span><\/div>\n<\/div>\n<\/li>\n
    25. \n
      \n
      <\/div>\n<\/div>\n
      \n
      if<\/span> ((frameData[1<\/span>] & 0x80<\/span>) != 0x80<\/span>)<\/div>\n<\/div>\n<\/li>\n
    26. \n
      \n
      <\/div>\n<\/div>\n
      \n
      {<\/div>\n<\/div>\n<\/li>\n
    27. \n
      \n
      <\/div>\n<\/div>\n
      \n
      ret = WS_ERROR_FRAME;<\/div>\n<\/div>\n<\/li>\n
    28. \n
      \n
      <\/div>\n<\/div>\n
      \n
      }<\/div>\n<\/div>\n<\/li>\n
    29. \n
      \n
      <\/div>\n<\/div>\n
      \n
      <\/div>\n<\/div>\n<\/li>\n
    30. \n
      \n
      <\/div>\n<\/div>\n
      \n
      \/\/ \u64cd\u4f5c\u7801<\/span><\/div>\n<\/div>\n<\/li>\n
    31. \n
      \n
      <\/div>\n<\/div>\n
      \n
      uint16_t<\/span> payloadLength = 0<\/span>;<\/div>\n<\/div>\n<\/li>\n
    32. \n
      \n
      <\/div>\n<\/div>\n
      \n
      uint8_t<\/span> payloadFieldExtraBytes = 0<\/span>;<\/div>\n<\/div>\n<\/li>\n
    33. \n
      \n
      <\/div>\n<\/div>\n
      \n
      uint8_t<\/span> opcode = static_cast<\/span><uint8_t<\/span> >(frameData[0<\/span>] & 0x0f<\/span>);<\/div>\n<\/div>\n<\/li>\n
    34. \n
      \n
      <\/div>\n<\/div>\n
      \n
      if<\/span> (opcode == WS_TEXT_FRAME)<\/div>\n<\/div>\n<\/li>\n
    35. \n
      \n
      <\/div>\n<\/div>\n
      \n
      {<\/div>\n<\/div>\n<\/li>\n
    36. \n
      \n
      <\/div>\n<\/div>\n
      \n
      \/\/ \u5904\u7406utf-8\u7f16\u7801\u7684\u6587\u672c\u5e27<\/span><\/div>\n<\/div>\n<\/li>\n
    37. \n
      \n
      <\/div>\n<\/div>\n
      \n
      payloadLength = static_cast<\/span><uint16_t<\/span> >(frameData[1<\/span>] & 0x7f<\/span>);<\/div>\n<\/div>\n<\/li>\n
    38. \n
      \n
      <\/div>\n<\/div>\n
      \n
      if<\/span> (payloadLength == 0x7e<\/span>)<\/div>\n<\/div>\n<\/li>\n
    39. \n
      \n
      <\/div>\n<\/div>\n
      \n
      {<\/div>\n<\/div>\n<\/li>\n
    40. \n
      \n
      <\/div>\n<\/div>\n
      \n
      uint16_t<\/span> payloadLength16b = 0<\/span>;<\/div>\n<\/div>\n<\/li>\n
    41. \n
      \n
      <\/div>\n<\/div>\n
      \n
      payloadFieldExtraBytes = 2<\/span>;<\/div>\n<\/div>\n<\/li>\n
    42. \n
      \n
      <\/div>\n<\/div>\n
      \n
      memcpy<\/span>(&payloadLength16b, &frameData[2<\/span>], payloadFieldExtraBytes);<\/div>\n<\/div>\n<\/li>\n
    43. \n
      \n
      <\/div>\n<\/div>\n
      \n
      payloadLength = ntohs(payloadLength16b);<\/div>\n<\/div>\n<\/li>\n
    44. \n
      \n
      <\/div>\n<\/div>\n
      \n
      }<\/div>\n<\/div>\n<\/li>\n
    45. \n
      \n
      <\/div>\n<\/div>\n
      \n
      else<\/span> if<\/span> (payloadLength == 0x7f<\/span>)<\/div>\n<\/div>\n<\/li>\n
    46. \n
      \n
      <\/div>\n<\/div>\n
      \n
      {<\/div>\n<\/div>\n<\/li>\n
    47. \n
      \n
      <\/div>\n<\/div>\n
      \n
      \/\/ \u6570\u636e\u8fc7\u957f,\u6682\u4e0d\u652f\u6301<\/span><\/div>\n<\/div>\n<\/li>\n
    48. \n
      \n
      <\/div>\n<\/div>\n
      \n
      ret = WS_ERROR_FRAME;<\/div>\n<\/div>\n<\/li>\n
    49. \n
      \n
      <\/div>\n<\/div>\n
      \n
      }<\/div>\n<\/div>\n<\/li>\n
    50. \n
      \n
      <\/div>\n<\/div>\n
      \n
      }<\/div>\n<\/div>\n<\/li>\n
    51. \n
      \n
      <\/div>\n<\/div>\n
      \n
      else<\/span> if<\/span> (opcode == WS_BINARY_FRAME || opcode == WS_PING_FRAME || opcode == WS_PONG_FRAME)<\/div>\n<\/div>\n<\/li>\n
    52. \n
      \n
      <\/div>\n<\/div>\n
      \n
      {<\/div>\n<\/div>\n<\/li>\n
    53. \n
      \n
      <\/div>\n<\/div>\n
      \n
      \/\/ \u4e8c\u8fdb\u5236\/ping\/pong\u5e27\u6682\u4e0d\u5904\u7406<\/span><\/div>\n<\/div>\n<\/li>\n
    54. \n
      \n
      <\/div>\n<\/div>\n
      \n
      }<\/div>\n<\/div>\n<\/li>\n
    55. \n
      \n
      <\/div>\n<\/div>\n
      \n
      else<\/span> if<\/span> (opcode == WS_CLOSING_FRAME)<\/div>\n<\/div>\n<\/li>\n
    56. \n
      \n
      <\/div>\n<\/div>\n
      \n
      {<\/div>\n<\/div>\n<\/li>\n
    57. \n
      \n
      <\/div>\n<\/div>\n
      \n
      ret = WS_CLOSING_FRAME;<\/div>\n<\/div>\n<\/li>\n
    58. \n
      \n
      <\/div>\n<\/div>\n
      \n
      }<\/div>\n<\/div>\n<\/li>\n
    59. \n
      \n
      <\/div>\n<\/div>\n
      \n
      else<\/span><\/div>\n<\/div>\n<\/li>\n
    60. \n
      \n
      <\/div>\n<\/div>\n
      \n
      {<\/div>\n<\/div>\n<\/li>\n
    61. \n
      \n
      <\/div>\n<\/div>\n
      \n
      ret = WS_ERROR_FRAME;<\/div>\n<\/div>\n<\/li>\n
    62. \n
      \n
      <\/div>\n<\/div>\n
      \n
      }<\/div>\n<\/div>\n<\/li>\n
    63. \n
      \n
      <\/div>\n<\/div>\n
      \n
      <\/div>\n<\/div>\n<\/li>\n
    64. \n
      \n
      <\/div>\n<\/div>\n
      \n
      \/\/ \u6570\u636e\u89e3\u7801<\/span><\/div>\n<\/div>\n<\/li>\n
    65. \n
      \n
      <\/div>\n<\/div>\n
      \n
      if<\/span> ((ret != WS_ERROR_FRAME) && (payloadLength > 0<\/span>))<\/div>\n<\/div>\n<\/li>\n
    66. \n
      \n
      <\/div>\n<\/div>\n
      \n
      {<\/div>\n<\/div>\n<\/li>\n
    67. \n
      \n
      <\/div>\n<\/div>\n
      \n
      \/\/ header: 2\u5b57\u8282, masking key: 4\u5b57\u8282<\/span><\/div>\n<\/div>\n<\/li>\n
    68. \n
      \n
      <\/div>\n<\/div>\n
      \n
      const<\/span> char<\/span> *maskingKey = &frameData[2<\/span> + payloadFieldExtraBytes];<\/div>\n<\/div>\n<\/li>\n
    69. \n
      \n
      <\/div>\n<\/div>\n
      \n
      char<\/span> *payloadData = new<\/span> char<\/span>[payloadLength + 1<\/span>];<\/div>\n<\/div>\n<\/li>\n
    70. \n
      \n
      <\/div>\n<\/div>\n
      \n
      memset<\/span>(payloadData, 0<\/span>, payloadLength + 1<\/span>);<\/div>\n<\/div>\n<\/li>\n
    71. \n
      \n
      <\/div>\n<\/div>\n
      \n
      memcpy<\/span>(payloadData, &frameData[2<\/span> + payloadFieldExtraBytes + 4<\/span>], payloadLength);<\/div>\n<\/div>\n<\/li>\n
    72. \n
      \n
      <\/div>\n<\/div>\n
      \n
      for<\/span> (int<\/span> i = 0<\/span>; i < payloadLength; i++)<\/div>\n<\/div>\n<\/li>\n
    73. \n
      \n
      <\/div>\n<\/div>\n
      \n
      {<\/div>\n<\/div>\n<\/li>\n
    74. \n
      \n
      <\/div>\n<\/div>\n
      \n
      payloadData[i] = payloadData[i] ^ maskingKey[i % 4<\/span>];<\/div>\n<\/div>\n<\/li>\n
    75. \n
      \n
      <\/div>\n<\/div>\n
      \n
      }<\/div>\n<\/div>\n<\/li>\n
    76. \n
      \n
      <\/div>\n<\/div>\n
      \n
      <\/div>\n<\/div>\n<\/li>\n
    77. \n
      \n
      <\/div>\n<\/div>\n
      \n
      outMessage = payloadData;<\/div>\n<\/div>\n<\/li>\n
    78. \n
      \n
      <\/div>\n<\/div>\n
      \n
      delete<\/span>[] payloadData;<\/div>\n<\/div>\n<\/li>\n
    79. \n
      \n
      <\/div>\n<\/div>\n
      \n
      }<\/div>\n<\/div>\n<\/li>\n
    80. \n
      \n
      <\/div>\n<\/div>\n
      \n
      <\/div>\n<\/div>\n<\/li>\n
    81. \n
      \n
      <\/div>\n<\/div>\n
      \n
      return<\/span> ret;<\/div>\n<\/div>\n<\/li>\n
    82. \n
      \n
      <\/div>\n<\/div>\n
      \n
      }<\/div>\n<\/div>\n<\/li>\n<\/ol>\n
      <\/code><\/pre>\n
      3.\u00a0\u89e3\u7801\u5b8c\u6570\u636e\u5e27\uff0c\u670d\u52a1\u7aef\u505a\u51fa\u76f8\u5e94\u5904\u7406\u540e\u5c06\u7ed3\u679c\u6309\u7167\u00a0WebSocket\u00a0\u534f\u8bae\u7f16\u7801\uff0c\u7136\u540e\u53d1\u7ed9h5\u5ba2\u6237\u7aef\uff1a<\/p>\n
      <\/code><\/pre>\n
        \n
      1. \n
        \n
        <\/div>\n<\/div>\n
        \n
        int<\/span> wsEncodeFrame<\/span>(string<\/span> inMessage, string<\/span> &outFrame, enum<\/span> WS_FrameType frameType)<\/span><\/span><\/div>\n<\/div>\n<\/li>\n
      2. \n
        \n
        <\/div>\n<\/div>\n
        \n
        {<\/div>\n<\/div>\n<\/li>\n
      3. \n
        \n
        <\/div>\n<\/div>\n
        \n
        int<\/span> ret = WS_EMPTY_FRAME;<\/div>\n<\/div>\n<\/li>\n
      4. \n
        \n
        <\/div>\n<\/div>\n
        \n
        const<\/span> uint32_t<\/span> messageLength = inMessage.size();<\/div>\n<\/div>\n<\/li>\n
      5. \n
        \n
        <\/div>\n<\/div>\n
        \n
        if<\/span> (messageLength > 32767<\/span>)<\/div>\n<\/div>\n<\/li>\n
      6. \n
        \n
        <\/div>\n<\/div>\n
        \n
        {<\/div>\n<\/div>\n<\/li>\n
      7. \n
        \n
        <\/div>\n<\/div>\n
        \n
        \/\/ \u6682\u4e0d\u652f\u6301\u8fd9\u4e48\u957f\u7684\u6570\u636e<\/span><\/div>\n<\/div>\n<\/li>\n
      8. \n
        \n
        <\/div>\n<\/div>\n
        \n
        return<\/span> WS_ERROR_FRAME;<\/div>\n<\/div>\n<\/li>\n
      9. \n
        \n
        <\/div>\n<\/div>\n
        \n
        }<\/div>\n<\/div>\n<\/li>\n
      10. \n
        \n
        <\/div>\n<\/div>\n
        \n
        <\/div>\n<\/div>\n<\/li>\n
      11. \n
        \n
        <\/div>\n<\/div>\n
        \n
        uint8_t<\/span> payloadFieldExtraBytes = (messageLength <= 0x7d<\/span>) ? 0<\/span> : 2<\/span>;<\/div>\n<\/div>\n<\/li>\n
      12. \n
        \n
        <\/div>\n<\/div>\n
        \n
        \/\/ header: 2\u5b57\u8282, mask\u4f4d\u8bbe\u7f6e\u4e3a0(\u4e0d\u52a0\u5bc6), \u5219\u540e\u9762\u7684masking key\u65e0\u987b\u586b\u5199, \u7701\u75654\u5b57\u8282<\/span><\/div>\n<\/div>\n<\/li>\n
      13. \n
        \n
        <\/div>\n<\/div>\n
        \n
        uint8_t<\/span> frameHeaderSize = 2<\/span> + payloadFieldExtraBytes;<\/div>\n<\/div>\n<\/li>\n
      14. \n
        \n
        <\/div>\n<\/div>\n
        \n
        uint8_t<\/span> *frameHeader = new<\/span> uint8_t<\/span>[frameHeaderSize];<\/div>\n<\/div>\n<\/li>\n
      15. \n
        \n
        <\/div>\n<\/div>\n
        \n
        memset<\/span>(frameHeader, 0<\/span>, frameHeaderSize);<\/div>\n<\/div>\n<\/li>\n
      16. \n
        \n
        <\/div>\n<\/div>\n
        \n
        \/\/ fin\u4f4d\u4e3a1, \u6269\u5c55\u4f4d\u4e3a0, \u64cd\u4f5c\u4f4d\u4e3aframeType<\/span><\/div>\n<\/div>\n<\/li>\n
      17. \n
        \n
        <\/div>\n<\/div>\n
        \n
        frameHeader[0<\/span>] = static_cast<\/span><uint8_t<\/span>>(0x80<\/span> | frameType);<\/div>\n<\/div>\n<\/li>\n
      18. \n
        \n
        <\/div>\n<\/div>\n
        \n
        <\/div>\n<\/div>\n<\/li>\n
      19. \n
        \n
        <\/div>\n<\/div>\n
        \n
        \/\/ \u586b\u5145\u6570\u636e\u957f\u5ea6<\/span><\/div>\n<\/div>\n<\/li>\n
      20. \n
        \n
        <\/div>\n<\/div>\n
        \n
        if<\/span> (messageLength <= 0x7d<\/span>)<\/div>\n<\/div>\n<\/li>\n
      21. \n
        \n
        <\/div>\n<\/div>\n
        \n
        {<\/div>\n<\/div>\n<\/li>\n
      22. \n
        \n
        <\/div>\n<\/div>\n
        \n
        frameHeader[1<\/span>] = static_cast<\/span><uint8_t<\/span>>(messageLength);<\/div>\n<\/div>\n<\/li>\n
      23. \n
        \n
        <\/div>\n<\/div>\n
        \n
        }<\/div>\n<\/div>\n<\/li>\n
      24. \n
        \n
        <\/div>\n<\/div>\n
        \n
        else<\/span><\/div>\n<\/div>\n<\/li>\n
      25. \n
        \n
        <\/div>\n<\/div>\n
        \n
        {<\/div>\n<\/div>\n<\/li>\n
      26. \n
        \n
        <\/div>\n<\/div>\n
        \n
        frameHeader[1<\/span>] = 0x7e<\/span>;<\/div>\n<\/div>\n<\/li>\n
      27. \n
        \n
        <\/div>\n<\/div>\n
        \n
        uint16_t<\/span> len = htons(messageLength);<\/div>\n<\/div>\n<\/li>\n
      28. \n
        \n
        <\/div>\n<\/div>\n
        \n
        memcpy<\/span>(&frameHeader[2<\/span>], &len, payloadFieldExtraBytes);<\/div>\n<\/div>\n<\/li>\n
      29. \n
        \n
        <\/div>\n<\/div>\n
        \n
        }<\/div>\n<\/div>\n<\/li>\n
      30. \n
        \n
        <\/div>\n<\/div>\n
        \n
        <\/div>\n<\/div>\n<\/li>\n
      31. \n
        \n
        <\/div>\n<\/div>\n
        \n
        \/\/ \u586b\u5145\u6570\u636e<\/span><\/div>\n<\/div>\n<\/li>\n
      32. \n
        \n
        <\/div>\n<\/div>\n
        \n
        uint32_t<\/span> frameSize = frameHeaderSize + messageLength;<\/div>\n<\/div>\n<\/li>\n
      33. \n
        \n
        <\/div>\n<\/div>\n
        \n
        char<\/span> *frame = new<\/span> char<\/span>[frameSize + 1<\/span>];<\/div>\n<\/div>\n<\/li>\n
      34. \n
        \n
        <\/div>\n<\/div>\n
        \n
        memcpy<\/span>(frame, frameHeader, frameHeaderSize);<\/div>\n<\/div>\n<\/li>\n
      35. \n
        \n
        <\/div>\n<\/div>\n
        \n
        memcpy<\/span>(frame + frameHeaderSize, inMessage.c_str(), messageLength);<\/div>\n<\/div>\n<\/li>\n
      36. \n
        \n
        <\/div>\n<\/div>\n
        \n
        frame[frameSize] = ‘\\0’<\/span>;<\/div>\n<\/div>\n<\/li>\n
      37. \n
        \n
        <\/div>\n<\/div>\n
        \n
        outFrame = frame;<\/div>\n<\/div>\n<\/li>\n
      38. \n
        \n
        <\/div>\n<\/div>\n
        \n
        <\/div>\n<\/div>\n<\/li>\n
      39. \n
        \n
        <\/div>\n<\/div>\n
        \n
        delete<\/span>[] frame;<\/div>\n<\/div>\n<\/li>\n
      40. \n
        \n
        <\/div>\n<\/div>\n
        \n
        delete<\/span>[] frameHeader;<\/div>\n<\/div>\n<\/li>\n
      41. \n
        \n
        <\/div>\n<\/div>\n
        \n
        return<\/span> ret;<\/div>\n<\/div>\n<\/li>\n
      42. \n
        \n
        <\/div>\n<\/div>\n
        \n
        }<\/div>\n<\/div>\n<\/li>\n<\/ol>\n
        <\/code><\/pre>\n
        4.\u00a0\u63e1\u624b\u53ea\u9700\u4e00\u6b21\uff0c\u968f\u540e\u53cd\u590d\u6267\u884c\u7b2c2\u6b65\u53ca\u7b2c3\u6b65\uff0c\u5c31\u5b8c\u6210\u4e86\u670d\u52a1\u7aef\u4e0eh5\u5ba2\u6237\u7aef\u901a\u4fe1\u3002\u8fd9\u4e2a\u53ea\u662fc++\u7248\u672c\u7684\uff0c\u53ef\u4ee5\u5f88\u5bb9\u6613\u6539\u6210java\u7248\u672c\u7684\u3002\u4e0b\u9762\u662f\u4e0a\u8ff0\u65b9\u6cd5\u7528\u5230\u7684\u4e00\u4e9b\u679a\u4e3e\uff1a<\/p>\n
        <\/code><\/pre>\n
          \n
        1. \n
          \n
          <\/div>\n<\/div>\n
          \n
          enum<\/span> WS_Status<\/div>\n<\/div>\n<\/li>\n
        2. \n
          \n
          <\/div>\n<\/div>\n
          \n
          {<\/div>\n<\/div>\n<\/li>\n
        3. \n
          \n
          <\/div>\n<\/div>\n
          \n
          WS_STATUS_CONNECT = 0<\/span>,<\/div>\n<\/div>\n<\/li>\n
        4. \n
          \n
          <\/div>\n<\/div>\n
          \n
          WS_STATUS_UNCONNECT = 1<\/span>,<\/div>\n<\/div>\n<\/li>\n
        5. \n
          \n
          <\/div>\n<\/div>\n
          \n
          };<\/div>\n<\/div>\n<\/li>\n
        6. \n
          \n
          <\/div>\n<\/div>\n
          \n
          <\/div>\n<\/div>\n<\/li>\n
        7. \n
          \n
          <\/div>\n<\/div>\n
          \n
          enum<\/span> WS_FrameType<\/div>\n<\/div>\n<\/li>\n
        8. \n
          \n
          <\/div>\n<\/div>\n
          \n
          {<\/div>\n<\/div>\n<\/li>\n
        9. \n
          \n
          <\/div>\n<\/div>\n
          \n
          WS_EMPTY_FRAME = 0xF0<\/span>,<\/div>\n<\/div>\n<\/li>\n
        10. \n
          \n
          <\/div>\n<\/div>\n
          \n
          WS_ERROR_FRAME = 0xF1<\/span>,<\/div>\n<\/div>\n<\/li>\n
        11. \n
          \n
          <\/div>\n<\/div>\n
          \n
          WS_TEXT_FRAME = 0x01<\/span>,<\/div>\n<\/div>\n<\/li>\n
        12. \n
          \n
          <\/div>\n<\/div>\n
          \n
          WS_BINARY_FRAME = 0x02<\/span>,<\/div>\n<\/div>\n<\/li>\n
        13. \n
          \n
          <\/div>\n<\/div>\n
          \n
          WS_PING_FRAME = 0x09<\/span>,<\/div>\n<\/div>\n<\/li>\n
        14. \n
          \n
          <\/div>\n<\/div>\n
          \n
          WS_PONG_FRAME = 0x0A<\/span>,<\/div>\n<\/div>\n<\/li>\n
        15. \n
          \n
          <\/div>\n<\/div>\n
          \n
          WS_OPENING_FRAME = 0xF3<\/span>,<\/div>\n<\/div>\n<\/li>\n
        16. \n
          \n
          <\/div>\n<\/div>\n
          \n
          WS_CLOSING_FRAME = 0x08<\/span><\/div>\n<\/div>\n<\/li>\n
        17. \n
          \n
          <\/div>\n<\/div>\n
          \n
          };<\/div>\n<\/div>\n<\/li>\n<\/ol>\n
          <\/code><\/pre>\n
          \u53c2\u8003\u8d44\u6599\uff1a<\/p>\n
          \u00a0 \u00a0 \u00a0 \u00a0https:\/\/developer.mozilla.org\/en-US\/docs\/Web\/API\/WebSockets_API\/Writing_WebSocket_server<\/a><\/div>\n
          \u00a0 \u00a0 \u00a0 \u00a0https:\/\/www.ibm.com\/developerworks\/cn\/web\/1112_huangxa_websocket\/<\/a><\/div>\n<\/div>\n<\/div>\n<\/article>\n","protected":false},"excerpt":{"rendered":"
          \u670d\u52a1\u7aef\u4f7f\u7528c++\u5b9e\u73b0websocket\u534f<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"colormag_page_container_layout":"default_layout","colormag_page_sidebar_layout":"default_layout","footnotes":""},"categories":[24],"tags":[121],"class_list":["post-1629","post","type-post","status-publish","format-standard","hentry","category-value_docs","tag-05-"],"_links":{"self":[{"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/posts\/1629","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/comments?post=1629"}],"version-history":[{"count":0,"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/posts\/1629\/revisions"}],"wp:attachment":[{"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/media?parent=1629"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/categories?post=1629"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/tags?post=1629"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}