websocket 为什么是按顺序执行的？

[wunonglin]

我用的是 echo 里面的 gorilla websocket 示例

https://echo.labstack.com/cookbook/websocket

我原本的后台是 node 写的，node 上没事，但是为什么 go 这边是按顺序执行的而不是同时执行？

[keepeye]

@wunonglin 按顺序处理每一条消息

[BingoXuan]

@wunonglin
我觉得你不要开协程去做 readloop，直接执行 readloop 。如果 CreateFromUrl 方法中涉及 io 处理或者可以并发执行的话，可以开协程执行并通过 chan 取回结果。参考： http://litang.me/post/golang-channel/#%E5%A4%9A%E5%86%99%E4%B8%80%E8%AF%BB

[wunonglin]

@xylophone21 #18

https://i.loli.net/2020/07/10/CxVOXqPmNdyvZ5D.png

打印出了 goroutine 和随机 Sleep 值

[wunonglin]

@keepeye #21 是这理没错，可是我想要按顺序多个一起执行

[Fitz]

看到最后才看懂楼主的顺序执行是什么意思......同一个连接里收到的 event, 那可不就是顺序执行, 想要并发就在 for 循环里只要 ReadMessage 读到数据, 就启个 goroutine 去处理, 你 go c.readLoop(ctx)用错地方了.

[joesonw]

@Fitz 不要教坏人家了. 弄一个 channel 缓存, 然后按照想要的并发量起 goroutine.

[wunonglin]

@Fitz #25
@joesonw #26

的确是 read 到数据就开个 goroutine 就行了

[hantsy]

@wunonglin NestJS 不是应该用 Rxjs 多？

[wunonglin]

@hantsy 都有用，但是有些复杂的地方用 rxjs 也会嵌套太深

[hantsy]

@wunonglin 最近玩了一下 Nestjs，如果没有 Rxjs 支持, 我根本就没兴趣。

Nestjs 很多概念很源自 Angular，写 Angular 习惯了，async，await 和 promise 那一套实在用起来难受。Nestjs 内部几乎和 Angular 一致，都是 Rxjs 优先，但可惜，第三方集成很多还是基于 Promise 。

https://github.com/hantsy/nestjs-sample 我这个的 Sample 除了 LocalStrategy 用了 Promise （用 Observable，需要额外转换），其它地方都是 Rxjs 。