`
wangchao_17915566
  • 浏览: 169538 次
  • 性别: Icon_minigender_1
  • 来自: 西安
社区版块
存档分类
最新评论

xfire+webservice(客户端调用篇)

阅读更多

     服务接口,就是用来调用的,所以客户端显得尤为重要,xfire客户端对返回list很挑剔,所以需要使用泛型。

     如何建立webservice client

     步骤1,建立webservice  project

   

    下一步

   

    下一步,默认

   

    选择xfire包

   

    finish,  这样,webservice项目就完成了

    接下来是如何进行客户端开发.

    在项目中右键,new webservice client

   

    接着,选择你服务文件,wsdl

   

   完成。

   这样在你的项目中,会根据wsdl服务文件,生成客户端所需要的内容。

   自动生成文件,下去就细细体会,给出一个测试代码

  

package com.seavision.huayi2.service;

import java.net.MalformedURLException;
import java.util.Collection;
import java.util.HashMap;
import java.util.List;

import javax.xml.bind.JAXBElement;
import javax.xml.namespace.QName;
import org.codehaus.xfire.XFireRuntimeException;
import org.codehaus.xfire.aegis.AegisBindingProvider;
import org.codehaus.xfire.annotations.AnnotationServiceFactory;
import org.codehaus.xfire.annotations.jsr181.Jsr181WebAnnotations;
import org.codehaus.xfire.client.XFireProxyFactory;
import org.codehaus.xfire.jaxb2.JaxbTypeRegistry;
import org.codehaus.xfire.service.Endpoint;
import org.codehaus.xfire.service.Service;
import org.codehaus.xfire.soap.AbstractSoapBinding;
import org.codehaus.xfire.transport.TransportManager;

import com.seavision.huayi2.domain.ArrayOfTBusinsessLog;
import com.seavision.huayi2.domain.TBusinsessLog;
import com.seavision.huayi2.domain.TStationMonthReport;

public class IWebserviceClient {

    private static XFireProxyFactory proxyFactory = new XFireProxyFactory();
    private HashMap endpoints = new HashMap();
    private Service service0;

    public IWebserviceClient() {
        create0();
        Endpoint IWebservicePortTypeLocalEndpointEP = service0 .addEndpoint(new QName("http://service.huayi2.seavision.com", "IWebservicePortTypeLocalEndpoint"), new QName("http://service.huayi2.seavision.com", "IWebservicePortTypeLocalBinding"), "xfire.local://IWebservice");
        endpoints.put(new QName("http://service.huayi2.seavision.com", "IWebservicePortTypeLocalEndpoint"), IWebservicePortTypeLocalEndpointEP);
        Endpoint IWebserviceHttpPortEP = service0 .addEndpoint(new QName("http://service.huayi2.seavision.com", "IWebserviceHttpPort"), new QName("http://service.huayi2.seavision.com", "IWebserviceHttpBinding"), "http://localhost:8080/seavision/services/IWebservice");
        endpoints.put(new QName("http://service.huayi2.seavision.com", "IWebserviceHttpPort"), IWebserviceHttpPortEP);
    }

    public Object getEndpoint(Endpoint endpoint) {
        try {
            return proxyFactory.create((endpoint).getBinding(), (endpoint).getUrl());
        } catch (MalformedURLException e) {
            throw new XFireRuntimeException("Invalid URL", e);
        }
    }

    public Object getEndpoint(QName name) {
        Endpoint endpoint = ((Endpoint) endpoints.get((name)));
        if ((endpoint) == null) {
            throw new IllegalStateException("No such endpoint!");
        }
        return getEndpoint((endpoint));
    }

    public Collection getEndpoints() {
        return endpoints.values();
    }

    private void create0() {
        TransportManager tm = (org.codehaus.xfire.XFireFactory.newInstance().getXFire().getTransportManager());
        HashMap props = new HashMap();
        props.put("annotations.allow.interface", true);
        AnnotationServiceFactory asf = new AnnotationServiceFactory(new Jsr181WebAnnotations(), tm, new AegisBindingProvider(new JaxbTypeRegistry()));
        asf.setBindingCreationEnabled(false);
        service0 = asf.create((com.seavision.huayi2.service.IWebservicePortType.class), props);
        {
            AbstractSoapBinding soapBinding = asf.createSoap11Binding(service0, new QName("http://service.huayi2.seavision.com", "IWebservicePortTypeLocalBinding"), "urn:xfire:transport:local");
        }
        {
            AbstractSoapBinding soapBinding = asf.createSoap11Binding(service0, new QName("http://service.huayi2.seavision.com", "IWebserviceHttpBinding"), "http://schemas.xmlsoap.org/soap/http");
        }
    }

    public IWebservicePortType getIWebservicePortTypeLocalEndpoint() {
        return ((IWebservicePortType)(this).getEndpoint(new QName("http://service.huayi2.seavision.com", "IWebservicePortTypeLocalEndpoint")));
    }

    public IWebservicePortType getIWebservicePortTypeLocalEndpoint(String url) {
        IWebservicePortType var = getIWebservicePortTypeLocalEndpoint();
        org.codehaus.xfire.client.Client.getInstance(var).setUrl(url);
        return var;
    }

    public IWebservicePortType getIWebserviceHttpPort() {
        return ((IWebservicePortType)(this).getEndpoint(new QName("http://service.huayi2.seavision.com", "IWebserviceHttpPort")));
    }

    public IWebservicePortType getIWebserviceHttpPort(String url) {
        IWebservicePortType var = getIWebserviceHttpPort();
        org.codehaus.xfire.client.Client.getInstance(var).setUrl(url);
        return var;
    }

    public static void main(String[] args) {
        

        IWebserviceClient client = new IWebserviceClient();
        
		//create a default service endpoint
        IWebservicePortType service = client.getIWebserviceHttpPort();
       
        /**
         * 使用ObjectFactory插入
         * */    
            com.seavision.huayi2.domain.ObjectFactory cfactory=new com.seavision.huayi2.domain.ObjectFactory();
            com.seavision.huayi2.domain.TStationMonthReport  newTStationMonthReport = cfactory.createTStationMonthReport();
            newTStationMonthReport.setStationMonthReportId(cfactory.createTStationMonthReportStationMonthReportId("123465464864"));
//            
    /**
     * 使用JAXBElement插入
     * */
            
//            JAXBElement<String> id = new JAXBElement<String>(new
//                    QName("http://domain.huayi2.seavision.com", "stationMonthReportId"),String.class,"gefa");
//            newTStationMonthReport.setStationMonthReportId(id);
            
            service.insertYueJiHua(newTStationMonthReport);
        /**
         * 测试返回list结果
         * */
        ArrayOfTBusinsessLog aot = service.getYeWuList();
        List list = aot.getTBusinsessLog();
        System.out.println(list.size());
        for(int i=0;i<list.size();i++){
        	TBusinsessLog tlog = (TBusinsessLog) list.get(i);
        	System.out.println(i+"++++++"+tlog.getLogContent().getValue());
        }
		//TODO: Add custom client code here
        		//
        		//service.yourServiceOperationHere();
        
		System.out.println("test client completed");
        		System.exit(0);
    }

}

   注意以下内容,1:返回list内容,先存放入Arrayof**对象当中,再进行list遍历。

                         2: 对象属性取值,getValue();

                         3:对象属性封装,通过JAXBElement进行封装后,放入对象。

  • 大小: 41.4 KB
  • 大小: 46.1 KB
  • 大小: 44.1 KB
  • 大小: 47 KB
  • 大小: 36.7 KB
  • 大小: 48.6 KB
分享到:
评论
2 楼 同学、木 2011-12-08  
客户端要传复杂对象到服务端要怎么写?例如:传list
1 楼 erich2008 2009-01-01  
<pre name='code' class='java'>package com.seavision.huayi2.service;

import java.net.MalformedURLException;
import java.util.Collection;
import java.util.HashMap;
import java.util.List;

import javax.xml.bind.JAXBElement;
import javax.xml.namespace.QName;
import org.codehaus.xfire.XFireRuntimeException;
import org.codehaus.xfire.aegis.AegisBindingProvider;
import org.codehaus.xfire.annotations.AnnotationServiceFactory;
import org.codehaus.xfire.annotations.jsr181.Jsr181WebAnnotations;
import org.codehaus.xfire.client.XFireProxyFactory;
import org.codehaus.xfire.jaxb2.JaxbTypeRegistry;
import org.codehaus.xfire.service.Endpoint;
import org.codehaus.xfire.service.Service;
import org.codehaus.xfire.soap.AbstractSoapBinding;
import org.codehaus.xfire.transport.TransportManager;

import com.seavision.huayi2.domain.ArrayOfTBusinsessLog;
import com.seavision.huayi2.domain.TBusinsessLog;
import com.seavision.huayi2.domain.TStationMonthReport;

public class IWebserviceClient {

    private static XFireProxyFactory proxyFactory = new XFireProxyFactory();
    private HashMap endpoints = new HashMap();
    private Service service0;

    public IWebserviceClient() {
        create0();
        Endpoint IWebservicePortTypeLocalEndpointEP = service0 .addEndpoint(new QName("http://service.huayi2.seavision.com", "IWebservicePortTypeLocalEndpoint"), new QName("http://service.huayi2.seavision.com", "IWebservicePortTypeLocalBinding"), "xfire.local://IWebservice");
        endpoints.put(new QName("http://service.huayi2.seavision.com", "IWebservicePortTypeLocalEndpoint"), IWebservicePortTypeLocalEndpointEP);
        Endpoint IWebserviceHttpPortEP = service0 .addEndpoint(new QName("http://service.huayi2.seavision.com", "IWebserviceHttpPort"), new QName("http://service.huayi2.seavision.com", "IWebserviceHttpBinding"), "http://localhost:8080/seavision/services/IWebservice");
        endpoints.put(new QName("http://service.huayi2.seavision.com", "IWebserviceHttpPort"), IWebserviceHttpPortEP);
    }

    public Object getEndpoint(Endpoint endpoint) {
        try {
            return proxyFactory.create((endpoint).getBinding(), (endpoint).getUrl());
        } catch (MalformedURLException e) {
            throw new XFireRuntimeException("Invalid URL", e);
        }
    }

    public Object getEndpoint(QName name) {
        Endpoint endpoint = ((Endpoint) endpoints.get((name)));
        if ((endpoint) == null) {
            throw new IllegalStateException("No such endpoint!");
        }
        return getEndpoint((endpoint));
    }

    public Collection getEndpoints() {
        return endpoints.values();
    }

    private void create0() {
        TransportManager tm = (org.codehaus.xfire.XFireFactory.newInstance().getXFire().getTransportManager());
        HashMap props = new HashMap();
        props.put("annotations.allow.interface", true);
        AnnotationServiceFactory asf = new AnnotationServiceFactory(new Jsr181WebAnnotations(), tm, new AegisBindingProvider(new JaxbTypeRegistry()));
        asf.setBindingCreationEnabled(false);
        service0 = asf.create((com.seavision.huayi2.service.IWebservicePortType.class), props);
        {
            AbstractSoapBinding soapBinding = asf.createSoap11Binding(service0, new QName("http://service.huayi2.seavision.com", "IWebservicePortTypeLocalBinding"), "urn:xfire:transport:local");
        }
        {
            AbstractSoapBinding soapBinding = asf.createSoap11Binding(service0, new QName("http://service.huayi2.seavision.com", "IWebserviceHttpBinding"), "http://schemas.xmlsoap.org/soap/http");
        }
    }

    public IWebservicePortType getIWebservicePortTypeLocalEndpoint() {
        return ((IWebservicePortType)(this).getEndpoint(new QName("http://service.huayi2.seavision.com", "IWebservicePortTypeLocalEndpoint")));
    }

    public IWebservicePortType getIWebservicePortTypeLocalEndpoint(String url) {
        IWebservicePortType var = getIWebservicePortTypeLocalEndpoint();
        org.codehaus.xfire.client.Client.getInstance(var).setUrl(url);
        return var;
    }

    public IWebservicePortType getIWebserviceHttpPort() {
        return ((IWebservicePortType)(this).getEndpoint(new QName("http://service.huayi2.seavision.com", "IWebserviceHttpPort")));
    }

    public IWebservicePortType getIWebserviceHttpPort(String url) {
        IWebservicePortType var = getIWebserviceHttpPort();
        org.codehaus.xfire.client.Client.getInstance(var).setUrl(url);
        return var;
    }

    public static void main(String[] args) {
       

        IWebserviceClient client = new IWebserviceClient();
       
//create a default service endpoint
        IWebservicePortType service = client.getIWebserviceHttpPort();
      
        /**
         * 使用ObjectFactory插入
         * */   
            com.seavision.huayi2.domain.ObjectFactory cfactory=new com.seavision.huayi2.domain.ObjectFactory();
            com.seavision.huayi2.domain.TStationMonthReport  newTStationMonthReport = cfactory.createTStationMonthReport();
            newTStationMonthReport.setStationMonthReportId(cfactory.createTStationMonthReportStationMonthReportId("123465464864"));
//           
    /**
     * 使用JAXBElement插入
     * */
           
//            JAXBElement&lt;String&gt; id = new JAXBElement&lt;String&gt;(new
//                    QName("http://domain.huayi2.seavision.com", "stationMonthReportId"),String.class,"gefa");
//            newTStationMonthReport.setStationMonthReportId(id);
           
            service.insertYueJiHua(newTStationMonthReport);
        /**
         * 测试返回list结果
         * */
        ArrayOfTBusinsessLog aot = service.getYeWuList();
        List list = aot.getTBusinsessLog();
        System.out.println(list.size());
        for(int i=0;i&lt;list.size();i++){
        TBusinsessLog tlog = (TBusinsessLog) list.get(i);
        System.out.println(i+"++++++"+tlog.getLogContent().getValue());
        }
//TODO: Add custom client code here
        //
        //service.yourServiceOperationHere();
       
System.out.println("test client completed");
        System.exit(0);
    }

}</pre>
<p> </p>

相关推荐

    xfire+spring+webservice+client

    标题中的“xfire+spring+webservice+client”是一个关于集成XFire、Spring框架和Web服务客户端的专题,这涉及到Java开发中的一项重要技术——Web服务的消费与提供。在这个主题下,我们将深入探讨以下几个核心知识点...

    Xfire客户端调用webservice jar包

    在这个场景下,"Xfire客户端调用webservice jar包"是指Xfire客户端为了实现某些功能,如获取服务器数据或更新信息,需要调用Web服务的接口。这些接口通常以Java的jar包形式提供,方便开发者集成到他们的应用中。 ...

    XFire+WebService的jar包合集

    5. 客户端调用:在客户端使用XFire的客户端API创建代理,调用远程服务。 这个“XFire+WebService的jar包合集”正是为了方便开发者搭建和使用基于XFire的Web服务而整理的,包含了所有必要的依赖。开发者可以将这些...

    webservice xfire 客户端调用实现

    本篇文章将深入探讨如何使用XFire客户端调用Web服务,以及对象传递在Web服务开发中的应用。 首先,理解Web服务的基本概念至关重要。Web服务采用标准的协议如SOAP(Simple Object Access Protocol)进行通信,XML...

    java使用XFire调用webService接口

    "Java 使用 XFire 调用 webService 接口" ...我们了解了服务端和客户端的开发步骤,并了解了使用 XFire 调用 webService 接口的优点。通过本文,我们可以更好地理解和应用 XFire 框架,提高 Web 服务的开发和集成效率。

    spring+xfire( 编写webservice完整配置+案例)

    Spring 和 XFire 是一个经典的组合,用于在Java应用程序中创建和消费Web服务。Spring作为一个强大的框架,提供了全面的依赖注入和面向切面编程能力,而XFire是早先的Web服务实现,它允许开发者轻松地将Java接口转换...

    Java使用XFire调用WebService接口

    这篇博客“Java使用XFire调用WebService接口”显然是讨论如何利用XFire这个开源框架来与Web服务交互。 XFire是Apache CXF项目的前身,它提供了一种简单的方式来创建和消费SOAP Web服务。XFire的强项在于其轻量级和...

    Xfire 开发webservice与客户端调用教程与实例

    本教程将深入探讨Xfire如何实现Web服务的创建、部署以及客户端调用,同时提供实例代码供学习参考。 **1. Xfire简介** Xfire是基于Java的Web服务框架,它提供了全面的WS-I(Web Services Interoperability)兼容性...

    xfire+spring+webservice例子

    4. **服务调用**:如何使用Spring的Web服务模板或者XFire的客户端API来消费远程Web服务。 5. **集成开发环境(IDE)的使用**:如何在Eclipse或MyEclipse中配置和运行Web服务项目。 6. **部署与测试**:理解Web服务的...

    Xfire调用webservice无法传递参数问题

    检查服务接口定义(WSDL文件)与客户端调用的参数类型是否匹配。 4. **配置问题**:Xfire的配置文件(如xfire-config.xml)可能没有正确设置,导致参数传递失败。检查配置文件中的服务地址、命名空间、操作名等是否...

    xfire+spring+webservice

    5. 测试和调用:使用客户端工具(如cURL或测试类)进行服务调用,验证其功能和性能。 此外,XFire还支持Spring的AOP拦截器,这意味着我们可以利用Spring的拦截器机制来实现Web服务的安全性、性能监控等功能。同时,...

    xfire+spring+maven构建webservice服务器和客户端

    标题中的“xfire+spring+maven构建webservice服务器和客户端”揭示了本教程将围绕三个主要技术进行讨论:XFire、Spring和Maven。这三者都是Java开发中不可或缺的工具,尤其在构建Web服务方面。 XFire是早期的一个...

    Xfire调用webservice无法接收到参数问题解决

    标题"Xfire调用webservice无法接收到参数问题解决"指出的核心问题是:当使用Xfire作为客户端调用Web服务时,服务端无法正确接收到传递的参数。这可能是由于多种原因引起的,如: 1. **XML序列化与反序列化问题**:...

    xfire+spring+webservice入门例子

    【xfire+Spring+WebService 入门实例详解】 在IT行业中,Web服务是一个重要的通信方式,它允许不同系统间的应用程序进行数据交换。本入门实例将深入探讨如何使用XFire框架与Spring集成来构建和消费Web服务。XFire是...

    Webservice使用xfire发布及客户端调用

    2. **客户端调用Web服务**: - 客户端需要知道Web服务的WSDL(Web服务描述语言)URL,WSDL定义了服务的接口、消息结构和调用方式。 - XFire提供了一个`ClientProxyFactoryBean`,用于根据WSDL生成一个Java客户端...

    Xfire+spring+hiebrnate webService

    在本项目中,Xfire作为Web服务的服务器端实现,负责处理来自客户端的请求,执行业务逻辑,并返回相应的响应。 【Spring】: Spring是一个全面的企业级应用开发框架,它简化了Java应用程序的开发,尤其是Java EE...

    webservice客户端调用几种方式汇总

    webservice客户端几种方式调用汇总,客户端代码生成及调用方式详细说明等

    xfire访问webservice客户端用到的jar包

    在提供的压缩包“Xfire_webservice”中,应该包含以下关键库: - `xfire-aegis-binding.jar`:Aegis绑定器,用于将Java对象转换为XML和反之。 - `xfire-core.jar`:XFire的核心库,包含服务生命周期管理、消息处理...

    XFire Webservice 客户端

    XFire Webservice客户端可能设计为跨平台,可以在不同的操作系统上运行,如Windows、Mac OS和Linux,这需要考虑各种平台的API调用和兼容性问题。 **10. 开发工具与调试** 开发XFire Webservice客户端时,开发者可能...

    xFire+spring webService 示例

    5. **消费服务**:如果需要调用其他服务,可以使用`JaxWsProxyFactoryBean`创建一个客户端代理对象。只需指定服务的WSDL地址,Spring会自动生成客户端代码。 6. **测试与调试**:使用JUnit或其他测试框架编写测试...

Global site tag (gtag.js) - Google Analytics