ApacheCXF实战之六：创建安全的WebService

我们在使用Web Service的过程中，很多情况是需要对web service请求做认证的，对于运行在web容器里的应用程序来说，可能会比较简单一些，通常可以通过filter来做一些处理，但是其实CXF本身也提供了对web service认证的方式。下面来看一下如何实现。

成都创新互联成立与2013年，我们提供高端网站建设、成都小程序开发、电商视觉设计、重庆APP软件开发及网络营销搜索优化服务，在传统互联网与移动互联网发展的背景下，我们坚守着用标准的设计方案与技术开发实力作基础，以企业及品牌的互联网商业目标为核心，为客户打造具商业价值与用户体验的互联网+产品。

1. 首先是一个简单pojo

 
 
 
  
  
  package com.googlecode.garbagecan.cxfstudy.security;    
  
     
  
  public class User {    
  
      private String id;    
  
      private String name;    
  
      private String password;    
  
      public String getId() {    
  
          return id;    
  
      }    
  
      public void setId(String id) {    
  
          this.id = id;    
  
      }    
  
      public String getName() {    
  
          return name;    
  
      }    
  
      public void setName(String name) {    
  
          this.name = name;    
  
      }    
  
      public String getPassword() {    
  
          return password;    
  
      }    
  
      public void setPassword(String password) {    
  
          this.password = password;    
  
      }    
  
  }

2. Web Service接口

 
 
 
  
  
  package com.googlecode.garbagecan.cxfstudy.security;    
  
     
  
  import java.util.List;    
  
     
  
  import javax.jws.WebMethod;    
  
  import javax.jws.WebResult;    
  
  import javax.jws.WebService;    
  
     
  
  @WebService   
  
  public interface UserService {    
  
      @WebMethod   
  
      @WebResult List list();    
  
     
  
  }

3. Web Service实现类

 
 
 
  
  
  package com.googlecode.garbagecan.cxfstudy.security;    
  
     
  
  import java.util.ArrayList;    
  
  import java.util.List;    
  
     
  
  public class UserServiceImpl implements UserService {    
  
     
  
      public List list() {    
  
          List users = new ArrayList();    
  
          for (int i = 0; i < 10; i++) {    
  
              User user = new User();    
  
              user.setId("" + i);    
  
              user.setName("user_" + i);    
  
              user.setPassword("password_" + i);    
  
              users.add(user);    
  
          }    
  
          return users;    
  
      }    
  
     
  
  }

4. Server端Handler，其中使用了一个Map来存放用户信息，真是应用中可以使用数据库或者其它方式获取用户和密码

 
 
 
  
  
  package com.googlecode.garbagecan.cxfstudy.security;    
  
     
  
  import java.io.IOException;    
  
  import java.util.HashMap;    
  
  import java.util.Map;    
  
     
  
  import javax.security.auth.callback.Callback;    
  
  import javax.security.auth.callback.CallbackHandler;    
  
  import javax.security.auth.callback.UnsupportedCallbackException;    
  
     
  
  import org.apache.ws.security.WSPasswordCallback;    
  
     
  
  public class ServerUsernamePasswordHandler implements CallbackHandler {    
  
     
  
      // key is username, value is password    
  
      private Map users;    
  
     
  
      public ServerUsernamePasswordHandler() {    
  
          users = new HashMap();    
  
          users.put("admin", "admin");    
  
      }    
  
     
  
      public void handle(Callback[] callbacks) throws IOException, UnsupportedCallbackException {    
  
          WSPasswordCallback callback = (WSPasswordCallback) callbacks[0];    
  
          String id = callback.getIdentifier();    
  
          if (users.containsKey(id)) {    
  
              if (!callback.getPassword().equals(users.get(id))) {    
  
                  throw new SecurityException("Incorrect password.");    
  
              }    
  
          } else {    
  
              throw new SecurityException("Invalid user.");    
  
          }    
  
      }    
  
  }

5. Client端Handler，用来设置用户密码，在真实应用中可以根据此类和下面的测试类来修改逻辑设置用户名和密码。

 
 
 
  
  
  package com.googlecode.garbagecan.cxfstudy.security;    
  
     
  
  import java.io.IOException;    
  
     
  
  import javax.security.auth.callback.Callback;    
  
  import javax.security.auth.callback.CallbackHandler;    
  
  import javax.security.auth.callback.UnsupportedCallbackException;    
  
     
  
  import org.apache.ws.security.WSPasswordCallback;    
  
     
  
  public class ClientUsernamePasswordHandler implements CallbackHandler {    
  
      public void handle(Callback[] callbacks) throws IOException, UnsupportedCallbackException {    
  
          WSPasswordCallback callback = (WSPasswordCallback) callbacks[0];    
  
          int usage = callback.getUsage();    
  
          System.out.println("identifier: " + callback.getIdentifier());    
  
          System.out.println("usage: " + callback.getUsage());    
  
          if (usage == WSPasswordCallback.USERNAME_TOKEN) {    
  
              callback.setPassword("admin");    
  
          }    
  
      }    
  
  }

