###Nio实现细节架构图
public class ServerBootstrapTest {
static {
//1 init context
Serializer serializer = new JavaSerializer();
Context.<Request, Response>builder()
.decoder(new DefaultDecoder<>(serializer))
.encoder(new DefaultEncoder<>(serializer))
.serializer(serializer)
.channelHandler(new RequestHandler())
.executorService(Executors.newFixedThreadPool(20, new NamedThreadFactory()))
.build()
.init();
}
public static void main(String[] args) throws Exception {
// 2 init rpc server
ServerBootstrap serverBootstrap = new ServerBootstrap(9999);
//3 registry shutdown clean hook
Runtime.getRuntime().addShutdownHook(new Thread(serverBootstrap::shutdown));
//4 registry services..
serverBootstrap.registry(UserService.class, new SimpleUserService());
//5 started rpc server and await thread
serverBootstrap.startup();
}
}
public class BootstrapTest {
static {
//1 init
Serializer serializer = new JavaSerializer();
Context.<Request, Response>builder()
.decoder(new DefaultDecoder<>(serializer))
.encoder(new DefaultEncoder<>(serializer))
.serializer(serializer)
.channelHandler(new ResponseHandler())
.executorService(Executors.newFixedThreadPool(20, new NamedThreadFactory()))
.build()
.init();
}
public static void main(String[] args) throws Exception {
//2 create client
Bootstrap bootstrap = new Bootstrap("localhost", 9999);
//3 started client
bootstrap.startup();
//4 get proxy service
UserService service = bootstrap.getService(UserService.class);
//5 remote invoker
User add = service.add(new User());
// out result
System.out.println(add);
//7 shutdown
bootstrap.shutdown();
}
}
1.PerfServerBootstrapTest
2.PerfClientTest
gdRPC 根目录
--$|{applicationName.version.group} 模块名称.版本号.分组 account.v1.0.0.shanghai
--|${service} 服务类全路径 com.goudai.test.UserService
--| provider 服务提供者目录
--|具体的服务提通知"provider://host:port/com.goudai.test.UserService?timeout=1000&methods=test,getUser,findUser&app=gd-app&version=v1.0.0&group=gd-group"
--| consumer 消费者目录
--|具体的调用者 "consumer://host:port/com.goudai.test.UserService?timeout=1000&methods=test,getUser,findUser&app=gd-app&version=v1.0.0&group=gd-group"
public class ServerBootTest {
public static void main(String[] args) throws Exception {
ClusterConfig.application = "myApp";
//1 init context
Serializer serializer = new JavaSerializer();
ZooKeeRegistry registry = new ZooKeeRegistry();
registry.startup();
Context.<Request, Response>builder()
.decoder(new DefaultDecoder<>(serializer))
.encoder(new DefaultEncoder<>(serializer))
.serializer(serializer)
.channelHandler(new ClusterRequestHandler(registry))
.sessionListener(new AbstractSessionListener())
.executorService(Executors.newFixedThreadPool(200, new NamedThreadFactory()))
.build()
.init();
ClusterConfig.port = 6161;
// 2 init rpc server
ClusterServerBootstrap serverBootstrap = new ClusterServerBootstrap(2);
//4 registry services..
serverBootstrap.registry(UserService.class, new SimpleUserService());
//3 registry shutdown clean hook
Runtime.getRuntime().addShutdownHook(new Thread(serverBootstrap::shutdown));
//5 started rpc server and await thread
serverBootstrap.startup();
}
}
public class ClusterBootstrapTest {
static {
// init
Serializer serializer = new JavaSerializer();
Context.<Request, Response>builder()
.decoder(new DefaultDecoder<>(serializer))
.encoder(new DefaultEncoder<>(serializer))
.serializer(serializer)
.channelHandler(new ResponseHandler())
.sessionListener(new RpcListener())
.executorService(Executors.newFixedThreadPool(20, new NamedThreadFactory("goudai-rpc-works", true)))
.build()
.init();
}
public static void main(String[] args) throws Exception {
//application name is requied
ClusterConfig.application = "myApp";
//2 create client
ZooKeeRegistry registry = new ZooKeeRegistry();
ClusterBootstrap clusterBootstrap = new ClusterBootstrap(registry, 1);
//3 started client
clusterBootstrap.startup();
//4 get proxy service
UserService service = clusterBootstrap.getService(UserService.class);
//5 remote invoker
User add = service.add(new User());
// out result
System.err.println(add);
//7 shutdown
clusterBootstrap.shutdown();
}
}