2. 程式人生 > >Mule ESB 學習筆記 服務呼叫

Mule ESB 學習筆記 服務呼叫

阿新 • • 發佈：2019-02-03

1. Mule實現並提供Web Service

在Mule上開發併發佈一個Web Service供客戶端呼叫。

·         示例配置

<flow name="local-ws">

    <core:inbound-endpoint address="http://localhost:65082/services/Echo1"

        exchange-pattern="request-response" doc:name="Generic" doc:description="Generic endpoint specified by address URI" />

    <cxf:jaxws-service serviceClass="demo.mule.component.Echo" doc:name="SOAP"

        doc:description="Make a web service available via CXF" />

    <component doc:name="Component" doc:description="Invoke a Java component">

        <singleton-object class="demo.mule.component.Echo" />

    </component>

</ flow >


·         測試方法

在瀏覽器位址列中輸入“http://localhost:65082/services/Echo1/echo/text/hello”，回車後瀏覽器中將顯示返回結果資訊。地址中的“echo”是服務的方法，“text”是方法的引數，“hello”是引數的值。

2. Web Service Proxy

    Web Service Proxy用來將客戶端的WS請求直接轉發至相應的遠端WS服務端處理，並返回處理結果。Mule本身不做任何處理。

2.1 配置方式1

·         示例配置

<flow name="local2remote-ws">

    <http:inbound-endpoint keep-alive="false" address="http://localhost:65000"

        encoding="UTF-8" disableTransportTransformer="false" exchange-pattern="request-response" doc:name="HTTP"

        doc:description="" />

    <http:outbound-endpoint method="GET" keep-alive="false"

        address="http://localhost:5050#[header:INBOUND:http.request]" responseTimeout="10000" encoding="UTF-8"

        disableTransportTransformer="false" followRedirects="false" exchange-pattern="request-response"

        doc:name="HTTP" doc:description="" />

</ flow >


·         說明

注意outbound-endpoint中address引數中的表示式。

·         測試方法

瀏覽器中通過“http://localhost:65000/webservice/EchoService?wsdl”（將內容複製，儲存為*.wsdl），然後使用SoapUI測試。

2.2 配置方式2

·         示例配置

<pattern:web-service-proxy name="ws-proxy" inboundAddress="http://localhost:65082/services/Echo2"

    outboundAddress="http://localhost:65082/services/Echo1?method=echo">

</pattern:web-service-proxy>


·         說明

Mule為這種常見的場景提供了現成的模式，以簡化配置。

·         測試方法

通過“http://localhost:65082/services/Echo2?wsdl”獲取wsdl檔案，然後使用SoapUI測試。

3. Web Service to Web Service

    Web Service To Web Service用於在Mule中提供Web Service供客戶端呼叫，Mule接收請求後呼叫遠端的Web Service進行處理，並返回結果。

·         示例配置

<flow name="local-ws2remote-ws">

    <core:inbound-endpoint address="http://localhost:65082/services/Echo8"

        disableTransportTransformer="false" exchange-pattern="request-response" doc:name="Generic"

        doc:description="Generic endpoint specified by address URI" />

    <cxf:jaxws-service serviceClass="demo.mule.component.Echo" doc:name="SOAP"

        doc:description="Make a web service available via CXF" />

    <core:outbound-endpoint

        address="wsdl-cxf:http://server1:5050/mule-business/webservice/EchoService?wsdl&method=Echo" />

</ flow >


·         說明

注意outbound-endpoint中address引數的配置方式，使用了wsdl-cxf字首表示此web service是由cxf提供的。

·         測試方法

在瀏覽器中輸入“http://localhost:65082/services/Echo8/echo/text/hello”進行測試。

4. Socket to Socket

    Socket To Socket用於將客戶端的Socket請求轉發至遠端的Socket服務端處理，並返回處理結果。

·         示例配置

<flow name="tcp2tcp">

    <tcp:inbound-endpoint host="localhost" port="7100" responseTimeout="10000"

        encoding="UTF-8" disableTransportTransformer="false" exchange-pattern="request-response" doc:name="TCP"

        doc:description="The TCP transport enables events to be sent and received over TCP sockets." />

    <tcp:outbound-endpoint host="localhost" port="7000" responseTimeout="10000"

        encoding="UTF-8" disableTransportTransformer="false" exchange-pattern="request-response" doc:name="TCP"

        doc:description="The TCP transport enables events to be sent and received over TCP sockets." />

