ApacheCXF实战之五:压缩WebService数据

在现实应用中有些时候会有比较大的数据对象需要传输,或者在一个比较慢的网络环境下发布调用web service,此时可以通过压缩数据流的方式来减小数据包的大小,从而提高web service的性能。下面来看看怎样来做到这一点。

鼓楼ssl适用于网站、小程序/APP、API接口等需要进行数据传输应用场景,ssl证书未来市场广阔!成为成都创新互联公司的ssl证书销售渠道,可以享受市场价格4-6折优惠!如果有意向欢迎电话联系或者加微信:028-86922220(备注:SSL证书合作)期待与您的合作!

1. 首先模拟一个可以存放大数据的pojo对象,这个对象可以通过构造参数给定的size来模拟一个size大小的字符串。

 
 
 
  1. package com.googlecode.garbagecan.cxfstudy.compress;  
  2.  
  3.  
  4. public class BigData {  
  5.       
  6.     private String name;  
  7.       
  8.     private String data;  
  9.       
  10.     public BigData() {  
  11.           
  12.     }  
  13.       
  14.     public BigData(String name, int size) {  
  15.         this.name = name;  
  16.         StringBuilder sb = new StringBuilder();  
  17.         for (int i = 0; i < size; i++) {  
  18.             sb.append("0");  
  19.         }  
  20.         this.data = sb.toString();  
  21.     }  
  22.  
  23.     public String getName() {  
  24.         return name;  
  25.     }  
  26.  
  27.     public void setName(String name) {  
  28.         this.name = name;  
  29.     }  
  30.  
  31.     public String getData() {  
  32.         return data;  
  33.     }  
  34.  
  35.     public void setData(String data) {  
  36.         this.data = data;  
  37.     }  

2. Web Service接口类,和普通的接口定义没有什么区别。

 
 
 
  1. package com.googlecode.garbagecan.cxfstudy.compress;  
  2.  
  3. import javax.jws.WebMethod;  
  4. import javax.jws.WebParam;  
  5. import javax.jws.WebResult;  
  6. import javax.jws.WebService;  
  7.  
  8. @WebService 
  9. public interface BigDataService {  
  10.       
  11.     @WebMethod 
  12.     @WebResult BigData getBigData(@WebParam String name, @WebParam int size);  

3. Web Service实现类

 
 
 
  1. package com.googlecode.garbagecan.cxfstudy.compress;  
  2.  
  3. public class BigDataServiceImpl implements BigDataService {  
  4.     public BigData getBigData(String name, int size) {  
  5.         BigData bigData = new BigData(name, size);  
  6.         return bigData;  
  7.     }  

4. 测试类,这片文章使用了JUnit测试类来做测试。setUpBeforeClass方法用来启动Service, testGetBigData方法用来测试web service。

注意setUpBeforeClass方法中的

factoryBean.getInInterceptors().add(new GZIPInInterceptor());

factoryBean.getOutInterceptors().add(new GZIPOutInterceptor());

和testGetBigData方法中的

endpoint.getInInterceptors().add(new GZIPInInterceptor());

endpoint.getOutInterceptors().add(new GZIPOutInterceptor());

上面两段代码就是告诉CXF使用压缩Interceptor来压缩和解压缩数据包。

 
 
 
  1. package com.googlecode.garbagecan.cxfstudy.compress;  
  2.  
  3. import org.apache.cxf.endpoint.Client;  
  4. import org.apache.cxf.endpoint.Endpoint;  
  5. import org.apache.cxf.frontend.ClientProxy;  
  6. import org.apache.cxf.interceptor.LoggingInInterceptor;  
  7. import org.apache.cxf.interceptor.LoggingOutInterceptor;  
  8. import org.apache.cxf.jaxws.JaxWsProxyFactoryBean;  
  9. import org.apache.cxf.jaxws.JaxWsServerFactoryBean;  
  10. import org.apache.cxf.transport.http.gzip.GZIPInInterceptor;  
  11. import org.apache.cxf.transport.http.gzip.GZIPOutInterceptor;  
  12. import org.junit.Assert;  
  13. import org.junit.BeforeClass;  
  14. import org.junit.Test;  
  15.  
  16. public class BigDataServiceTest {  
  17.  
  18.     private static final String address = "http://localhost:9000/ws/compress/bigDataService";  
  19.       
  20.     @BeforeClass 
  21.     public static void setUpBeforeClass() throws Exception {  
  22.         JaxWsServerFactoryBean factoryBean = new JaxWsServerFactoryBean();  
  23.         factoryBean.getInInterceptors().add(new LoggingInInterceptor());  
  24.         factoryBean.getOutInterceptors().add(new LoggingOutInterceptor());  
  25.         factoryBean.getInInterceptors().add(new GZIPInInterceptor());  
  26.         factoryBean.getOutInterceptors().add(new GZIPOutInterceptor());  
  27.           
  28.         factoryBean.setServiceClass(BigDataServiceImpl.class);  
  29.         factoryBean.setAddress(address);  
  30.         factoryBean.create();  
  31.     }  
  32.  
  33.     @Test 
  34.     public void testGetBigData() {  
  35.         JaxWsProxyFactoryBean factoryBean = new JaxWsProxyFactoryBean();  
  36.         factoryBean.setAddress(address);  
  37.         factoryBean.setServiceClass(BigDataService.class);  
  38.         Object obj = factoryBean.create();  
  39.           
  40.         Client client = ClientProxy.getClient(obj);  
  41.         Endpoint endpoint = client.getEndpoint();  
  42.         endpoint.getInInterceptors().add(new GZIPInInterceptor());  
  43.         endpoint.getOutInterceptors().add(new GZIPOutInterceptor());  
  44.           
  45.         BigDataService service = (BigDataService) obj;  
  46.         Assert.assertNotNull(service);  
  47.           
  48.         String name = "my big data";  
  49.         int size = 1024 * 1024 * 10;  
  50.           
  51.         long start = System.currentTimeMillis();  
  52.         BigData bigData = service.getBigData(name, size);  
  53.         long stop = System.currentTimeMillis();  
  54.         System.out.println("Time: " + (stop - start));  
  55.           
  56.         Assert.assertNotNull(bigData);  
  57.         Assert.assertEquals(name, bigData.getName());  
  58.         Assert.assertEquals(size, bigData.getData().length());  
  59.     }  

5. 运行此unit test,可以在日志中看到数据包前后大小和内容。

原文链接:http://blog.csdn.net/kongxx/article/details/7530216

【系列文章】

  1. Apache CXF实战之五:压缩Web Service数据
  2. Apache CXF实战之四:构建RESTful Web Service
  3. Apache CXF实战之三:传输Java对象
  4. Apache CXF实战之二:集成Sping与Web容器
  5. Apache CXF实战之一:Hello World Web Service

分享名称:ApacheCXF实战之五:压缩WebService数据
URL分享:http://www.gawzjz.com/qtweb2/news49/4299.html

网站建设、网络推广公司-创新互联,是专注品牌与效果的网站制作,网络营销seo公司;服务项目有等

广告

声明:本网站发布的内容(图片、视频和文字)以用户投稿、用户转载内容为主,如果涉及侵权请尽快告知,我们将会在第一时间删除。文章观点不代表本网站立场,如需处理请联系客服。电话:028-86922220;邮箱:631063699@qq.com。内容未经允许不得转载,或转载时需注明来源: 创新互联