探索 Web 服务总线，第 2 部分: 比较总线过滤器和 Axis 处理程序

package gaf.filter.sq;
public class SQ {
    public float getQuote(String symbol) throws Exception {
        if (symbol.equals("XXX")) {
            return ((float) 55.25);
        } else if (symbol.equals("YYY")) {
            return ((float) 125.35);
        } else {
            return ((float) 0);
        }
    }
}

package services.demos.wsbus.client.examples;
public class BusSQClient extends SQClientBase {
    public static void main(String[] args) throws Exception {
        System.setProperty(
            WSIFServiceFactory.WSIFFACTORY_CLASSNAME,
            "com.ibm.wsbus.wsif.WSIFBusServiceFactory");
        WSIFBusServiceFactory factory =
            (WSIFBusServiceFactory) WSIFServiceFactory.newInstance();
        WSIFService service = factory.getService(null, args[0]);
        getQuote(service, "XXX");
        getQuote(service, "YYY");
        getQuote(service, "ZZZ");
    }
    private static void getQuote(WSIFService service, String sym) 
        throws Exception {
        javax.wsdl.Port wp = getPort();
        WSIFPort port = service.getPort(wp.getName());
        WSIFOperation operation =
            port.createOperation("getQuote", "getQuoteRequest", null);
        WSIFMessage inputMessage = operation.createInputMessage();
        WSIFMessage outputMessage = operation.createOutputMessage();
        WSIFMessage faultMessage = operation.createFaultMessage();
        inputMessage.setObjectPart("symbol", sym);
        boolean operationSucceeded =
            operation.executeRequestResponseOperation(
                inputMessage, 
                outputMessage,
                faultMessage);
        System.out.println("The quote: " + outputMessage.getFloatPart("return"));
    }
}

package services.demos.wsbus.client.examples;
public class AxisSQClient extends SQClientBase {
    public static void main(String[] args) throws Exception {
            
        QName serviceQN = wsdlService.getQName();
        Service service = new Service(new URL(args[0]), serviceQN);
        getQuote(service, "XXX");
        getQuote(service, "YYY");
        getQuote(service, "ZZZ");
    }
    private static void getQuote(Service service, String sym) 
        throws Exception {
        QName portQN = new QName(def.getTargetNamespace(), getPort().getName());
        Call call = (Call) service.createCall(portQN, "getQuote");
        Object in[] = new Object[1];
        RPCParam p = new RPCParam("", "symbol", sym);
        in[0] = p;
                
        Float ret = (Float) call.invoke(in);
        System.out.println("The quote: " + ret);
    }
}

package services.demos.wsbus.client.filters;
public class CompressFilter implements Filter {
    private static QName name = new QName("http://gaf.filter.test", "compressType");
    public FilterAction filterRequest(WSIFRequest request, WSIFResponse response)
        throws WSBusException, FilterException {
        try {
            // get parameter
            WSIFMessage requestMessage = request.getIncomingMessage();
            sym = (String) requestMessage.getObjectPart("symbol");
            // "compress"
            if (sym.equals("XXX")) {
                System.out.println("Filter compressing with X type.");
                requestMessage.setObjectPart("symbol", "X");
                compType = "X";
            } else if (sym.equals("YYY")) {
                System.out.println("Filter compressing with Y type.");
                requestMessage.setObjectPart("symbol", "Y");
                compType = "Y";
            }
            // create element that indicates compression type
            DocumentBuilderFactory factory = DocumentBuilderFactory.newInstance();
            Document doc = factory.newDocumentBuilder().newDocument();
            Element token = doc.createElementNS(name.getNamespaceURI(), 
                                    name.getLocalPart());
            token.setAttribute("type", compType);
            // insert context that indicates compression type
            WSIFMessage contextMessage = request.getContextMessage();
            if (contextMessage == null) {
                contextMessage = new WSIFDefaultMessage();
                request.setContextMessage(contextMessage);
            }
            contextMessage.setObjectPart(name.toString(), token);
        } catch (Exception e) {
            e.printStackTrace();
            throw new WSBusException("Compressor: didn't work!");
        }
        return action;
    }
}

package gaf.filter.sq;
public class DecompressFilter implements Filter {
    private static QName name = new QName("http://gaf.filter.test", "compressType");
    public FilterAction filterRequest(WSIFRequest request, WSIFResponse response)
        throws WSBusException, FilterException {
        try {
            // get parameter
            WSIFMessage requestMessage = request.getIncomingMessage();
            sym = (String) requestMessage.getObjectPart("symbol");
            // get the compression type
            WSIFMessage contextMessage = request.getContextMessage();
            // since do 'custom' name creation from qname, use following format
            Element token = 
                (Element) contextMessage.getObjectPart(name.getNamespaceURI() + 
                   ":" + name.getLocalPart());
            compType = token.getAttribute("type");
            // "decompress"
            WSIFMessage newReq = null;
            if (!compType.equals("none")) {
                newReq = new WSIFDefaultMessage();
                request.setIncomingMessage(newReq);
            }
            if (compType.equals("X")) {
                System.out.println("Filter decompressing with type X.");
                newReq.setObjectPart("symbol", "XXX");
            } else if (compType.equals("Y")) {
                System.out.println("Filter decompressing with type Y.");
                newReq.setObjectPart("symbol", "YYY");
            }
        } catch (Exception ex) {
            throw new WSBusException("Decompressor: can't work!");
        }
        
        return action;
    }
}

