netcore-go/netcore.go at main · phuhao00/netcore-go · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
// Package netcore 提供NetCore-Go框架的主要入口点
// Author: NetCore-Go Team
// Created: 2024

package netcore

import (
	"github.com/phuhao00/netcore-go/pkg/core"
	"github.com/phuhao00/netcore-go/pkg/http"
	"github.com/phuhao00/netcore-go/pkg/kcp"
	"github.com/phuhao00/netcore-go/pkg/rpc"
	"github.com/phuhao00/netcore-go/pkg/tcp"
	"github.com/phuhao00/netcore-go/pkg/udp"
	"github.com/phuhao00/netcore-go/pkg/websocket"
)

// NewTCPServer 创建TCP服务器
func NewTCPServer(opts ...core.ServerOption) core.Server {
	return tcp.NewTCPServer(opts...)
}

// NewUDPServer 创建UDP服务器
func NewUDPServer(opts ...core.ServerOption) core.Server {
	return udp.NewUDPServer(opts...)
}

// NewWebSocketServer 创建WebSocket服务器
func NewWebSocketServer(opts ...core.ServerOption) core.Server {
	return websocket.NewServer(opts...)
}

// NewRPCServer 创建RPC服务器
func NewRPCServer(opts ...core.ServerOption) *rpc.RPCServer {
	return rpc.NewRPCServer(opts...)
}

// NewServer 创建通用服务器
func NewServer(opts ...core.ServerOption) core.Server {
	return tcp.NewTCPServer(opts...)
}

// NewHTTPServer 创建HTTP服务器
func NewHTTPServer(opts ...core.ServerOption) *http.HTTPServer {
	// 使用core配置创建HTTP服务器
	coreConfig := core.DefaultServerConfig()
	for _, opt := range opts {
		opt(coreConfig)
	}
	return http.NewHTTPServerWithCoreConfig(coreConfig)
}

// NewKCPServer 创建KCP服务器
func NewKCPServer(opts ...core.ServerOption) *kcp.KCPServer {
	return kcp.NewKCPServer(opts...)
}

// ServerConfig 服务器配置（别名）
type ServerConfig = core.ServerConfig

// Config 服务器配置（向后兼容）
type Config struct {
	Host string `json:"host"`
	Port int    `json:"port"`
}

// 导出常用的配置选项
var (
	WithMaxConnections    = core.WithMaxConnections
	WithReadBufferSize    = core.WithReadBufferSize
	WithWriteBufferSize   = core.WithWriteBufferSize
	WithHeartbeat         = core.WithHeartbeat
	WithConnectionPool    = core.WithConnectionPool
	WithMemoryPool        = core.WithMemoryPool
	WithGoroutinePool     = core.WithGoroutinePool
	WithReadTimeout       = core.WithReadTimeout
	WithWriteTimeout      = core.WithWriteTimeout
	WithIdleTimeout       = core.WithIdleTimeout
	WithMetrics           = core.WithMetrics
)

// 导出常用的中间件
var (
	LoggingMiddleware  = core.LoggingMiddleware
	MetricsMiddleware  = core.MetricsMiddleware
	RecoveryMiddleware = core.RecoveryMiddleware
	AuthMiddleware     = core.AuthMiddleware
	RateLimitMiddleware = core.RateLimitMiddleware
)

// 导出核心类型
type (
	Connection     = core.Connection
	Message        = core.Message
	MessageHandler = core.MessageHandler
	Middleware     = core.Middleware
	Context        = core.Context
	ServerStats    = core.ServerStats
	MessageType    = core.MessageType
)

// 导出消息类型常量
var (
	MessageTypeText   = core.MessageTypeText
	MessageTypeBinary = core.MessageTypeBinary
	MessageTypeClose  = core.MessageTypeClose
	MessageTypePing   = core.MessageTypePing
	MessageTypePong   = core.MessageTypePong
)

// 导出核心函数
var (
	NewMessage = core.NewMessage
)