</ flow >


·         說明

主要配置host、port引數，表明服務地址。

·         測試方法

通過

SimpleServer和SimpleClient測試類，首先啟動SimpleServer，然後啟動SimpleClient，傳送請求並接收處理結果。

5. JMS Topic

客戶端傳送Web Service請求，Mule將請求訊息傳送至遠端JMS的Topic中。

·         示例配置

<flow name="local-ws2jms-topic">

    <core:inbound-endpoint address="http://localhost:65082/services/Echo3"

        responseTimeout="10000" encoding="UTF-8" disableTransportTransformer="false" mimeType="text/plain"

        exchange-pattern="one-way" doc:name="Generic" doc:description="Generic endpoint specified by address URI" />

    <cxf:jaxws-service serviceClass="demo.mule.component.Echo" doc:name="SOAP"

        doc:description="Make a web service available via CXF" />

    <jms:outbound-endpoint topic="topic1" responseTimeout="10000" encoding="UTF-8"

        disableTransportTransformer="false" disableTemporaryReplyToDestinations="false" exchange-pattern="one-way"

        connector-ref="activemqConnector" doc:name="JMS" doc:description="Send or receive messages from a JMS queue" />

</flow>

<flow name="jms-topic2echo">

    <jms:inbound-endpoint topic="topic1" responseTimeout="10000" encoding="UTF-8"

        disableTransportTransformer="false" disableTemporaryReplyToDestinations="false" exchange-pattern="one-way"

        connector-ref="activemqConnector" doc:name="JMS" doc:description="Send or receive messages from a JMS queue" />

    <echo-component doc:name="Echo" doc:description="Echoes message payload." />

</ flow >


·         說明

JMS endpoint是單向的，不需要返回值。通過topic屬性指定JMS Server的Topic名稱，connector-ref指明瞭使用的JMS連線。

·         測試方法

在瀏覽器位址列中輸入“http://localhost:65082/services/Echo3/echo/text/hello”傳送請求，Mule控制檯上輸出訂閱者的處理結果（上述示例中通過Mule配置了一個JMS的訂閱者）。也可以通過ActiveMQ的控制檯，檢視到Topic中增加了一條釋出的訊息。

二. 基於訊息內容的路由

    Mule提供基於訊息內容的路由機制，根據訊息中的指定資訊，將訊息傳送至不同的服務端進行處理。

1. Socket to Socket 路由

·         示例配置

<flow name="tcp2tcp-router">

    <tcp:inbound-endpoint host="localhost" port="7101" responseTimeout="10000"

        encoding="UTF-8" disableTransportTransformer="false" exchange-pattern="request-response" doc:name="TCP"

        doc:description="The TCP transport enables events to be sent and received over TCP sockets." />

    <choice>

        <when evaluator="jxpath" expression="(req/area)='bj'">

            <tcp:outbound-endpoint host="server1" port="7101"

                responseTimeout="10000" encoding="UTF-8" disableTransportTransformer="false" exchange-pattern="request-response"

                doc:name="TCP" doc:description="The TCP transport enables events to be sent and received over TCP sockets." />

        </when>

        <when evaluator="jxpath" expression="(req/area)='sh'">

            <tcp:outbound-endpoint host="server1" port="7102"

                responseTimeout="10000" encoding="UTF-8" disableTransportTransformer="false" exchange-pattern="request-response"

                doc:name="TCP" doc:description="The TCP transport enables events to be sent and received over TCP sockets." />

        </when>

    </choice>

</ flow >


·         說明

路由使用了<choice>、<when>元素，表示路由分支。When元素使用evaluator指明表示式的解析方式，使用expression描述訊息內容的判斷條件。

·         測試方法

同Socket To Socket測試，訊息內容分別為<req><area>bj</area></req>、<req><area>sh</area></req>，檢視傳送至不同伺服器的輸出。

2. Web Service to JMS Topic 路由

·         示例配置

