构建 SOA 组合业务服务，第 11 部分: 实现订阅者授权流程

                
 <?xml version="1.0" encoding="UTF-8"?>
<xsd:schema
	targetNamespace="http://f49.j2b.ibm.com/1/0/template"
	xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:sdo="commonj.sdo"
	xmlns:sdoxml="commonj.sdo/xml"
	xmlns:tns="http://www.ibm.com/xmlns/prod/serviceregistry/6/0/governance/SampleTaxonomy"
|-------10--------20--------30--------40--------50--------60--------70--------80--------9|
|-------- XML error:  The previous line is longer than the max of 90 characters ---------|
	xmlns:srsdo="http://www.ibm.com/xmlns/prod/serviceregistry/6/0/sdo">

	<xsd:complexType name="Service">
		<xsd:attribute name="businessOwner" type="xsd:string" />
		<xsd:attribute name="availableEndpoints" type="xsd:IDREFS" />
		<xsd:attribute name="providedInterface" type="xsd:IDREFS" />
		<xsd:attribute name="contractTemplate" type="xsd:IDREFS"/>
		<xsd:attribute name="serviceDependencies" type="xsd:IDREFS" />
	</xsd:complexType>

	<xsd:complexType name="Batch ACH Service Subscribe Endpoint">
		<xsd:attribute name="executionCost" type="xsd:string" />
		<xsd:attribute name="responseTime" type="xsd:string" />
		<xsd:attribute name="maxChecksPerBatch" type="xsd:string" />
		<xsd:attribute name="minChecksPerBatch" type="xsd:string" />
		<xsd:attribute name="definingWSDLPort" type="xsd:IDREFS" />
	</xsd:complexType>

	<xsd:complexType name="Batch ACH Service Subscribe Contract">
		<xsd:attribute name="responsetime" type="xsd:string" />
		<xsd:attribute name="cost" type="xsd:string" />
		<xsd:attribute name="email" type="xsd:string" />
		<xsd:attribute name="servicename" type="xsd:string" />
		<xsd:attribute name="maxChecksPerRequest" type="xsd:string" />
		<xsd:attribute name="maxRequestPerHour" type="xsd:string" />
		<xsd:attribute name="isTestNeeded" type="xsd:string" />
		<xsd:attribute name="service" type="xsd:IDREFS" />
	</xsd:complexType>

</xsd:schema>
        

                
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE rdf:RDF [
	<!ENTITY wsrrgst "http://f49.j2b.ibm.com/1/0/Taxonomy#">
]?>
<rdf:RDF xml:base="http://f49.j2b.ibm.com/1/0/Taxonomy#"
	xmlns:owl="http://www.w3.org/2002/07/owl#"
	xmlns:rdf="http://www.w3.org/1999/02/22-rdf-syntax-ns#"
	xmlns:rdfs="http://www.w3.org/2000/01/rdf-schema#"
	xmlns:wsrrgst="http://f49.j2b.ibm.com/1/0/Taxonomy#"
	xmlns:xsd="http://www.w3.org/2001/XMLSchema#"?>
	
<owl:Ontology rdf:about="http://f49.j2b.ibm.com/1/0/Taxonomy"?>
	<rdfs:label>Jivaro2 Taxonomy</rdfs:label?>
</owl:Ontology?>

<owl:Class rdf:about="&wsrrgst;Production"?>
	<rdfs:label?>Product?</rdfs:label?>
	<rdfs:comment?>Services that are published as part of products?</rdfs:comment?>
</owl:Class?>
<owl:Class rdf:about="&wsrrgst;Test"?>
	<rdfs:label?>Test?</rdfs:label?>
	<rdfs:comment?>Services that are published for test?</rdfs:comment?>
</owl:Class?>
<owl:Class rdf:about="&wsrrgst;Public"?>
	<rdfs:label?>Public?</rdfs:label?>
	<rdfs:comment?>Services that are public?</rdfs:comment?>
</owl:Class?>
<owl:Class rdf:about="&wsrrgst;Private"?>
	<rdfs:label>Private</rdfs:label?>
	<rdfs:comment?>Services that are private?</rdfs:comment?>
</owl:Class?>
<owl:Class rdf:about="&wsrrgst;ContractTemplate"?>
	<rdfs:label?>ContractTemplate?</rdfs:label?>
	<rdfs:comment?>Contract Template?</rdfs:comment?>
</owl:Class?>
<owl:Class rdf:about="&wsrrgst;Contract"?>
	<rdfs:label?>Contract?</rdfs:label?>
	<rdfs:comment?>Contract?</rdfs:comment?>
</owl:Class?>


