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)