refactor: server 移除 WithConnMessageChannelSize 可选项

server/constants.go

@@ -24,7 +24,6 @@ const (
 	DefaultMessageBufferSize     = 1024
 	DefaultAsyncPoolSize         = 256
 	DefaultWebsocketReadDeadline = 30 * time.Second
-	DefaultConnectionChannelSize = 1024 * 10
 )
 
 const (

server/options.go

@@ -42,19 +42,6 @@ type runtime struct {
 	websocketCompression      int              // websocket压缩等级
 	websocketWriteCompression bool             // websocket写入压缩
 	limitLife                 time.Duration    // 限制最大生命周期
-	connMessageChannelSize    int              // 连接消息通道大小
-}
-
-// WithConnMessageChannelSize 通过指定连接消息通道大小的方式创建服务器
-//   - 足够大的消息通道可以确保连接在写入消息时不至于阻塞
-//   - 默认值为 DefaultConnectionChannelSize
-func WithConnMessageChannelSize(size int) Option {
-	return func(srv *Server) {
-		if size <= 0 {
-			size = DefaultConnectionChannelSize
-		}
-		srv.connMessageChannelSize = size
-	}
 }
 
 // WithLimitLife 通过限制最大生命周期的方式创建服务器

server/server.go

@@ -33,8 +33,7 @@ import (
 func New(network Network, options ...Option) *Server {
 	server := &Server{
 		runtime: &runtime{
-			messagePoolSize:        DefaultMessageBufferSize,
-			connMessageChannelSize: DefaultConnectionChannelSize,
+			messagePoolSize: DefaultMessageBufferSize,
 		},
 		option:       &option{},
 		network:      network,