Mule 例子：以axis做为inbound，传递复杂类型，MuleClient UMOMessage

2024-01-25 19:32
文章标签 类型 传递 例子 复杂 axis inbound mule muleclient umomessage

本文主要是介绍Mule 例子：以axis做为inbound，传递复杂类型，MuleClient UMOMessage，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

这个例子出自：http://raymondhekk.iteye.com/blog/300604

 

重点演示了：

1、用 mule 的 inbound 来发布 axis 的 web services。

2、用 mule 的 MuleClient，UMOMessage 来调用 web services。

3、调用 web services 时候，传递复杂类型。

 

类清单:
  Person: 数据类，测试复杂数据类型的传递
  PersonService: 服务接口类
  PersonServiceImpl: 服务实现类。
  PersonServiceLaucher: Mule 服务器启动类
  PersonClient: 客户端测试类。
  person-config.xml, Mule 配置，其中将 PersonServiceImpl 暴露为一个axis1.4的服务。

 

Person.java

import java.util.Date;

public class Person implements java.io.Serializable {
    private String name;
    private String surname;
    private Date registerDate = new Date();
    private int age = 20;   
    public Person() {
        this.name = "defaultName";
        this.surname = "defaultSurname";
        this.registerDate = new Date();
        this.age = 39;
    }   
    public Person(String name, String surname) {
        this.name = name;
        this.surname = surname;
        this.registerDate = new Date();
        this.age = 39;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    public String getSurname() {
        return surname;
    }
    public void setSurname(String surname) {
        this.surname = surname;
    }
    public Date getRegisterDate() {
        return registerDate;
    }
    public void setRegisterDate(Date registerDate) {
        this.registerDate = registerDate;
    }
    public int getAge() {
        return age;
    }
    public void setAge(int age) {
        this.age = age;
    }
}

 

PersonService.java

public interface PersonService {   
    int countPerson(int i);   
    String printPerson(Person person);
    Person createPerson(String name, String surname, int age);
    Person[] batchCreatePerson(String namePattern);
}

PersonServiceImpl.java

public class PersonServiceImpl implements PersonService {
   
    public int countPerson(int i) {
        System.out.println("Mule Axis Function countPerson is Called!!");
        return 31;
    }
   
    public String printPerson(Person person) {
        System.out.println("Mule Axis Function printPerson is Called!!");
        return "person:name=" + person.getName() + ",surname="
                + person.getSurname();
    }

    public Person createPerson(String name, String surname, int age) {
        System.out.println("Mule Axis Function createPerson is Called!!");
        Person p = new Person(name, surname);
        p.setAge(age);
        System.out.println("a person is created:" + p.getName());
        return p;
    }

    public Person[] batchCreatePerson(String namePattern) {
        System.out.println("Mule Axis Function batchCreatePerson is Called!!");
        Person[] persons = new Person[3];
        for (int i = 0; i < persons.length; i++) {
            Person p = new Person(namePattern + i, namePattern + i);
            p.setAge(20 + i);
            persons[i] = p;
        }
        return persons;
    }
}

 

PersonServiceLaucher.java

import org.mule.config.ConfigurationException;
import org.mule.config.builders.MuleXmlConfigurationBuilder;
import org.mule.umo.manager.UMOManager;

 public class PersonServiceLaucher { 
     public static void main(String[] args) throws ConfigurationException { 
         MuleXmlConfigurationBuilder muleXmlConfigurationBuilder =
                     new MuleXmlConfigurationBuilder(); 
         UMOManager manager = muleXmlConfigurationBuilder
                     .configure("demo/mule/person/person-config.xml"); 
         System.out.println("Mule Server has started!");
     }
 }

 

PersonClient.java

import org.mule.extras.client.MuleClient;
import org.mule.impl.MuleMessage;
import org.mule.umo.UMOException;
import org.mule.umo.UMOMessage;

public class PersonClient {
    private MuleClient muleClient;

    public PersonClient() {
        try {
            muleClient = new MuleClient();
        } catch (UMOException e) {
            e.printStackTrace();
        }
    }
   
    public void testCountPerson() throws Exception {
        Object[] args = new Object[] { 1 };
        UMOMessage msg = new MuleMessage(args);
        UMOMessage message = muleClient
                .send(
                        "axis:http://localhost:8082/services/personService?method=countPerson", msg);

        System.out.println("message:" + message.getPayloadAsString());
    }

    public void testPrintPerson() throws Exception {

        Person person = new Person("David", "Jones");
        UMOMessage msg = new MuleMessage(person);
        UMOMessage message = muleClient
                .send(
                        "axis:http://localhost:8082/services/personService?method=printPerson",
                        msg);

        System.out.println("message:" + message.getPayloadAsString());
    }

    public void testCreatePerson() throws Exception {
        Object[] args = new Object[] { "xiaolong", "li", new Integer(23) };
        UMOMessage msg = new MuleMessage(args);
        UMOMessage message = muleClient
                .send(
                        "axis:http://localhost:8082/services/personService?method=createPerson",
                        msg);

        Person p = (Person) message.getPayload();
        System.out.println("message:" + message.getPayloadAsString());
        System.out.println("payload:" + p.getName() + "," + p.getSurname()
                + "," + p.getAge());
    }

    public void testBatchCreatePerson() throws UMOException {
        Object[] args = new Object[] { "Admin" };
        UMOMessage msg = new MuleMessage(args);
        UMOMessage message = muleClient
                .send(
                        "axis:http://localhost:8082/services/personService?method=batchCreatePerson",
                        msg);

        Person[] ps = (Person[]) message.getPayload();
        System.out.println("persons:" + ps.length);
        for (int i = 0; i < ps.length; i++) {
            Person p = ps[i];
            System.out.println("person:" + p.getName() + "," + p.getSurname()
                    + "," + p.getAge());
        }
    }

