zhanghqgit / jsf-sdk Goto Github PK

<bean id="helloService" class="com.ipd.testjsf.HelloServiceImpl"/>
<jsf:server id="jsf" protocol="jsf" port="9090"/>
<jsf:provider id="helloServiceExport" interface="com.ipd.testjsf.HelloService"
              ref="helloService" server="jsf" alias="JSF:0.0.1" register="false">
</jsf:provider>

<jsf:consumer id="helloService" interface="com.ipd.testjsf.HelloService" retries="0"
              protocol="jsf" alias="JSF:0.0.1" timeout="60000" url="jsf://127.0.0.1:9090">
</jsf:consumer>

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

    HelloService helloService = new HelloServiceImpl();
    
    ServerConfig serverConfig = new ServerConfig();
    
    serverConfig.setProtocol("jsf");
    
    logger.info("ServerConfig");
    
    ProviderConfig<HelloService> providerConfig = new ProviderConfig<HelloService>();
    
    providerConfig.setInterfaceId("com.ipd.testjsf.HelloService");
    
    providerConfig.setRef(helloService);
    
    providerConfig.setAlias("JSF:0.0.1");
    
    providerConfig.setServer(serverConfig);
    
    logger.info("ProviderConfig");
    
    providerConfig.export();
    
    logger.info("Publishing is finished");

    synchronized (ServerMainAPI.class) {
        while (true) {
            try {
                ServerMainAPI.class.wait();
            } catch (InterruptedException e) {
            }
        }
    }
}

public static void main(String[] args){

    ConsumerConfig<HelloService> consumerConfig = new ConsumerConfig<HelloService>();
    
    consumerConfig.setInterfaceId("com.ipd.testjsf.HelloService");
    
    consumerConfig.setProtocol("jsf");
    
    consumerConfig.setAlias("JSF:0.0.1");
    
    consumerConfig.setUrl("jsf://127.0.0.1:22000;jsf://127.0.0.1:22001");
    
    logger.info("ConsumerConfig");
    
    HelloService service = consumerConfig.refer();
    
    while (true) {
        try {
            String result = service.echoStr("string put");
            logger.info("result msg:{}", result);
        } catch (Exception e) {
            logger.error("",e);
        }
        try {
            Thread.sleep(3000);
        } catch (Exception e) {
        }
    }
}