•      BPEL(Business Process Execution Language)又叫BPEL4WS(Business Process Execution Language For Web Service)，面向Web服務的業務流程執行語言。是一種使用Web服務定義和執行業務流程的語言。BPEL提供了一種相對簡單易懂的方法，可將多個WEB服務組合到一個新的復合服務(稱作業務流程)中。

•      BPEL本身是一個Web服務，可以作為服務的提供者。

•      BPEL是基於Web服務的，沒有Web服務就沒有BPEL。

  

 BPEL的運作方式

 BPEL的一般構成

•      一個以bpel為後綴的文件(例如MyFlow.bpel)

•      一個WSDL文件

•      一個部置XML文件，樣子形似bpel.xml

 BPEL的實現需求

•      需要熟悉單個的Web Service的使用方法

•      需要了解具體的業務流程

•      需要一個運行BPEL的處理器

•      需要一個流程設計器

•      當然需要對BPEL語法標簽的掌握等

8.6 BPEL的結構

BPEL的一般結構

•            <process>

•              <partnerLinks>

•                <partnerLink>

•                </partnerLink>

•              </partnerLinks>

•              <variables>

•                <variable/>

•              </variables>

•              <faultHandlers>   

•              </faultHandlers>

•              <sequence>

•                  Activities

•              </sequence>

•            </process>

<process>的屬性

<process name="ncname" targetNamespace="uri"

         queryLanguage="anyURI"?

         expressionLanguage="anyURI"?

         suppressJoinFailure="yes|no"?

         enableInstanceCompensation="yes|no"?

         abstractProcess="yes|no"?         xmlns="http://schemas.xmlsoap.org/ws/2003/03/business-process/">

.

.

</process>

<partnerLinks>樣式

<partnerLinks>

    <!– 注意:至少要指定一個角色. -->

    <partnerLink name="ncname"

                         partnerLinkType="qname"

                         myRole="ncname“

                         partnerRole="ncname">

    </partnerLink>

 </partnerLinks>

<variables>樣式

<variables>

    <variable name="ncname"  

                    messageType="qname“/>

 </variables>

<faultHandlers>樣式

<faultHandlers>

 <catch faultName="qname“

             faultVariable="ncname">

      activity

    </catch>

    <catchAll>

      activity

    </catchAll>

 </faultHandlers>

Activities包含具體如下

•            <receive>

•            <reply>

•            <invoke>

•            <assign>

•            <throw>

•            <terminate>

•            <wait>

•            <empty>

•            <sequence>

•            <switch>

•            <while>

•            <pick>

•            <flow>

•            <scope>

•            <compensate>

基本活動一

•            <invoke>

– 調用某個 Web 服務上的操作

•            <receive>

– 等待一條消息來回應由某人從外部進行調用的服務介面的操作

•            <reply>

– 生成輸入／輸出操作的回應

•            <wait>

– 等待一段時間

基本活動二

•            <assign>

– 把資料從一個地方複製到另一個地方

•            <throw>

– 指明某個地方出錯了

•            <terminate>

– 終止整個服務實例

•            <empty>

– 什麽也不做

結構化活動

•            <sequence>

– 定義一組步驟的有序序列

•            <switch>

– 使用現在常見的“case-statement”辦法來産生分支

•            <while>

– 定義一個迴圈

•            <pick>

– 執行幾條可選路徑中的一條

•            <flow>

– 以及指明一組步驟應該並行地執行

一個完整的簡單示例

<process name="test" targetNamespace="http://acm.org/samples"

               suppressJoinFailure="yes"

               xmlns:tns="http://acm.org/samples"

               xmlns="http://schemas.xmlsoap.org/ws/2003/03/business-process/"

               xmlns:bpelx="http://schemas.oracle.com/bpel/extension"

               xmlns:ora="http://schemas.oracle.com/xpath/extension"

               xmlns:bpws="http://schemas.xmlsoap.org/ws/2003/03/business-process/">

   <partnerLinks>

   <!-- The 'client' role represents the requester of this service. -->

      <partnerLink name="client" partnerLinkType="tns:test" myRole="testProvider"/>

   </partnerLinks>

   <variables>

      <variable name="input" messageType="tns:testRequestMessage"/>

      <variable name="output" messageType="tns:testResponseMessage"/>

   </variables>

   <sequence name="main">

      <receive name="receiveInput" partnerLink="client" portType="tns:test" operation="process" variable="input" createInstance="yes"/>

      <assign name="creatReturnStr">

         <copy>

            <from expression="concat(&quot;Hello&quot;, bpws:getVariableData('input','payload','/tns:testRequest/tns:input'))"></from>

            <to variable="output" part="payload" query="/tns:testResponse/tns:result"/>

         </copy>

      </assign>

      <reply name="replyOutput" partnerLink="client" portType="tns:test" operation="process" variable="output"/>

   </sequence>

