golang中怎么处理socket长连接

Python036

golang中怎么处理socket长连接,第1张

为每个client fd开两个goroutine，一个recv，一个send。同时还有加2个channel，一个用于recv routine向逻辑主线程传送收到的数据，一个用于逻辑主线程向send goroutine传送待发送的数据，是这样的么？

实际上需要 3 个 goroutine，一个 read，一个 send，还有一个 handle。

read goroutine 读，然后写入 recevice chan。

write goroutine 把 send chan 的东西写。

handle goroutine 是 conn 的主要处理逻辑，负责把 recevice chan 的东西读出来 call 业务逻辑。

业务逻辑中要写数据就直接写入 send chan。

这样就可以保证，业务逻辑的读写都是在 handle goroutine 上处理，而避免 race 产生。

如果需要定时任务（比如心跳），就在 handle goroutine 上加上一个 timer.C；

如果需要 goroutine 下发任务，在 handle goroutine 增加一个 task chan，hanlde 收到 task 后处理业务；

如果需要输出结果，那就增加 result chan，业务逻辑把数据输出即可。

----------------------------

还有，如果我开2个goroutine的话，client断开连接了，假设recv goroutine先发生err并且close(fd)，那在send goroutine中该如何处理呢？有可能不应该这样处理，那应该怎么处理呢？

如果 net.Conn Close() 了，不论 Read() 阻塞还是 Write() 阻塞都会立即收到 err 返回。

一般来说，Write() 是不可能主动知道连接断开的，除非是 SetDeadline() 猜测对方断掉了，指定时间内没有写成功就认为是断开。Read() 是可以主动收到对方发来的断开（TCP FIN），但也没办法知道异常的断开（当然也可以设置超时）。

无论是谁，是确实收到 FIN 还是 Deadline 猜测断开，只要 Close() 大家就知道连接断开了。

handle goroutine 还有一个用处就是：你的程序主动结束的时候，能正确的 close conn，让对方知道你是真的断开了，而不用去猜。

mina与netty都是Trustin Lee的作品，所以在很多方面都十分相似，他们线程模型也是基本一致，采用了Reactors in threads模型，即Main Reactor + Sub Reactors的模式。由main reactor处理连接相关的任务：accept、connect等，当连接处理完毕并建立