Function newServerWithConfig

znet/server.go:129–178

newServerWithConfig creates a server handle based on config (根据config创建一个服务器句柄)

(config *zconf.Config, ipVersion string, opts ...Option)

// newServerWithConfig creates a server handle based on config
// (根据config创建一个服务器句柄)
func newServerWithConfig(config *zconf.Config, ipVersion string, opts ...Option) ziface.IServer {
	logo.PrintLogo()

	s := &Server{
		Name:             config.Name,
		IPVersion:        ipVersion,
		IP:               config.Host,
		Port:             config.TCPPort,
		WsPort:           config.WsPort,
		WsPath:           config.WsPath,
		KcpPort:          config.KcpPort,
		msgHandler:       newMsgHandle(),
		RouterSlicesMode: config.RouterSlicesMode,
		RequestPoolMode:  config.RequestPoolMode,
		ConnMgr:          newConnManager(),
		exitChan:         nil,
		// Default to using Zinx's TLV data pack format
		// (默认使用zinx的TLV封包方式)
		packet:  zpack.Factory().NewPack(ziface.ZinxDataPack),
		decoder: zdecoder.NewTLVDecoder(), // Default to using TLV decode (默认使用TLV的解码方式)
		upgrader: &websocket.Upgrader{
			ReadBufferSize: int(config.IOReadBuffSize),
			CheckOrigin: func(r *http.Request) bool {
				return true
			},
		},
		kcpConfig: &KcpConfig{
			KcpACKNoDelay:      config.KcpACKNoDelay,
			KcpStreamMode:      config.KcpStreamMode,
			KcpNoDelay:         config.KcpNoDelay,
			KcpInterval:        config.KcpInterval,
			KcpResend:          config.KcpResend,
			KcpNc:              config.KcpNc,
			KcpSendWindow:      config.KcpSendWindow,
			KcpRecvWindow:      config.KcpRecvWindow,
			KcpFecDataShards:   config.KcpFecDataShards,
			KcpFecParityShards: config.KcpFecParityShards,
		},
	}

	for _, opt := range opts {
		opt(s)
	}

	// Display current configuration information
	// (提示当前配置信息)
	config.Show()

	return s
}

// NewServer creates a server handle
// (创建一个服务器句柄)