使用axis2构建webservice时客户端内存不断增长导致应用服务器频繁重启的解决方案 .

   使用axis2构建webservice时，发现系统运行一段时间后客户端的内存使用一直不断增高，导致应用服务器无法承受而重启，这里提供了一种解决方案。

 

       原因分析：客户端以stub方式请求服务，stub对象是一个非常重量级的对象，每次客户端向服务端请求服务时，stub对象不断被创建，占用大量系统资源

       解决方案：考虑到所有的客户端stub都继承自org.apache.axis2.client.Stub类，考虑使用简单工厂模式+简单的对象池来提供stub对象实例，这样只需首次需要stub对象时实例化一次，以后需要用的时候从stub对象池中取得，工厂类本身做成单例模式。

 

代码实现：

 

       

[java] view plain copy print ?

1. public class StubFactory{  
2.    //从配置文件中取客户端应用context的绝对路径   
3.    public static final String path=ServiceConfig.getPath();  
4.    //从配置文件中取服务url   
5.    public static final String serviceUrl=ServiceConfig.getServiceUrl();  
6.      
7.    private static Map map=new HashMap();//这里可以是一个同步的Map，也可以直接用Hashtable   
8.    private static ConfigurationContext configurationContext=null;  
9.    private static StubFactory stubFactory=new StubFactory();  
10.      
11.    private StubFactory(){};  
12.      
13.    static{  
14.       try{  
15.         configurationContext=ConfigurationContextFactory.createConfigurationContextFromFileSystem(path+"/WEB-INF",path+"/WEB-INF/conf/axis2.xml");  
16.       }catch(AxisFault e){  
17.          e.printstacktrace();  
18.       }  
19.    }  
20.   
21.    public Stub getStub(String type){  
22.      Stub stub=null;  
23.      if(map.get(type)==null){  
24.        stub=(Stub)this.createStub(type);  
25.        map.put(type,stub);  
26.      }  
27.      return (Stub)map.get(type);  
28.    }  
29.      
30.    private Stub createStub(String type){  
31.      Stub stub=null;  
32.      String targetEndpoint=null;  
33.      try{  
34.        if("SearchServiceStub".equals(type)){  
35. targetEndpoint=serviceUrl+"services/SearchService.SearchServiceHttpSoap12Endpoint/";  
36.         stub=new SearchServiceStub(configurationContext,targetEndpoint);  
37.        }  
38.         if("CalculateServiceStub".equals(type)){  
39. targetEndpoint=serviceUrl+"services/CalculateService.CalculateServiceHttpSoap12Endpoint/";  
40.         stub=new CalculateServiceStub(configurationContext,targetEndpoint);  
41.        }  
42.         if("MessageServiceStub".equals(type)){  
43. targetEndpoint=serviceUrl+"services/MessageService.MessageServiceHttpSoap12Endpoint/";  
44.         stub=new MessageServiceStub(configurationContext,targetEndpoint);  
45.        }  
46.      }catch(Exception e){  
47.         e.printstacktrace();  
48.      }  
49.      return stub;  
50.    }  
51.      
52.    public static StubFactory getInstance(){  
53.      return stubFactory;  
54.    }  
55. }  

public class StubFactory{ //从<a href="/tag/peizhiwenjian/" target="_blank" class="keywords">配置文件</a>中取客户端应用context的<a href="/tag/jueduilujing/" target="_blank" class="keywords">绝对路径</a> public static final String path=ServiceCon<a href="/tag/fig/" target="_blank" class="keywords">fig</a>.getPath(); //从<a href="/tag/peizhiwenjian/" target="_blank" class="keywords">配置文件</a>中取服务url public static final String serviceUrl=ServiceCon<a href="/tag/fig/" target="_blank" class="keywords">fig</a>.getServiceUrl(); private static Map map=new HashMap();//这里可以是<a href="/tag/yige/" target="_blank" class="keywords">一个</a>同步的Map，也可以直接用Hashtable private static Con<a href="/tag/fig/" target="_blank" class="keywords">fig</a>urationContext con<a href="/tag/fig/" target="_blank" class="keywords">fig</a>urationContext=null; private static StubFactory stubFactory=new StubFactory(); private StubFactory(){}; static{ try{ con<a href="/tag/fig/" target="_blank" class="keywords">fig</a>urationContext=Con<a href="/tag/fig/" target="_blank" class="keywords">fig</a>urationContextFactory.createCon<a href="/tag/fig/" target="_blank" class="keywords">fig</a>urationContextFromFileSy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>(path+"/WEB-INF",path+"/WEB-INF/conf/axis2.xml"); }catch(AxisFault e){ e.<a href="/tag/printstacktrace/" target="_blank" class="keywords">printstacktrace</a>(); } } public Stub getStub(String type){ Stub stub=null; if(map.get(type)==null){ stub=(Stub)this.createStub(type); map.put(type,stub); } return (Stub)map.get(type); } private Stub createStub(String type){ Stub stub=null; String targetEndpoint=null; try{ if("SearchServiceStub".equals(type)){ targetEndpoint=serviceUrl+"services/SearchService.SearchServiceHttpSoap12Endpoint/"; stub=new SearchServiceStub(con<a href="/tag/fig/" target="_blank" class="keywords">fig</a>urationContext,targetEndpoint); } if("Cal<a href="/tag/cula/" target="_blank" class="keywords">cula</a>teServiceStub".equals(type)){ targetEndpoint=serviceUrl+"services/Cal<a href="/tag/cula/" target="_blank" class="keywords">cula</a>teService.Cal<a href="/tag/cula/" target="_blank" class="keywords">cula</a>teServiceHttpSoap12Endpoint/"; stub=new Cal<a href="/tag/cula/" target="_blank" class="keywords">cula</a>teServiceStub(con<a href="/tag/fig/" target="_blank" class="keywords">fig</a>urationContext,targetEndpoint); } if("MessageServiceStub".equals(type)){ targetEndpoint=serviceUrl+"services/MessageService.MessageServiceHttpSoap12Endpoint/"; stub=new MessageServiceStub(con<a href="/tag/fig/" target="_blank" class="keywords">fig</a>urationContext,targetEndpoint); } }catch(Exception e){ e.<a href="/tag/printstacktrace/" target="_blank" class="keywords">printstacktrace</a>(); } return stub; } public static StubFactory getInstance(){ return stubFactory; } }

      

取stub对象只要如下代码：

      

[java] view plain copy print ?

1. SearchServiceStub stub=(SearchServiceStub)StubFactory.getInstance().getStub("SearchServiceStub");