一：导包----apache-cxf-2.6.2\lib
maven添加cfx
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf</artifactId>
<version>2.6.2</version>
</dependency>
2：编写服务器代码
/**
*
*/
package com.hoo.service;
import javax.jws.WebParam;
import javax.jws.WebService;
import javax.jws.soap.soAPBinding;
import javax.jws.soap.soAPBinding.Style;
/**
* @author Administrator
*
*/
@WebService
@SOAPBinding(style=Style.RPC)
public class HelloWorldService {
public String sayHello(@WebParam(name = "name")String name){
return name += " say: Hello World ";
}
}
3：编写发布服务器类
在服务器类的main方法中
HelloWorldService service = new HelloWorldService();
String address = "http://localhost:8080/helloWorld";
Endpoint.publish(address,service);
4：定制客户端调用webservice的接口
@WebService
publicinterface IHelloWorldService {
public String sayHello(@WebParam(name = "name") String name);
}
publicclass HelloWorldServiceClient {
publicstaticvoid main(String[] args) {
JaxWsProxyfactorybean factory = new JaxWsProxyfactorybean();
factory.setServiceClass(IHelloWorldService.class);
factory.setAddress("http://localhost:8080/helloWorld");
IHelloWorldService service = (IHelloWorldService)factory.create();
System.out.println("[result]"+service.sayHello("hoojo"));
}
}
例如：
MesssageInterceptor extends AbstractPhaseInterceptor<Message>
实现public void handleMessage(Message message)方法
然后再发布拦截器
JaxWsServerfactorybean factory = new JaxWsServerfactorybean();
factroy.setServiceClass(HelloWorldService.class);
factory.setAddress("http://localhost:8080/helloWorld");
factory.setServiceBean(new HelloWorldService());
factory.getininterceptors().add(new MesssageInterceptor(Phase.Receive));
factory.getininterceptors().add(new MesssageInterceptor(Phase.SEND));
factory.create();
8：传递复杂类型对象
通过POJO，然后再组合成集合类，然后再发布，最终客户端执行调用；
9：CXF整合Spring
9.1：导包
9.2：新建applicationContext-Server.xml文件
9.3：编写服务器代码----接口、实现类
9.4：编写applicationContext-server.xml
9.5：编写客户端
9.6：application-client.xml
9.7:客户端请求代码
不是CXF去读取那些文件，主动权在Spring这里。Spring读取配置的例如：applicationContext-webservice.xml 。如果是server端，spring会实例化工厂JaxWsServerfactorybean，根据配置发布服务。
如果是client端，spring会实例化工厂JaxWsProxyfactorybean,生成soap,去和server端通信。
配置CXF框架
我的电脑->属性->高级->环境变量
创建一个CXF_HOEM变量，值为CXF框架所在根目录，修改一下
CLAsspATH=%CXF_HOME%/lib;PATH=%CXF_HOME%/bin;这时有会问为什么要配置这两个参数据呢，其实配置这两个参数用途与配置JAVA变量一下，在DOS窗口下直接运行java2ws,wsdl2java等可执行文件。当然你没有配置也可以进到CXF框架的bin目录下远行这个几个可执行文件。
配置好了后，你在DOS窗口下输入java2ws，看看配置是否效。肯定没有成功，原因是使用6.0的JDK，我们还得在%JAVA_HOME%/jre/lib目录下创建一下endorsed文件夹，将jaxb-api.jar,jaxws.jar拷贝进去。现在再运一下java2ws,成功运行，配置生效了。
三：解组和编组
解组原理
编组原理
具体代码参考：
public class SoapClient {
private final static String MODEL = "com.itdcl.model";
public static void main(String[] args) throws ParserConfigurationException,JAXBException,TransformerException{
ObjectFactory factory = new ObjectFactory();
Customer customer = factory.createCustomer();
customer.setAge(20);
customer.setName("Josen");
DocumentBuilderFactory dbf = DocumentBuilderFactory.newInstance();
dbf.setNamespaceAware(true);
DocumentBuilder db = dbf.newDocumentBuilder();
Document doc = db.newDocument();
JAXBContext jaxbContext = JAXBContext.newInstance(MODEL);
//Java对象转换成XML
Marshaller marshaller = jaxbContext.createMarshaller();
marshaller.marshal(customer,doc);
DOMSource domSource = new DOMSource(doc);
StringWriter writer = new StringWriter();
StreamResult result = new StreamResult(writer);
TransformerFactory tf = TransformerFactory.newInstance();
Transformer transformer = tf.newTransformer();
transformer.transform(domSource,result);
String xmlString = writer.toString();
System.out.println(xmlString);
//XML转换成Java对象
Unmarshaller unmarshaller = jaxbContext.createUnmarshaller();
StringReader reader = new StringReader(xmlString);
Customer cus = (Customer)unmarshaller.unmarshal(reader);
System.out.println("Age:"+cus.getAge());
System.out.println("Name:"+cus.getName());
}
}
也可通过Ant配置来解组，如下：
Java代码
<?xml version="1.0" encoding="utf-8" ?>
<project default="xjc-compile" basedir=".">
<property name="src.dir" location="src" />
<property name="lib.dir" location="E:/cxf-lib" />
<property name="xml-schema.dir" location="src/WEB-INF" />
<property name="schema.name" value="cxfdemo.xsd" />
<property name="package" value="com.itdcl.model" />
<path id="classpath">
<fileset dir="${lib.dir}" includes="*.jar" />
</path>
<taskdef name="xjc" classname="com.sun.tools.xjc.XJCTask"
<target name="xjc-compile">
<echo message="Build Jaxb Class from Schema" />
<xjc schema="${xml-schema.dir}/${schema.name}"
destdir="${src.dir}" package="${package}" >
<produces dir="src/com/itdcl/model" includes="*" />
</xjc>
</target>
</project>
四：传输过程中加密
我们就得给消息加密。CXF可以结合WSS4J来对消息安全进行管理，可以使用令牌，X.509认证对消息头或内容进行加密。这节我只对令牌加密做一个简单的描述，我们还以Demo的形式来讲解一下。
<jaxws:endpoint id="service"
implementor="com.itdcl.service.ServiceImpl" address="/Service">
<jaxws:inInterceptors>
<bean
class="org.apache.cxf.interceptor.LoggingInInterceptor" />
<bean
class="org.apache.cxf.binding.soap.saaj.saajInInterceptor" />
<bean
class="org.apache.cxf.ws.security.wss4j.WSS4JInInterceptor">
<constructor-arg>
<map>
<entry key="action" value="Usernametoken" />
<entry key="passwordType"
value="PasswordText" />
<entry key="user" value="cxfServer" />
<entry key="passwordCallbackRef">
<ref bean="serverPasswordCallback" />
</entry>
</map>
</constructor-arg>
</bean>
</jaxws:inInterceptors>
</jaxws:endpoint>
passwordType:PasswordText指密码加密策略，这里直接文本
user:cxfServer指别名
passwordCallBackRef:serverPasswordCallback指消息验证
五：CFX 结合JSON
项目中需要用到json与java List之间的转换，在此写出来自己的方法，这里采用的是jackson。请先下载jackson相关包和apache cxf下的jettison-1.2.jar
1：新建POJO类
public class TestPojo {
private String name;
private String sex;
。。。。
}
2:json与List<TestPojo>之间的转换
public static void main(String[] args) {
List<TestPojo> list = new ArrayList<TestPojo>();
for(int i = 0; i < 10; i++) {
TestPojo pojo1 = new TestPojo();
pojo1.setName(i + "11");
pojo1.setSex(i + "22");
list.add(pojo1);
}
ObjectMapper mapper = new ObjectMapper();
StringWriter sw = new StringWriter();
try {
mapper.writeValue(sw,list);
} catch (JsonGenerationException e) {
e.printstacktrace();
} catch (JsonMappingException e) {
e.printstacktrace();
} catch (IOException e) {
e.printstacktrace();
}
List<TestPojo> list2 = new ArrayList<TestPojo>();
try {
JSONArray array = new JSONArray(sw.toString());
for(int i = 0; i < array.length(); i++) {
TestPojo pojoReverse = mapper.readValue(array.getString(i),TestPojo.class);
System.out.println(pojoReverse);
list2.add(pojoReverse);
}
} catch (JsonParseException e) {
e.printstacktrace();
} catch (JsonMappingException e) {
e.printstacktrace();
} catch (IOException e) {
e.printstacktrace();
} catch (JSONException e) {
// Todo Auto-generated catch block
e.printstacktrace();
}
System.out.println("list size = " + list.size());
System.out.println("list2 size = " + list2.size());
}
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 [email protected] 举报，一经查实，本站将立刻删除。