</rdf:RDF?>

                   
<perspective-definition xmlns="http://www.ibm.com/xmlns/prod/serviceregistry/6/0/
  PerspectiveDefinition"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.ibm.com/xmlns/prod/serviceregistry/6/0/
  PerspectiveDefinition
     ./../schemas/PerspectiveDefinition.xsd"
    perspective-definition-name="Viewer"
    weight="97">

 <title-message resource-bundle-name="SampleResources" message-key=
  "perspective.display.name.viewer"/>

 <roles>
  <role>Viewer</role>
 </roles>
	
 <navigation-tree-name>ViewerNavigationTree</navigation-tree-name>

 <detail-view-mappings>
  ......
  <view-mapping display-type="Service" view-definition-name="JivaroService" />
  <view-mapping display-type="Subscriber" view-definition-name="JivaroSubscriber" />
  <view-mapping display-type="contract" view-definition-name="JivaroContractDetail" />
  ......
 </detail-view-mappings>

 <collection-view-mappings>
  ......
  <view-mapping display-type="Service" view-definition-name="JivaroServices" />
  <view-mapping display-type="Subscriber" view-definition-name="JivaroSubscribers" />
  ......
 </collection-view-mappings>
</perspective-definition>

                  
<NavigationTree xmlns="http://www.ibm.com/xmlns/prod/serviceregistry/6/0/
     NavigationTreeDefinition"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xsi:schemaLocation="http://www.ibm.com/xmlns/prod/serviceregistry/6/0/
        NavigationTreeDefinition ../../schemas/NavigationTree.xsd"
       name="ViewerNavigationTree">
				
 <node id="navtree_root" node-resource-key="navigationtree.service.registry">
  <node id="businessmetadata" node-resource-key="navigationtree.unified.service.metadata">
   <node id="bservice" node-resource-bundle="SampleResources"
    node-resource-key="navigationtree.service.business.service" view-query-id=
    "showViewServices"/>
		</node>
  </node>
</NavigationTree>

                    
<ViewQueryDefinitionSet xmlns="http://www.ibm.com/xmlns/prod/serviceregistry/6/0/
  ViewQueryDefinitionSet" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xsi:schemaLocation="http://www.ibm.com/xmlns/prod/serviceregistry/6/0/
  ViewQueryDefinitionSet ../../schemas/ViewQueryDefinitionSet.xsd">
    <QueryDefinitions>
     ......
     <Query id="showViewServices">
      <ObjectType>GenericObject</ObjectType>
      <DisplayType>Service</DisplayType>
      <Relationship name="template">
        <Target>
          <Property name="name" value="Service" />
        </Target>
      </Relationship>
     </Query>
     ......
    </QueryDefinitions>
</ViewQueryDefinitionSet>

                  
<collection-view-definition xmlns="http://www.ibm.com/xmlns/prod/serviceregistry/6/0/
      CollectionViewDefinition"  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      xsi:schemaLocation="http://www.ibm.com/xmlns/prod/serviceregistry/6/0/
      CollectionViewDefinition ../../../schemas/CollectionViewDefinition.xsd"
      view-definition-name="JivaroServices">
 <messages>
  <title-message resource-bundle-name="SampleResources"
      message-key="sample.collection.view.business.services.title"/>
  <description-message resource-bundle-name="SampleResources"
      message-key="sample.collection.view.business.services.description"/>
 </messages>
  <column-definitions>
   <column-definition filterable="true">
  <heading-message message-key="collection.view.column.name"/>
    <property-name>name</property-name>
    <action>ViewDetail</action>
   </column-definition>
   <column-definition filterable="true">
  <heading-message message-key="collection.view.column.description"/>
    <property-name>description</property-name>
   </column-definition>
   <column-definition filterable="true">
  <heading-message message-key="collection.view.column.version"/>
    <property-name>version</property-name>
   </column-definition>
  </column-definitions>
 
  <button-definitions>
  </button-definitions>
</collection-view-definition>

                     
detail-view-definition xmlns="http://www.ibm.com/xmlns/prod/serviceregistry/6/0/
  DetailViewDefinition" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
  xsi:schemaLocation="http://www.ibm.com/xmlns/prod/serviceregistry/6/0/
  DetailViewDefinition ../../../schemas/DetailViewDefinition.xsd" 
  view-definition-name="JivaroService">
 <messages>
  <callout-message resource-bundle-name="SampleResources"
   message-key="sample.detail.view.business.service.callout" />
  <title-message resource-bundle-name="SampleResources" message-key=
   "sample.detail.view.business.service.title" />
  <description-message resource-bundle-name="SampleResources"
   message-key="sample.detail.view.business.service.description" />
 </messages>
 <tab-definition tab-name="details" tab-content="/pages/detailContent.jsp">
  <tab-title-message message-key="detail.details" />
  <general-properties>
   <heading-message message-key="detail.view.general.properties" />
   <property>
    <property-name>name</property-name>
    <property-messages>
     <property-message message-key="detail.view.name" />
     <field-help-message message-key="detail.view.name.field.help" />
    </property-messages>
   </property>
   ......
  </general-properties>
  <additional-properties>
   <heading-message message-key="detail.view.relationships" />
   <property hide-on-new="true">
    <action>ViewRelationshipDetail</action>
    <property-name>contractTemplate</property-name>
    <property-messages>
     <property-message resource-bundle-name="SampleResources" message-key=
        "sample.detail.view.contract" />
     <field-help-message message-key="detail.view.version.field.help" />
    </property-messages>
   </property>
  </additional-properties>
 </tab-definition>