    public static void main(String[] args) throws Exception {
        PersonClient personClient = new PersonClient();
        //personClient.testCountPerson();
        personClient.testPrintPerson();
        //personClient.testCreatePerson();
        //personClient.testBatchCreatePerson();
    }
}

 

person-config.xml

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mule-configuration PUBLIC "-//MuleSource //DTD mule-configuration XML V1.0//EN" "http://mule.mulesource.org/dtds/mule-configuration.dtd">

<mule-configuration id="mule-test" version="1.0">


    <model name="personService">
        <!-- test: http://localhost:8082/services/personService?method=createPerson -->
        <mule-descriptor name="personService"
            implementation="demo.mule.person.PersonServiceImpl">
            <inbound-router>
                <endpoint
                    address="axis:http://localhost:8082/services">
                </endpoint>
            </inbound-router>
           
                <!-- not nessesary
                <properties> 
                <property name="style" value="wrapped"/> 
                <property name="use" value="literal"/> 
                </properties>  -->
           
        </mule-descriptor>
    </model>
</mule-configuration>

 

 

测试过程：


1） 启动Mule 服务容器。访问 http://localhost:8082/services/personService?wsdl ，确定 web services 发布成功。
2） 执行PersonClient

 

 

 

 

 

这篇关于Mule 例子：以axis做为inbound，传递复杂类型，MuleClient UMOMessage的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/644371。

相关文章

Spring Boot 配置文件之类型、加载顺序与最佳实践记录

Spring Boot 配置文件之类型、加载顺序与最佳实践记录

《SpringBoot配置文件之类型、加载顺序与最佳实践记录》SpringBoot的配置文件是灵活且强大的工具,通过合理的配置管理,可以让应用开发和部署更加高效,无论是简单的属性配置,还是复杂... 目录Spring Boot 配置文件详解一、Spring Boot 配置文件类型1.1 applicatio
阅读更多...
Python如何查看数据的类型

Python如何查看数据的类型

《Python如何查看数据的类型》：本文主要介绍Python如何查看数据的类型方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录python查看数据的类型1. 使用 type()2. 使用 isinstance()3. 检查对象的 __class__ 属性4.
阅读更多...
Python容器类型之列表/字典/元组/集合方式

Python容器类型之列表/字典/元组/集合方式

《Python容器类型之列表/字典/元组/集合方式》：本文主要介绍Python容器类型之列表/字典/元组/集合方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录1. 列表（List） - 有序可变序列1.1 基本特性1.2 核心操作1.3 应用场景2. 字典（D
阅读更多...
Python如何在Word中生成多种不同类型的图表

Python如何在Word中生成多种不同类型的图表

《Python如何在Word中生成多种不同类型的图表》Word文档中插入图表不仅能直观呈现数据,还能提升文档的可读性和专业性,本文将介绍如何使用Python在Word文档中创建和自定义各种图表,需要的... 目录在Word中创建柱形图在Word中创建条形图在Word中创建折线图在Word中创建饼图在Word
阅读更多...
SpringBoot接收JSON类型的参数方式

SpringBoot接收JSON类型的参数方式

《SpringBoot接收JSON类型的参数方式》：本文主要介绍SpringBoot接收JSON类型的参数方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、jsON二、代码准备三、Apifox操作总结一、JSON在学习前端技术时，我们有讲到过JSON，而在
阅读更多...
SpringBoot实现导出复杂对象到Excel文件

SpringBoot实现导出复杂对象到Excel文件

《SpringBoot实现导出复杂对象到Excel文件》这篇文章主要为大家详细介绍了如何使用Hutool和EasyExcel两种方式来实现在SpringBoot项目中导出复杂对象到Excel文件,需要... 在Spring Boot项目中导出复杂对象到Excel文件，可以利用Hutool或EasyExcel
阅读更多...
Rust中的BoxT之堆上的数据与递归类型详解

Rust中的BoxT之堆上的数据与递归类型详解

《Rust中的BoxT之堆上的数据与递归类型详解》本文介绍了Rust中的BoxT类型,包括其在堆与栈之间的内存分配,性能优势,以及如何利用BoxT来实现递归类型和处理大小未知类型,通过BoxT,Rus... 目录1. Box<T> 的基础知识1.1 堆与栈的分工1.2 性能优势2.1 递归类型的问题2.2
阅读更多...
Python如何计算两个不同类型列表的相似度

Python如何计算两个不同类型列表的相似度

《Python如何计算两个不同类型列表的相似度》在编程中,经常需要比较两个列表的相似度,尤其是当这两个列表包含不同类型的元素时,下面小编就来讲讲如何使用Python计算两个不同类型列表的相似度吧... 目录摘要引言数字类型相似度欧几里得距离曼哈顿距离字符串类型相似度Levenshtein距离Jaccard相
阅读更多...
Go语言中三种容器类型的数据结构详解

Go语言中三种容器类型的数据结构详解

《Go语言中三种容器类型的数据结构详解》在Go语言中,有三种主要的容器类型用于存储和操作集合数据：本文主要介绍三者的使用与区别,感兴趣的小伙伴可以跟随小编一起学习一下... 目录基本概念1. 数组（Array）2. 切片（Slice）3. 映射（Map）对比总结注意事项基本概念在 Go 语言中，有三种主要
阅读更多...
异步线程traceId如何实现传递

异步线程traceId如何实现传递

《异步线程traceId如何实现传递》文章介绍了如何在异步请求中传递traceId,通过重写ThreadPoolTaskExecutor的方法和实现TaskDecorator接口来增强线程池,确保异步... 目录前言重写ThreadPoolTaskExecutor中方法线程池增强总结前言在日常问题排查中，
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2