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

以下是进级请求处理的基准：标准net/http办事器与net.Listen()加零拷贝进级：

BenchmarkUpgradeHTTP 5156 ns/op 8576 B/op 9 allocs/op  
BenchmarkUpgradeTCP 973 ns/op 0 B/op 0 allocs/op

切换到ws和零拷贝进级节俭了别的24 GB内存 - 这是由net/http处理法度榜样请求处理时为I/O缓冲区分派的空间。

概要

让我们结合代码告诉你我们做的优化。

攫取内部缓冲区的goroutine是异常昂贵的。解决筹划：netpoll(epoll，kqueue); 重用缓冲区。
写入内部缓冲区的goroutine是异常昂贵的。解决筹划：须要时启动goroutine; 重用缓冲区。
DDOS，netpoll将无法工作。解决筹划：从新应用数量限制的goroutines。
net/http不是处理进级到WebSocket的最快办法。解决筹划：在连接上应用零拷贝进级。

结论

这就是办事器代码的样子：

邮件轮询涉及每秒大年夜约50,000个HTTP萌芽，个中60%返回304状况，这意味着邮箱没有变更。

import ( 
    "net" 
    "github.com/gobwas/ws" 
) 
 
ln, _ := net.Listen("tcp", ":8080") 
 
for { 
    // Try to accept incoming connection inside free pool worker. 
    // If there no free workers for 1ms, do not accept anything and try later. 
    // This will help us to prevent many self-ddos or out of resource limit cases. 
    err := pool.ScheduleTimeout(time.Millisecond, func() { 
        conn := ln.Accept() 
        _ = ws.Upgrade(conn) 
 
        // Wrap WebSocket connection with our Channel struct. 
        // This will help us to handle/send our app's packets. 
        ch := NewChannel(conn) 
 
        // Wait for incoming bytes from connection. 
        poller.Start(conn, netpoll.EventRead, func() { 
            // Do not cross the resource limits. 
            pool.Schedule(func() { 
                // Read and	
			 6/7   首页 上一页 4 5 6 7 下一页 尾页	
			

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


本文标题：如何使用Go建开发高负载WebSocket服务器
地址：http://www.17bianji.com/lsqh/37391.html
 1/2    1