XFire使用举例

 闲来无事，顺便写个XFire的小例子，也算是打发时间了，o(∩_∩)o...哈哈

 

定义POM文件：

 

<project xmlns="http://maven.apache.org/POM/4.0.0"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
	<modelVersion>4.0.0</modelVersion>
	<groupId>org.danlley.xfire</groupId>
	<artifactId>xfire_001</artifactId>
	<packaging>war</packaging>
	<version>1.0-SNAPSHOT</version>
	<name>xfire_001 Maven Webapp</name>
	<url>http://maven.apache.org</url>
	<dependencies>
		<dependency>
			<groupId>org.codehaus.xfire</groupId>
			<artifactId>xfire-spring</artifactId>
			<version>1.2.6</version>
		</dependency>
		<dependency>
			<groupId>javax.servlet</groupId>
			<artifactId>servlet-api</artifactId>
			<version>2.3</version>
			<scope>provided</scope>
		</dependency>
	</dependencies>
	<build>
		<finalName>xfire_001</finalName>
		<plugins>
			<plugin>
				<groupId>org.apache.maven.plugins</groupId>
				<artifactId>maven-compiler-plugin</artifactId>
				<configuration>
					<source>1.5</source>
					<target>1.5</target>
				</configuration>
			</plugin>
		</plugins>
	</build>
</project>

 

 

 

 构造需用的数据模型：

 

一：构造Book模型

 

package org.codehaus.xfire.demo;

public class Book {
	private String title;
	private String isbn;
	private String author;

	public String getIsbn() {
		return isbn;
	}

	public void setIsbn(String isbn) {
		this.isbn = isbn;
	}

	public String getTitle() {
		return title;
	}

	public void setTitle(String title) {
		this.title = title;
	}

	public String getAuthor() {
		return author;
	}

	public void setAuthor(String author) {
		this.author = author;
	}

	public String toString() {
		return "[title=" + this.title + "\tisbn=" + this.isbn + "\tauthor="
				+ this.author + "]";
	}
}

 

 

 二：构造Order模型：

 

package org.codehaus.xfire.demo;

public class Order {
	private String order_id;
	private String quantity;
	private String price;

	public String getOrder_id() {
		return order_id;
	}

	public void setOrder_id(String order_id) {
		this.order_id = order_id;
	}

	public String getQuantity() {
		return quantity;
	}

	public void setQuantity(String quantity) {
		this.quantity = quantity;
	}

	public String getPrice() {
		return price;
	}

	public void setPrice(String price) {
		this.price = price;
	}

	public String toString() {
		return "[price=" + this.price + "\tquantity=" + this.quantity
				+ "\torder_id=" + this.order_id + "]";
	}
}

 

 

三：构造调用返回对象

 

package org.codehaus.xfire.demo;

public class Result {

	private boolean isSuccess = false;

	private String message;

	public boolean isSuccess() {
		return isSuccess;
	}

	public void setSuccess(boolean isSuccess) {
		this.isSuccess = isSuccess;
	}

	public String getMessage() {
		return message;
	}

	public void setMessage(String message) {
		this.message = message;
	}
}

 

定义XFire接口：

 

package org.codehaus.xfire.demo;

import java.util.Map;

public interface BookService {

	public Book[] getBooks();

	public Book findBook(String isbn);

	@SuppressWarnings("unchecked")
	public Map getBooksMap();

	public Book initBooks(Book book);

	public Result record(Book book, Order order);
}

 

 

XFire对外接口实现：

 

package org.codehaus.xfire.demo;

import java.util.HashMap;
import java.util.Map;

public class BookServiceImpl implements BookService {
	private Book onlyBook;

	public Book initBooks(Book book) {
		book.setAuthor("danlley");
		return book;
	}

	public Result record(Book book, Order order) {
		System.out.println(order.toString());
		System.out.println(book);

		Result result = new Result();
		result.setSuccess(true);
		return result;
	}

	public BookServiceImpl() {
		onlyBook = new Book();
		onlyBook.setAuthor("Dan Diephouse");
		onlyBook.setTitle("Using XFire");
		onlyBook.setIsbn("0123456789");
	}

	public Book[] getBooks() {
		return new Book[] { onlyBook };
	}

