WebSocket草案10テキストデータ解析と送信

44611 ワード
websocket
握手協議が実現しました.次はデータの解析です.これは相対的に面倒くさいです.草案7.6より複雑になりました.下図はデータ転送のフォーマットです.
WebSocket草案10文本数据解析和发送
各値の具体的な意味はこの中国語の翻訳を参照することができます.
簡単に要約すると、FINはずっと1で、RSV 1、RSV 2、RSV 3はずっと0で、内容がテキストを送る時、opcodeは1で、MASKは1のためにマスクを使うなら、4ビットのマスクを獲得して、順番に順番を変えて、データと異種の演算をします.最初のコンテンツデータは最初のマスクと違います.第二のコンテンツデータは第二のマスクと違っています.第五のコンテンツデータは第一のマスクと違っています.
Chrome/Firefoxの下では、FINは常に1であり、テキストメッセージだけであれば、opcodeは1であり、RSV 1、RSV 2、RSV 3はいずれも0であるため、最初のデータは0である.×81;MASKは1で、データ長についていくので、2番目のデータは0より大きいです.×80は、データの長さが違っていますので、必要なバイト数も違います.したがって、マスクの位置も違います.規格によると、換算すると、データの総長さ(FIN、RSVなどを含む)は0より小さいです.×84なら、マスクは第三のデータから第六のデータまでです.データの総長さ(FIN、RSVなどの情報を含む)が0 x fe81より小さい場合、マスクは5番目のデータから8番目のデータまでです.他のマスクは13番目のデータから16番目のデータまでです.データの長さが一つのパケットの長さを超えている場合、後ろのパケットはもうRIN、RSV、MASKなどの情報を含んでいません.二つは直接コンテンツデータです.前回取ったMASKによって異和演算を行う必要があります.クライアントが積極的にリンクの切断を要求すると、コンテンツデータがなく、ヘッダ情報とマスクだけがあり、長さは6に固定されています.混淆を避けるために、Chromeは正常なコンテンツの送信時に6バイトのデータが現れないことを保証します.基本的には6バイトの切断接続要求を処理することができます.クライアントの能動的な要求を区別して、接続の切断と正常な連続データパケットは長さによって区別されます.連続的なパケットであれば、解析されたパケットの長さはヘッダ情報の長さより小さくなります.そうでなければ、クライアントが積極的にリンクの切断を要求すると考えられます.接続をアクティブに切断すると送信される追加のパケットの場合、最初のバイトは正常な0にはなりません.×81,通常は0です×88、NodeJSが書いたのは大体この通りです.

 
 
    

  
  
  1.  module.exports = Parser; 
    2. 

  
  
  2.   
    3. 

  
  
  3.  var util = require('util'), 
    4. 

  
  
  4.   events = require('events'); 
    5. 

  
  
  5.   
    6. 

  
  
  6.  /** 
    7. 

  
  
  7.  * http.Server       
    8. 

  
  
  8.  * */ 
    9. 

  
  
  9.  function Parser(version) { 
    10. 

  
  
  10.   events.EventEmitter.call(this); 
    11. 

  
  
  11.   
    12. 

  
  
  12.   this.version = version || 'draft10'; 
    13. 

  
  
  13.   this.length = 0; 
    14. 

  
  
  14.   this.parsed = 0; 
    15. 

  
  
  15.   this.maskData = []; 
    16. 

  
  
  16.   this.frameData = []; 
    17. 

  
  
  17.   this.order = 0; 
    18. 

  
  
  18.   this.closing = false; 
    19. 

  
  
  19.  } 
    20. 

  
  
  20.   
    21. 

  
  
  21.  util.inherits(Parser, events.EventEmitter); 
    22. 

  
  
  22.   
    23. 

  
  
  23.  Parser.prototype.write = function(data) { 
    24. 

  
  
  24.   console.log(data.length); 
    25. 

  
  
  25.   dataParser[this.version](data, this); 
    26. 

  
  
  26.  }; 
    27. 

  
  
  27.   
    28. 

  
  
  28.  //        
    29. 

  
  
  29.  var dataParser = { 
    30. 

  
  
  30.   'draft10': function(data, parser){ 
    31. 

  
  
  31.   var pkt, i =0, len = 0, start = 0; 
    32. 

  
  
  32.   
    33. 

  
  
  33.   //        ，           
    34. 

  
  
  34.   //           ，      0x88 
    35. 

  
  
  35.   if(data[0] != 0x81 && parser.length == 0){ 
    36. 

  
  
  36.   parser.emit('close'); 
    37. 

  
  
  37.   parser.closing = false; 
    38. 

  
  
  38.   return; 
    39. 

  
  
  39.   } 
    40. 

  
  
  40.   
    41. 

  
  
  41.   //   10 
    42. 

  
  
  42.   //           
    43. 

  
  
  43.   if(data[0] == 0x81){ 
    44. 

  
  
  44.   //       
    45. 

  
  
  45.   if(data[1] >= 0x80){ 
    46. 

  
  
  46.   //        ，        
    47. 

  
  
  47.   if(data.length < 0x84){ 
    48. 

  
  
  48.   // firefox ，                   
    49. 

  
  
  49.   //           ，      0xfe 
    50. 

  
  
  50.   if(data[1] == 0xfe){ 
    51. 

  
  
  51.   len = data.length; 
    52. 

  
  
  52.   // firefox 
    53. 

  
  
  53.   parser.maskData = [data[len - 4], data[len - 3], data[len - 2], data[len - 1]]; 
    54. 

  
  
  54.   parser.length = data[len - 5]; 
    55. 

  
  
  55.   for(i = len - 6; i > 1; i--){ 
    56. 

  
  
  56.   parser.length += data[i] * (len - 5 - i) * 256; 
    57. 

  
  
  57.   } 
    58. 

  
  
  58.   console.log('firefox multi packages, length: ', parser.length); 
    59. 

  
  
  59.   start = data.length; 
    60. 

  
  
  60.   } 
    61. 

  
  
  61.   else{ 
    62. 

  
  
  62.   // chrome 
    63. 

  
  
  63.   parser.length = data[1] - 0x80; 
    64. 

  
  
  64.   console.log('7bit, length: ', parser.length); 
    65. 

  
  
  65.   parser.maskData = [data[2], data[3], data[4], data[5]]; 
    66. 

  
  
  66.   start = 6; 
    67. 

  
  
  67.   } 
    68. 

  
  
  68.   } 
    69. 

  
  
  69.   else if(data.length < 0xfe80){ parser.length = data[2] * 256 + data[3]; console.log('7 + 16bit, length: ', parser.length); parser.maskData = [data[4], data[5], data[6], data[7]]; start = 8; } else{ dparser.length = data[11]; for(i = 10; i > 3; i--){ 
    70. 

  
  
  70.   parser.length += data[i] * (11 - i) * 256; 
    71. 

  
  
  71.   } 
    72. 

  
  
  72.   console.log('7 + 64bit, length: ', parser.length); 
    73. 

  
  
  73.   parser.maskData = [data[12], data[13], data[14], data[15]]; 
    74. 

  
  
  74.   start = 16; 
    75. 

  
  
  75.   } 
    76. 

  
  
  76.   
    77. 

  
  
  77.   for(i = start, len = data.length; i < len; i++){ 
    78. 

  
  
  78.   parser.frameData.push(parser.maskData[(i - start) % 4] ^ data[i]); 
    79. 

  
  
  79.   } 
    80. 

  
  
  80.   } 
    81. 

  
  
  81.   else{ 
    82. 

  
  
  82.   if(data.length < 0x80){ 
    83. 

  
  
  83.   start = 2; 
    84. 

  
  
  84.   } 
    85. 

  
  
  85.   else if(data.length < 0xfe81){ 
    86. 

  
  
  86.   start = 4; 
    87. 

  
  
  87.   } 
    88. 

  
  
  88.   else{ 
    89. 

  
  
  89.   start = 12; 
    90. 

  
  
  90.   } 
    91. 

  
  
  91.   // find contents 
    92. 

  
  
  92.   parser.frameData = data.splice(start); 
    93. 

  
  
  93.   } 
    94. 

  
  
  94.   console.log('1st packge frame length: ', parser.frameData.length); 
    95. 

  
  
  95.   if(parser.frameData.length == parser.length){ 
    96. 

  
  
  96.   pkt = new Buffer(parser.frameData); 
    97. 

  
  
  97.   // console.log(pkt.toString('utf8', 0, pkt.length)); 
    98. 

  
  
  98.   parser.emit('message', pkt.toString('utf8', 0, pkt.length)); 
    99. 

  
  
  99.   //      ，       
    100. 

  
  
  100.   parser.frameData = []; 
    101. 

  
  
  101.   parser.length = 0; 
    102. 

  
  
  102.   } 
    103. 

  
  
  103.   return; 
    104. 

  
  
  104.   } 
    105. 

  
  
  105.   
    106. 

  
  
  106.   //        
    107. 

  
  
  107.   if(parser.maskData.length){ 
    108. 

  
  
  108.   // continue to parse data 
    109. 

  
  
  109.   for(i = 0, l = data.length; i < l; i++){ 
    110. 

  
  
  110.   parser.frameData.push(parser.maskData[i % 4] ^ data[i]); 
    111. 

  
  
  111.   } 
    112. 

  
  
  112.   console.log('frame length: ', parser.frameData.length); 
    113. 

  
  
  113.   if(parser.frameData.length == parser.length){ 
    114. 

  
  
  114.   pkt = new Buffer(parser.frameData); 
    115. 

  
  
  115.   // console.log(pkt.toString('utf8', 0, pkt.length)); 
    116. 

  
  
  116.   parser.emit('message', pkt.toString('utf8', 0, pkt.length)); 
    117. 

  
  
  117.   //      ，       
    118. 

  
  
  118.   parser.frameData = []; 
    119. 

  
  
  119.   parser.length = 0; 
    120. 

  
  
  120.   } 
    121. 

  
  
  121.   return; 
    122. 

  
  
  122.   } 
    123. 

  
  
  123.   } 
    124. 

  
  
  124.  }; 
    125.
回転:http://fdream.net/blog/article/759.aspx
Draft 10において、データを解析する過程が明らかになれば、これはより簡単になります.戻りデータのフォーマットは前に受けたデータフォーマットと非常に似ています.ただし、markを生成しなくてもいいです.頭の他のフォーマットは同じです.
最初のバイトですか?それとも固定ですか?0です.×81は、データを受け取る意味と同じです.第二バイトも、後七桁はデータ長を表します.maskがないので、第一位は0です.長さの表示方法と受け入れの表示方法が一致しており、7ビットで表現することもあり、16ビットで表現することもあります.
NodeJSで下記のように実現します.

  
  
    

   
   
  1.  var socketWriter = { 
    2. 

   
   
  2.   'draft10': function(socket, data){ 
    3. 

   
   
  3.   var frames, 
    4. 

   
   
  4.   length = new Buffer(data, 'utf8').length; 
    5. 

   
   
  5.   if(data.length > 0x7d){ 
    6. 

   
   
  6.   frames = new Buffer(4); 
    7. 

   
   
  7.   frames[0] = 0x81; 
    8. 

   
   
  8.   frames[1] = 0x7e; 
    9. 

   
   
  9.   frames[2] = length >> 8; 
    10. 

   
   
  10.   frames[3] = length & 0xFF; //1111 1111 
    11. 

   
   
  11.   } 
    12. 

   
   
  12.   else{ 
    13. 

   
   
  13.   frames = new Buffer(2); 
    14. 

   
   
  14.   frames[0] = 0x81; 
    15. 

   
   
  15.   frames[1] = length; 
    16. 

   
   
  16.   } 
    17. 

   
   
  17.   
    18. 

   
   
  18.   if (socket.writable) { 
    19. 

   
   
  19.   socket.write(frames, 'binary'); 
    20. 

   
   
  20.   socket.write(data, 'utf8'); 
    21. 

   
   
  21.   return true; 
    22. 

   
   
  22.   } 
    23. 

   
   
  23.   return false; 
    24. 

   
   
  24.   }, 
    25. 

   
   
  25.   'draft76': function(socket, data){ 
    26. 

   
   
  26.   var byteLen = Buffer.byteLength(data, 'utf8'), 
    27. 

   
   
  27.   bytes = new Buffer(byteLen + 2); 
    28. 

   
   
  28.   
    29. 

   
   
  29.   bytes[0] = 0x00; 
    30. 

   
   
  30.   bytes.write(data, 1, 'utf8'); 
    31. 

   
   
  31.   bytes[byteLen + 1] = 0xFF; 
    32. 

   
   
  32.   
    33. 

   
   
  33.   return socket.write(bytes); 
    34. 

   
   
  34.   } 
    35. 

   
   
  35.  }; 
    36. 

   
   
  36.   
    37. 

   
   
  37.  socketWriter['draft75'] = socketWriter['draft76']; 
    38.
回転:http://fdream.net/blog/article/767.aspx
http://fdream.net/blog/article/767.aspx
Android Google Maps待ち受け地図の拡大縮小