package services.demos.wsbus.client.filters;
public class CompressHandler extends BasicHandler {
    private static QName name = new QName("http://gaf.filter.test", "compressType");
    public void invoke(MessageContext context) throws AxisFault {
        try {
            // get the parameter
            SOAPPart part =
                (org.apache.axis.SOAPPart) context.getCurrentMessage().getSOAPPart();
            SOAPEnvelope envelope = part.getAsSOAPEnvelope();
            RPCElement pel = (RPCElement) envelope.getFirstBody();
            RPCParam parm = pel.getParam("symbol");
            sym = (String) parm.getValue();
            // "compress"
            if (sym.equals("XXX")) {
                System.out.println("Handler compressing with X type.");
                parm.setValue("X");
                compType = "X";
            } else if (sym.equals("YYY")) {
                System.out.println("Handler compressing with Y type.");
                parm.setValue("Y");
                compType = "Y";
            }
            // create element that indicates compression type
            DocumentBuilderFactory factory = DocumentBuilderFactory.newInstance();
            Document doc = factory.newDocumentBuilder().newDocument();
            Element token = doc.createElementNS(name.getNamespaceURI(), 
                 name.getLocalPart());
            token.setAttribute("type", compType);
            // insert a header that indicates compression type
            envelope.addHeader(new SOAPHeaderElement(token));
            part.setSOAPEnvelope(envelope);
        } catch (Exception ex) {
            AxisFault fault = AxisFault.makeFault(ex);
            throw fault;
        }
    }
}

package gaf.filter.sq;
public class DecompressHandler extends BasicHandler {
    private static QName name = new QName("http://gaf.filter.test", "compressType");
    public void invoke(MessageContext context) throws AxisFault {
               
        try {
            // get the parameter
            SOAPPart part =
                (org.apache.axis.SOAPPart) context.getCurrentMessage().getSOAPPart();
            SOAPEnvelope envelope = part.getAsSOAPEnvelope();
            RPCElement pel = (RPCElement) envelope.getFirstBody();
            RPCParam parm = pel.getParam("symbol");
            sym = (String) parm.getValue();
            // get the compression type
            SOAPHeaderElement header =
                envelope.getHeaderByName(name.getNamespaceURI(), name.getLocalPart());
            Element token = header.getAsDOM();
            compType = token.getAttribute("type");
            // "decompress"
            if (compType.equals("X")) {
                System.out.println("Handler decompressing with type X.");
                parm.setValue("XXX");
            } else if (compType.equals("Y")) {
                System.out.println("Handler decompressing with type Y.");
                parm.setValue("YYY");
            }
        } catch (Exception ex) {
            AxisFault fault = AxisFault.makeFault(ex);
            throw fault;
        }
    }
}

<deploy force="true">
  <filters>
    <filter name="decompressor" started="true" 
        className="gaf.filter.sq.DecompressFilter"/>
  </filters>
  <busServices>
    <busService serviceName="SQBus" ...>
      <channels>
        <channelReference channel="axis"/>
      </channels>
      <targetServices>
        <targetService className="gaf.filter.sq.SQ" serviceName="SQService" .../>
      </targetServices>
      <preFilters>
        <filterReference filter="decompressor" />
      </preFilters>
    </busService>
  </busServices>  
</deploy>

<busInfo started="true" >
  <filters >
    <filter name="compressor" 
         className="services.demos.wsbus.client.filters.CompressFilter" ... />
  </filters>
  <busServices >
    <busService serviceName="SQBus" ... >
      <preFilters >
        <filterReference  filter="compressor" >
        </filterReference>
      </preFilters>
    </busService>
  </busServices>
</busInfo>

C:\wstk-3.2.2\services\demos\wsbus\client>RunBusSQ.bat
 ===> Deploy the service and filter in the Bus off-ramp engine
Results: OK
 ===> Deploy service and filter in Bus on-ramp engine
 ===> Request quotes
Retrieving document at 'http://<hostname>:<port>/wstk/wsbus/ServiceDefinition?name=SQBus'.
Retrieving import document at 'http://<hostname>:<port>/wstk/wsbus/ServiceInterface?name=SQBus
Using WSIFServiceFactory
BusServiceFactory: no class name for discovery or selection. Using default.
Filter compressing with X type.
The quote: 55.25
Filter compressing with Y type.
The quote: 125.35
The quote: 0.0
 ===> Undeploy the service and filter in the Bus off-ramp
