- 浏览: 451676 次
- 性别:
- 来自: 北京
文章分类
- 全部博客 (371)
- Java (44)
- Flex (25)
- Design Pattern / UML (5)
- JVM (14)
- Software Engineer (4)
- Testing (30)
- Web Backend (60)
- Linux (7)
- Database (11)
- SOA (28)
- English (6)
- FX (5)
- SAP Support (25)
- SAP Development (5)
- SAP Impl & Oprn (8)
- Articles (15)
- Music (4)
- Recipe (14)
- Multi-thread (4)
- Lucene (2)
- CS basic / Algorithm (12)
- Tour (3)
- C C++ (21)
- Others (10)
- Code Repository C++ (1)
- Code Repository Java (1)
- Code Repository Algorithm (1)
- Code Repository SQL (1)
- Web Frontend (4)
最新评论
-
xiangxm:
Java 强引用、 软引用、 弱引用、虚引用 -
nml-lyb:
123
Mule 的第一个例子 -
nml-lyb:
http://www.baidu.com
Mule 的第一个例子 -
white___ant:
...
Java 强引用、 软引用、 弱引用、虚引用 -
joeyon:
...
Java NIO介绍
这个例子出自: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
发表评论
-
Axis 客户端代码
2009-09-22 16:16 1807import org.apache.axis.client.C ... -
Mule, AquaLogic ESB 学习阶段性总结 (2009.9.21)
2009-09-21 14:53 1326下面这段文字为转载:http://dragonetzhou.i ... -
Mule 的 Loan Broker 例子的 PPT (经典的ESB的例子)
2009-09-21 14:26 1692http://wiki.springside.org.cn/d ... -
Aqualogic Service Bus 的第三个例子 (消息流进阶)
2009-09-18 17:34 983P87 的那个例子 1、已经发布的Web Servic ... -
Aqualogic Service Bus 的第二个例子 (消息流基础)
2009-09-17 15:15 1188消息流节点类型: 启动节点、路由节点、分支节点、管道对节点 ... -
Aqualogic Service Bus 的第一个例子 (入门)
2009-09-17 11:17 1540本例子出自 《SOA权威指南》 第三章中的那个入门例子。 亲 ... -
Mule Transformers
2009-09-07 14:58 1676Using Transformers [ Configuri ... -
XMPP协议简介
2009-09-07 14:15 1751XMPP协议简介 XMPP(Ext ... -
REST(Representational State Transfer) 介绍
2009-08-31 23:24 1299REST(Representational State Tra ... -
Staged Event Driven Architecture (SEDA) 介绍
2009-08-31 10:29 2428一、前言 二、当前流行的两种并发处理编程模型 ... -
Camel 入门
2009-08-27 18:25 864前段时间和一些朋友聊 ... -
OSGi 入门
2009-08-27 18:15 667还没开始入... -
Mule 的消息路由
2009-08-27 17:53 1202Mule的消息路由 作者 J ... -
Mule 的第二个例子
2009-08-27 15:17 2924这个例子 主要 演示了 web service 作为 inbo ... -
Geronimo入门
2009-08-25 16:23 915http://www.matrix.org.cn/resour ... -
Apache Mina 入门
2009-08-25 13:31 11542007 年 12 月 24 日 本文将通过一个简单的问 ... -
CXF -- JAXB
2009-08-21 10:38 5423JAXB : Java API for XML Bindin ... -
CXF -- JAX-WS
2009-08-21 10:01 1332JAX-WS Java API for XML Web Se ... -
CXF的第一个例子 -- 深入剖析
2009-08-20 20:43 1686Web Service 的 Client 和 Server 端 ... -
CXF的第一个例子 (附 wsdl详解)
2009-08-20 16:52 29951、在eclipse中 创建一个java project。 ...
相关推荐
详细对mule的两个例子进行分析
mule 具体例子(代码)mule 具体例子(代码)
Mule ESB实际开发例子,适合初学者。
mule esb 项目 例子 入门
开源企业服务总线资料,介绍MULE ESB 官方例子的使用和原理。
博文链接:https://hideto.iteye.com/blog/65607
Mule ESB 是一个轻量级的基于java的企业服务总线和集成平台, 使得开发人员可以快速,简单的连接多个应用, 使得它们可以交换数据。 Mule ESB 容易集成现有异构系统,包括:JMS, Web Services, JDBC, HTTP, 等. ESB...
博文链接:https://hideto.iteye.com/blog/65822
mule,mule esb,Mule,ESB
关于在tomcat上进行mule多线程数量参数配置
Mule ESB 项目在Linux中的部署与开发与应用案例
Mule通过HTTP连接并传参给webService例子,此例子可以参考https://blog.csdn.net/dl348/article/details/83185036的例子说明
CSV,TSV或其他以定界符分隔的数据集中的列数据集的强大(但灵活)解析器 用法 将依赖项添加到Cargo.toml : mule = " 0.0.0 " use mule :: {read_file, Result }; #[tokio::main] pub async fn main () -> Result...
骡子 mule esb 上的一个小演示
Mule是一个以Java为核心的轻量级的消息框架和整合平台,基于EIP(Enterprise Integeration Patterns,由Hohpe和Woolf编写的一本书)而实现的。Mule的核心组件是UMO(Universal Message Objects,从Mule2.0开始UMO这一...
mule基本节点解释汇总 <mule> <inbound....> .... </inbound> ....... ..... ... </mule>
虽然Mule没有基于JBI来构建其架构,但是它为JBI容器提供了JBI适配器,因此可以很好地与JBI容器整合在一起。而 Mule更关注其灵活性,高效性以及易开发性。从2005年发表1.0版本以来,Mule吸引了越来越多的关注者,成为...