activiti designer源码的研究(四) 之servicetask调用webservice

发布时间：2020-12-16 23:03:59 所属栏目：安全来源：网络整理

导读：一个调用webservice的例子，webservice发布在不同的包中 CounterThree.java span style="font-size:14px;"package org.chen.webservice;import javax.jws.WebService;@WebServicepublic interface CounterThree { ?String prettyPrintCount(String prefix,St

一个调用webservice的例子，webservice发布在不同的包中

CounterThree.java

<span style="font-size:14px;">package org.chen.webservice;

import javax.jws.WebService;

@WebService
public interface CounterThree {
  ?String prettyPrintCount(String prefix,String suffix);
  
}</span>

CounterThreeImpl.java

<span style="font-size:14px;">package org.chen.webservice;

public class CounterThreeImpl implements CounterThree {
	@Override
	public String prettyPrintCount(String prefix,String suffix) {
		// TODO Auto-generated method stub
		return prefix + " " + suffix;
	}
}</span>

Server.java

<span style="font-size:14px;">package org.chen.webservice;

import javax.xml.ws.Endpoint;

public class Server {
   public static void main(String[]args){
	   Endpoint.publish("http://localhost:63083/CounterThree",new CounterThreeImpl());
   }
}</span>

CounterTwo.java

<span style="font-size:14px;">package org.fan.webservice;

import javax.jws.WebService;

@WebService
public interface CounterTwo {
  String prettyPrintCountTwo(String suffixTwo,String prefixTwo);
  
  void inc();
}</span>

CounterTwoImpl.java

<span style="font-size:14px;">package org.fan.webservice;

public class CounterTwoImpl implements CounterTwo{

	@Override
	public String prettyPrintCountTwo(String suffixTwo,String prefixTwo) {
		// TODO Auto-generated method stub
		return suffixTwo + " "+ prefixTwo;
	}

	@Override
	public void inc() {
		// TODO Auto-generated method stub
		
	</span>}
}

Server.java

<span style="font-size:14px;">package org.fan.webservice;

import javax.xml.ws.Endpoint;

public class Server {
   public static void main(String[]args){
	   Endpoint.publish("http://localhost:63082/CounterTwo",new CounterTwoImpl());
   }</span>
}

WebServiceSimplisticThreeTest.testWebServiceInvocationWithSimplisticDataFlow.bpmn20.xml

<span style="font-size:14px;"><?xml version="1.0" encoding="UTF-8"?>
<definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL"
             xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
             xmlns:xsd="http://www.w3.org/2001/XMLSchema" 
             xmlns:activiti="http://activiti.org/bpmn" 
             xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" 
             xmlns:omgdc="http://www.omg.org/spec/DD/20100524/DC" 
             xmlns:omgdi="http://www.omg.org/spec/DD/20100524/DI" 
             xmlns:tns="org.activiti.engine.test.bpmn.servicetask" 
             xmlns:counter="http://webservice.activiti.org/" 
             typeLanguage="http://www.w3.org/2001/XMLSchema" 
             expressionLanguage="http://www.w3.org/1999/XPath" 
             targetNamespace="org.activiti.engine.test.bpmn.servicetask">
  <import importType="http://schemas.xmlsoap.org/wsdl/" location="http://localhost:63083/CounterThree?wsdl" namespace="http://webservice.activiti.org/"></import>
  <import importType="http://schemas.xmlsoap.org/wsdl/" location="http://localhost:63082/CounterTwo?wsdl" namespace="http://webservice.activiti.org/"></import>
  
  <message id="prettyPrintCountRequestMessage" itemRef="tns:prettyPrintCountRequestItem"></message>
  <message id="prettyPrintCountResponseMessage" itemRef="tns:prettyPrintCountResponseItem"></message>
  <message id="incRequestMessage" itemRef="tns:incRequestItem"></message>
  <message id="incResponseMessage" itemRef="tns:incResponseItem"></message>
  <message id="prettyPrintCountTwoRequestMessage" itemRef="tns:prettyPrintCountTwoRequestItem"></message>
  <message id="prettyPrintCountTwoResponseMessage" itemRef="tns:prettyPrintCountTwoResponseItem"></message>
  <itemDefinition id="prettyPrintCountRequestItem" structureRef="counter:prettyPrintCount"></itemDefinition>
  <itemDefinition id="prettyPrintCountResponseItem" structureRef="counter:prettyPrintCountResponse"></itemDefinition>
  <itemDefinition id="SuffixVariable" structureRef="String"></itemDefinition>
  <itemDefinition id="PrettyPrintResult" structureRef="String"></itemDefinition>
  <itemDefinition id="PrefixVariable" structureRef="String"></itemDefinition>
  <itemDefinition id="incRequestItem" structureRef="counter:inc"></itemDefinition>
  <itemDefinition id="incResponseItem" structureRef="counter:incResponse"></itemDefinition>
  <itemDefinition id="prettyPrintCountTwoRequestItem" structureRef="counter:prettyPrintCountTwo"></itemDefinition>
  <itemDefinition id="prettyPrintCountTwoResponseItem" structureRef="counter:prettyPrintCountTwoResponse"></itemDefinition>
  <itemDefinition id="PrettyPrintTwoResult" structureRef="String"></itemDefinition>
  <itemDefinition id="PrefixTwoVariable" structureRef="String"></itemDefinition>
  <interface id="CounterThree Interface" name="CounterThree Interface" implementationRef="counter:CounterThree">
    <operation id="prettyPrintCountOperation" name="prettyPrintCountOperation" implementationRef="counter:prettyPrintCount">
      <inMessageRef>tns:prettyPrintCountRequestMessage</inMessageRef>
      <outMessageRef>tns:prettyPrintCountResponseMessage</outMessageRef>
    </operation>
  </interface>
  <interface id="CounterTwo Interface" name="CounterTwo Interface" implementationRef="counter:CounterTwo">
    <operation id="incOperation" name="incOperation" implementationRef="counter:inc">
      <inMessageRef>tns:incRequestMessage</inMessageRef>
      <outMessageRef>tns:incResponseMessage</outMessageRef>
    </operation>
    <operation id="prettyPrintCountTwoOperation" name="prettyPrintCountTwoOperation" implementationRef="counter:prettyPrintCountTwo">
      <inMessageRef>tns:prettyPrintCountTwoRequestMessage</inMessageRef>
      <outMessageRef>tns:prettyPrintCountTwoResponseMessage</outMessageRef>
    </operation>
  </interface>
  <process id="webServiceInvocationWithSimplisticDataFlow" name="My process" isExecutable="true">
    <startEvent id="startevent1" name="Start"></startEvent>
    <serviceTask id="servicetask1" name="Service Task" resultVariableName="node-pd(211.69.207.1)#进攻#CounterThreeΨCounterThree:prettyPrintCount" implementation="##WebService" operationRef="tns:prettyPrintCountOperation">
      <dataInputAssociation>
        <sourceRef>SuffixVariable</sourceRef>
        <targetRef>arg1</targetRef>
      </dataInputAssociation>
      <dataInputAssociation>
        <sourceRef>PrefixVariable</sourceRef>
        <targetRef>arg0</targetRef>
      </dataInputAssociation>
      <dataOutputAssociation>
        <sourceRef>_return</sourceRef>
        <targetRef>PrettyPrintResult</targetRef>
      </dataOutputAssociation>
    </serviceTask>
    <serviceTask id="servicetask2" name="Service Task" resultVariableName="node-pd(211.69.207.1)#进攻#CounterTwoΨCounterTwo:inc" implementation="##WebService" operationRef="tns:incOperation"></serviceTask>
    <serviceTask id="servicetask3" name="Service Task" resultVariableName="node-pd(211.69.207.1)#进攻#CounterTwoΨCounterTwo:prettyPrintCountTwo" implementation="##WebService" operationRef="tns:prettyPrintCountTwoOperation">
      <dataInputAssociation>
        <sourceRef>PrefixTwoVariable</sourceRef>
        <targetRef>arg1</targetRef>
      </dataInputAssociation>
      <dataInputAssociation>
        <sourceRef>PrettyPrintResult</sourceRef>
        <targetRef>arg0</targetRef>
      </dataInputAssociation>
      <dataOutputAssociation>
        <sourceRef>_return</sourceRef>
        <targetRef>PrettyPrintTwoResult</targetRef>
      </dataOutputAssociation>
    </serviceTask>
    <receiveTask id="receivetask1" name="Receive Task"></receiveTask>
    <endEvent id="endevent1" name="End"></endEvent>
    <sequenceFlow id="flow1" sourceRef="receivetask1" targetRef="endevent1"></sequenceFlow>
    <sequenceFlow id="flow2" sourceRef="startevent1" targetRef="servicetask1"></sequenceFlow>
    <sequenceFlow id="flow3" sourceRef="servicetask1" targetRef="servicetask2"></sequenceFlow>
    <sequenceFlow id="flow4" sourceRef="servicetask2" targetRef="servicetask3"></sequenceFlow>
    <sequenceFlow id="flow5" sourceRef="servicetask3" targetRef="receivetask1"></sequenceFlow>
  </process>
  <bpmndi:BPMNDiagram id="BPMNDiagram_myProcess">
    <bpmndi:BPMNPlane bpmnElement="myProcess" id="BPMNPlane_myProcess">
      <bpmndi:BPMNShape bpmnElement="startevent1" id="BPMNShape_startevent1">
        <omgdc:Bounds height="35.0" width="35.0" x="30.0" y="250.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="servicetask1" id="BPMNShape_servicetask1">
        <omgdc:Bounds height="55.0" width="105.0" x="170.0" y="240.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="servicetask2" id="BPMNShape_servicetask2">
        <omgdc:Bounds height="55.0" width="105.0" x="360.0" y="240.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="servicetask3" id="BPMNShape_servicetask3">
        <omgdc:Bounds height="55.0" width="105.0" x="540.0" y="240.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="receivetask1" id="BPMNShape_receivetask1">
        <omgdc:Bounds height="55.0" width="105.0" x="700.0" y="240.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="endevent1" id="BPMNShape_endevent1">
        <omgdc:Bounds height="35.0" width="35.0" x="850.0" y="250.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNEdge bpmnElement="flow1" id="BPMNEdge_flow1">
        <omgdi:waypoint x="805.0" y="267.0"></omgdi:waypoint>
        <omgdi:waypoint x="850.0" y="267.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="flow2" id="BPMNEdge_flow2">
        <omgdi:waypoint x="65.0" y="267.0"></omgdi:waypoint>
        <omgdi:waypoint x="170.0" y="267.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="flow3" id="BPMNEdge_flow3">
        <omgdi:waypoint x="275.0" y="267.0"></omgdi:waypoint>
        <omgdi:waypoint x="360.0" y="267.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="flow4" id="BPMNEdge_flow4">
        <omgdi:waypoint x="465.0" y="267.0"></omgdi:waypoint>
        <omgdi:waypoint x="540.0" y="267.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="flow5" id="BPMNEdge_flow5">
        <omgdi:waypoint x="645.0" y="267.0"></omgdi:waypoint>
        <omgdi:waypoint x="700.0" y="267.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
    </bpmndi:BPMNPlane>
  </bpmndi:BPMNDiagram>
</definitions></span>

WebServiceSimplisticThreeTest.java

<span style="font-size:14px;">
package org.activiti.engine.test.bpmn.servicetask;

import java.util.HashMap;
import java.util.Map;

import org.activiti.engine.runtime.ProcessInstance;
import org.activiti.engine.test.Deployment;

public class WebServiceSimplisticThreeTest extends AbstractWebServiceTaskTest {

  protected boolean isValidating() {
    return false;
  }
  
  @Deployment
  public void testWebServiceInvocationWithSimplisticDataFlow() throws Exception {
    Map<String,Object> variables = new HashMap<String,Object>();
    variables.put("PrefixVariable","The counter has the value");
    variables.put("SuffixVariable","Good news");
    variables.put("PrefixTwoVariable","append What news");

    ProcessInstance instance = processEngine.getRuntimeService().startProcessInstanceByKey("webServiceInvocationWithSimplisticDataFlow",variables);
    waitForJobExecutorToProcessAllJobs(10000L,250L);

    String response = (String) processEngine.getRuntimeService().getVariable(instance.getId(),"PrettyPrintResult");
    System.out.println(response);
    assertEquals("The counter has the value Good news",response);
    
    String response2 = (String) processEngine.getRuntimeService().getVariable(instance.getId(),"PrettyPrintTwoResult");
    System.out.println(response2);
    assertEquals("The counter has the value Good news append What news",response2);
  }
}
</span>

注意点：

<1>被发布的类（counterTwo.java counterThree.java）在那个目录下并不重要，但是要保持targetNamespace与tns相同，并且可以随意定

<2>默认情况下，返回值sourceRef为_return，而不是return(即使wsdl上面为return)

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!