tp-micro

Ants

Ants is a highly available microservice platform based on Ant and Teleport.

简体中文

1. Install

go version ≥ 1.9

go get -u github.com/xiaoenai/ants/...

2. Feature

• Support auto service-discovery
• Supports custom service linker
• Support load balancing
• Support NIO and connection pool
• Support custom protocol
• Support custom body codec
• Support plug-in expansion
• Support heartbeat mechanism
• Detailed log information, support print input and output details
• Support for setting slow operation alarm thresholds
• Support for custom log
• Support smooth shutdown and update
• Support push handler
• Support network list: tcp, tcp4, tcp6, unix, unixpacket and so on
• Client support automatically redials after disconnection

3. Project Structure

(recommend)

├── README.md
├── main.go
├── api
│   ├── handlers.gen.go
│   ├── handlers.go
│   ├── router.gen.go
│   └── router.go
├── logic
│   └── xxx.go
├── sdk
│   ├── rpc.gen.go
│   ├── rpc.gen_test.go
│   ├── rpc.go
│   └── rpc_test.go
└── types
    ├── types.gen.go
    └── types.go

Desc:

• add .gen suffix to the file name of the automatically generated file

4. Demo of Ant

• server

package main

import (
	"github.com/henrylee2cn/ant"
	tp "github.com/henrylee2cn/teleport"
)

// Args args
type Args struct {
	A int
	B int `param:"<range:1:>"`
}

// P handler
type P struct {
	tp.PullCtx
}

// Divide divide API
func (p *P) Divide(args *Args) (int, *tp.Rerror) {
	return args.A / args.B, nil
}

func main() {
	srv := ant.NewServer(ant.SrvConfig{
		ListenAddress: ":9090",
	})
	srv.RoutePull(new(P))
	srv.Listen()
}

• client

package main

import (
	"github.com/henrylee2cn/ant"
)

func main() {
	cli := ant.NewClient(
		ant.CliConfig{},
		ant.NewStaticLinker(":9090"),
	)
	defer	cli.Close()

	type Args struct {
		A int
		B int
	}

	var reply int
	rerr := cli.Pull("/p/divide", &Args{
		A: 10,
		B: 2,
	}, &reply).Rerror()
	if rerr != nil {
		ant.Fatalf("%v", rerr)
	}
	ant.Infof("10/2=%d", reply)
	rerr = cli.Pull("/p/divide", &Args{
		A: 10,
		B: 0,
	}, &reply).Rerror()
	if rerr == nil {
		ant.Fatalf("%v", rerr)
	}
	ant.Infof("test binding error: ok: %v", rerr)
}

More

5. License

Ants is under Apache v2 License. See the LICENSE file for the full license text