</process>

二.JBI(Java Business Integration)
JBI是SOA的解決和集成的基礎
JBI提供了組件之間交互的消息基礎：
 1)NormalizedMessage(NM) 所有基于消息的數據片段——SOAP片段、MOM消息、HTTP數據或其它信息——被聚合、集中、
 應用到業務邏輯、傳輸，如果有必要則轉換成其他格式隨後被分派到最終目的地
 2)JBI machine (SE)
   組件提供或者消費服務是基於本地的
 3)JBI binding (BC)
   組件 提供或者消費服務是通過一些通信協議或者是其他遠程技術
 組件之間的交互通過消息交換，消息是服務提供者發佈的WSDL 
服務元件(Service Unit)
 一個服務元件看作是一個黑盒子,它提供了一個靜態的服務，
 服務元件中包含有，提供的服務和服務消費者。它們都從屬服務元件，一個服務元件可以有0個或者多個服務

 服務集合(service Assembly)
 組合服務元件是大的應用程序或者新的服務形式出現 A Service Assembly:一組JBI 服務元件連同描述它們的關係和目標組件
總結:
JBI是SOA結構的基礎，它把原來的業務函數集成為一個服務，使服務提供者和服務消費者之間的交互是松耦合的，通過service assembly(服務集合）
可以組合不同的程序，架構圖:

servicemix

消息結構的介紹
用過web services(SOAP)應該知道消息包括信封、消息頭、主體、附件.同樣JMS消息結構也是差不多包括消息頭、消息屬性、消息體.
以JMS、SOAP為基礎可以實現面向消息模型(MOM Message Oriented Model)。
JMS消息樣式:
SpyTextMessage {
     Header {
        jmsDestination  : QUEUE.mytestjms
        jmsDeliveryMode : 2
        jmsExpiration   : 0
        jmsPriority     : 4
        jmsMessageID    : ID:6-11454947326091
        jmsTimeStamp    : 1145494732609
        jmsCorrelationID: null
        jmsReplyTo      : null
        jmsType         : null
        jmsRedelivered  : false
        jmsProperties   : {}
        jmsPropReadWrite: false
        msgReadOnly     : true
        producerClientId: ID:6
     }
     Body {
        text            :sender message from liao test
     }
JMS簡單編程實現點對點的消息　服務器用jboss-4.0.3SP1
1)首先在JBOSS中部屬一個點對點的消息隊列
配置文件放在JBOSS_Home\server\default\deploy\jms
配置文件的內容為:
<?xml version="1.0" encoding="UTF-8"?>

<server>
 <!--是一個點對點的用org.jboss.mq.server.jmx.Queue(Topic),desination的名稱為mytestjms 
  更多的配置說明可以看原來jboss自帶的Jms配置文件，文件名要用*-service.xml
 -->
  <mbean code="org.jboss.mq.server.jmx.Queue" name="jboss.mq.destination:service=Queue,name=mytestjms">
    <depends optional-attribute-name="DestinationManager">jboss.mq:service=DestinationManager</depends>
  </mbean>

</server>
2)實現消息發送者
import java.util.Hashtable;
import javax.jms.*;
import javax.naming.*;
public class JMSSender {
    QueueSession session;
    QueueConnection conn;
    QueueSender sender;
    QueueReceiver receiver;
    public void clientconnect()throws Exception
    {
        //消息服務器(destination)設置
        Hashtable env =  new Hashtable();
        env.put(Context.INITIAL_CONTEXT_FACTORY,"org.jnp.interfaces.NamingContextFactory");
        env.put(Context.PROVIDER_URL,"localhost");
        Context iniCtx = new InitialContext(env)  ;
         //查找創建JMS連接的工廠類
        Object tmp = iniCtx.lookup("ConnectionFactory");
        QueueConnectionFactory qcf = (QueueConnectionFactory)tmp;
        
        //查找JMS目標對象 點對點
        Queue queue = (Queue)iniCtx.lookup("queue/mytestjms");
        //創建JMS連接
        conn = qcf.createQueueConnection();
        //創建JMS會話
         session = conn.createQueueSession(false,QueueSession.AUTO_ACKNOWLEDGE);
         //開始連接
        conn.start();
        sender = session.createSender(queue);
        receiver = session.createReceiver(queue);
    }
    public  JMSSender()
    {
        try{
           System.out.println("begin");
            clientconnect();
            TextMessage textmsg = this.session.createTextMessage();
            textmsg.setText("sender message from liao test");
            //發送消息　點對點
            sender.send(textmsg);
            disConnect();
            System.out.println("success");
        }catch(Exception e)
        {
            e.printStackTrace();
        }

    }
    /**
     * 停止和關閉JMS連接
     * @throws JMSException
     */
    public void disConnect() throws JMSException
    {
        conn.stop();
        session.close();
        conn.close();
    }
    public Message receiver() throws JMSException
    {
        return receiver.receive(1000);
    }
    public static void main(String[] args)throws Exception
    {
         new JMSSender();
    }
}
3)實現消息接受者
import java.util.Hashtable;
import javax.jms.*;
import javax.naming.*;
public class JMSReceiver {
    QueueSession session;
    QueueConnection conn;
    QueueReceiver receiver;
   
