`

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  
分享到:
评论

相关推荐

Global site tag (gtag.js) - Google Analytics