nano

package module
v0.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 17, 2021 License: MIT Imports: 20 Imported by: 0

README

Go Nano

Nano is a lightweight and efficient framework in Golang for real-time interactive systems. It provides a core network architecture and a series of tools and libraries that can help developers eliminate boring duplicate work for common underlying logic. The goal of nano is to improve development efficiency by eliminating the need to spend time on repetitious network related programming.

Nano was designed for server-side applications like real-time games, social games, mobile games, etc of all sizes. Nano also contains a simple JavaScript library to help developing web games.

How to build a system with Nano

What does a Nano application look like?

The simplest "nano" application as shown in the following figure, you can make powerful applications by combining different components.

+-------------+  Response
| Nano Client <-----------+
|(Web Browser)|           |
+-------------+           | Request   +-------------+
                          +----------->             |
+-------------+                       |             |
| Nano Client <-Persistent Connection-> Nano Server |
|(Mobile App) |                       | (Components)|
+-------------+           +----------->             |
                          | Notify    |             |
+-------------+           |           +-------------+
| Nano Client <-----------+
|(Desktop App)|   Push
+-------------+

In fact, the nano application server is a collection of Component, and a component is a bundle of Handler. once you register a component to nano, nano will register all methods that can be converted to Handler to nano application server. The handler will be called while client request. The handler will receive two parameters while handling a message:

  • *session.Session: corresponding a client that apply this request or notify.
  • *protocol.FooBar: the payload of the request.

While you had processed your logic, you can response or push message to the client by session.Response(payload) and session.Push('eventName', payload), or returns error when some unexpected data received.

See Get Started for more informations.

How to build distributed system with Nano

Nano contains built-in distributed system solution, and make you creating a distributed game server easily.

See The distributed chat demo

The Nano will remain simple, but you can perform any operations in the component and get the desired goals. You can startup a group of Nano application as agent to dispatch message to backend servers.

How to execute the asynchronous task
func (manager *PlayerManager) Login(s *session.Session, msg *ReqPlayerLogin) error {
    var onDBResult = func(player *Player) {
        manager.players = append(manager.players, player)
        s.Push("PlayerSystem.LoginSuccess", &ResPlayerLogin)
    }

    // run slow task in new gorontine
    go func() {
        player, err := db.QueryPlayer(msg.PlayerId) // ignore error in demo
        // handle result in main logical gorontine
        scheduler.Run(func(){ onDBResult(player) })
    }
    return nil
}

Documents

Resources

Go version

>= go1.14

Installation

go get github.com/aclisp/go-nano

# dependencies
go get -u github.com/golang/protobuf
go get -u github.com/gorilla/websocket

Benchmark

# Case:   PingPong
# OS:     Windows 10
# Device: i5-6500 3.2GHz 4 Core/1000-Concurrent   => IOPS 11W(Average)
# Other:  ...

cd ./benchmark/io
go test -v -tags "benchmark"

License

MIT License

Fork

This project is a refined version of the original repo made by Lonng. It has following critical improvements:

  • a new scheduler
  • tidy logging messages
  • various bug fixing
  • renamed some APIs
  • fixed broken demos and docs
  • remove stale sessions
  • shrink rpc client
  • cluster: smarter startup: unregister then retry

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrCloseClosedGroup   = errors.New("close closed group")
	ErrClosedGroup        = errors.New("group closed")
	ErrMemberNotFound     = errors.New("member not found in the group")
	ErrSessionDuplication = errors.New("session already existed in the current group")
)

Errors that could be occurred during message handling.

View Source
var VERSION = "0.5.0"

VERSION returns current nano version

Functions

func Listen

func Listen(addr string, opts ...Option)

Listen listens on the TCP network address addr and then calls Serve with handler to handle requests on incoming connections.

func Shutdown

func Shutdown()

Shutdown send a signal to let 'nano' shutdown itself.

Types

type Group

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

Group represents a session group which used to manage a number of sessions, data send to the group will send to all session in it.

func NewGroup

func NewGroup(n string) *Group