	public Book findBook(String isbn) {
		System.out.println(isbn);
		return onlyBook;
	}

	@SuppressWarnings("unchecked")
	public Map getBooksMap() {
		Map result = new HashMap();
		result.put(onlyBook.getIsbn(), onlyBook);
		return result;
	}
}

 

 

在 src\main\webapp\WEB-INF\classes\META-INF\xfire下定义services.xml，如下：

<beans xmlns="http://xfire.codehaus.org/config/1.0">
	<service>
		<name>BookService</name>
		<namespace>http://xfire.codehaus.org/BookService</namespace>
		<serviceClass>org.codehaus.xfire.demo.BookService</serviceClass>
		<implementationClass>
			org.codehaus.xfire.demo.BookServiceImpl
		</implementationClass>
	</service>
</beans>

 

 在src\main\webapp\WEB-INF下定义web.xml，如下：

 

<!DOCTYPE web-app
    PUBLIC "-//Sun Microsystems, Inc.//DTD Web Application 2.3//EN"
    "http://java.sun.com/dtd/web-app_2_3.dtd">
<web-app>
	<servlet>
		<servlet-name>XFireServlet</servlet-name>
		<display-name>XFire Servlet</display-name>
		<servlet-class>
			org.codehaus.xfire.transport.http.XFireConfigurableServlet
		</servlet-class>
	</servlet>

	<servlet-mapping>
		<servlet-name>XFireServlet</servlet-name>
		<url-pattern>/servlet/XFireServlet/*</url-pattern>
	</servlet-mapping>

	<servlet-mapping>
		<servlet-name>XFireServlet</servlet-name>
		<url-pattern>/services/*</url-pattern>
	</servlet-mapping>
</web-app>

 

 开始编写客户端调用：

 

1). 无参数方法调用

 

	@SuppressWarnings("unchecked")
	private void testBookService() {
		String serviceURL = "http://localhost:8080/xfire_001/services/BookService";
		Service serviceModel = new ObjectServiceFactory().create(
				BookService.class, null,
				"http://xfire.codehaus.org/BookService", null);

		XFireProxyFactory serviceFactory = new XFireProxyFactory();

		try {
			BookService service = (BookService) serviceFactory.create(
					serviceModel, serviceURL);
			Client client = Client.getInstance(service);
			client.setProperty(CommonsHttpMessageSender.HTTP_TIMEOUT, "0");

			Book[] books = service.getBooks();
			Map booksMap = service.getBooksMap();
			System.out.print("Received map with " + booksMap.size()
					+ " book(s) \n");
			System.out.println("BOOKS:");

			for (int i = 0; i < books.length; i++) {
				System.out.println(books[i].getTitle());
			}
		} catch (MalformedURLException e) {
			e.printStackTrace();
		}
	}

 

 2). 参数为单个对象的方法调用

 

	private void testBook_002() {
		String service_url = "http://localhost:8080/xfire_001/services/BookService";
		Service serviceModel = new ObjectServiceFactory().create(
				BookService.class, null,
				"http://xfire.codehaus.org/BookService", null);
		XFireProxyFactory serviceFactory = new XFireProxyFactory();
		try {
			BookService service = (BookService) serviceFactory.create(
					serviceModel, service_url);
			Client client = Client.getInstance(service);
			client.setProperty(CommonsHttpMessageSender.HTTP_TIMEOUT, "0");
			Book book = new Book();
			book.setAuthor("min.weixm");
			Book my = service.initBooks(book);
			System.out.println("my.getAuthor()" + my.getAuthor());
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

 

3). 接口参数为多个的情况下，方法调用

 

	private void testBook_001() {
		String service_url = "http://localhost:8080/xfire_001/services/BookService";
		Service serviceModel = new ObjectServiceFactory().create(
				BookService.class, null,
				"http://xfire.codehaus.org/BookService", null);
		XFireProxyFactory serviceFactory = new XFireProxyFactory();
		try {
			BookService service = (BookService) serviceFactory.create(
					serviceModel, service_url);
			Client client = Client.getInstance(service);
			client.setProperty(CommonsHttpMessageSender.HTTP_TIMEOUT, "0");
			Result result = service.record(getBook(), getOrder());
			System.out.println("result:" + result.isSuccess());
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

 

未完待续