学步园

import java.io.FileOutputStream;
import java.io.PrintWriter;
import java.util.Date;

import org.apache.axis.AxisFault;
import org.apache.axis.Handler;
import org.apache.axis.MessageContext;
import org.apache.axis.handlers.BasicHandler;

public class LogHandler extends BasicHandler {
  
   /**invoke，每一个handler都必须实现的方法。
  */
    public void invoke(MessageContext msgContext) throws AxisFault
    {
       //每当web服务被调用，都记录到log中。
        try {
            Handler handler = msgContext.getService();
            String filename = (String)getOption("filename");
            if ((filename == null) || (filename.equals("")))
                throw new AxisFault("Server.NoLogFile",
                                 "No log file configured for the LogHandler!",
                                    null, null);
            FileOutputStream fos = new FileOutputStream(filename, true);            
            PrintWriter writer = new PrintWriter(fos);            
            Integer counter = (Integer)handler.getOption("accesses");
            if (counter == null)
                counter = new Integer(0);
            
            counter = new Integer(counter.intValue() + 1);            
            Date date = new Date();
            msgContext.getMessage().writeTo(System.out);
           
            String result = "在"+date + ": Web 服务 " +
                            msgContext.getTargetService() +
                            " 被调用，现在已经共调用了 " + counter + " 次.";
            handler.setOption("accesses", counter);            
            writer.println(result);            
            writer.close();
        } catch (Exception e) {
            throw AxisFault.makeFault(e);
        }
    }
}

…
</globalConfiguration>
…
  <handler name="logging" type="java:com.hellking.webservice.LogHandler">
  <parameter name="filename" value="c://MyService.log"/>
 </handler>
…
<service name="HandleredService" provider="java:RPC">
…
  <requestFlow>
  <handler type="logging"/>
   …<!--在这里可以指定多个Handler-->
  </requestFlow>
 </service>

//此handler的目的是对用户认证，只有认证的用户才能访问目标服务。
public class AuthenticationHandler extends BasicHandler
{
 /**invoke，每一个handler都必须实现的方法。
  */
 public void invoke(MessageContext msgContext)throws AxisFault
 {  
        SecurityProvider provider = (SecurityProvider)msgContext.getProperty("securityProvider");
  if(provider==null)
  {
   provider= new SimpleSecurityProvider();
             msgContext.setProperty("securityProvider", provider);
         }
        if(provider!=null)
        {         
         String userId=msgContext.getUsername();
         String password=msgContext.getPassword();
         
         //对用户进行认证，如果authUser==null，表示没有通过认证，
抛出Server.Unauthenticated异常。
            org.apache.axis.security.AuthenticatedUser authUser 
= provider.authenticate(msgContext);
            if(authUser==null)
              throw new AxisFault("Server.Unauthenticated", 
Messages.getMessage("cantAuth01", userId), null,null);
            //用户通过认证，把用户的设置成认证了的用户。
            msgContext.setProperty("authenticatedUser", authUser);
        } 
    }
}

import…

//此handler的目的是对认证的用户授权，只有授权的用户才能访问目标服务。
public class AuthorizationHandler extends BasicHandler
{
 /**invoke，每一个handler都必须实现的方法。
  */
 public void invoke(MessageContext msgContext)
        throws AxisFault
    {
      
        AuthenticatedUser user = (AuthenticatedUser)msgContext.getProperty("authenticatedUser");
        if(user == null)
            throw new AxisFault("Server.NoUser", Messages.getMessage("needUser00"), null, null);
        String userId = user.getName();
        Handler serviceHandler = msgContext.getService();
        if(serviceHandler == null)
            throw new AxisFault(Messages.getMessage("needService00"));
        String serviceName = serviceHandler.getName();
        String allowedRoles = (String)serviceHandler.getOption("allowedRoles");
        if(allowedRoles == null)
        {          
            return;
        }
        SecurityProvider provider = (SecurityProvider)msgContext.getProperty("securityProvider");
        if(provider == null)
            throw new AxisFault(Messages.getMessage("noSecurity00"));
        for(StringTokenizer st = new StringTokenizer(allowedRoles, ","); st.hasMoreTokens();)
        {
            String thisRole = st.nextToken();
            if(provider.userMatches(user, thisRole))
            {
                return;//访问授权通过。
            }
        }
        //没有通过授权，不能访问目标服务，抛出Server.Unauthorized异常。
        throw new AxisFault("Server.Unauthorized", 
Messages.getMessage("cantAuth02", userId, serviceName), null, null);
    }     
}