`

cxf动态调用webservice设置超时,测试线程安全[转]

 
阅读更多
Java代码  收藏代码
  1. import java.util.Random;  
  2. import java.util.concurrent.ArrayBlockingQueue;  
  3. import java.util.concurrent.ThreadPoolExecutor;  
  4. import java.util.concurrent.TimeUnit;  
  5.   
  6. import org.apache.cxf.endpoint.Client;  
  7. import org.apache.cxf.jaxws.endpoint.dynamic.JaxWsDynamicClientFactory;  
  8. import org.apache.cxf.transport.http.HTTPConduit;  
  9. import org.apache.cxf.transports.http.configuration.HTTPClientPolicy;  
  10.   
  11. public class WSClient {  
  12.     public static void main(String[] args)throws Exception {  
  13.         String wsdlUrl = "http://172.16.11.11:8080/webws/CalculatorPort?wsdl";  
  14.         //动态调用的客户端工厂类  
  15.         JaxWsDynamicClientFactory factory = JaxWsDynamicClientFactory.newInstance();  
  16.         final Client client = factory.createClient(wsdlUrl);  
  17.   
  18.         //设置超时单位为毫秒  
  19.         HTTPConduit http = (HTTPConduit) client.getConduit();        
  20.         HTTPClientPolicy httpClientPolicy = new HTTPClientPolicy();        
  21.         httpClientPolicy.setConnectionTimeout(3000);  //连接超时      
  22.         httpClientPolicy.setAllowChunking(false);    //取消块编码   
  23.         httpClientPolicy.setReceiveTimeout(3000);     //响应超时  
  24.         http.setClient(httpClientPolicy);  
  25.           
  26.         //用线程池试了下client对象线程安全性,发现是安全的  
  27.         ThreadPoolExecutor pool = new ThreadPoolExecutor(5,50,1000,  
  28.                 TimeUnit.MICROSECONDS,new ArrayBlockingQueue<Runnable>(50));  
  29.         for (int i=0;i<100;i++){  
  30.             pool.execute(new Runnable() {  
  31.                 @Override  
  32.                 public void run() {  
  33.                     try {  
  34.                         String threadName = Thread.currentThread().getName();  
  35.                         int a = new Random().nextInt(10);  
  36.                         int b = new Random().nextInt(10);  
  37.                         Object[] res = client.invoke("adD", a,b);  
  38.                         System.out.println(threadName+":"+a+"+"+b+"="+res[0]);  
  39.                     } catch (Exception e) {  
  40.                         e.printStackTrace();  
  41.                     }  
  42.                 }  
  43.             });  
  44.         }  
  45.     }  
  46. }  

 结果:

Java代码  收藏代码
  1. pool-1-thread-37:0+5=5  
  2. pool-1-thread-21:1+4=5  
  3. pool-1-thread-33:6+3=9  
  4. pool-1-thread-49:6+0=6  
  5. pool-1-thread-42:7+1=8  
  6. ...  
  7. ...  
  8. ...  
  9. pool-1-thread-7:7+5=12  
  10. pool-1-thread-46:9+2=11  
  11. pool-1-thread-17:6+2=8  
  12. pool-1-thread-34:2+3=5  
  13. pool-1-thread-36:8+3=11  
  14. pool-1-thread-40:1+9=10  
  15. pool-1-thread-26:4+4=8  
  16. pool-1-thread-35:3+4=7  
分享到:
评论

相关推荐

    Android使用KSOAP调用webservice返回自定义类

    在服务端,你需要创建一个支持SOAP的Web Service,比如使用Java的JAX-WS或CXF框架。定义方法,接受参数,返回自定义类。确保服务端的WSDL(Web Service描述语言)文档正确地描述了自定义类的结构。 五、注意事项 1....

    android app webservice 交互

    1. **线程管理**:由于Android主线程不能进行耗时操作,如网络请求,因此通常需要在子线程中进行网络通信,然后通过Handler或AsyncTask更新UI。 2. **错误处理**:处理网络连接失败、超时、数据解析错误等各种异常...

    JAVA面试_Dubbo常问面试题30个.pdf

    消费者端设置优先级更高,可以灵活控制服务调用的超时,超时时,服务端线程不会被占用,但会产生警告。 【Dubbo注册中心】 - **Multicast注册中心**:无中心节点,通过组播地址实现服务注册和发现。 - **Zookeeper...

    Java Dubbo面试及答案

    3. WebService 协议:基于 WebService 的远程调用协议,集成 CXF 实现,提供和原生 WebService 的互操作。多个短连接,基于 HTTP 传输,同步传输,适用系统集成和跨语言调用。 4. HTTP 协议:基于 Http 表单提交的...

    Dubbo面试及答案(上).pdf

    3. **webservice**:基于WebService的远程调用协议,集成CXF库,支持与原生WebService的互操作。它使用HTTP传输,适用于系统集成和跨语言调用,多采用短连接,同步传输。 4. **http**:使用Spring的HttpInvoke实现...

    Dubbo服务框架面试题及答案.pdf

    Dubbo超时设置能保证服务调用的稳定性,避免因服务延迟导致的线程阻塞和资源浪费。 Dubbo支持的注册中心有多种,包括Multicast注册中心、Zookeeper注册中心、redis注册中心等。Multicast注册中心不需要中心节点,...

    2021Java字节跳动面试题——面向字节_Dubbo(上).pdf

    - **特点**:基于WebService的远程调用协议,集成CXF实现,提供和原生WebService的互操作。 - **传输协议**:HTTP - **序列化方式**:XML/JSON - **应用场景**:适用于系统集成和跨语言调用。 - **优点**:良好的跨...

    Java ExcutorService优雅关闭方式解析

    这样,当`shutdownNow`发出中断请求时,线程可以在适当的位置安全地退出,实现优雅关闭。 在实际开发中,我们还需要注意,即使调用了`shutdownNow`,仍需要对可能出现的InterruptedException进行处理,因为`...

Global site tag (gtag.js) - Google Analytics