Terry.Li-彬

虛其心，可解天下之問(wèn)；專其心，可治天下之學(xué)；靜其心，可悟天下之理；恒其心，可成天下之業(yè)。

BlogJava :: 首頁(yè) :: 新隨筆 :: 聯(lián)系 :: 聚合

:: 管理 ::

143 隨筆 :: 344 文章 :: 130 評(píng)論 :: 0 Trackbacks

? 官網(wǎng)上很辛苦在一個(gè)旮旯里找到如何向 Mule暴露的axis web service 傳遞復(fù)雜數(shù)據(jù)類型，http://www.mulesource.org/pages/viewpage.action?pageId=4678，官網(wǎng)上只提供了原理，自己補(bǔ)充了一下客戶端測(cè)試代碼,部分服務(wù)類做了修改。
???
? 類清單:
? Person: 數(shù)據(jù)類，測(cè)試復(fù)雜數(shù)據(jù)類型的傳遞
? PersonService: 服務(wù)接口類
? PersonServiceImpl: 服務(wù)實(shí)現(xiàn)類。
? PersonServiceLaucher: Mule服務(wù)器啟動(dòng)類
? PersonClient: 客戶端測(cè)試類。
? person-config.xml, Mule 配置，其中將 PersonServiceImpl 暴露為一個(gè)axis1.4的服務(wù)。

1. Person數(shù)據(jù)類

Java代碼

? public ? class ?Person? ??
??{ ??
private ?String?name; ??
private ?String?surname; ??
private ?Date?registerDate?=? new ?Date(); ??
private ? int ?age?=? 20 ; ??
???...??

  public class Person 
   {
	private String name;
	private String surname;
	private Date registerDate = new Date();
	private int age = 20;
    ...

2.? 服務(wù)接口類

Java代碼

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

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

3. 實(shí)現(xiàn)類：

Java代碼

package?demo.mule.person; ??
??
public?class?PersonServiceImpl?implements?PersonService?{ ??
????public?String?printPerson(Person?person)?{?????? ??
????????return?"person:name="?+?person.getName()?+",surname="?+?person.getSurname(); ??
????} ??
???? ??
????/** ?
?????*?test?return?a?complex?type?by?web?service ?
?????*/??
????public?Person?createPerson(String?name,?String?surname,int?age)?{ ??
????????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)?{ ??
????????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; ??
????} ??
}??

package demo.mule.person;

public class PersonServiceImpl implements PersonService {
	public String printPerson(Person person) {		
		return "person:name=" + person.getName() +",surname=" + person.getSurname();
	}
	
	/**
	 * test return a complex type by web service
	 */
	public Person createPerson(String name, String surname,int age) {
		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) {
		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;
	}
}

4. person-config.xml

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">??
??????????????????? ??
????????<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>??

  <?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>

5. server啟動(dòng)

Java代碼

??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"); ??
} ??

   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");
	}
}

6. 測(cè)試類

Java代碼

?public?class?PersonClient?{???? ??
????private?MuleClient?muleClient?;? ??
????public?PersonClient()?{ ??
????????try?{ ??
????????????muleClient?=?new?MuleClient(); ??
????????}?catch?(UMOException?e)?{?????? ??
????????????e.printStackTrace(); ??
????????} ??
????} ??
??
????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[]{"小龍","李",?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.testPrintPerson(); ??
????????personClient.testCreatePerson();???????? ??
????????personClient.testBatchCreatePerson(); ??
????} ??
}??

 public class PersonClient {	
	private MuleClient muleClient ;	
	public PersonClient() {
		try {
			muleClient = new MuleClient();
		} catch (UMOException e) {		
			e.printStackTrace();
		}
	}

	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[]{"小龍","李", 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.testPrintPerson();
		personClient.testCreatePerson();		
		personClient.testBatchCreatePerson();
	}
}

測(cè)試過(guò)程：
1）啟動(dòng)Mule服務(wù)容器
2）執(zhí)行PersonClient

總結(jié)：
? 1) Mule暴露POJO為一個(gè)服務(wù)還是很簡(jiǎn)單的, 配置非常少
? 2) 傳遞和返回Java復(fù)雜數(shù)據(jù)類型，自定義數(shù)據(jù)類型都非常方便。不過(guò)，客戶端需要明確知道每個(gè)方法傳遞的參數(shù)個(gè)數(shù)和類型，以及返回的參數(shù)類型，并且需要自己type cast。在具體項(xiàng)目中，可以自己再做一層封裝或用AOP，以本地調(diào)用的方式調(diào)用 mule 的web service。

posted on 2009-09-19 20:42 禮物閱讀(1741) 評(píng)論(0) 編輯收藏所屬分類: Axis 、ESB

新用戶注冊(cè) 刷新評(píng)論列表


只有注冊(cè)用戶登錄后才能發(fā)表評(píng)論。




網(wǎng)站導(dǎo)航: 博客園 IT新聞 Chat2DB C++博客博問(wèn) 管理
相關(guān)文章: （原）Axis2 的RPC和AXIOM兩種方式 sipity backend 之 web service 開(kāi)發(fā)個(gè)人記錄 (轉(zhuǎn))結(jié)合Axis和Ant開(kāi)發(fā)Web服務(wù) （轉(zhuǎn)）牛人的WebService筆記（轉(zhuǎn)）WebService大講堂之Axis2(10)：使用soapmonitor模塊監(jiān)視soap請(qǐng)求與響應(yīng)消息（轉(zhuǎn)）WebService大講堂之Axis2(8)：異步調(diào)用WebService （轉(zhuǎn)）WebService大講堂之Axis2(9)：編寫(xiě)Axis2模塊（Module）（轉(zhuǎn)）WebService大講堂之Axis2(7)：將Spring的裝配JavaBean發(fā)布成WebService （轉(zhuǎn)）WebService大講堂之Axis2(5)：會(huì)話（Session）管理（轉(zhuǎn)）WebService大講堂之Axis2(6)：跨服務(wù)會(huì)話(Session)管理

Terry.Li-彬

常用鏈接

留言簿(19)

隨筆分類(107)

隨筆檔案(141)

文章分類(284)

文章檔案(342)

相冊(cè)

收藏夾(58)

家裝

最新隨筆

搜索

積分與排名

最新評(píng)論

閱讀排行榜

評(píng)論排行榜