</detail-view-definition>

                  
public void create(OriginalObject obj, boolean success.
     ServiceRegistryException arg2) {
   if (classificationURI==null)
        initProperties();
   if (!success)
        return;
   if ((obj==null) || (obj.getTemplate()==null) || 
   (obj.getTemplate().getClassificationURIs()==null))
   {
        return;
   }
   if (!obj.getTemplate().getClassificationURIs().contains(
             classificationURI)) {
        return;
   }

   if (wsrrClient == null) {
        init();
   }
	
   try {
        String servicename = BSRSDOHelper.INSTANCE.getPropertyValue(obj,"servicename");
        if ((servicename==null) || (servicename.trim().length()==0))
        {
             throw new RuntimeException("Servicename cannot be null");
        }
        GenericObject service = getServiceObjectFromServicename(servicename);
        if (service==null) {
             System.out.println("Cannot find subscribed service name");
             return;
        }
		
        BSRSDOHelper.INSTANCE.setTargetObject(obj,"service",service);
        ((WSRR)((GenericObjectImpl)obj).getRootObject()).
        getArtefacts().addAll(
        ((WSRR)((ComplexTypeDefinitionImpl)service.getTemplate()).getRootObject()).
        getArtefacts());
        obj.getClassificationURIs().add(contractClassification);
        wsrrClient.update(obj);

        String email="",responsetime="";

        StringBuffer buffer=new StringBuffer();
        List properties = obj.getUserDefinedProperties();
        for (int i = 0; i < properties.size(); i++) {
              UserDefinedProperty property = (UserDefinedProperty) properties.get(i);
              String propertyname = property.getName();
              if (propertyname.equals("email"))
              {
                   email=property.getValue();
              }
              else if (propertyname.equals("responsetime"))
              {
                   responsetime=property.getValue();
              }
              else if (!propertyname.equals("servicename")){
                   String propertyvalue = property.getValue();
                   if (propertyvalue!=null && propertyvalue.length()>0)
                   {
                      if (i==0)
                        buffer.append(property.getName()+"="+property.getValue());
                      else
                        buffer.append("&"+property.getName()+"="+property.getValue());
                   }
              }
        }

        invokeEntitlementProcess(service.getName(),obj.getOwner(),
             email,responsetime,buffer.toString(),obj.getBsrURI());
        }
        catch(Exception e)
        {
        System.out.println("Exception happened when add the relationship 
             service in contract:"+e.getMessage());
        e.printStackTrace();
        }
}

private String invokeEntitlementProcess(String serviceName,
        String contactorUserId,
        String contactorEmail,
        String contractResponsetime,
        String contractString,
        String contractBsrURI)
{
   try{
        EntitlementProcessInterfaceProxy proxy = new EntitlementProcessInterfaceProxy();
        proxy.setEndpoint(processendpoint);
        EntitlementProcessInterface service = proxy.getEntitlementProcessInterface();
        String result = service.process(serviceName,contactorUserId,contactorEmail,
             contractResponsetime,contractString,contractBsrURI);
        return result;
        }
   catch(Exception e)
        {
        e.printStackTrace();
	}
   return "";
}

                  
   System.setProperty(SYSTEM_TRUST_STORE, "C:\\DummyClientTrustFile.jks");
   System.setProperty(SYSTEM_TRUST_STORE_PASSWORD, "WebAS");
   System.setProperty(SYSTEM_KEY_STORE, "C:\\DummyClientKeyFile.jks");
   System.setProperty(SYSTEM_KEY_STORE_PASSWORD, "WebAS");
WSRRCoreSDOClient wsrrClient = new WSRRCoreSDOClient("https://localhost:9443/
WSRRCoreSDO/services/WSRRCoreSDOPort","wpsbind","wpsbind");

                  
 Subscription sub = (Subscription)DataFactory.INSTANCE.create(Subscription.class);
sub.setTargetBsrURI(serviceInstance.getBsrURI());
sub.setEmailAddress("mailto:"+email);
sub.setString("name","Subscription for service "+serviceName);
sub.setString("owner",userid);
String bsrURI = wsrrClient.create(sub);

                  
 BaseObject obj = wsrrClient.retrieve(bsrURI);
BSRSDOHelper.INSTANCE.setPropertyValue(obj,property,value);
wsrrClient.update(obj);	

                
 GraphQuery graphQuery = SdoFactory.INSTANCE.createGraphQuery();
String FIND_WSDL = "/WebSphere Service Registry and Repository/GenericObject[@name=\""
+serviceName+"\" and template(.)/@name=\"Service\"]";
graphQuery.setQueryExpression(FIND_WSDL);
List results = wsrrClient.executeQuery(graphQuery);
GenericObject serviceObj = (GenericObject)results.get(0);
List relations = serviceObj.getUserDefinedRelationships();
for(int i=0;i<relations.size();i++)
{
	UserDefinedRelationship relation = (UserDefinedRelationship)relations.get(i);
	if (relation.getName().equals("availableEndpoints"))
	{
		List targets = relation.getTargets();
		......
	}
}