Jupiter:

• Jupiter 是一款性能非常不错的, 轻量级的分布式服务框架

Jupiter Architecture:

       ═ ═ ═▷ init         ─ ─ ─ ▷ async       ──────▶ sync
----------------------------------------------------------------------------------------

                        ┌ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─
                                   ┌ ─ ─ ─ ┐ │
       ─ ─ ─ ─ ─ ─ ─ ─ ─│ Registry  Monitor ───────────────────────────┐
      │                            └ ─ ─ ─ ┘ │                         │
                        └ ─ ─△─ ─ ─ ─ ─△─ ─ ─                          ▼
      │                                                           ┌ ─ ─ ─ ─
    Notify                   ║         ║                            Telnet │
      │         ═ ═ ═ ═ ═ ═ ═           ═ ═ ═ ═ ═ ═ ═ ═ ═         └ ─ ─ ─ ─
               ║                                         ║             ▲
      │    Subscribe                                  Register         │
               ║                                         ║             │
      │  ┌ ─ ─ ─ ─ ─                          ┌ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─    │
                    │─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ▷           ┌ ─ ─ ─ ┐ │   │
      └ ▷│ Consumer           Invoke          │ Provider  Monitor ─────┘
                    │────────────────────────▶           └ ─ ─ ─ ┘ │
         └ ─ ─ ─ ─ ─                          └ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─

RELEASE-NOTES

性能:

• 小数据包请求(不带业务)在四核刀片服务器上可达到17w+的tps, 详情见 Benchmark
• 参考: 多个 RPC 框架的 Benchmark 见这里

文档:

• High performance RPC with netty
• High performance RPC with netty.pdf
• Wiki
• 其他文档
• 发展路线

一次 RPC 调用:

感谢 @远墨 提供的图

快速开始:

工程依赖:

• JDK1.8 或更高版本
• 依赖管理工具: Maven3.x 版本

最新版本OSS下载

最新版本Maven中心仓库下载

Maven依赖:

    org.jupiter-rpc
    jupiter-all
    ${jupiter.version}

简单调用示例:

1. 创建服务接口:

@ServiceProvider(group = "test", name = "serviceTest")
public interface ServiceTest {
    String sayHelloString();
}

@ServiceProvider:
    - 建议每个服务接口通过此注解来指定服务信息, 如不希望业务代码对jupiter依赖也可以不使用此注解而手动去设置服务信息
        + group: 服务组别(选填, 默认组别为'Jupiter')
        + name: 服务名称(选填, 默认名称为接口全限定名称)

2. 创建服务实现:

@ServiceProviderImpl(version = "1.0.0")
public class ServiceTestImpl implements ServiceTest {

@Override
public String sayHelloString() {
    return "Hello jupiter";
}
}
@ServiceProviderImpl:
    - 建议每个服务实现通过此注解来指定服务版本信息, 如不希望业务代码对jupiter依赖也可以不使用此注解而手动去设置版本信息
        + version: 服务版本号(选填, 默认版本号为'1.0.0')

3. 启动注册中心:

- 选择1: 使用 jupiter 默认的注册中心:

public class HelloJupiterRegistryServer {

public static void main(String[] args) {
    // 注册中心
    RegistryServer registryServer = RegistryServer.Default.createRegistryServer(20001, 1);
    try {
        registryServer.startRegistryServer();
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}
}

- 选择2: 使用 zookeeper 作为注册中心:

默认注册中心只建议在测试环境使用, 线上建议使用 zookeeper 实现

// 设置使用 zookeeper 作为注册中心
JServer server = new DefaultServer(RegistryService.RegistryType.ZOOKEEPER)
JClient client = new DefaultClient(RegistryService.RegistryType.ZOOKEEPER)
在 server 和 client 中配置 jupiter-registry-zookeeper 依赖(jupiter-all 包含 jupiter-registry-zookeeper)

    org.jupiter-rpc
    jupiter-registry-zookeeper
    ${jupiter.version}

4. 启动服务提供(Server):

public class HelloJupiterServer {

public static void main(String[] args) throws Exception {
    JServer server = new DefaultServer().withAcceptor(new JNettyTcpAcceptor(18090));
    // provider
    ServiceTestImpl service = new ServiceTestImpl();
    // 本地注册
    ServiceWrapper provider = server.serviceRegistry()
            .provider(service)
            .register();
    // 连接注册中心
    server.connectToRegistryServer("127.0.0.1:20001");
    // 向注册中心发布服务
    server.publish(provider);
    // 启动server
    server.start();
}
}

5. 启动服务消费者(Client)

public class HelloJupiterClient {

public static void main(String[] args) {
    JClient client = new DefaultClient().withConnector(new JNettyTcpConnector());
    // 连接RegistryServer
    client.connectToRegistryServer("127.0.0.1:20001");
    // 自动管理可用连接
    JConnector.ConnectionWatcher watcher = client.watchConnections(ServiceTest.class);
    // 等待连接可用
    if (!watcher.waitForAvailable(3000)) {
        throw new ConnectFailedException();
    }

    ServiceTest service = ProxyFactory.factory(ServiceTest.class)
            .version("1.0.0")
            .client(client)
            .newProxyInstance();

    service.sayHelloString();
}
}

Server/Client 代码示例

新特性

v1.3 新增

InvokeType.AUTO

CompletableFuture

结合Spring使用示例:

1. Server端配置:

2. Client 端配置:

SpringServer/SpringClient 代码示例

更多示例代码

其他

• qq交流群: 397633380
• 邮件交流: [email protected]