From 36f200571ad2c7b421caaaf43eda65eac423813a Mon Sep 17 00:00:00 2001 From: kercylan98 Date: Fri, 19 May 2023 11:23:32 +0800 Subject: [PATCH] =?UTF-8?q?=E5=87=BD=E6=95=B0=E5=90=8D=E7=A7=B0=E8=B0=83?= =?UTF-8?q?=E6=95=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- main.go | 2 +- server/options.go | 8 ++++---- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/main.go b/main.go index 5003bac..866b688 100644 --- a/main.go +++ b/main.go @@ -4,7 +4,7 @@ import "github.com/kercylan98/minotaur/server" // 无意义的测试main入口 func main() { - srv := server.New(server.NetworkWebsocket, server.WithConnectPacketDiversion(3, 2)) + srv := server.New(server.NetworkWebsocket, server.WithMessageDiversion(3, 2)) srv.RegConnectionReceiveWebsocketPacketEvent(func(srv *server.Server, conn *server.Conn, packet []byte, messageType int) { conn.Write(packet, messageType) }) diff --git a/server/options.go b/server/options.go index 84eda17..2ccf809 100644 --- a/server/options.go +++ b/server/options.go @@ -59,14 +59,14 @@ func WithCross(crossName string, serverId int64, cross Cross) Option { } } -// WithConnectPacketDiversion 通过连接数据包消息分流的方式创建服务器 -// - 连接消息分流后数据包消息将会从其他消息类型中独立出来，并且由多个消息管道及协程进行处理 +// WithMessageDiversion 通过消息分流的方式创建服务器 +// - 连接消息分流后消息将会从其他消息类型中独立出来，并且由多个消息管道及协程进行处理 // - 默认不会进行消息分流 // - 需要注意并发编程 -func WithConnectPacketDiversion(diversionNumber, channelSize int) Option { +func WithMessageDiversion(diversionNumber, channelSize int) Option { return func(srv *Server) { if srv.network == NetworkHttp || srv.network == NetworkGRPC { - log.Warn("WithConnectPacketDiversion", zap.String("Network", string(srv.network)), zap.Error(ErrOnlySupportSocket)) + log.Warn("WithMessageDiversion", zap.String("Network", string(srv.network)), zap.Error(ErrOnlySupportSocket)) return } srv.diversionMessageChannels = make([]chan *message, diversionNumber)