<flow name="local-ws2jms-topic-router">

    <core:inbound-endpoint address="http://localhost:65082/services/Echo7"

        disableTransportTransformer="false" exchange-pattern="request-response" doc:name="Generic"

        doc:description="Generic endpoint specified by address URI" />

    <cxf:jaxws-service serviceClass="demo.mule.component.Echo" doc:name="SOAP"

        doc:description="Make a web service available via CXF" />

    <choice>

        <when evaluator="jxpath" expression="(req/area)='bj'">

            <jms:outbound-endpoint topic="topic1" responseTimeout="10000" encoding="UTF-8"

                disableTransportTransformer="false" disableTemporaryReplyToDestinations="false"

                exchange-pattern="one-way" connector-ref="activemqConnector" doc:name="JMS"

                doc:description="Send or receive messages from a JMS queue" />

        </when>

        <when evaluator="jxpath" expression="(req/area)='sh'">

            <jms:outbound-endpoint topic="topic2" responseTimeout="10000" encoding="UTF-8"

                disableTransportTransformer="false" disableTemporaryReplyToDestinations="false"

                exchange-pattern="one-way" connector-ref="activemqConnector" doc:name="JMS"

                doc:description="Send or receive messages from a JMS queue" />

        </when>

    </choice>

</ flow >


·         測試方法

通過“http://localhost:65082/services/Echo7?wsdl”獲取wsdl檔案，然後通過SoapUI傳送請求，檢視返回結果。修改訊息內容，檢視結果的變化。

3. Web Service to Web Service 路由

·         示例配置

<flow name="local-ws2jms-topic-router">

    <core:inbound-endpoint address="http://localhost:65082/services/Echo9"

        disableTransportTransformer="false" exchange-pattern="request-response" doc:name="Generic"

        doc:description="Generic endpoint specified by address URI" />

    <cxf:jaxws-service serviceClass="demo.mule.component.Echo" doc:name="SOAP"

        doc:description="Make a web service available via CXF" />

    <choice>

        <when evaluator="jxpath" expression="(req/area)='bj'">

            <core:outbound-endpoint

                address="wsdl-cxf:http://server1:5050/mule-business/webservice/CalcService?wsdl&method=processXml" />

        </when>

        <when evaluator="jxpath" expression="(req/area)='sh'">

            <core:outbound-endpoint

                address="wsdl-cxf:http://server2:5050/mule-business/webservice/CalcService?wsdl&method=processXml" />

        </when>

    </choice>

</ flow >


·         測試方法

使用“<![CDATA[<req><seq>1</seq><area>bj</area><price>123.45</price><count>10</count></req>]]>”資料進行測試。

三. 資料轉換

1. 壓縮解壓

    Mule原生提供了gzip壓縮方式的Transformer。

·         示例配置

 

<flow name="gzip">

    <stdio:inbound-endpoint ref="stdioInEndpoint" />

    <core:string-to-byte-array-transformer encoding="UTF-8" />

    <component class="demo.mule.component.Passthrough" />

    <core:gzip-compress-transformer encoding="UTF-8" />

    <component class="demo.mule.component.Passthrough" />

    <core:gzip-uncompress-transformer encoding="UTF-8" />

    <component class="demo.mule.component.Passthrough" />

    <core:byte-array-to-string-transformer encoding="UTF-8" />

    <stdio:outbound-endpoint ref="stdioOutEndpoint" />

</ flow >


·         說明

gzip-compress-transformer針對byte[]進行壓縮處理，因此對於字串型別的訊息，首先需要通過string-to-byte-array-transformer進行轉換。

·         測試方法

在控制檯的提示資訊後輸入測試字串，完成後控制檯輸出同樣的資訊。

2. 加密解密

加密、解密是一種特定的資料轉換方式，因此通過自定義Transformer的形式支援。

·         示例配置

<flow name="encrypt">

    <core:inbound-endpoint address="http://localhost:65082/services/Echo11"

        responseTimeout="10000" encoding="UTF-8" disableTransportTransformer="false" mimeType="text/plain"

        exchange-pattern="one-way" />

    <cxf:jaxws-service serviceClass="demo.mule.component.Echo" />

    <component>

        <singleton-object class="demo.mule.component.Echo" />

    </component>

    <core:custom-transformer class="demo.mule.transformer.DesEncryptTransformer" encoding="UTF-8" />

    <component class="demo.mule.component.Passthrough" />

    <core:custom-transformer class="demo.mule.transformer.DesDecryptTransformer" encoding="UTF-8" />

    <stdio:outbound-endpoint ref="stdioOutEndpoint" />

</ flow >


·         說明

DesEncryptTransformer是自定義的壓縮轉換器，DesDecryptTransformer是對應的解壓轉換器。

·         測試方法

在瀏覽器位址列中輸入“http://localhost:65082/services/Echo11/echo/text/測試字串”，在控制檯中可見加密後的字串和最終解密後與原串相同的字串。

