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

case p.work <- task:

case p.sem <- struct{}{}:

go p.worker(task)

}

func (p *Pool) worker(task func()) {

defer func() { <-p.sem }

for {

task()

task = <-p.work

}

如今我们的netpoll代码如下：

所以如今我们攫取数据包可以在池中应用了余暇的goroutine。

同样，我们将更改Send() ：

pool := gopool.New(128) 
 
func (ch *Channel) Send(p Packet) { 
    if c.noWriterYet() { 
        pool.Schedule(ch.writer) 
    } 
    ch.send <- p 
}

而不是go ch.writer() ，我们想写一个重用的goroutine。是以，对于N goroutines池，我们可以包管在N请求同时处理并且达到N + 1我们不会分派N + 1缓冲区进行攫取。 goroutine池还许可我们限制新连接的Accept()和Upgrade() ，并避免大年夜多半情况下被DDoS打倒。

零拷贝进级

让我们大年夜WebSocket协定中偏离一点。如前所述，客户端应用HTTP进级请求切换到WebSocket协定。协定是样子：

也就是说，在我们的例子中，我们须要HTTP要乞降header才能切换到WebSocket协定。这个常识点和http.Request的内部实现注解我们可以做优化。我们会在处理HTTP请求时摈弃不须要的内存分派和复制，并放弃标准的net/http办事器。

例如， http.Request 包含一个具有雷同名称的头文件类型的字段，它经由过程将数据大年夜连接复制到值字符串而无前提填充所有请求头。想像一下这个字段中可以保存若干额外的数据，例如大年夜型Cookie头。

然则要做什么呢?

WebSocket实现

如不雅我们有一个如许的API的看维我们可以大年夜连接中攫取数据包，如下所示(数据包写入看起来差不多)：

我们来看看“reader”的实现：

// getReadBuf, putReadBuf are intended to  
// reuse *bufio.Reader (with sync.Pool for example). 
func getReadBuf(io.Reader) *bufio.Reader 
func putReadBuf(*bufio.Reader) 
 
// readPacket must be called when data could be read from conn. 
func readPacket(conn io.Reader) error { 
    buf := getReadBuf() 
    defer putReadBuf(buf) 
 
    buf.Reset(conn) 
    frame, _ := ReadFrame(buf) 
    parsePacket(frame.Payload) 
    //... 
}

简而言之，如今是制造我们本身库的时刻了。

github.com/gobwas/ws

完美! 经由过程摆脱两个持续运行的goroutine中的客栈和I/O缓冲区，我们节俭了48 GB 。

为了避免将协定操作逻辑强加给用户，我们编写了WS库。所有读写办法都接收标准的io.Reader和io.Writer接口，可以应用或不应用缓冲或任何其他I/O包装器。

除潦攀来自标准net/http进级请求之外， ws支撑零拷贝进级，进级请求的处理和切换到WebSocket，而无需内存分派或复制。 ws.Upgrade()接收io.ReadWriter ( net.Conn实现了这个接口)。换句话说，我们可以应用标准的net.Listen()并将接收到的连接大年夜ln.Accept()急速传递给ws.Upgrade() 。该库可以复制任何请求数据以供将来在应用法度榜样中应用(例如， Cookie以验证会话)。

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

　　推荐阅读

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

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

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

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

1/2 1