Apache CXF 入門

jopen 11年前發布 | 37K 次閱讀 Apache CXF WEB服務/RPC/SOA

服務端和客戶端都是Java Project，先看服務端代碼

首先是SEI

package com.jadyer.service;

import java.util.List;

import javax.jws.WebParam;
import javax.jws.WebResult;
import javax.jws.WebService;

import com.jadyer.model.User;

@WebService(targetNamespace="http://blog.csdn.net/jadyer")
public interface HelloService {
    @WebResult(name="sayHelloResult")
    public String sayHello(@WebParam(name="name")String name);

    /**
     * 獲取指定編號的用戶信息
     */
    public User getUserByID(int id);

    /**
     * 只有用戶jadyer才可以獲取所有用戶信息,其它用戶只能獲取自己的用戶信息
     */
    public List<User> getUserList(User user);
}

下面是SIB

package com.jadyer.service;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import javax.jws.WebService;

import com.jadyer.model.User;

@WebService(endpointInterface="com.jadyer.service.HelloService", targetNamespace="http://blog.csdn.net/jadyer")
public class HelloServiceImpl implements HelloService {
    //模擬的一個內存數據庫
    private static Map<Integer, User> userMap = new HashMap<Integer, User>();
    static{
        userMap.put(1, new User(1, "admin", "xuanyu", 11));
        userMap.put(2, new User(2, "jadyer", "hongyu", 22));
    }

    @Override
    public String sayHello(String name) {
        System.out.println("Receive the name=[" + name + "]");
        if(null==name){
            return "Hello,World";
        }else{
            return "Hello," + name;
        }
    }

    @Override
    public User getUserByID(int id) {
        return userMap.get(id);
    }

    @Override
    public List<User> getUserList(User user) {
        List<User> userList = new ArrayList<User>();
        if(user.getUsername().equals("jadyer")){
            for(Map.Entry<Integer, User> entry : userMap.entrySet()){
                userList.add(entry.getValue());
            }
        }else{
            userList.add(user);
        }
        return userList;
    }
}

下面是用到的一個實體類User.java

package com.jadyer.model;

public class User {
    private int id;
    private String username;
    private String password;
    private int age;

    /*三個屬性的setter和getter略*/

    public User(){}
    public User(int id, String username, String password, int age) {
        this.id = id;
        this.username = username;
        this.password = password;
        this.age = age;
    }
}

下面是服務端自定義的用于接收SOAPHeader信息的Handler類

package com.jadyer.handler;

import java.util.Iterator;
import java.util.Set;

import javax.xml.namespace.QName;
import javax.xml.soap.SOAPEnvelope;
import javax.xml.soap.SOAPException;
import javax.xml.soap.SOAPHeader;
import javax.xml.soap.SOAPHeaderElement;
import javax.xml.ws.handler.MessageContext;
import javax.xml.ws.handler.soap.SOAPHandler;
import javax.xml.ws.handler.soap.SOAPMessageContext;

public class LicenseHandler implements SOAPHandler<SOAPMessageContext> {
    @Override
    public Set<QName> getHeaders() {
        return null;
    }

    @Override
    public void close(MessageContext context) {}

    @Override
    public boolean handleFault(SOAPMessageContext context) {
        return false;
    }

    @SuppressWarnings("unchecked")
    @Override
    public boolean handleMessage(SOAPMessageContext context) {
        Boolean isOutBound = (Boolean)context.get(SOAPMessageContext.MESSAGE_OUTBOUND_PROPERTY);
        if(!isOutBound){
            SOAPHeader header = null;
            try {
                SOAPEnvelope envelope = context.getMessage().getSOAPPart().getEnvelope();
                header = envelope.getHeader();
                if(null == header){
                    header = envelope.addHeader();
                }
            } catch (SOAPException e) {
                e.printStackTrace();
            }
            Iterator<SOAPHeaderElement> iterator = header.getChildElements();
            while(iterator.hasNext()){
                SOAPHeaderElement headerElement = iterator.next();
                if(headerElement.getLocalName().equals("licenseInfo")){
                    System.out.println("Receive the header=[" + headerElement.getTextContent() + "]");
                }
            }
        }
        return true;
    }
}

最后是服務端用于發布服務的ServerApp.java

package com.jadyer.server;

import java.util.ArrayList;
import java.util.List;

import javax.xml.ws.handler.Handler;

import org.apache.cxf.interceptor.LoggingInInterceptor;
import org.apache.cxf.interceptor.LoggingOutInterceptor;
import org.apache.cxf.jaxws.JaxWsServerFactoryBean;

import com.jadyer.handler.LicenseHandler;
import com.jadyer.service.HelloService;
import com.jadyer.service.HelloServiceImpl;

