server

package

v0.0.1 Latest Latest Go to latest Published: Nov 14, 2025 License: MIT Imports: 7 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/EquentR/simple-rpc

Links

Open Source Insights

Documentation ¶

Overview ¶

Package server 提供TCP服务器实现包括连接管理、路由、工作池等功能

Index ¶

type Conn
type Mux
- func NewMux() *Mux
- func (mx *Mux) Handle(path string, h rpc.Handler)
type Server
- func New(addr string, cfg *tls.Config, workers int) *Server
- func (s *Server) Serve() error
- func (s *Server) Shutdown(d time.Duration)
type WorkerPool
- func NewWorkerPool(size int) *WorkerPool

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Conn ¶

type Conn = conn.Connection

Conn 类型别名，使用conn.Connection

type Mux ¶

type Mux struct {
	// contains filtered or unexported fields
}

Mux 是路由多路复用器，管理路由到处理函数的映射

func NewMux ¶

func NewMux() *Mux

NewMux 创建新的路由多路复用器

func (*Mux) Handle ¶

func (mx *Mux) Handle(path string, h rpc.Handler)

Handle 注册路由处理函数

type Server ¶

type Server struct {
	Addr      string      // 服务器监听地址
	TLSConfig *tls.Config // TLS配置
	Mux       *Mux        // 路由多路复用器
	Pool      *WorkerPool // 工作池
	// contains filtered or unexported fields
}

Server TCP服务器

func New ¶

func New(addr string, cfg *tls.Config, workers int) *Server

New 创建新的TCP服务器

func (*Server) Serve ¶

func (s *Server) Serve() error

Serve 启动服务器，开始监听和处理连接

func (*Server) Shutdown ¶

func (s *Server) Shutdown(d time.Duration)

Shutdown 优雅地关闭服务器

type WorkerPool ¶

type WorkerPool struct {
	// contains filtered or unexported fields
}

WorkerPool 管理处理请求的goroutine

func NewWorkerPool ¶

func NewWorkerPool(size int) *WorkerPool

NewWorkerPool 创建工作池

func (*WorkerPool) Start ¶

func (p *WorkerPool) Start(size int)

Start 启动工作池，创建指定数量的工作goroutine

func (*WorkerPool) Stop ¶

func (p *WorkerPool) Stop()

Stop 停止工作池

func (*WorkerPool) Submit ¶

func (p *WorkerPool) Submit(ctx *rpc.Context)

Submit 提交任务到工作池

Source Files ¶

View all Source files

server.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL