3

我已经编写了三个实现 XStream 的类。它编组/解组以下 XML。

<Message calledProgram="XXX" programName="YYY">
  <Fields>
    <Field name="SupplierName" value="ABC"/>
    <Field name="SupplierNo" value="123456"/>
    <Field name="SupplierCountry" value="AA"/>
    <Field name="TermsOfDelivery" value="5"/>
    <Field name="PaymentTerms" value="90"/>
    <Field name="Currency" value="GBP"/>
  </Fields>
</Message>

如何在 Mule 中使用这些类？它是一个使用另外两个的类，所以它只是一个使用的类。

我将收到一个类似上面的 XML。我想将它转换为一个对象。

它在纯 Java 中工作，但我如何在流程中使用它。从 Mule 获取所有可能的异常。

Exception in thread "main" org.mule.module.launcher.DeploymentInitException: InstantiationException: xxx.com.GenericClass
at org.mule.module.launcher.application.DefaultMuleApplication.init(DefaultMuleApplication.java:220)
at org.mule.module.launcher.application.ApplicationWrapper.init(ApplicationWrapper.java:64)
at org.mule.module.launcher.DefaultMuleDeployer.deploy(DefaultMuleDeployer.java:46)
at org.mule.tooling.server.application.ApplicationDeployer.run(ApplicationDeployer.java:56)
at org.mule.tooling.server.application.ApplicationDeployer.main(ApplicationDeployer.java:88)
Caused by: org.mule.api.config.ConfigurationException: Error creating bean with name 'MyB24Flow1': Invocation of init method failed; nested exception is org.mule.api.lifecycle.InitialisationException: Unable to initialize XStream (org.mule.api.lifecycle.InitialisationException) (org.mule.api.config.ConfigurationException)
at org.mule.config.builders.AbstractConfigurationBuilder.configure(AbstractConfigurationBuilder.java:52)
at org.mule.config.builders.AbstractResourceConfigurationBuilder.configure(AbstractResourceConfigurationBuilder.java:78)
at org.mule.context.DefaultMuleContextFactory.createMuleContext(DefaultMuleContextFactory.java:80)
at org.mule.module.launcher.application.DefaultMuleApplication.init(DefaultMuleApplication.java:208)
... 4 more


Caused by: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'MyB24Flow1': Invocation of init method failed; nested exception is org.mule.api.lifecycle.InitialisationException: Unable to initialize XStream
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1455)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:519)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:456)
at org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:294)
at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:225)
at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:291)
at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:193)
at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:585)
at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:913)
at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:464)
at org.mule.config.spring.SpringRegistry.doInitialise(SpringRegistry.java:89)
at org.mule.registry.AbstractRegistry.initialise(AbstractRegistry.java:109)
... 14 more
Caused by: org.mule.api.lifecycle.InitialisationException: Unable to initialize XStream
at org.mule.module.xml.transformer.AbstractXStreamTransformer.initialise(AbstractXStreamTransformer.java:52)
at org.mule.processor.chain.AbstractMessageProcessorChain.initialise(AbstractMessageProcessorChain.java:79)
at org.mule.construct.AbstractFlowConstruct.initialiseIfInitialisable(AbstractFlowConstruct.java:309)
at org.mule.construct.AbstractPipeline.doInitialise(AbstractPipeline.java:161)
at org.mule.construct.AbstractFlowConstruct$1.onTransition(AbstractFlowConstruct.java:111)
at org.mule.construct.AbstractFlowConstruct$1.onTransition(AbstractFlowConstruct.java:105)
at org.mule.lifecycle.AbstractLifecycleManager.invokePhase(AbstractLifecycleManager.java:141)
at org.mule.construct.FlowConstructLifecycleManager.fireInitialisePhase(FlowConstructLifecycleManager.java:81)
at org.mule.construct.AbstractFlowConstruct.initialise(AbstractFlowConstruct.java:104)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeCustomInitMethod(AbstractAutowireCapableBeanFactory.java:1581)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeInitMethods(AbstractAutowireCapableBeanFactory.java:1522)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1452)
... 25 more

更新：

虽然这不是我真正的代码。但是你是什么意思OOTB？这也不起作用。也尝试过不使用 File-2-String。

<?xml version="1.0" encoding="UTF-8"?>
<mule xmlns:file="http://www.mulesoft.org/schema/mule/file" xmlns:mulexml="http://www.mulesoft.org/schema/mule/xml" xmlns="http://www.mulesoft.org/schema/mule/core" xmlns:doc="http://www.mulesoft.org/schema/mule/documentation" xmlns:spring="http://www.springframework.org/schema/beans" version="CE-3.3.1" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="
http://www.mulesoft.org/schema/mule/xml         http://www.mulesoft.org/schema/mule/xml/current/mule-xml.xsd 
http://www.mulesoft.org/schema/mule/file     http://www.mulesoft.org/schema/mule/file/current/mule-file.xsd 
http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-current.xsd 
http://www.mulesoft.org/schema/mule/core   http://www.mulesoft.org/schema/mule/core/current/mule.xsd ">
    <flow name="MyXStreamFlow1" doc:name="MyXStreamFlow1">
    <file:inbound-endpoint path="E:\JavaDev\Test" responseTimeout="10000" doc:name="File"/>
    <logger level="INFO" doc:name="Logger"/>
    <file:file-to-string-transformer doc:name="File to String"/>
    <logger message="WTF" level="INFO" doc:name="Logger"/>
    <mulexml:xml-to-object-transformer doc:name="XML to Object"/>
    <logger level="INFO" doc:name="Logger"/>
    <mulexml:object-to-xml-transformer doc:name="Object to XML"/>
    <logger level="INFO" doc:name="Logger"/>
