商业服务网格，第 2 部分: 实现商业服务网格

import com.ibm.edge.webservices.systemservices.servicedesk.ServiceDesk;

        

public StockQuoteServiceDesk extends ServiceDesk {
    public StockQuoteServiceDesk() throws Exception
    {
      super();

      String wsdlImplURL =          
        "http://localhost/wstk/servicedomain/
           StockQuoteServiceDesk_Impl.wsdl";
      String wsdlIntURL =          
        "http://localhost/wstk/servicedomain/
           StockQuoteServiceDesk_Interface.wsdl";
      String serviceName = "StockQuoteServiceDeskService";         
      String nameSpace =  "http://StockQuoteServiceDesk";       
      String portName =  "stockquoteservicedesk";        
      String endPointAddress = "http://localhost/wstk/services/
         stockquoteservicedesk";
    
      ServiceInfo info;
      info = new ServiceInfo("",
      serviceName,
      wsdlIntURL,
      wsdlImplURL,
      nameSpace,
      portName,
      endPointAddress,
      "Stock Quote Service Desk",
      "I provide Stock Quotes");
      super.setServiceInfo(info);
    }
}

                
      

public class StockQuoteServiceDesk extends ServiceDesk {
   . . . . . . . .
   . . . . . . . .
        public String getQuoteDescriptive(String session, String arg)
   throws Exception
  {
    ResponseContext result = InvokeOperation(session,          "getQuoteDescriptive",
                               new Object[] { arg });
    return (String)result.getResult();
  }
  
  public String getQuoteSingle(String session, String symbol)
    throws Exception
  {
    ResponseContext result = InvokeOperation(session, 
      "getQuoteSingle", new Object[] { symbol });
    return (String)result.getResult();
  }
  
  public String getQuoteMultiple(String session, String[] symbols)
    throws Exception
  {
    ResponseContext result = InvokeOperation(session, 
      "getQuoteMultiple", new Object[] { symbols });
    return (String)result.getResult();
  }
        . . . . . . . . 
        . . . . . . . .
}


                

SDgen.bat -i StockQuoteService -o StockQuoteServiceDesk -m StockQuote -p
StockQuoteServiceDeskPolicy.xml -s stockquoteservicedesk.properties

        


        
          Where the StockQuoteService Java interface for the operations is:
        
        

     public interface StockQuoteService {
        public String getQuoteDescriptive(String symbol);
        public String getQuoteSingle(String symbol);
        public String[] getQuoteMultiple(String[] symbol);
     }

        

        
          assumes the following:
            

a. a service policy file, StockQuoteServiceDeskPolicy.xml, exists.
b. stockquoteservicedesk.properties can be found in the classpath 
   at run time.
c. the properties file, stockquoteservicedesk.properties, 
   contains the following properties:
          
        

#######################################################
# Sample properties file for setting service info for
# a sample service desk
# The properties SERVICE_NAME, SERVICE_IMPL_WSDL_URL, NAME_SPACE
# and SERVICE_PORT_NAME are mandatory. The rest are optional.
#
SERVICE_NAME=StockQuoteServiceDesk
SERVICE_INTERFACE_WSDL_URL=http://localhost:80/wstk/StockQuoteServiceDesk/
   StockQuoteServiceDesk_Interface.wsdl
SERVICE_IMPL_WSDL_URL=http://localhost:80/wstk/StockQuoteServiceDesk/
   StockQuoteServiceDesk_Impl.wsdl
NAME_SPACE=http://StockQuoteServiceDesk
SERVICE_PORT_NAME=stockquoteservicedesk
ENDPOINT_ADDRESS=http://localhost:80/wstk/services/stockquoteservicedesk
PROVIDER_NAME=StockQuoteServiceProvider
PROVIDER_DESCRIPTION=ProvideStockQuotes


        
          note:

