tcp

package

v0.0.0-...-3153823 Latest Latest Go to latest Published: Nov 30, 2020 License: MIT Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/alex-my/mugo-core

Documentation ¶

Overview ¶

Package tcp TCP 服务器

Index ¶

func NewServer(onHander network.MessageHander, sessionManager network.SessionManager, ...) network.Peer
type Config
type Option

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewServer ¶

func NewServer(onHander network.MessageHander, sessionManager network.SessionManager, opts ...Option) network.Peer

NewServer 创建一个 tcp 服务器

Types ¶

type Config ¶

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

Config 一些配置

type Option ¶

type Option func(*server)

Option ..

func WithCloseTimeout ¶

func WithCloseTimeout(closeTimeout time.Duration) Option

WithCloseTimeout 设置服务名称

func WithDatapack ¶

func WithDatapack(datapack network.Datapack) Option

WithDatapack 封包与解包器

func WithHost ¶

func WithHost(host string) Option

WithHost 设置监听地址

func WithIPVersion ¶

func WithIPVersion(ipVersion string) Option

WithIPVersion 设置 IP 版本 ipVersion: "tcp", "tcp4", "tcp6"

func WithLogger ¶

func WithLogger(logger logger.Logger) Option

WithLogger 设置日志

func WithMaxConnNum ¶

func WithMaxConnNum(maxConnNum int) Option

WithMaxConnNum 设置连接数量上限

func WithName ¶

func WithName(name string) Option

WithName 设置服务名称

func WithOnConnClose ¶

func WithOnConnClose(onConnClose network.ConnFunc) Option

WithOnConnClose 客户端连接关闭

func WithOnConnected ¶

func WithOnConnected(onConnected network.ConnFunc) Option

WithOnConnected 客户端连接到来

func WithOnServerStart ¶

func WithOnServerStart(onServerStart network.ServerFunc) Option

WithOnServerStart 服务器启动时触发，此时尚未有客户端连进来

func WithPort ¶

func WithPort(port int) Option

WithPort 设置监听端口

func WithRecvBufferSize ¶

func WithRecvBufferSize(recvBufferSize int) Option

WithRecvBufferSize 设置连接数量上限

func WithRecvDeadLine ¶

func WithRecvDeadLine(recvDeadLine time.Duration) Option

WithRecvDeadLine 设置连接数量上限

func WithRecvQueueSize ¶

func WithRecvQueueSize(recvQueueSize int) Option

WithRecvQueueSize 接收到的消息队列大小，接收到的消息由 Session 放到 Peer 的队列中，异步处理

func WithSendBufferSize ¶

func WithSendBufferSize(sendBufferSize int) Option

WithSendBufferSize 设置连接数量上限

func WithSendDeadLine ¶

func WithSendDeadLine(sendDeadLine time.Duration) Option

WithSendDeadLine 设置连接数量上限

func WithSendQueueSize ¶

func WithSendQueueSize(sendQueueSize int) Option

WithSendQueueSize 发送的消息队列大小，消息优先发送到消息队列，然后写入到套接字中

func WithWhetherCloseConnWhenFailed ¶

func WithWhetherCloseConnWhenFailed(isForceClose bool) Option

WithWhetherCloseConnWhenFailed 当错误发生时，是否关闭连接

func WithonServerClose ¶

func WithonServerClose(onServerClose network.ServerFunc) Option

WithonServerClose 服务端关闭时触发，此时尚已关闭客户端连接

Source Files ¶

View all Source files

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