3. 自定義Transformer

·         示例程式碼

import demo.mule.dto.Envelope;

 

public class String2EnvelopeTransformer extends AbstractTransformer {

    private static Log log = LogFactory.getLog(String2EnvelopeTransformer.class);

 

    @Override

    protected Object doTransform(Object src, String enc) throws TransformerException {

        Envelope env = new Envelope();

        if (src instanceof String) {

            StringTokenizer st = new StringTokenizer((String) src, ",");

            String area = st.nextToken();

            String data = st.nextToken();

            env.create(area, data);

        }

        log.debug(env);

        return env;

    }

}


·         說明

自定義Transformer需要繼承AbstractTransformer類，實現其doTransform方法。該方法接收兩個引數，一個是訊息物件，一個是訊息的Encoding，方法丟擲TransformerException，返回轉換後的訊息物件。

·         例項配置

<flow name="local-ws">

    <core:inbound-endpoint address="http://localhost:65082/services/Echo1"

        exchange-pattern="request-response" doc:name="Generic" doc:description="Generic endpoint specified by address URI" />

    <cxf:jaxws-service serviceClass="demo.mule.component.Echo" doc:name="SOAP"

        doc:description="Make a web service available via CXF" />

    <component doc:name="Component" doc:description="Invoke a Java component">

        <singleton-object class="demo.mule.component.Echo" />

    </component>

    <core:custom-transformer class="demo.mule.transformer.String2EnvelopeTransformer"></core:custom-transformer>

    <core:outbound-endpoint address="stdio://System.out" exchange-pattern="one-way" />

</ flow >


·         測試方法

在瀏覽器中輸入“http://localhost:65082/services/Echo1/echo/text/bj,hello”進行測試，觀察控制檯輸出結果。

僅以上述示例程式碼作為這一段時間Mule文件閱讀及試用的總結。

相關推薦

Mule ESB 學習筆記 服務呼叫

1. Mule實現並提供Web Service 在Mule上開發併發佈一個Web Service供客戶端呼叫。 ·         示例配置 <flow name="local-ws"> <core:inbound-endpoint address="http://

mule studio學習筆記（六）：外部web service呼叫

1.eclipse中建立web Service        eclipse中配置axis2；       建立dynamic web service，Java Resource src中放置服務實現類，右擊，creat web service生成wsdl，右擊wsdl，p

ESB學習筆記-持續更新

ESB全稱為Enterprise Service Bus，即企業服務匯流排。它是傳統中介軟體技術與XML、Web服務等技術結合的產物。 ESB提供了網路中最基本的連線中樞，是構築企業神經系統的必要元素。 ESB的出現改變了傳統的軟體架構，可以提供比傳統中介軟體產品更為廉價的

DNS學習筆記-服務的配置與基礎概念

1、DNS的基礎知識 上網時本輸入IP就可以了，但人們方便記憶的是字串。所以，DNS就誕生了，DNS負責域名（字串）到IP的轉換 正向查詢：最基本的通過主機名查IP 反向查詢：用IP來查主機名

Android學習筆記9-呼叫攝像頭和相簿

呼叫攝像頭和手機的相簿 呼叫手機的攝像頭和相機拍照的功能，在許多app中都非常常見，當我們用qq，微信，微博等app給別人分享圖片時都會用到這個功能。 1，呼叫攝像頭拍照 activity_main.xml佈局程式碼 <?xml version="1.0" enc

GO學習筆記——defer呼叫（21）

