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。

相关文章

如何在页面调用utility bar并传递参数至lwc组件

如何在页面调用utility bar并传递参数至lwc组件

1.在app的utility item中添加lwc组件： 2.调用utility bar api的方式有两种： 方法一，通过lwc调用： import {LightningElement,api ,wire } from 'lwc';import { publish, MessageContext } from 'lightning/messageService';import Ca
阅读更多...
零基础学习Redis(10) -- zset类型命令使用

零基础学习Redis(10) -- zset类型命令使用

zset是有序集合，内部除了存储元素外，还会存储一个score，存储在zset中的元素会按照score的大小升序排列，不同元素的score可以重复，score相同的元素会按照元素的字典序排列。 1. zset常用命令 1.1 zadd  zadd key [NX | XX] [GT | LT]   [CH] [INCR] score member [score member ...]
阅读更多...
自定义类型：结构体(续)

自定义类型：结构体(续)

目录 一. 结构体的内存对齐 1.1 为什么存在内存对齐？ 1.2 修改默认对齐数 二. 结构体传参 三. 结构体实现位段 一. 结构体的内存对齐 在前面的文章里我们已经讲过一部分的内存对齐的知识，并举出了两个例子，我们再举出两个例子继续说明： struct S3{double a;int b;char c;};int mian(){printf("%zd\n",s
阅读更多...
【编程底层思考】垃圾收集机制，GC算法，垃圾收集器类型概述

【编程底层思考】垃圾收集机制，GC算法，垃圾收集器类型概述

Java的垃圾收集（Garbage Collection，GC）机制是Java语言的一大特色，它负责自动管理内存的回收，释放不再使用的对象所占用的内存。以下是对Java垃圾收集机制的详细介绍： 一、垃圾收集机制概述： 对象存活判断：垃圾收集器定期检查堆内存中的对象，判断哪些对象是“垃圾”，即不再被任何引用链直接或间接引用的对象。内存回收：将判断为垃圾的对象占用的内存进行回收，以便重新使用。
阅读更多...
flume系列之：查看flume系统日志、查看统计flume日志类型、查看flume日志

flume系列之：查看flume系统日志、查看统计flume日志类型、查看flume日志

遍历指定目录下多个文件查找指定内容 服务器系统日志会记录flume相关日志 cat /var/log/messages |grep -i oom 查找系统日志中关于flume的指定日志 import osdef search_string_in_files(directory, search_string):count = 0
阅读更多...
两个月冲刺软考——访问位与修改位的题型(淘汰哪一页)；内聚的类型；关于码制的知识点；地址映射的相关内容

两个月冲刺软考——访问位与修改位的题型(淘汰哪一页)；内聚的类型；关于码制的知识点；地址映射的相关内容

1.访问位与修改位的题型(淘汰哪一页) 访问位：为1时表示在内存期间被访问过，为0时表示未被访问；修改位：为1时表示该页面自从被装入内存后被修改过，为0时表示未修改过。 置换页面时，最先置换访问位和修改位为00的，其次是01(没被访问但被修改过)的，之后是10(被访问了但没被修改过)，最后是11。 2.内聚的类型 功能内聚：完成一个单一功能，各个部分协同工作，缺一不可。 顺序内聚：
阅读更多...
Mysql BLOB类型介绍

Mysql BLOB类型介绍

BLOB类型的字段用于存储二进制数据 在MySQL中，BLOB类型，包括：TinyBlob、Blob、MediumBlob、LongBlob，这几个类型之间的唯一区别是在存储的大小不同。 TinyBlob 最大 255 Blob 最大 65K MediumBlob 最大 16M LongBlob 最大 4G
阅读更多...
Oracle type （自定义类型的使用）

Oracle type （自定义类型的使用）

oracle - type   type定义： oracle中自定义数据类型 oracle中有基本的数据类型，如number，varchar2，date，numeric，float....但有时候我们需要特殊的格式， 如将name定义为（firstname,lastname）的形式，我们想把这个作为一个表的一列看待，这时候就要我们自己定义一个数据类型 格式 ：create or repla
阅读更多...
MyBatis 切换不同的类型数据库方案

MyBatis 切换不同的类型数据库方案

下属案例例当前结合SpringBoot 配置进行讲解。 背景： 实现一个工程里面在部署阶段支持切换不同类型数据库支持。 方案一 数据源配置 关键代码(是什么数据库，该怎么配就怎么配） spring:datasource:name: test# 使用druid数据源type: com.alibaba.druid.pool.DruidDataSource# @需要修改 数据库连接及驱动u
阅读更多...
利用matlab bar函数绘制较为复杂的柱状图，并在图中进行适当标注

利用matlab bar函数绘制较为复杂的柱状图，并在图中进行适当标注

示例代码和结果如下：小疑问：如何自动选择合适的坐标位置对柱状图的数值大小进行标注？😂 clear; close all;x = 1:3;aa=[28.6321521955954 26.2453660695847 21.69102348512086.93747104431360 6.25442246899816 3.342835958564245.51365061796319 4.87
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2