Provider
public class EchoProvider{
public static void main() throws Exception{
ServiceConfig service =
new ServiceConfig<>();
service.setApplication(new ApplicationConfig("java-echo-provider"));
service.setRegistry(new RegistryConfig("zookeeper://127.0.0.1:2181"));
service.setInterface(Echoservice.class);
service.serRef(new EchoServiceImpl());
service.export();
System.out.println("java-echo-provider is running");
System.in.read();
}
}
Consumer
public class EchoConsumer{
public static void main(String[] args){
ReferenceConfig ref = new ReferenceCongig<>();
reference.setApplication(new ApplicationConfig("java-echo-consumer"));
reference.setRegistry(new RegistryConfig("zookeeper://127.0.0.1:2181"));
reference.setInterface(Echoservice.class);
EchoService service = reference.get();
System.out.println("result:"+service.echo("hello world!"));
}
}