低调星空

 

下面是一个XFire服务实例，这个例子已经在tomcat 5.5.28+jdk1.4.2中测试通过。

1、 创建服务接口ReadArticle，代码如下

package cn.starfield.service;

 

public interface ReadArticle {

       String getContent(String article) ;

}

本类实现了一个服务方法getContent(String article)

2、 创建服务类ReadArticleImpl，代码如下：

package cn.starfield.service.impl;

 

import java.io.BufferedReader;

import java.io.File;

import java.io.FileInputStream;

import java.io.FileNotFoundException;

import java.io.IOException;

import java.io.InputStreamReader;

 

import org.apache.commons.logging.Log;

 

import cn.starfield.log.Logger;

import cn.starfield.service.ReadArticle;

 

public class ReadArticleImpl implements ReadArticle {

       private static Log log = Logger.getLog();

 

       public String getContent(String article) {

              StringBuffer datas = new StringBuffer(1024);

              File articleFile = new File("../webapps/xfiredemo/art/" + article

                            + ".art");

              try {

                     BufferedReader br = new BufferedReader(new InputStreamReader(

                                   new FileInputStream(articleFile)));

 

                     if (br != null) {

                            String line = br.readLine();

                            while (line != null) {

                                   datas.append(line);

                                   datas.append('\n');

                                   line = br.readLine();

                            }

                     }

              } catch (FileNotFoundException e) {

                     log.error("Article conn't found!", e);

              } catch (IOException e) {

                     log.error("Article conn't read!", e);

              }

              return datas.toString();

       }

}

本类实现了服务接口，完成服务的最终操作。

3、 创建services.xml，代码如下：

<beans xmlns="http://xfire.codehaus.org/config/1.0">

         <service>

                   <name>ReadArticle</name>

                   <namespace>http://starfield.cn/ReadArticle</namespace>

                   <serviceClass>cn.starfield.service.ReadArticle</serviceClass>

                   <implementationClass>

                            cn.starfield.service.impl.ReadArticleImpl

                   </implementationClass>

         </service>

</beans>

将此文件置于class/META-INF目录下

4、 修改web.xml。修改方法在前而的部署手册中已经说明。

 

 

下载工程代码后，在lib中导入必要的包就可发布服务了。（需要的包在前面的手册中有说明）

 

客户端调用代码如下：

package cn.starfield.service.client;

 

import java.lang.reflect.Proxy;

import java.net.MalformedURLException;

 

import org.apache.commons.logging.Log;

import org.codehaus.xfire.client.Client;

import org.codehaus.xfire.client.XFireProxy;

import org.codehaus.xfire.client.XFireProxyFactory;

import org.codehaus.xfire.service.Service;

import org.codehaus.xfire.service.binding.ObjectServiceFactory;

import org.codehaus.xfire.transport.http.CommonsHttpMessageSender;

 

import cn.starfield.log.Logger;

import cn.starfield.service.ReadArticle;

 

public class ReadArticleClient {

       Log log = Logger.getLog();

       public String getContent(String atrticle) {

              String content = null;

              String serviceURL = "http://127.0.0.1:8080/xfiredemo/services/ReadArticle";

 

              // 创建service对象

              Service serviceModel = new ObjectServiceFactory().create(

                            ReadArticle.class, null, "http://test.yicha.cn/adreport", null);

 

              XFireProxyFactory serviceFactory = new XFireProxyFactory();

              try {

                     // 获取服务对象

                     ReadArticle service = (ReadArticle) serviceFactory.create(

                                   serviceModel, serviceURL);

 

                     // 获取客户端代理

                     Client client = ((XFireProxy) Proxy.getInvocationHandler(service))

                                   .getClient();

                     // 启动response压缩

                     client.setProperty(CommonsHttpMessageSender.GZIP_RESPONSE_ENABLED,

                                   Boolean.TRUE);

                     // 启动request压缩

                     client.setProperty(CommonsHttpMessageSender.GZIP_RESPONSE_ENABLED,

                                   Boolean.TRUE);

                     // 同时启动response和request压缩

                     client.setProperty(CommonsHttpMessageSender.GZIP_ENABLED,

                                   Boolean.TRUE);

                     // 忽略超时

                     client.setProperty(CommonsHttpMessageSender.HTTP_TIMEOUT, "0");

 

                     // 调用服务

                     content = service.getContent(atrticle);

              } catch (MalformedURLException e) {

                     log.error("Service conn't be use.", e);

              }

              return content;

 

       }

 

       /**

        * 测试用

        */

       public static void main(String[] args) {

              ReadArticleClient client = new ReadArticleClient();

              String content = client.getContent("article1");

              System.out.print(content);

       }

}