关于处理 continue 结束包的疑问

[shaovie]

https://github.com/lxzan/gws/blob/master/reader.go#L111C6-L111C6 if fin && opcode != OpcodeContinuation { return c.emitMessage(&Message{index: index, Opcode: opcode, Data: bytes.NewBuffer(p)}, compressed) } 这里不包含 continue 结束包吗

[lxzan]

是的，这里是处理不分片的消息

[shaovie]

但是分片消息结束的标志 不就是 fin && opcode != OpcodeContinuation 并且 c.continuationFrame.initialized == true 吗？ 你这样提前判断，就会漏掉最后一个分片完成消息的处理了

[lxzan]

分片消息结束的标志是 fin && opcode == OpcodeContinuation，分片消息开始的标志是 !fin && opcode == OpcodeText|OpcodeBinary.

[shaovie]

哦，我看的文章 写错了 https://zhuanlan.zhihu.com/p/407711596 这里边说的是： 对于最后一个分片的消息, 其 FIN 字段为 1, 并且 Opcode 字段的值为 0x1

我又查了一下，最后一片 opcode=0

[shaovie]

TMD https://zhuanlan.zhihu.com/p/605823149 这个文章 也说的最后一片 opcode=1，妈蛋，要查RFC吗

[lxzan]

WS有完善的测试工具：https://lxzan.github.io/gws/reports/servers/

[shaovie]

我查了rfc ，确实是跟你说的规则一样，最后片 fin=1 opcode=0 https://www.rfc-editor.org/rfc/rfc6455.html#section-5.4

[lxzan]

如果只是为了性能压测，你不需要做完整的实现

[shaovie]

完成 差不多了，https://github.com/shaovie/goev/blob/main/example/websocket.go 哈哈

[lxzan]

这么快👍🏻

[shaovie]

https://github.com/lxzan/gws/blob/master/protocol.go#L137

给长度赋值，为什么要用 += ?

[lxzan]

https://github.com/lxzan/gws/blob/master/protocol.go#L137

给长度赋值，为什么要用 += ?

看RFC帧头结构，这里加和或是等效的

[shaovie]

我意思是 为什么不是直接 赋值 = ，为什么要累加

[lxzan]

先给 Payload len 赋值后设置 MASK 也是可以的, 加法不用考虑顺序

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 ...                |
     +---------------------------------------------------------------+

[shaovie]

WS有完善的测试工具：https://lxzan.github.io/gws/reports/servers/

这个站为啥打不开？我也翻墙了

[lxzan]

WS有完善的测试工具：https://lxzan.github.io/gws/reports/servers/

这个站为啥打不开？我也翻墙了

检查代理配置 / 换个节点试试

[shaovie]

不行，台湾 东京 香港都不行，测试卡在write frame header了，

测试站 提示invalide frame header

[shaovie]

我看测试站，一般都是 上来就先发一个close frame 是吧

[lxzan]

不行，台湾 东京 香港都不行，测试卡在write frame header了，

测试站 提示invalide frame header

你的帧头构造得有问题

[lxzan]

我看测试站，一般都是 上来就先发一个close frame 是吧

断点看

[shaovie]

没看出来哪里有问题呢，就两个字节

[lxzan]

没看出来哪里有问题呢，就两个字节

打印hex字符串，和gws对比，完全一致的话就去网络库找问题

[shaovie]

测试流程没问题吧，对方发个close过来，我把close信息原样返回去

[lxzan]

测试流程没问题吧，对方发个close过来，我把close信息原样返回去

回1000，nil

[shaovie]

我有个疑问，为什么switch成功后，对方先发一个 closeframe code=1002 err="WebSocket Protocol” 过来？

[lxzan]

我有个疑问，为什么switch成功后，对方先发一个 closeframe code=1002 err="WebSocket Protocol” 过来？

协议错误，原因很多，你去gws里面搜一下哪些地方返回了这个

[shaovie]

我还有个疑问 https://github.com/lxzan/gws/blob/master/protocol.go#L204

