Mule ESB的transformer(一)——基础transform及自定义transformer

1. transformer的作用

    transformer将services间传递的message的payload转化为它们所需要的格式。

 

2. 配置transformer

    2.1 配置分类

        transformer分为locally（本地的）和globally（全局）。当transformer在endpoint上或flow中，它是locally的，而transformer配置在<modle>或<flow>标签之前，它是globally的。

 

    2.2 transformer链

        用户可以使用多个transformer，将message的payload格式进行转化。

        方法一：在一个transformer-refs或responseTransformer-refs中使用空格分隔多个transformer

        transformer-refs="ByteArrayToString StringToObject ObjectToInputStream"

        方法二：使用多个transformer-refs或responseTransformer-refs

        <transformer ref="ByteArrayToString"/>

        <transformer ref="StringToObject"/>

        <transformer ref="ObjectToInputStream"/>

 

3. 可使用的Transformer

    3.1 基础transformer

        3.1.1 BeanBuilderTransformer

        用定义的对象构造一个bean对象，然后设置一些表达式，用于配置bean的属性。

        <bean-builder-transformer name="testTransformer3" beanClass="org.mule.test.fruit.Orange">
            <bean-property property-name="brand" evaluator="mule" expression="message.payload" optional="true"/>
            <bean-property property-name="segments" evaluator="mule" expression="message.header(SEGMENTS)"/>
        </bean-builder-transformer>

         

        3.1.2 ByteArrayToHexString <-> HexStringToByteArray

        将字节数组类型和16进制串进行转换

 

        3.1.3 ByteArrayToMuleMessage <-> MuleMessageToByteArray

        将字节类型和Mule的Message进行转换。

 

        3.1.4 ByteArrayToObject <-> ObjectToByteArray

        将字节类型和对象之间进行转换，如果字节数组没有序列化（serialized），ByteArrayToObject将会返回一个由字节数组创建的一个String类型串。

 

        3.1.5 ByteArrayToSerializable <-> SerializableToByteArray

        将字节类型的数组进行序列化和反序列化。

 

        3.1.6 ExpressionTransformer

        ExpressionTransformer将执行message的一个或多个表达式，并将表达式的结果作为当前message的payload。

        假设component的接口：

        public interface ShippingRequestMessage
        {
            public Customer getCustomer();
            public Item[] getShippingItems();
            //etc
        }

         <expression-transformer>设计，required属性标记该属性是否是必须的

        <expression-transformer>
            <return-argument evaluator="bean" expression="customer"/>
            <return-argument evaluator="bean" expression="shippingItems"/>
            <return-argument evaluator="attachment" expression="supportingDocs" required="false"/>
        </expression-transformer>

         3.1.7 MessagePropertiesTransformer

        允许用户对当前message的属性进行增、删、改等操作。下面的例子将xml中head的ID标签和body标签拼接为message的GUID属性：

        <message-properties-transformer>
            <add-message-property key="GUID" value="#[string:#[xpath:/msg/header/ID]-#[xpath:/msg/body/@ref]]" />
        </message-properties-transformer>

         3.1.8 ObjectArrayToString <-> StringToObjectArray

        将对象数组类型和字符串类型进行转换。

 

        3.1.9 ObjectToInputStream

        将可序列化的对象转化为一个输入流，但是当对象为String时，将会调用getBytes方法将Stirng转化为byte数组后再操作。

 

        3.1.10 ObjectToOutputHandler

        将一个String对象转化为输出流。

 

        3.1.11 ObjectToString

        将各类对象转化为人类可识别的字符串。该transformer常用语debug。

 

        3.1.12 StringAppendTransformer

        在当前的String串后面添加指定的字符串。

        

        3.1.13 StringToObjectArray

        将一个字符串转化为一个对象数组。

 

    3.2 其他类型

        以下transformer涉及知识点较多，不进行详细介绍

        3.2.1 xml类型

        XmlToObject <-> ObjectToXml

        JAXB XmlToObject <-> JAXB ObjectToXml

        XSLT

        XQuery

        DomToXml <-> XmlToDom

        XmlToXMLStreamReader

        XPath Extractor

        JXPath Extractor

        XmlPrettyPrinter

 

        3.2.2 JSON类型

        支持json格式的相关转换，需要配置文件需要引入json的命名空间：

        <?xml version="1.0" encoding="UTF-8"?>
        <mule xmlns="http://www.mulesoft.org/schema/mule/core"
        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
        xmlns:json="http://www.mulesoft.org/schema/mule/json"
        xsi:schemaLocation="
        http://www.mulesoft.org/schema/mule/core
        http://www.mulesoft.org/schema/mule/core/3.0/mule.xsd
        http://www.mulesoft.org/schema/mule/json
        http://www.mulesoft.org/schema/mule/json/3.0/mule-json.xsd">
        </mule>

         

        3.2.3 Scripting【脚本】

        使用脚本进行对象转化，目前支持javascript和groovy。

 

        3.2.4 Encryption【加密】

        Encryption <-> Decryption：使用EncryptionStrategy接口的实现类对数据进行加密和解密操作。

 

        3.2.5 Compression【压缩】

        GZipCompressTransformer <-> GZipUncompressTransformer：对数据进行压缩和解压缩操作。

 

        3.2.6 Encoding

        Base64Encoder <-> Base64Decoder：使用Base64对数据进行编码和解码操作。

        XMLEntityEncoder <-> XMLEntityDecoder：对xml的节点信息进行编码和解码操作。

 

        3.2.7 Email

        包含一系列transformer用于将email转化为字符串、对象转换为MIME等。

 

        3.2.8 File

        File transformer允许对本地的文件系统进行读写操作。

 

        3.2.9 HTTP

        HTTP transformer支持一些列transformer，用于将http请求转换为字符串或是将mesage转化为http请求。

 

        3.2.10 JDBC

        JDBC Transformer可以将CSV或xml文件中的数据转移到数据库中。

 

        3.2.11 JMS

        支持将JMS格式message转化为其他类型的数据。

 

        3.2.12 Strings and Byte Arrays

        Multicast Transport和TCP Transport均提供了byte array和对象之间转换的transformer。

 

        3.2.13 XMPP

        支持XMPP包和字符串之间的转换操作。

 

 

 

    3.3 transformer的通用属性及配置

        returnClass：指定transformer返回的java类名称。

        ignoreBadInput：如果设置true，transformer将忽略它不识别的类型，但是transformer链中的其他transformer会执行；如果设置false，transformer依旧忽略它所不识别的类型，但是其他的transformer不会被调用。

        mimeType：设置通过该transformer的message的迷你类型。

        encoding：设置通过该transformer的message编码格式。

 

