diff --git a/server/constants.go b/server/constants.go index fe375d2..fbbe1c8 100644 --- a/server/constants.go +++ b/server/constants.go @@ -24,7 +24,6 @@ const ( DefaultMessageBufferSize = 1024 DefaultAsyncPoolSize = 256 DefaultWebsocketReadDeadline = 30 * time.Second - DefaultConnectionChannelSize = 1024 * 10 ) const ( diff --git a/server/options.go b/server/options.go index ad4de9f..e2debab 100644 --- a/server/options.go +++ b/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 通过限制最大生命周期的方式创建服务器 diff --git a/server/server.go b/server/server.go index eab2000..1e882eb 100644 --- a/server/server.go +++ b/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,