Results: OK

[<date & time >] 6fa289b6 SystemOut     U Filter decompressing with type X.
[<date & time >] 6fa289b6 SystemOut     U Filter decompressing with type Y.

<deployment xmlns="http://xml.apache.org/axis/wsdd/" 
            xmlns:java="http://xml.apache.org/axis/wsdd/providers/java">
  <handler name="decompressor" type="java:gaf.filter.sq.DecompressHandler">
  </handler>
  <service name="SQAxis" provider="java:RPC">
    <parameter name="className" value="gaf.filter.sq.SQ"/>
    <parameter name="allowedMethods" value="getQuote"/>
    <requestFlow>
      <handler type="decompressor"/>
    </requestFlow>
  </service>
</deployment>

<deployment xmlns="http://xml.apache.org/axis/wsdd/" 
            xmlns:java="http://xml.apache.org/axis/wsdd/providers/java">
  <handler name="compressor" 
      type="java:services.demos.wsbus.client.filters.CompressHandler">
  </handler>
  <service name="http://localhost/wstk/services/SQAxis/wstk/services/SQAxis" 
       provider="java:RPC">
    <requestFlow>
      <handler type="compressor"/>
    </requestFlow>
  </service>
</deployment>

C:\wstk-3.2.2\services\demos\wsbus\client>RunAxisSQ.bat
 ===> Deploy the service and handler in the Axis server engine
- Processing file deployment/deployAxisSQ.wsdd
<Admin>Done processing</Admin>
 ===> Deploy the service and handler in the Axis client engine
 
 ===> Request quotes
Retrieving document at 'http://<hostname>:<port>/wstk/services/SQAxis?wsdl'.
Handler compressing with X type.
The quote: 55.25
Handler compressing with Y type.
The quote: 125.35
The quote: 0.0
 ===> Undeploy the service and handler from Axis client engine
 ===> Undeploy the service and handler from the Axis server engine
- Processing file deployment/undeployAxisSQ.wsdd
<Admin>Done processing</Admin>

[<date & time >] 6fce09b6 SystemOut     U Handler decompressing with type X.
[<date & time >] 6fce09b6 SystemOut     U Handler decompressing with type Y.

<busInfo started="true" >
  <filters >
    <filter name="compressor" 
         className="services.demos.wsbus.client.filters.CompressFilter" ... />
  </filters>
  <busServices >
    <busService serviceName="SQService" ... >
      <preFilters >
        <filterReference  filter="compressor" >
        </filterReference>
      </preFilters>
    </busService>
  </busServices>
</busInfo>

C:\wstk-3.2.2\services\demos\wsbus\client>RunBusSQX.bat
 ===> Deploy the service and handler in the Axis server engine
- Processing file deployment/deployAxisSQ.wsdd
<Admin>Done processing</Admin>
 ===> Deploy service and filter in Bus on-ramp engine
 ===> Request quotes
Retrieving document at 'http://<hostname>:<port>/wstk/services/SQAxis?wsdl'.
using WSIFServiceFactory
BusServiceFactory: no class name for discovery or selection. Using default.
Filter compressing with X type.
The quote: 55.25
Filter compressing with Y type.
The quote: 125.35
The quote: 0.0
 ===> Undeploy the service and handler from the Axis server engine
- Processing file deployment/undeployAxisSQ.wsdd
<Admin>Done processing</Admin>

[<date & time >] 6fa289b6 SystemOut     U Handler decompressing with type X.
[<date & time >] 6fa289b6 SystemOut     U Handler decompressing with type Y.

<deployment xmlns="http://xml.apache.org/axis/wsdd/" 
            xmlns:java="http://xml.apache.org/axis/wsdd/providers/java">
  <handler name="compressor" 
      type="java:services.demos.wsbus.client.filters.CompressHandler">
  </handler>
  <service name=""http://mybus/#SQBus" provider="java:RPC">
    <requestFlow>
      <handler type="compressor"/>
    </requestFlow>
  </service>
</deployment>

C:\wstk-3.2.2\services\demos\wsbus\client>RunAxisSQX.bat
 ===> Deploy the service and filter in the Bus off-ramp engine
Results: OK
 ===> Deploy the service and handler in the Axis client engine
 ===> Request quotes
Retrieving document at 'http://<hostname>:<port>/wstk/wsbus/ServiceDefinition?name=SQBus'.
Retrieving import document at 'http://<hostname>:<port>/wstk/wsbus/ServiceInterface?name=SQBus
Handler compressing with X type.
The quote: 55.25
Handler compressing with Y type.
The quote: 125.35
The quote: 0.0
 
 ===> Undeploy the service and handler from Axis client engine
 ===> Undeploy the service and filter in the Bus off-ramp
Results: OK

[<date & time >] 6fbe49b6 SystemOut     U Filter decompressing with type X.
[<date & time >] 6fbe49b6 SystemOut     U Filter decompressing with type Y.