public final class DemoApplication {

    public static void main(String[] args) throws Exception {

    	String zkConnStr = EasyConfig.instance.getString("service.zk","127.0.0.1:2181");

		EasyService service = new EasyService(zkConnStr);
    	service.create("profile", 8001, new DemoService());
    	service.startAndWait();
    	
    }
}

public class DemoService {

	private Logger log = LoggerFactory.getLogger(DemoService.class);
    
    /**
    * EasyMethod 注解把getProfile 方法映射到onGetProfile 函数
    * 这是异步方式，返回的是CompletableFuture
    */
    @EasyMethod(method="getProfile")
    public CompletableFuture<Response> onGetProfile(Request request) throws Exception {

		CompletableFuture<Response> completableFuture = new CompletableFuture<>();
		log.info("req getProfile head=[{}],body=[{}]",request.getHead().toString(),request.getBody().toString());
		new Thread(()->{

			ObjectNode respBody = Utils.json.createObjectNode();
			ObjectNode info =  respBody.putObject("info");
			info.put("name","hello");
			info.put("tag","xxxxxxxx");
			info.put("headPic","https://www.xxxx.com/xxx/xxxx.jpg");
			info.put("uid",10000);

			try{  Thread.sleep(500); } catch (Exception e){}

			completableFuture.complete(newResponse().setHead(request.getHead().setRet(0).setMsg("ok")).setBody(respBody));
		}).start();

    	return completableFuture;
    }
    
   /**
    * EasyMethod 注解把getProfile 方法映射到onGetProfile 函数
    * 这是同步方式，返回的是Response
    */
    @EasyMethod(method="setProfile")
    public Response onSetProfile(Request request) {
    
    	//log.info("req setProfile head=[{}],body=[{}]",request.getHead().toString(),request.getBody().toString());
		ObjectNode respBody = Utils.json.createObjectNode();

    	respBody.put("msg","ok");
    	respBody.put("ret",0);
    	return new Response().setHead(request.getHead().setRet(0).setMsg("ok")).setBody(respBody);
    }
}

public class RequestDemo {
	
	public static void main(String[] args) throws Exception
	{
		try
		{	
			//创建客户端调用类参数为zk地址，io 线程数，负载均衡类型
			EasyClient client = new EasyClient(127.0.0.1:2181,4, LoadBalance.LB_ROUND_ROBIN);
			ObjectNode reqBody = Utils.json.createObjectNode();
			reqBody.put("uid",100000).put("seq",0);
			//调用profile 服务的getProfile 方法，请求body 为reqBody，默认用msgpack 方式序列化，超时时间1000ms	
			EasyPackage pkg = client.syncRequest("profile","getProfile",reqBody, 1000);
			System.out.println(pkg.getBody().toString());

		}
		catch (Throwable e)
		{
			e.printStackTrace();
		}
	}
}