public class ServerApp {
    @SuppressWarnings("unchecked")
    public static void main(String[] args) {
        //基于JAX-WS的發布方式
        //Endpoint.publish("http://127.0.0.1:8088/myHelloService", new HelloServiceImpl());

        //基于CXF的發布方式
        JaxWsServerFactoryBean factory = new JaxWsServerFactoryBean();
        factory.setAddress("http://127.0.0.1:8088/myHelloService");
        factory.setServiceClass(HelloService.class);
        factory.setServiceBean(new HelloServiceImpl());

        //打印接收和響應的SOAP通信報文,這樣就不用再使用tcpmon了
        factory.getInInterceptors().add(new LoggingInInterceptor());
        factory.getOutInterceptors().add(new LoggingOutInterceptor());

        //set Handler(只需此步,無需SIB注解@HandlerChain,也不用提供xml文件)
        //對于CXF而言,用Handler真的沒有多大必要,我們完全可以用它的Interceptor來代替Handler
        List<Handler> handlers = new ArrayList<Handler>();
        handlers.add(new LicenseHandler());
        factory.setHandlers(handlers);

        factory.create();
    }
}

OK，服務端代碼示例完畢，下面是客戶端代碼

首先是客戶端自定義的用于發送SOAPHeader信息的Handler類

package com.jadyer.handler;

import java.util.Set;

import javax.xml.namespace.QName;
import javax.xml.soap.SOAPEnvelope;
import javax.xml.soap.SOAPException;
import javax.xml.soap.SOAPHeader;
import javax.xml.ws.handler.MessageContext;
import javax.xml.ws.handler.soap.SOAPHandler;
import javax.xml.ws.handler.soap.SOAPMessageContext;

public class LicenseHandler implements SOAPHandler<SOAPMessageContext> {
    @Override
    public Set<QName> getHeaders() {
        return null;
    }

    @Override
    public void close(MessageContext context) {}

    @Override
    public boolean handleFault(SOAPMessageContext context) {
        return false;
    }

    @Override
    public boolean handleMessage(SOAPMessageContext context) {
        Boolean isOutBound = (Boolean)context.get(SOAPMessageContext.MESSAGE_OUTBOUND_PROPERTY);
        if(isOutBound){
            try {
                SOAPEnvelope envelope = context.getMessage().getSOAPPart().getEnvelope();
                SOAPHeader header = envelope.getHeader();
                if(null == header){
                    header = envelope.addHeader();
                }
                QName qname = new QName("http://blog.csdn.net/jadyer", "licenseInfo", "ns");
                header.addHeaderElement(qname).setValue("Jadyer");
                return true;
            } catch (SOAPException e) {
                e.printStackTrace();
            }
        }
        return false;
    }
}

最后是客戶端調用服務端的模擬入口ClientApp.java

注意：具體客戶端代碼由CXF提供的wsdj2java生成

package com.jadyer.client;

import java.util.ArrayList;
import java.util.List;

import javax.xml.ws.handler.Handler;

import net.csdn.blog.jadyer.HelloService;
import net.csdn.blog.jadyer.User;

import org.apache.commons.lang.builder.ReflectionToStringBuilder;
import org.apache.commons.lang.builder.ToStringStyle;
import org.apache.cxf.interceptor.LoggingInInterceptor;
import org.apache.cxf.interceptor.LoggingOutInterceptor;
import org.apache.cxf.jaxws.JaxWsProxyFactoryBean;

import com.jadyer.handler.LicenseHandler;

/**
 * 使用CXF提供的wsdj2java
 * 1)將D:\Develop\apache-cxf-2.7.0\bin加入環境變量path中
 * 2)使用CXF提供的wsdl2java.bat生成客戶端代碼,其用法與JAX-WS的wsimport基本相同
 *   wsdl2java -d D:/Download/ -frontend jaxws21 -keep -verbose http://127.0.0.1:8088/myHelloService?wsdl
 * 補充：wsimport用法見-->http://blog.csdn.net/jadyer/article/details/8692108
 * @create May 30, 2013 5:09:13 PM
 * @author 玄玉<http://blog.csdn.net/jadyer>
 */
public class ClientApp {
    @SuppressWarnings("unchecked")
    public static void main(String[] args) {
        /**
         * 基于JAX-WS的客戶端調用方式
         */
        //System.out.println(new HelloServiceService().getHelloServicePort().sayHello("玄玉"));
        /**
         * 基于CXF的客戶端調用方式
         */
        JaxWsProxyFactoryBean factory = new JaxWsProxyFactoryBean();
        factory.setAddress("http://127.0.0.1:8088/myHelloService");
        factory.setServiceClass(HelloService.class);
        factory.getInInterceptors().add(new LoggingInInterceptor());
        factory.getOutInterceptors().add(new LoggingOutInterceptor());
        List<Handler> handlers = new ArrayList<Handler>();
        handlers.add(new LicenseHandler());
        factory.setHandlers(handlers);
        HelloService hello = (HelloService)factory.create();
        //System.out.println(hello.sayHello("玄玉"));
        //System.out.println(ReflectionToStringBuilder.toString(hello.getUserByID(2), ToStringStyle.MULTI_LINE_STYLE));
        User user = new User();
        user.setUsername("jadyer");
        List<User> userList = hello.getUserList(user);
        for(User uu : userList){
            System.out.println(ReflectionToStringBuilder.toString(uu, ToStringStyle.MULTI_LINE_STYLE));
        }
    }
}

