Apache cxf端口常规创建

Question

在我的项目中，我必须创建一些Soap web服务客户机，我使用apache cxf创建端口并使用web服务，我注意到端口的创建我复制了很多代码，所以我创建了一个抽象类，如下所示

public abstract class WebServiceConsumerPort<P>{

    protected Class<P> port;

    private static Logger log = LoggerFactory.getLogger(WebServiceConsumerPort.class);

    public void createPort(String url, String timeoutS) {

        try {
            Long timeout = Long.parseLong(timeoutS);
            JaxWsProxyFactoryBean factory = new JaxWsProxyFactoryBean();
            factory.setServiceClass(port.getClass());
            factory.setAddress(url);

            port = (Class<P>) factory.create();

            Client client = ClientProxy.getClient(port);

            if (client != null) {

                log.info("Timeout WEB WERVICES: {}", timeout);

                HTTPConduit conduit = (HTTPConduit) client.getConduit();
                HTTPClientPolicy policy = new HTTPClientPolicy();
                policy.setAllowChunking(false);
                policy.setConnectionTimeout(timeout * 1000);
                policy.setReceiveTimeout(timeout * 1000);
                conduit.setClient(policy);
            }
        } catch (Exception e) {
            log.error("Peoblem creating the port", e);
        }
    }
}

public class WebService1Consumer extends WebServiceConsumerPort<WebService1Interface> {
        public void consumeMethod1() {
            port.method1();
        }

        public void consumeMethod2() {
            port.method2();
        }
    }

另一个类看起来像

public class WebService2Consumer extends WebServiceConsumerPort<WebService2Interface> {
        public void consumeMethod1() {
            port.method3();
        }

        public void consumeMethod2() {
            port.method4();
        }
    }

但在两个类中说不能解析端口中的方法。

Answer 1

它终于起作用了，代码如下所示：

import org.apache.cxf.endpoint.Client;
import org.apache.cxf.frontend.ClientProxy;
import org.apache.cxf.jaxws.JaxWsProxyFactoryBean;
import org.apache.cxf.transport.http.HTTPConduit;
import org.apache.cxf.transports.http.configuration.HTTPClientPolicy;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public abstract class WebServiceConsumerPort<P>{


    protected P puerto;
    private static Logger log = LoggerFactory.getLogger(WebServiceConsumerPort.class);

    public void creaPuerto(String url, String timeoutS, Class<P> tipoClase) {

        try {
            Long timeout = Long.parseLong(timeoutS);
            JaxWsProxyFactoryBean factory = new JaxWsProxyFactoryBean();
            factory.setServiceClass(tipoClase);
            factory.setAddress(url);
            puerto = (P) factory.create();

            Client client = ClientProxy.getClient(puerto);

            if (client != null) {
                HTTPConduit conduit = (HTTPConduit) client.getConduit();
                HTTPClientPolicy policy = new HTTPClientPolicy();
                policy.setAllowChunking(false);
                policy.setConnectionTimeout(timeout * 1000);
                policy.setReceiveTimeout(timeout * 1000);
                conduit.setClient(policy);
            }
            nIntento = 0;
        } catch (Exception e) {
            puerto = null;
            nIntento++;
        }
    }
}

感谢@Ben-Thurley在帖子中给出的答案