4. 自定义transformer

    如果Mule自带的transformer不能满足用户的需求，可以定制化transformer。定制的transformer需要继承AbstractTransformer或AbstractMessageAwareTransformer，然后定制化个性转化。

 

    4.1 注册源和返回类型

        在构造方法中，使用registerSourceType(Class class)方法指定期望输入的数据类型，使用setReturnClass(Class class)指定返回的数据类型：

        public class OrderToHtmlTransformer extends AbstractMessageAwareTransformer
        {
            public OrderToHtmlTransformer() {
                registerSourceType(Order.class);
                setReturnClass(String.class);
                setName("OrderToHTML");
            }
        }

 

    4.2 使用声明周期方法

        AbstractTransformer或AbstractMessageAwareTransformer类都实现了org.mule.api.lifecycle.Initialisable接口，该接口提供doInitialise()方法。

        当所有的bean属性配置到transformer（如果有bean属性），doInitialise()将被调用。这个方法可以用于初始化transformer所需要的信息。

 

    4.3 创建可覆盖的transformer

        Mule提供自动的转换。当调用getPayload()方法时，mule将尝试使用标准的transformer进行类型转换：

        Document doc = (Document)muleMessage.getPayload(org.dom4j.Document.class);

 

        如果想使用自定义的转换器进行转化（与Mule的冲突时），需要实现org.mule.api.transformer.DiscoverableTransformer接口：

        接口包含两个方法getPriorityWeighting()和setPriorityWeighting(int weighting)，用于设置权重，权重从1到10，10的权重最大。Mule的transformer权重默认是1，通常比任何自定义transformer的权重都低。

 

        自定义transformer的权重：

        public class OrderToHtmlTransformer extends AbstractMessageAwareTransformer implements DiscoverableTransformer
        {
            private int weighting = DiscoverableTransformer. DEFAULT_PRIORITY_WEIGHTING + 1;
            int getPriorityWeighting() {
                return weighting;
            }
            
            void setPriorityWeighting(int weighting) {
                this.weighting = weighting;
            }
        }

     4.4 注册transformer

        使用<custom-transformer>配置自定义transformer。但是如果需要自动被加载，需要添加registry-bootstrap.properties文件到/META-INF/services/org/mule/config目录下，registry-bootstrap.properties示例如下：

        orderToHtml=com.foo.OrderToHtml

        

    4.5 完整示例：

        将包含transactionId的HTML的message进行转化，实现AbstractMessageAwareTransformer：

public Object transform(MuleMessage message, String encoding) throws TransformerException
{
    Order order = (Order)message.getPayload();
    StringBuffer html = new StringBuffer();
    html.append("");
    html.append("");
    html.append("");
    html.append("Dear ").append(order.getCustomer().getName()).append("");
    html.append("Thank you for your order. Your transaction reference is: <strong>");
    html.append(message.getProperty("transactionId").append("</strong>");
    html.append("("");
    return html.toString();
}

 

实现AbstractTransformer

package org.mule.example.hello;
import org.mule.api.transformer.TransformerException;
import org.mule.transformer.AbstractTransformer;
public class StdinToNameString extends AbstractTransformer
{
    public StdinToNameString()
    {
        super();
        this.registerSourceType(String.class);
        this.setReturnClass(NameString.class);
    }
    public Object doTransform(Object src, String encoding) throws TransformerException
    {
        NameString nameString = new NameString();
        String name = (String) src;
        nameString.setName(name.replaceAll("\r", "").replaceAll("\n", "").trim());
        return nameString;
    }
}

 

    配置文件

<custom-transformer name="StdinToNameString" class="org.mule.example.hello.StdinToNameString" />
...
<service name="GreeterUMO">
    <inbound>
    <stdio:inbound-endpoint system="IN" transformer-refs="StdinToNameString" />
</inbound>
...

 

评论

2 楼 zoboy 2016-04-06  

的撒旦撒旦撒啊盛大盛大的撒大声的

1 楼 zoboy 2016-04-06  

洒洒的奋斗过