SDgen creates the Java class StockQuoteServiceDesk in the same 
package as the interface file (in this example, 
StockQuoteService).   If the package name is not specified, it 
is generated in package com.ibm.edge.applications  Compile the 
generated Java class. Run WSTK's Java2WSDL utility program to 
generate a WSDL for the new service desk.  Place this properties 
file in the webapp's classes directory so that the service desk 
can find it at run time.
        

                
      

   public class MyServiceHub extends ServiceHub {


  
        
          /**
   *  Instantiates an instance of MyServiceHub
   *  
   */
        

  public MyServiceHub() throws Exception
  {
    Super();
  
        
          //  set service information here 
        
  } 
    }

                
      

public class MyServiceHubHandler extends JavaProvider {
  . . . . . . . .
  . . . . . . . .
  /**
   * Redirect specific service request operation/method calls to a 
   * call to the
   * common receiving method "invokeOperationWithQos" of the hub.
   */
   public void processMessage(
        MessageContext msgContext,
  SOAPEnvelope reqEnv,
  SOAPEnvelope resEnv,
  Object obj)
  throws Exception
        {
        
        
          // process handler specific parameters from msgContext
              . . . . . . . .
           // process portname
        
                String portname = msgContext.getTargetService();
            
       
        
          // process operation/method name and arguments from reqEnv
        
              Vector       bodies = reqEnv.getBodyElements();
              RPCElement   body = null;

              for (int bNum = 0; body == null && bNum <  bodies.size(); 
                 bNum++ ) 
              {
           body = (RPCElement) bodies.get( bNum );
              }

    if (body == null) {
            throw new Exception();
    }
      
        String methodName = body.getMethodName();
                Vector args = body.getParams();
    Object [] newArgs = convertParams(portname, methodName, 
       newArgs);

    
        
          // call hub object
        
    JavaClass jc = JavaClass.find(obj.getClass());
    Method method = jc.getMethod("invokeOperationWithQoS");
    return method.invoke(obj, newArgs);

        } 

        protected Object[] convertParams(
                String port,
                String method,
                Vector args)
        {
             
        
          // insert portname and method name to the arguments 
                   and convert to array
        
  }
    . . . . . . . .
    . . . . . . . .
}

                
      

public class MyRegistryDiscoveryDomain extends RegistryDiscoveryDomain {

  /**
   *  Instantiates an instance of RegistryDiscoveryDomain
   *  
   */

  public MyRegistryDiscoveryDomain() throws Exception
  {
    Super();
  
        
          //  set service information here
        
  } 
}

                
      

ServiceHub MyServiceHub; 
        
          // instance of a resumed service, 
   MyServiceHub 
        
String akey;            
        
          // service instance key from the previous 
   run 
        

MyServiceHub.getServiceInfo(akey);

                
      

        
        
          #########################################################
# data files for user defined mode, e.g. MyHub
# the paths are all relative to WSTK's source directory (this is 
# how wstk folks do it)
#
# files for ServiceDesk Domains
# file used by listing to store information about suppliers
        
MyHub.listingProviderFileName=/services/demos/servicedomain/myhub/
   providers.xml


        
          # file used to store information about user sessions 
        
MyHub.sessionsFileName=/services/demos/servicedomain/myhub/sessions.xml


        
          # file used to store provider SLAs
        
MyHub.providerSLAFileName=/services/demos/servicedomain/myhub/
   providerSLA.xml


        
          # file used to store provider specific information for cloning
        
MyHub.cloneDataDir=/services/demos/servicedomain/myhub/cloneData


        
          #
# additional files for ServiceHub Domains
#  file containing the default master policy file for the service
    hub
        
MyHub.masterPolicyFileName=/services/demos/servicedomain/myhub/
   masterpolicy.xml


        
          # file to store meta data for service groups
        
MyHub.groupSetFileName=/services/demos/servicedomain/myhub/groupset.xml


        
          # log file used by the log handler MyHub.logFile=/services/demos/
   servicedomain/myhub/logfile.txt
        
      
                
      

      

ServiceHub MyServiceHub;    
        
          // instance of MyServiceHub
          

MyServiceHub.setMode("MyHub");  
        
          // set property mode