如何使用Go建开发高负载WebSocket服务器

for pkt := range c.send {

_ := writePacket(buf, pkt)

buf.Flush()

}

是以，我们须要别的24 GB的内存来保持300万个链接。

所以，我们的法度榜样即使什么都没做，也须要72G内存。

优化

我们往返想介绍部分中谈到的内容，并记住用户连接的行动。切换到WebSocket之后，客户端发送一个包含相干事宜的数据包，换句话说就是订阅事宜。然后(不推敲诸如ping/pong等技巧信息)，客户端可能在全部连接寿射中不二送任何其他信息。

连接寿命可能是几秒到几天。

不幸的是，在我们的办事器优化时存在的所有库都许可我们对标准的net/http办事器进行进级。此外，所有库都不克不及应用所有上述读写竽暌古化。为使这些优化可以或许正常工作，我们必须应用一个相当初级其余API来处理WebSocket。要重用缓冲区，我们须要procotol函数看起来像如许：

如今很明显，某些工作可以做得更好，不是吗?

Netpoll

你还记得bufio.Reader.Read()内部，Channel.reader()实现了在没有新数据的时刻conn.read()会被锁。如不雅连接中稀有据，Go运行时“唤醒”我们的goroutine并许可它攫取下一?数据包。之后，goroutine再次锁定，等待新的数据。让我们看看Go运行时若何懂得goroutine必须被“唤醒”。如不雅我们看看conn.Read()实现，我们将在个中看到net.netFD.Read()调用：

// net/fd_unix.go 
 
func (fd *netFD) Read(p []byte) (n int, err error) { 
    //... 
    for { 
        n, err = syscall.Read(fd.sysfd, p) 
        if err != nil { 
            n = 0 
            if err == syscall.EAGAIN { 
                if err = fd.pd.waitRead(); err == nil { 
                    continue 
                } 
            } 
        } 
        //... 
        break 
    } 
    //... 
}

Go在非浊宣模式下应用套接字。 EAGAIN表示，套接字中没稀有据，并且在大年夜空套接字攫取时不会被锁定，操作体系将控制权返还给我们。

我们大年夜连接文件描述符中看到一个read()体系调用。如不雅攫取返回EAGAIN缺点，则运行时会使pollDesc.waitRead()调用：

// net/fd_poll_runtime.go 
 
func (pd *pollDesc) waitRead() error { 
   return pd.wait('r') 
} 
 
func (pd *pollDesc) wait(mode int) error { 
   res := runtime_pollWait(pd.runtimeCtx, mode) 
   //... 
}

如不雅我们深刻发掘，我们将看到netpoll是应用Linux中的epoll和BSD中的kqueue来实现的。为什么不应用雷同的办法来进行连接? 我们可以分派一个读缓冲区，只有在真正有须要时才应用goroutine：当套接字中有真实可读的数据时。

3/7 首页上一页 1 2 3 4 5 6 下一页尾页

　　推荐阅读

　　通过云库存管理遏制随需应变的自助服务风险

51CTO诚邀您9月23号和秒拍/国美/美团元专家一路聊智能CDN的优化之路，抓紧时光哦！然则因为云计算的按需自助办事模式，营业的其他部分经常会供给新办事，并绕开企业的IT办事，这可能会增长>>>详细阅读

本文标题：如何使用Go建开发高负载WebSocket服务器

地址：http://www.17bianji.com/lsqh/37391.html

1/2 1