mask 是固定 10:14 吗？不对吧，应该是在payloadlen 后边的4个字节吧

[lxzan]

我还有个疑问 https://github.com/lxzan/gws/blob/master/protocol.go#L204

mask 是固定 10:14 吗？不对吧，应该是在payloadlen 后边的4个字节吧

我只是用这样方式解析，构造不是这样的。懒得算偏移量了

[shaovie]

这样不会有问题？当payload=uint16的时候 解出来的mask不对吧

[lxzan]

这样不会有问题？当payload=uint16的时候 解出来的mask不对吧

有问题autobahn早就测出来了

[shaovie]

逻辑不通吧

[shaovie]

我有个疑问，为什么switch成功后，对方先发一个 closeframe code=1002 err="WebSocket Protocol” 过来？

我知道了，应该是我的switch 回应有问题，所以它直接close了

铁子帮我喵一眼，有没有问题，看半天没查出问题

[lxzan]

我有个疑问，为什么switch成功后，对方先发一个 closeframe code=1002 err="WebSocket Protocol” 过来？

我知道了，应该是我的switch 回应有问题，所以它直接close了

铁子帮我喵一眼，有没有问题，看半天没查出问题

你的压缩扩展已经写好了？ response header似乎没这么多

[shaovie]

没啊，还没走到那一步呢，我不返回Extensions 对端也会close 1002

[lxzan]

The handshake from the server looks as follows:

    HTTP/1.1 101 Switching Protocols
    Upgrade: websocket
    Connection: Upgrade
    Sec-WebSocket-Accept: s3pPLMBiTxaQ9kYGzzhZRbK+xOo=

[shaovie]

Sec-WebSocket-Version: 13 这个得有

[lxzan]

Sec-WebSocket-Version: 13 这个得有

好好看RFC6455

[shaovie]

去掉这个 对端直接报 1002 Invalid reserv

[lxzan]

chrome连接gws server:

• request

  GET ws://127.0.0.1:8000/connect HTTP/1.1
  Host: 127.0.0.1:8000
  Connection: Upgrade
  Pragma: no-cache
  Cache-Control: no-cache
  User-Agent: Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/109.0.0.0 Safari/537.36
  Upgrade: websocket
  Origin: chrome-extension://laookkfknpbbblfpciffpaejjkokdgca
  Sec-WebSocket-Version: 13
  Accept-Encoding: gzip, deflate, br
  Accept-Language: zh-CN,zh;q=0.9,en;q=0.8,ja;q=0.7,pt;q=0.6
  Sec-WebSocket-Key: X6zYhq3pAMnwrzBideKXSw==
  Sec-WebSocket-Extensions: permessage-deflate; client_max_window_bits

• response

  HTTP/1.1 101 Switching Protocols
  Upgrade: websocket
  Connection: Upgrade
  Sec-WebSocket-Accept: tp1R6f0smIkI159YZ0+1i92ZIiQ=

[shaovie]

en，确实不需要，难道是accept 算错了？是抄你的代码啊，哈哈

[shaovie]

搞不定了，先放一放

[shaovie]

铁子，帮我看看呗 https://github.com/shaovie/goev/blob/main/example/websocket.go

[shaovie]

https://gitee.com/casterlee/websocket/blob/master/websocket.go 这个我看了，现在问题就卡在connectHandshake， connectHandshake 这部分我实在没看出来哪里有问题，为什么测试网站 给我close了

[lxzan]

chrome的提示很明显了

[lxzan]

这个地方应该是resp吧, 改完连接就不会自动断开了

[shaovie]

NB，echo我测通过了

[lxzan]

通过观察chrome给的信息我怀疑你写入了unexpected contents

[shaovie]

除了tcpkali 还有别的工具可以压测吗，我服务器上源码安装tcpkali没成功，编译失败，可能系统太新了，

[lxzan]

删掉这行就能编译了 https://github.com/satori-com/tcpkali/blob/3c3175e417366c7ccafba56454903690fede501a/src/tcpkali_syslimits.c#L34

[shaovie]

搞定了，给个echo测试的tcpkaili的参数呗