高性能轻量级 RPC 框架 ikasoa

MIT
Java
跨平台
2016-06-01
LarrySu

ikasoa-rpc是一款高性能轻量级的RPC框架,基于apache thrift开发.

  • 抛弃了thrift框架中的idl,客户端可以像调用本地接口一样调用远程接口,减少了idl的学习成本和生成代码的过程.

  • 超轻量级和简单的依赖关系,并不会强依赖某些框架(比如spring).

  • 继承了thrift优秀的性能和跨语言能力,提供了负载均衡和多种序列化实现.并补充了socket连接池,服务发现,监控,数据加密,等配套功能.

  • 包含一个spring-boot-starter,使其在spring-boot上使用更方便.

”helloworld”示例

创建接口和实现

新建例子接口(ExampleService.java),对象(ExampleVO.java)和实现 (ExampleServiceImpl.java)类:

ExampleService.java

public interface ExampleService {
    // 查询对象
    public ExampleVO findVO(int id);
}

ExampleServiceImpl.java

public class ExampleServiceImpl implements ExampleService {
    @Override
    public ExampleVO findVO(int id) {
        return new ExampleVO(id, “helloworld”);
    }
}

ExampleVO.java

public class ExampleVO {
    private int id;
    private String string;
    public ExampleVO() {
    }
    public ExampleVO(int id, String string) {
        this.id = id;
        this.string = string;
    }
    public int getId() {
        return id;
    }
    public void setId(int id) {
        this.id = id;
    }
    public String getString() {
        return string;
    }
    public void setString(String string) {
        this.string = string;
    }
}

服务端

Server.java

import com.ikasoa.rpc.DefaultIkasoaFactory;
import com.ikasoa.rpc.IkasoaException;
import com.ikasoa.rpc.IkasoaServer;
public class Server {
    private static IkasoaServer ikasoaServer;
    public static void start() {
        try {
            if (ikasoaServer == null) {
                ikasoaServer = new DefaultIkasoaFactory().getIkasoaServer(ExampleServiceImpl.class, 9999);
            }
            // 启动服务
            ikasoaServer.run();
        } catch (IkasoaException e) {
            e.printStackTrace();
        }
    }
    public static void stop() {
        if (ikasoaServer != null && ikasoaServer.isServing()) {
            // 停止服务
            ikasoaServer.stop();
        }
    }
}

客户端

Client.java

import com.ikasoa.rpc.DefaultIkasoaFactory;
import com.ikasoa.rpc.ServerInfoWrapper;
public class Client {
    public static void call() {
        // 客户端获取远程接口实现
        ExampleService es = new DefaultIkasoaFactory().getInstance(ExampleService.class, new ServerInfoWrapper("localhost", 9999));
        // 客户端输出结果
        System.out.println(es.findVO(1).getString());
    }
}

执行类

Main.java

public class Main {
    public static void main(String[] args) {
        try {
            // 启动服务
            Server.start();
            Thread.sleep(100);
            // 客户端调用
            Client.call();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            // 停止服务
            Server.stop();
        }
    }
}

执行Main.java,或单独调用Server.start()启动服务后再调用Client.call()执行.
如输出“helloworld”则表示执行成功.

的码云指数为
超过 的项目
加载中

评论(1)

北极心
北极心
有人用么?

ikasoa 0.3.2 发布,高性能轻量级 RPC 框架

ikasoa-rpc是基于apache-thrift框架的高性能RPC框架. 更新内容: 修复已知bug; 增加commons-pool2客户端连接池实现; 优化spring-boot-starter,增强对Eureka和ZooKeeper的支持; 引入lombok,对代...

2018/07/24 13:33

ikasoa 0.3.1 发布,高性能轻量级 RPC 框架

ikasoa是基于apache-thrift框架的java服务化治理解决方案.其中ikasoa-rpc是ikasoa的开源RPC框架,客户端可以像调用本地接口那样去调用远程接口. 更新内容: 修复已知bug; 优化代码,提升性能; 增...

2018/03/14 03:02

没有更多内容

加载失败,请刷新页面

没有更多内容

暂无问答

暂无博客

返回顶部
顶部