项目地址

• https://github.com/lesismal/arpc

Quick start

• start a server

package main

import "github.com/lesismal/arpc"

func main() {
    server := arpc.NewServer()

    // register router
    server.Handler.Handle("/echo", func(ctx *arpc.Context) {
        str := ""
        if err := ctx.Bind(&str); err == nil {
            ctx.Write(str)
        }
    })

    server.Run(":8888")
}

• start a client

package main

import (
    "log"
    "net"
    "time"

    "github.com/lesismal/arpc"
)

func main() {
    client, err := arpc.NewClient(func() (net.Conn, error) {
        return net.DialTimeout("tcp", "localhost:8888", time.Second*3)
    })
    if err != nil {
        panic(err)
    }

    client.Run()
    defer client.Stop()

    req := "hello"
    rsp := ""
    err = client.Call("/echo", &req, &rsp, time.Second*5)
    if err != nil {
        log.Fatalf("Call failed: %v", err)
    } else {
        log.Printf("Call Response: \"%v\"", rsp)
    }
}

网络交互的几种模式

传统RPC的缺点

1. 只支持单向 Call: c->s，不支持 s->c，不支持notify
2. 函数调用的写法，函数返回即结束调用，不支持函数体外的同步/异步回包
3. 多数rpc框架绑定了序列化

ARPC特点

1. 支持c/s双向call、notify
2. 支持自定制协议（tcp，unixsock，kcp，quic...）
3. 支持异步回包，handler函数返回不代表call处理结束，可以handler返回后再回包（同步异步皆可）
4. 支持自定制序列化（pb，msgpack各种，只要你喜欢，随意扩展），为了减少依赖目前默认用的标准库json
5. 提供类似gin的ctx.Bind方法，方便string、[]byte、struct等类型绑定
6. 支持contex，也支持直接使用timeout参数、非多步流程的调用等待写起来更方便
7. 像使用http router一样，不采用函数调用的写法，不依赖反射
8. 支持client pool，因为支持异步并发调用回包，pool实现采用简单的轮询，能够满足性能需要

• 最少依赖，默认使用方式只依赖标准库
• 示例请参考README、examples
• 更多特点请阅读代码，如需扩展，欢迎PR

ARPC性能

• 简单的echo压测

• arpc性能基本与当前其他第一梯队性能的golang rpc处于同样水平范围、甚至更高
• grpc由于使用了http2，性能浪费是不可避免的，这里对比grpc/rpcx只是为了给出个参考系
• 配置较低，更多配置、协议、序列化测试欢迎各位道友自行进行，arpc压测代码: server, client

示例工程

• 用arpc作为基础设施实现了个发布订阅服务：achan，示例请参考README