6. 单元测试类，注意在Server端添加了WSS4JInInterceptor到Interceptor列表中，在Client添加了WSS4JOutInterceptor到Interceptor列表中。

 
 
 
  
  
  package com.googlecode.garbagecan.cxfstudy.security;    
  
     
  
  import java.net.SocketTimeoutException;    
  
  import java.util.HashMap;    
  
  import java.util.List;    
  
  import java.util.Map;    
  
     
  
  import javax.xml.ws.WebServiceException;    
  
     
  
  import junit.framework.Assert;    
  
     
  
  import org.apache.cxf.endpoint.Client;    
  
  import org.apache.cxf.endpoint.Endpoint;    
  
  import org.apache.cxf.frontend.ClientProxy;    
  
  import org.apache.cxf.interceptor.LoggingInInterceptor;    
  
  import org.apache.cxf.interceptor.LoggingOutInterceptor;    
  
  import org.apache.cxf.jaxws.JaxWsProxyFactoryBean;    
  
  import org.apache.cxf.jaxws.JaxWsServerFactoryBean;    
  
  import org.apache.cxf.transport.http.HTTPConduit;    
  
  import org.apache.cxf.transports.http.configuration.HTTPClientPolicy;    
  
  import org.apache.cxf.ws.security.wss4j.WSS4JInInterceptor;    
  
  import org.apache.cxf.ws.security.wss4j.WSS4JOutInterceptor;    
  
  import org.apache.ws.security.WSConstants;    
  
  import org.apache.ws.security.handler.WSHandlerConstants;    
  
  import org.junit.BeforeClass;    
  
  import org.junit.Test;    
  
     
  
  public class UserServiceTest {    
  
     
  
      private static final String address = "http://localhost:9000/ws/security/userService";    
  
          
  
      @BeforeClass   
  
      public static void setUpBeforeClass() throws Exception {    
  
          JaxWsServerFactoryBean factoryBean = new JaxWsServerFactoryBean();    
  
          factoryBean.getInInterceptors().add(new LoggingInInterceptor());    
  
          factoryBean.getOutInterceptors().add(new LoggingOutInterceptor());    
  
     
  
          Map props = new HashMap();    
  
          props.put("action", "UsernameToken");    
  
          props.put("passwordType", "PasswordText");    
  
          props.put("passwordCallbackClass", ServerUsernamePasswordHandler.class.getName());    
  
          WSS4JInInterceptor wss4JInInterceptor = new WSS4JInInterceptor(props);    
  
          factoryBean.getInInterceptors().add(wss4JInInterceptor);    
  
              
  
          factoryBean.setServiceClass(UserServiceImpl.class);    
  
          factoryBean.setAddress(address);    
  
          factoryBean.create();    
  
      }    
  
     
  
      @Test   
  
      public void testList() {    
  
          JaxWsProxyFactoryBean factoryBean = new JaxWsProxyFactoryBean();    
  
          factoryBean.setAddress(address);    
  
          factoryBean.setServiceClass(UserService.class);    
  
          Object obj = factoryBean.create();    
  
              
  
          Client client = ClientProxy.getClient(obj);    
  
          Endpoint endpoint = client.getEndpoint();    
  
              
  
          Map props = new HashMap();    
  
          props.put(WSHandlerConstants.ACTION, WSHandlerConstants.USERNAME_TOKEN);    
  
          props.put(WSHandlerConstants.USER, "admin");    
  
          props.put(WSHandlerConstants.PASSWORD_TYPE, WSConstants.PW_TEXT);    
  
          props.put(WSHandlerConstants.PW_CALLBACK_CLASS, ClientUsernamePasswordHandler.class.getName());    
  
          WSS4JOutInterceptor wss4JOutInterceptor = new WSS4JOutInterceptor(props);    
  
          endpoint.getOutInterceptors().add(wss4JOutInterceptor);    
  
              
  
          HTTPConduit conduit = (HTTPConduit) client.getConduit();    
  
          HTTPClientPolicy policy = new HTTPClientPolicy();    
  
          policy.setConnectionTimeout(5 * 1000);    
  
          policy.setReceiveTimeout(5 * 1000);    
  
          conduit.setClient(policy);    
  
              
  
          UserService service = (UserService) obj;    
  
          try {    
  
              List users = service.list();    
  
              Assert.assertNotNull(users);    
  
              Assert.assertEquals(10, users.size());    
  
          } catch(Exception e) {    
  
              if (e instanceof WebServiceException     
  
                      && e.getCause() instanceof SocketTimeoutException) {    
  
                  System.err.println("This is timeout exception.");    
  
              } else {    
  
                  e.printStackTrace();    
  
              }    
  
          }    
  
      }    
  
     
  
  }

***运行上面的测试类来测试结果，也可以修改测试方法中的密码，看看错误结果，这里就不在写错误密码的测试用例了，因为我是一懒人。

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

【系列文章】

Apache CXF实战之六：创建安全的Web Service
Apache CXF实战之五:压缩Web Service数据
Apache CXF实战之四:构建RESTful Web Service
Apache CXF实战之三:传输Java对象
Apache CXF实战之二:集成Sping与Web容器
Apache CXF实战之一:Hello World Web Service

名称栏目：ApacheCXF实战之六：创建安全的WebService
网站路径：http://www.shufengxianlan.com/qtweb/news29/249229.html

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

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

猜你还喜欢下面的内容