defer呼叫也是一種流程控制語句，經常用來呼叫一些資源處理函式。 defer語句確保被執行的語句具有下面的呼叫時機 defer呼叫必須出現在函式內，並且在該函式返回之前才回去執行defer呼叫的函式  給一個示例來看一下 func testdefer(){ d

OPTEE學習筆記 - CA呼叫TA流程

今天開始學習optee相關的程式碼，目的是弄清optee的執行邏輯，學習optee。以下是雜記，僅用做學習記錄。學習程式碼均取自github和《手機安全和可信應用開發指南》（帥峰雲，黃騰，宋洋） 學習程式碼示例： void g_CryptoVerifyCa_Helloworld(void)

SpringCloud 學習筆記------服務鏈路追蹤(Spring Cloud Sleuth)

一、理論準備    目前以我的理解能力，能看明白的就是一句話——哪個介面呼叫了哪個介面，傳遞了什麼資料，花了多長時間。    Spring Cloud Sleuth 主要功能就是在分散式系統中提供追蹤解決方案，並且相容支援了 zipkin，你只需要在pom檔案中引入相應的依賴

mule studio學習筆記（五）：JDBC結果處理

JDBC結點查詢（where key>specific_value）的返回結果形式如下。 [{key=value1},{key=value2},......] 其中，{...}為Mule定義型別CaseInsensitiveHashMap (extends Abstr

ReactNative學習筆記之呼叫原生模組（進階）之Callback、Promise使用

前言 前文ReactNative學習筆記——呼叫原生模組（Android）簡單說了下ReactNative呼叫Android原生模組的基本用法，下面講解下呼叫原生模組經常會用到的Callback和Promise。 很多時候我們可能不僅僅是呼叫Native的方

L4RE學習筆記——服務介紹

1.服務概述： Sigma0,theRootPagerSigma0是L4Re的第一個非常有用的task，用於處理root task（moe）的缺頁異常。它可以認為是核心的一部分，儘管它執行在非特權模式。Moe,theRootTaskMoe是L4的根任務，負責bootstrap

mule studio 學習筆記 (二): test006-loanbroker-simple

lookupCustomerCreditProfile部分 1）服務介面 @WebService Both the annotation types are from package javax.jws. The @WebService annotation marks

OpenCV學習筆記_呼叫攝像頭錄製視訊(無聲音)

#include <cv.h> #include <highgui.h> using namespace std; int main(void){ cvNamedWind

Consul 學習筆記-服務註冊

Consul簡介：  　Consul是一種服務網格解決方案，提供具有服務發現，配置和分段功能的全功能控制平面。這些功能中的每一個都可以根據需要單獨使用，也可以一起使用以構建完整的服務網格。Consul需要一個數據平面，並支援代理和本機整合模型。Consul附帶了一個簡單的內建代理，因此開箱即用，但也

Consul 學習筆記—服務發現

前言： 　　上一篇文章簡單實用Consul試下服務註冊，本篇繼續學習Consul中的另外特性：服務發現、KV操作 ；以及對上篇文章中存在的問題進行解決 問題解決 　在上一篇文章中，註冊服務提示檢查失敗。  　通過排查發現為在docker 中執行的容器中配置的心跳檢查api地址配置錯誤： "C

stm32學習筆記（八）中斷服務函式與函式呼叫的區別

在《微機原理》和《計算機組成》等課程[1-4]教學中（本文以MCS-51微控制器為例），中斷過程既是教學難點又是教學重點，它與主程式呼叫子程式過程有一定相似性，但又有很大區別，呼叫子程式過程相對比較容易掌握，通過把兩過程結合起來，採用比較教學方法，能收到了很好的教學效果。  1、兩過程定義與作用     子

06.Spring Cloud學習筆記之宣告式服務呼叫元件Feign

前言 Spring Cloud Feign基於Netflix Feign實現，整合了Spring Cloud Ribbon與Spring Cloud Hystrix，除了提供這兩者的強大功能外，還提供了一種宣告式的Web服務客戶端定義方式，我們可以做到使用HT

呼叫webservice服務(一) 學習筆記

jdk   使用免費的webservice服務 1.先找到對應的wsdl檔案 2.下到本地java專案src下面利用黑視窗進入專案src目錄下面 3.使用jdk的wsimport命令生成程式碼 wsimport -keep wsdl文件位置 重新整理專案可以看到反向生成

Dubbo學習筆記001---分散式服務呼叫_Dubbo簡介_依賴zookeeper做為註冊中心進行服務註冊與發現

Dubbo是阿里巴巴SOA服務化治理方案的核心框架，每天為2,000+個服務提供3,000,000,000+次訪問量支援，並被廣泛應用於阿里巴巴集團的各成員站點。Dubbo是一個分散式服務框架，致力於提供高效能和透明化的RPC遠端服務呼叫方案，以及SOA服務治理方案。

SpringCloud學習筆記(3)：使用Feign實現宣告式服務呼叫

簡介 Feign是一個宣告式的Web Service客戶端，它簡化了Web服務客戶端的編寫操作，相對於Ribbon+RestTemplate的方式，開發者只需通過簡單的介面和註解來呼叫HTTP API。它支援Spring MVC註解和JAX-RS註解，還支援可插拔式的編碼器和解碼器。整合了Eureka，Rib