chenyh
/
vRp.CD2g_test
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

函数名称调整

This commit is contained in:
kercylan98 2023-05-19 11:23:32 +08:00
parent 42894e91a4
commit 36f200571a
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
main.go
View File

@ -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)
})

8
server/options.go
View File

@ -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)