webservice axis2客户端调用设置超时时间

左手的ㄟ右手 2022-01-05 23:51 1136阅读 0赞

axis2版本 ：1.6.2

import java.rmi.RemoteException;

import nc.pubitf.para.SysInitQuery;  
import nc.vo.pub.BusinessException;

import org.apache.axis2.AxisFault;  
import org.apache.axis2.client.Options;  
import org.apache.axis2.transport.http.HTTPConstants;  
import org.tempuri.HQSWcfServiceCallHQSWcfServiceCallSoapStub;

import com.yonyou.yh.nhis.bd.util.SysConfigParamUtil;  
import com.yonyouhealth.uaph.framework.comm.util.StringUtils;

public class ChinaShineUtils \{

private static HQSWcfServiceCallHQSWcfServiceCallSoapStub stub;  
    private static HQSWcfServiceCallHQSWcfServiceCallSoapStub getServiceStub() throws AxisFault, BusinessException\{  
        try \{  
            stub = null==stub? new HQSWcfServiceCallHQSWcfServiceCallSoapStub() : stub;  
              
         **   Options options = stub. \_getServiceClient().getOptions();  
            options.setProperty(HTTPConstants.CONNECTION\_TIMEOUT, 2 \* 1000);//设置服务端方法超时时间(单位是毫秒)  
            options.setProperty(HTTPConstants.SO\_TIMEOUT, 3 \* 1000);//设置等待客户连接的超时时间(单位是毫秒)  
              
            stub.\_getServiceClient().setOptions(options);//设置**  
              
        \} catch (AxisFault e) \{  
            throw new AxisFault("接口调用超时，接口返回信息："+ e.getMessage());  
        \}catch(Exception e)\{  
            throw new BusinessException("接口调用失败，接口返回信息："+ e.getMessage());  
        \}  
        return stub;  
    \}  
      
    private static HQSWcfServiceCallHQSWcfServiceCallSoapStub getServiceStub(String pk\_group) throws AxisFault, BusinessException\{  
        try \{  
            if(StringUtils.hasText(pk\_group))\{  
                String url = SysInitQuery.getParaString(pk\_group, "NHISPV014");  
                if(StringUtils.hasText(url) )\{  
                    stub = null==stub? new HQSWcfServiceCallHQSWcfServiceCallSoapStub(url) : stub;  
                      
                    String conn\_timeout\_str = new SysConfigParamUtil().getPubSysInitByGroup(pk\_group, "NHISPV022");  
                    Integer connection\_timeout = StringUtils.hasText(conn\_timeout\_str)? Integer.valueOf( conn\_timeout\_str) : 2000 ;  
                      
                    String so\_timeout\_str = new SysConfigParamUtil().getPubSysInitByGroup(pk\_group, "NHISPV023");  
                    Integer so\_timeout = StringUtils.hasText(so\_timeout\_str)?  Integer.valueOf(so\_timeout\_str) : 3000;  
                      
                   ** Options options = stub.\_getServiceClient().getOptions();  
                    options.setProperty(HTTPConstants.CONNECTION\_TIMEOUT, connection\_timeout);//设置服务端方法超时时间(单位是毫秒)  
                    options.setProperty(HTTPConstants.SO\_TIMEOUT, so\_timeout);//等待客户连接的超时时间(单位是毫秒)  
                      
                    stub.\_getServiceClient().setOptions(options);//设置**  
                \}else\{  
                    stub = getServiceStub();  
                \}  
            \}else\{  
                stub = getServiceStub();  
            \}  
        \} catch (AxisFault e) \{  
            throw new AxisFault("接口调用超时，接口返回信息："+ e.getMessage());  
        \}catch(Exception e)\{  
            throw new BusinessException("接口调用失败，接口返回信息："+ e.getMessage());  
        \}  
        return stub;  
    \}