Слияние кода завершено, страница обновится автоматически
public class TestServer {
public static void main(String[] args) throws IOException {
NioConfig.registered(new KryoSerializer());
final ServerHandler handler = new ServerHandler();
NioConfig.registered(handler);
NioConfig.initSessionHandler();
// Необходимые экспортированные службы и соответствующие реализации
handler.services.put(UserService.class, new RemoteUserService());
Server server = new Server(new InetSocketAddress("0.0.0.0", 6161), new Acceptor("acceptor-1", new ReactorPool(1)));
}
}
public class ProxyClientTest {
public static void main(String[] args) throws Exception {
NioConfig.registered(new KryoSerializer());
final Handler invocationHandler = new ClientHandler();
NioConfig.registered(invocationHandler);
NioConfig.registered(new Connector("connector", new ReactorPool(1)));
NioConfig.initSessionHandler();
URL url = new URL();
url.setHost("localhost");
url.setPort(6161);
Invoker invoker = new SimpleInvoker(url, 50);
ProxyClient proxyClient = new ProxyClient(invoker);
final AtomicLong counter = new AtomicLong(0);
UserService userService = proxyClient.refService(UserService.class);
userService.save(new User());
proxyClient.close();
}
}
public class ZookeeperServer {
public static void main(String[] args) throws IOException {
NioConfig.registered(new KryoSerializer());
final ServerHandler handler = new ServerHandler();
NioConfig.registered(handler);
NioConfig.initSessionHandler();
}
}
``````markdown
## Клиент ZooKeeper
```java
ZooKeeperClient zooKeeperClient = new DefaultZookeeperClient("192.168.1.66:2181");
String format = "/eyer/" + URLEncoder.encode(String.format("rpc/%s:%d/Services", "localhost", 6161), "UTF-8");
zooKeeperClient.create(format, true);
public class ZookeeperClient {
public static void main(String[] args) throws Exception {
NioConfig.registered(new KryoSerializer());
final Handler invocationHandler = new ClientHandler();
NioConfig.registered(invocationHandler);
NioConfig.registered(new Connector("ZookeeperProxyServicePerf-connector-1", new ReactorPool(1)));
NioConfig.initSessionHandler();
Invoker invoker = new ZookeeperInvoker("192.168.1.66:2181", new PollingBalance(), 50);
ProxyClient proxyClient = new ProxyClient(invoker);
UserService userService = proxyClient.refService(UserService.class);
System.out.println(save); // Непонятная переменная save
clientProxy.close(); // Непонятная переменная clientProxy
}
}
Вы можете оставить комментарий после Вход в систему
Неприемлемый контент может быть отображен здесь и не будет показан на странице. Вы можете проверить и изменить его с помощью соответствующей функции редактирования.
Если вы подтверждаете, что содержание не содержит непристойной лексики/перенаправления на рекламу/насилия/вульгарной порнографии/нарушений/пиратства/ложного/незначительного или незаконного контента, связанного с национальными законами и предписаниями, вы можете нажать «Отправить» для подачи апелляции, и мы обработаем ее как можно скорее.
Комментарии ( 0 )