rpcx-java

Unmaintained: 目前没有资源维护这个项目。欢迎有时间的开发者接手。

example

assume you have started a Go rpcx server:

package main

import (
	"context"
	"flag"

	"github.com/smallnest/rpcx/server"
)

var (
	addr = flag.String("addr", "192.168.31.82:8997", "server address")
)

type Echo int

func (t *Echo) Echo(ctx context.Context, args []byte, reply *[]byte) error {
	*reply = []byte("hello" + string(args))
	return nil
}

func main() {
	flag.Parse()

	s := server.NewServer()
	s.RegisterName("echo", new(Echo), "")
	s.Serve("tcp", *addr)
}

You can run it as:

go run main.go

Then you can write the java client:

    @Test
        public void testSendMsg() throws Exception {
            Message req = new Message("Echo", "Echo");
            req.setVersion((byte) 0);
            req.setMessageType(MessageType.Request);
            req.setHeartbeat(false);
            req.setOneway(false);
            req.setCompressType(CompressType.None);
            req.setSerializeType(SerializeType.SerializeNone);
            req.setSeq(123);
            req.metadata.put("test", "1234");
            req.payload = "world".getBytes("UTF-8");

            NettyClient client = new NettyClient(null);
            Message res = client.call("192.168.31.82:8997", req);
            System.out.println(new String(res.payload));
        }

借鉴项目

• dubbo
• rocketmq

feature

• 支持和spring-boot的集成
• 支持服务发现和注册
• 支持扩展(client 和 server都可扩展)
• 支持多语言调用
• 支持qps限流
• 支持accesslog记录
• 支持泛化调用
• 支持同步 异步 oneway调用
• 支持token调用
• 支持client端重试
• 支持调用数据采集
• 支持结果缓存
• 支持热更新
• 支持http gateway访问模式
• 调用失败支持(FailFast Failover Failtry)
• 支持select模式(RandomSelect RoundRobin WeightedRoundRobin SelectByUser)
• 支持优雅关机
• 支持服务治理(通过rpcx-ui)
• 支持服务分组