</flow>

这是我的主要 Java 类。

package test;
import java.io.FileInputStream;
import java.io.FileNotFoundException;

import com.thoughtworks.xstream.XStream;
import com.thoughtworks.xstream.annotations.XStreamAlias;
import com.thoughtworks.xstream.annotations.XStreamAsAttribute;
import com.thoughtworks.xstream.io.xml.DomDriver;

@XStreamAlias("Message")
public class GenericClass {

@XStreamAlias("calledProgram")
@XStreamAsAttribute
private String calledProgram;

@XStreamAlias("programName")
@XStreamAsAttribute
private String programName;

@XStreamAlias("Fields")
private Fields flds = new Fields(
    new Field("nameValue1", "valueValue1"),
    new Field("nameValue2", "valueValue2"),
    new Field("nameValue3", "valueValue2"));

private static XStream xstream;

public GenericClass() {
    new GenericClass("calledProgram", "programName");
}

public GenericClass(String calledProgram, String programName) {
    xstream = new XStream(new DomDriver());
    xstream.processAnnotations(GenericClass.class);
    this.calledProgram = calledProgram;
    this.programName = programName;
}

public static void main(String[] args) {

    GenericClass msg = new GenericClass();

    // Unmarshall
    FileInputStream file = null;
    try {
        file = new FileInputStream(
                "E:\\JavaDev\\JRecordFiles\\Samples\\LevisTest.xml");
    } catch (FileNotFoundException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
     msg = (GenericClass) xstream.fromXML(file);
     System.out.println("<?xml version=\"1.0\" encoding=\"utf-8\"?>\n" + xstream.toXML(msg));
}
}

-

package test;

import com.thoughtworks.xstream.annotations.XStreamAsAttribute;


public class Field {

private String field;

@XStreamAsAttribute
private String name;

@XStreamAsAttribute
private String value;

/**
 * @param field
 */
public Field(String name, String value) {
    this.name = name;
    this.value = value;
}

/**
 * @return the field
 */
public String getField() {
    return field;
}

/**
 * @param field
 *            the field to set
 */
public void setField(String field) {
    this.field = field;
}

/**
 * @return the name
 */
public String getName() {
    return name;
}

/**
 * @param name
 *            the name to set
 */
public void setName(String name) {
    this.name = name;
}

/**
 * @return the value
 */
public String getValue() {
    return value;
}

/**
 * @param value
 *            the value to set
 */
public void setValue(String value) {
    this.value = value;
}

}

-

package test;

import java.util.Arrays;
import java.util.List;

import com.thoughtworks.xstream.annotations.XStreamImplicit;



public class Fields {

@XStreamImplicit(itemFieldName = "Field")
private List<Field> fields;

public Fields(Field... field) {
    this.fields = Arrays.asList(field);
}

/**
 * @return the fields
 */
public List<Field> getFields() {
    return fields;
}

/**
 * @param fields
 *            the fields to set
 */
public void setFields(List<Field> fields) {
    this.fields = fields;
}

}

如何在 Mule 中使用 XStream？

4

3 回答 3

3

问题

默认的Object to XML转换器只支持类的别名注解：

<mulexml:object-to-xml-transformer doc:name="Object to XML">
    <mulexml:alias name="myAlias" class="com.my.package.MyClass"/>
</mulexml:object-to-xml-transformer>

并忽略所有其他注释。自 2012 年 7 月以来，官方错误跟踪器上已经存在一个问题，但直到现在仍未解决。

解决方案：自定义 XML 到对象转换器

1.创建变压器

在 Java 中创建一个自定义转换器，它扩展AbstractMessageTransformer：

public class ObjectToXml extends AbstractMessageTransformer {

  public Object transformMessage(MuleMessage message, String outputEncoding) throws TransformerException {

    XStream xstream = new XStream();

    // The payload should be the object to transform into XML
    Object object = message.getPayload();

    // Register all annotations in the XStream instance 
    xstream.processAnnotations(object.getClass());

    // Convert the object to XML and set it as payload
    message.setPayload(xstream.toXML(object));

    return message;
  }
}

2. 在您的 Mule 流程中使用自定义转换器

将Java Transfromer（不是 Java 组件）添加到您的流程中：

<custom-transformer class="com.my.package.ObjectToXml" doc:name="Object to XML"/>

而已！

于 2013-05-05T22:03:15.053 回答
2

我无法配置它，xml-to-object-transformer因此它可以与您的 XStream 注释类一起使用 OOTB。我能够加载上面的 XML 示例并成功完成流程的唯一方法是使用 Spring 实例化和配置 XStream，如下所示：

<spring:beans>
    <spring:bean name="xStream" class="com.thoughtworks.xstream.XStream" />
    <spring:bean
        class="org.springframework.beans.factory.config.MethodInvokingFactoryBean"
        p:targetObject-ref="xStream"
        p:targetMethod="processAnnotations">
        <spring:property name="arguments">
            <spring:list>
                <spring:value>test.GenericClass</spring:value>
            </spring:list>
        </spring:property>
    </spring:bean>
</spring:beans>

有了这个，我使用以下代替xml-to-object-transformer：

<expression-transformer
    expression="#[app.registry.xStream.fromXML(message.payload)]" />

我意识到这不是很好，所以希望其他人会有更好的解决方案。

于 2013-01-19T23:43:15.200 回答
0

Xml 到对象转换器在内部使用 Xstream，因此它应该可以工作 OOTB。

请提供流程配置，我会相应地更新我的答案。

于 2013-01-18T16:01:33.783 回答