NewGroup returns a new group instance

func (*Group) Add

func (c *Group) Add(session *session.Session) error

Add add session to group

func (*Group) Broadcast

func (c *Group) Broadcast(route string, v interface{}) error

Broadcast push the message(s) to all members

func (*Group) Close

func (c *Group) Close() error

Close destroy group, which will release all resource in the group

func (*Group) Contains

func (c *Group) Contains(uid int64) bool

Contains check whether a UID is contained in current group or not

func (*Group) Count

func (c *Group) Count() int

Count get current member amount in the group

func (*Group) Leave

func (c *Group) Leave(s *session.Session) error

Leave remove specified UID related session from group

func (*Group) LeaveAll

func (c *Group) LeaveAll() error

LeaveAll clear all sessions in the group

func (*Group) Member

func (c *Group) Member(uid int64) (*session.Session, error)

Member returns specified UID's session

func (*Group) Members

func (c *Group) Members() []int64

Members returns all member's UID in current group

func (*Group) Multicast

func (c *Group) Multicast(route string, v interface{}, filter SessionFilter) error

Multicast push the message to the filtered clients

type Option

type Option func(*cluster.Options)

Option is a function to set cluster options

func WithCheckOriginFunc

func WithCheckOriginFunc(fn func(*http.Request) bool) Option

WithCheckOriginFunc sets the function that check `Origin` in http headers

func WithComponents

func WithComponents(components *component.Components) Option

WithComponents sets the Components

func WithDebugMode

func WithDebugMode() Option

WithDebugMode let 'nano' to run under Debug mode.

func WithDictionary

func WithDictionary(dict map[string]uint16) Option

WithDictionary sets routes map

func WithGateAddr

func WithGateAddr(addr string) Option

WithGateAddr sets the listen address which is used by client to establish connection.

func WithGrpcOptions

func WithGrpcOptions(opts ...grpc.DialOption) Option

WithGrpcOptions sets the grpc dial options

func WithHTTPHandler

func WithHTTPHandler(pattern string, handler http.Handler) Option

WithHTTPHandler sets a http handler that shares with WebSocket server

func WithHandshakeValidator

func WithHandshakeValidator(fn func([]byte) error) Option

WithHandshakeValidator sets the function that Verify `handshake` data

func WithHeartbeatInterval

func WithHeartbeatInterval(d time.Duration) Option

WithHeartbeatInterval sets Heartbeat time interval

func WithIsWebsocket

func WithIsWebsocket(enableWs bool) Option

WithIsWebsocket indicates whether current node WebSocket is enabled

func WithLabel

func WithLabel(label string) Option

WithLabel sets the current node label in cluster

func WithLogger

func WithLogger(l log.Logger) Option

WithLogger overrides the default logger

func WithMaster

func WithMaster() Option

WithMaster sets the option to indicate whether the current node is master node

func WithPipeline

func WithPipeline(pipeline pipeline.Pipeline) Option

WithPipeline sets processing pipelines

func WithRegistryAddr

func WithRegistryAddr(addr string, regInterval ...time.Duration) Option

WithRegistryAddr sets the registry address option, it will be the service address of master node and an advertise address which cluster member to connect

func WithSerializer

func WithSerializer(serializer serialize.Serializer) Option

WithSerializer customizes application serializer, which automatically Marshal and UnMarshal handler payload

func WithTSLConfig

func WithTSLConfig(certificate, key string) Option

WithTSLConfig sets the `key` and `certificate` of TSL

func WithWSPath

func WithWSPath(path string) Option

WithWSPath sets websocket URI path, effective when WebSocket is enabled

type SessionFilter

type SessionFilter func(*session.Session) bool

SessionFilter represents a filter which was used to filter session when Multicast, the session will receive the message while filter returns true.

Directories

Path Synopsis
benchmark
io
examples
internal
env
Package env represents the environment of the current process, includes work path and config path etc.
Package env represents the environment of the current process, includes work path and config path etc.
log

Jump to

Keyboard shortcuts

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