    public void clientconnect()throws Exception
    {
        Hashtable env =  new Hashtable();
        env.put(Context.INITIAL_CONTEXT_FACTORY,"org.jnp.interfaces.NamingContextFactory");
        env.put(Context.PROVIDER_URL,"localhost");

        Context iniCtx = new InitialContext(env)  ;
        Object tmp = iniCtx.lookup("ConnectionFactory");
        QueueConnectionFactory qcf = (QueueConnectionFactory)tmp;
        Queue queue = (Queue)iniCtx.lookup("queue/mytestjms");
        conn = qcf.createQueueConnection();
         session = conn.createQueueSession(false,QueueSession.AUTO_ACKNOWLEDGE);
        conn.start();
        receiver = session.createReceiver(queue);
    }
    public void disConnect() throws JMSException
   {
       conn.stop();
       session.close();
       conn.close();
   }
   public Message receiver() throws JMSException
   {
       return receiver.receive(1000);
   }
   public JMSReceiver()throws Exception
   {
        clientconnect();
         Message msg = receiver();
         System.out.println(msg);
         if (msg instanceof TextMessage)
         {
             TextMessage tmsg = (TextMessage)msg;
             //消息主題內容:
             System.out.println(tmsg.getText());
         }
         System.out.println("success");
         disConnect();
 
   }

    public static void main(String[] args)throws Exception
    {
        new JMSReceiver();
    }
}

主題消息用到Topic,思路基本相同，接受必需先訂閱消息主題，當有發送者把消息發給這個主題的時候
先前訂閱的接受就會收到這個消息。
SOA中JMS也是一個熱門，客戶端通常用JMS發送消息再ESB中調用具體的服務。

1)       提供客戶端調用的接口(web services)

2)       編寫處理處理消息的類，消息現在包括 , 登陸消息、登出消息、消息發送,消息狀態的修改

登陸消息包括 : 客戶端的用戶名、 ip 、端口 ;

登出消息包括 : 客戶端的用戶名，服務器將注銷客戶端登陸時發過來的消息

發送的消息包括 : 發送人，接受人，發送事件，發送的內容 .
修改狀態:包括消息的關鍵字ID
3)       在客戶端登陸的時候監測是否是否有新消息，有則發送給客戶端

4)發送的消息如果接受用戶不在線，則保存該消息，等接受者登陸的時候再發送給接受者。

消息有一個狀態N表示新的消息，O表示已經確認的消息.
消息傳給用戶，用戶確認在回寫消息狀態
客戶端調用的接口可以是JMS,Http由於現在只有delphi客戶端，現在提供web services訪問
流程圖: