refactor: server 移除 WithConnMessageChannelSize 可选项
This commit is contained in:
parent
1bc32e2026
commit
31c0e1b735
|
@ -24,7 +24,6 @@ const (
|
|||
DefaultMessageBufferSize = 1024
|
||||
DefaultAsyncPoolSize = 256
|
||||
DefaultWebsocketReadDeadline = 30 * time.Second
|
||||
DefaultConnectionChannelSize = 1024 * 10
|
||||
)
|
||||
|
||||
const (
|
||||
|
|
|
@ -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 通过限制最大生命周期的方式创建服务器
|
||||
|
|
|
@ -34,7 +34,6 @@ func New(network Network, options ...Option) *Server {
|
|||
server := &Server{
|
||||
runtime: &runtime{
|
||||
messagePoolSize: DefaultMessageBufferSize,
|
||||
connMessageChannelSize: DefaultConnectionChannelSize,
|
||||
},
|
||||
option: &option{},
|
||||
network: network,
|
||||
|
|
Loading…
Reference in New Issue