Catty
Whole new RPC framework!
Features
- High performance.
- Async & reactor oriented.
- Micro-kernel & Easy to customize
- ProtoBuf supported.
Project Status
Catty has released a few versions, which means you could use Catty in your own project!
But as the version is senior than 1.0.0, which means catty is not stable and has not adequately tested yet, I temporarily do not recommend you to use it in any large distribution system. But I do recommend you to use it in a smaller system or point-to-point system, in which cases Catty would be more easier to use and control.
Usage
See example package or test package.
Maven:
<dependency>
<groupId>pink.catty</groupId>
<artifactId>catty-all</artifactId>
<version>0.2.6</version>
</dependency>build:
mvn clean install -DskipTests -Dmaven.javadoc.skip=true -Dgpg.skiptest:
mvn clean testSync:
Server:
ServerConfig serverConfig = ServerConfig.builder()
.port(20550)
.build();
ProtocolConfig protocolConfig = ProtocolConfig.defaultConfig();
Exporter exporter = new Exporter(serverConfig);
exporter.setProtocolConfig(protocolConfig);
exporter.registerService(IService.class, new IServiceImpl());
exporter.export();
Client:
ClientConfig clientConfig = ClientConfig.builder()
.addAddress("127.0.0.1:20550")
.build();
ProtocolConfig protocolConfig = ProtocolConfig.defaultConfig();
Reference<IService> reference = new Reference<>();
reference.setClientConfig(clientConfig);
reference.setProtocolConfig(protocolConfig);
reference.setInterfaceClass(IService.class);
IService service = reference.refer();
System.out.println(service.say0());
System.out.println(service.say1("catty"));
Async:
Server:
ServerConfig serverConfig = ServerConfig.builder()
.port(20550)
.build();
ProtocolConfig protocolConfig = ProtocolConfig.defaultConfig();
Exporter exporter = new Exporter(serverConfig);
exporter.setProtocolConfig(protocolConfig);
exporter.registerService(IService.class, new IServiceImpl());
exporter.export();Client:
ClientConfig clientConfig = ClientConfig.builder()
.addAddress("127.0.0.1:20550")
.build();
ProtocolConfig protocolConfig = ProtocolConfig.defaultConfig();
Reference<IService> reference = new Reference<>();
reference.setClientConfig(clientConfig);
reference.setProtocolConfig(protocolConfig);
reference.setInterfaceClass(IService.class);
IService service = reference.refer();
CompletableFuture<String> future = service.asyncSay("catty");
future.whenComplete((value, t) -> System.out.println(value));Welcome to join me!
There are lots of things need todo:
- doc
- benchmark
- test
- more useful extensions
- log & annotation
- code review & refactor
