diff --git a/server/constants.go b/server/constants.go index 1df8385..79b6c80 100644 --- a/server/constants.go +++ b/server/constants.go @@ -22,7 +22,7 @@ const ( const ( DefaultMessageBufferSize = 1024 - DefaultMessageChannelSize = 1024 * 4096 + DefaultMessageChannelSize = 1024 * 64 DefaultAsyncPoolSize = 256 DefaultWebsocketReadDeadline = 30 * time.Second ) diff --git a/server/options.go b/server/options.go index a7ad9d6..610d35b 100644 --- a/server/options.go +++ b/server/options.go @@ -69,6 +69,7 @@ func WithWebsocketCompression(level int) Option { } // WithMessageChannelSize 通过指定消息通道大小的方式创建服务器 +// - 足够大的消息通道可以确保服务器在短时间内接收到大量的消息而不至于阻塞 // - 默认值为 DefaultMessageChannelSize func WithMessageChannelSize(size int) Option { return func(srv *Server) { diff --git a/server/server_example_test.go b/server/server_example_test.go index 7fd49af..1f0c8ac 100644 --- a/server/server_example_test.go +++ b/server/server_example_test.go @@ -8,13 +8,14 @@ import ( func ExampleNew() { srv := server.New(server.NetworkWebsocket, server.WithDeadlockDetect(time.Second*5), + server.WithPProf("/debug/pprof"), ) srv.RegConnectionReceivePacketEvent(func(srv *server.Server, conn *server.Conn, packet server.Packet) { conn.Write(packet) }) - go func() { time.Sleep(1 * time.Second); srv.Shutdown() }() + //go func() { time.Sleep(1 * time.Second); srv.Shutdown() }() if err := srv.Run(":9999"); err != nil { panic(err) }