import org.apache.cxf.endpoint.Client;
import org.apache.cxf.jaxws.JaxWsProxyFactoryBean;
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.ZooKeeper;

import java.io.IOException;

public class ServiceClient {

    private static final String ZOOKEEPER_HOST = "localhost:2181";
    private static final String SERVICE_PATH = "/services/myWebService";

    public static void main(String[] args) {
        try {
            // ZooKeeper 클라이언트 생성
            ZooKeeper zooKeeper = new ZooKeeper(ZOOKEEPER_HOST, 5000, (event) -> {
                // 이벤트 처리 로직
            });

            // ZooKeeper에서 웹 서비스 엔드포인트 정보 조회
            byte[] data = zooKeeper.getData(SERVICE_PATH, false, null);
            String endpointURL = new String(data);

            // Apache CXF 클라이언트 설정
            JaxWsProxyFactoryBean factory = new JaxWsProxyFactoryBean();
            factory.setAddress(endpointURL);
            MyWebService service = (MyWebService) factory.create();

            // 웹 서비스 호출
            service.sayHello("John");

            // ZooKeeper 연결 종료
            zooKeeper.close();
        } catch (IOException | KeeperException | InterruptedException e) {
            e.printStackTrace();
        }
    }
}