最后再把控制臺輸出貼出來

下面是服務端的控制臺輸出

2013-5-31 22:28:59 org.apache.cxf.services.HelloServiceService.HelloServicePort.HelloService
信息: Inbound Message
----------------------------
ID: 4
Address: http://127.0.0.1:8088/myHelloService
Encoding: UTF-8
Http-Method: POST
Content-Type: text/xml; charset=UTF-8
Headers: {Accept=[*/*], Cache-Control=[no-cache], connection=[keep-alive], Content-Length=[351], content-type=[text/xml; charset=UTF-8], Host=[127.0.0.1:8088], Pragma=[no-cache], SOAPAction=[""], User-Agent=[Apache CXF 2.7.0]}
Payload: <soap:Envelope xmlns:soap="http://schemas.xmlsoap.org/soap/envelope/"><soap:Header><ns:licenseInfo xmlns:ns="http://blog.csdn.net/jadyer">Jadyer</ns:licenseInfo></soap:Header><soap:Body><ns2:getUserList xmlns:ns2="http://blog.csdn.net/jadyer"><arg0><age>0</age><id>0</id><username>jadyer</username></arg0></ns2:getUserList></soap:Body></soap:Envelope>
--------------------------------------
Receive the header=[Jadyer]
2013-5-31 22:28:59 org.apache.cxf.services.HelloServiceService.HelloServicePort.HelloService
信息: Outbound Message
---------------------------
ID: 4
Encoding: UTF-8
Content-Type: text/xml
Headers: {}
Payload: <soap:Envelope xmlns:soap="http://schemas.xmlsoap.org/soap/envelope/"><soap:Header/><soap:Body><ns2:getUserListResponse xmlns:ns2="http://blog.csdn.net/jadyer"><return><age>11</age><id>1</id><password>xuanyu</password><username>admin</username></return><return><age>22</age><id>2</id><password>hongyu</password><username>jadyer</username></return></ns2:getUserListResponse></soap:Body></soap:Envelope>
--------------------------------------

下面是客戶端的控制臺輸出

2013-5-31 22:28:58 org.apache.cxf.service.factory.ReflectionServiceFactoryBean buildServiceFromClass
信息: Creating Service {http://blog.csdn.net/jadyer}HelloServiceService from class net.csdn.blog.jadyer.HelloService
2013-5-31 22:28:59 org.apache.cxf.services.HelloServiceService.HelloServicePort.HelloService
信息: Outbound Message
---------------------------
ID: 1
Address: http://127.0.0.1:8088/myHelloService
Encoding: UTF-8
Http-Method: POST
Content-Type: text/xml
Headers: {Accept=[*/*], SOAPAction=[""]}
Payload: <soap:Envelope xmlns:soap="http://schemas.xmlsoap.org/soap/envelope/"><soap:Header><ns:licenseInfo xmlns:ns="http://blog.csdn.net/jadyer">Jadyer</ns:licenseInfo></soap:Header><soap:Body><ns2:getUserList xmlns:ns2="http://blog.csdn.net/jadyer"><arg0><age>0</age><id>0</id><username>jadyer</username></arg0></ns2:getUserList></soap:Body></soap:Envelope>
--------------------------------------
2013-5-31 22:28:59 org.apache.cxf.services.HelloServiceService.HelloServicePort.HelloService
信息: Inbound Message
----------------------------
ID: 1
Response-Code: 200
Encoding: UTF-8
Content-Type: text/xml;charset=UTF-8
Headers: {content-type=[text/xml;charset=UTF-8], Server=[Jetty(8.1.7.v20120910)], transfer-encoding=[chunked]}
Payload: <soap:Envelope xmlns:soap="http://schemas.xmlsoap.org/soap/envelope/"><soap:Header/><soap:Body><ns2:getUserListResponse xmlns:ns2="http://blog.csdn.net/jadyer"><return><age>11</age><id>1</id><password>xuanyu</password><username>admin</username></return><return><age>22</age><id>2</id><password>hongyu</password><username>jadyer</username></return></ns2:getUserListResponse></soap:Body></soap:Envelope>
--------------------------------------
net.csdn.blog.jadyer.User@168497f6[
  age=11
  id=1
  password=xuanyu
  username=admin
]
net.csdn.blog.jadyer.User@27db0da1[
  age=22
  id=2
  password=hongyu
  username=jadyer
]

本文由用戶 jopen 自行上傳分享，僅供網友學習交流。所有權歸原作者，若您的權利被侵害，請聯系管理員。

轉載本站原創文章，請注明出處，并保留原始鏈接、圖片水印。

本站是一個以用戶分享為主的開源技術平臺，歡迎各類分享！

本文地址：http://www.baiduhome.net/lib/view/open1379579480678.html

Apache CXF WEB服務/RPC/SOA

Apache CXF 入門

相關經驗

相關資訊

相關文檔

目錄