结合Spring框架的 CXF WebService编程实例

1、结合Spring框架的 CXF WebService编程实例1. 需要的jar包，除了以上的jar包以外，还需要Spring包，这里就不一一列出了，根据项目的不同可能还需要其他的jar包，后期调试的时候根据控制台出现的问题，找出原因。2. Web.xml的配置： org.springframework.web.context.ContextLoaderListener contextConfigLocation classpath*:applicationContext-server.xml org.springframework.web.util.IntrospectorCleanupLis

2、tener CXFService org.apache.cxf.transport.servlet.CXFServlet CXFService /*然后在src目录中，新建一个applicationContext-server.xml文件，这个applicationContext-server.xml需要在web.xml文件中引入（仔细查看上面在web.xml中的配置），当然不一定非要新建applicationContext-server.xml，也可以写在applicationContext.xml中.如果applicationContext-server.xml没有写在src下面则web.

3、xml中的文件应该这样写contextConfigLocation/WEB-INF/classes/config/spring/*.xml（这里解释下：自己查看下编译后的applicationContext-server.xml的位置是在项目）。我这是在src下面新建了config和spring两个包，再在里面新建的applicationContext-server.xml（我这里够啰嗦的了，但是为了你们明白点，别整晕了啊，哈哈哈）。下面是applicationContext-server.xml中的内容： 好了以上就是webservice服务器端外围的webservice环境；下面介绍具体的

4、编码实例；Javabean文件：里面有3个属：编号，姓名，电话package com.service;public class Person private String code;private String name;private String tel;public String getName() return name;public String getCode() return code;public void setCode(String code) this.code = code;public void setName(String name) = nam

5、e;public String getTel() return tel;public void setTel(String tel) this.tel = tel;Webservice方法的接口，里面定义了两个方法package com.service;import javax.jws.WebParam;import javax.jws.WebService;import javax.jws.soap.SOAPBinding;import javax.jws.soap.SOAPBinding.Style;WebService(name=PersonService)SOAPBinding(sty

6、le = Style.RPC)public interface PersonService /根据输入的字符串对数据库中的人员进行模糊查询WebParam(name=inputsth) String inputsthpublic String getPersonList(WebParam(name=inputsth) String inputsth);/根据登录的Code，获得人员信息public String getPersonInfo(WebParam(name=PROP_EMP_DISTINCT_NO) String PROP_EMP_DISTINCT_NO);以下是具体两个方法的实现类

7、：（这里数据访问采用的hibernate，dao层在这就不细讲了）package com.service.impl;import java.util.ArrayList;import java.util.List;import javax.jws.WebMethod;import javax.jws.WebService;import org.hibernate.criterion.DetachedCriteria;import org.hibernate.criterion.Restrictions;import file.dao.IEmployeeDAO;import

8、file.domain.Employee;import com.service.CharacterSetToolkit;import com.service.Person;import com.service.PersonService;import com.service.User;WebServicepublic class PersonServiceImpl implements PersonServicepublic IEmployeeDAO getEmployeeDAO() return employeeDAO;public void setEmployeeDAO

9、(IEmployeeDAO employeeDAO) this.employeeDAO = employeeDAO;private IEmployeeDAO employeeDAO = null; WebMethodpublic String getPersonList(String inputsth) /inputsth=张; String s = CharacterSetToolkit.fromUnicode(inputsth.toCharArray(), 0, inputsth.length(), inputsth.toCharArray();System.out.println(fff

10、ffffffffgg=+s); DetachedCriteria dc = DetachedCriteria.forClass(Employee.class); dc.add(Restrictions.ilike(Employee.PROP_EMP_NAME, %+s+%); List employee=employeeDAO.findByCriteria(dc); System.out.println(对象=+employee.size();if(employee!=null&employee.size()0)String name=;List pl = new ArrayList();fo

11、r(int i=0;iemployee.size();i+)name=employee.get(i).getEmpName();String code=employee.get(i).getEmpDistinctNo();String tel=employee.get(i).getEmpWorkPhone();System.out.println(111sss=+name);Person p=new Person();p.setName(name);p.setCode(code);p.setTel(tel);pl.add(p);/ return pl;return new com.servic

12、e.DataSyncXml().personListXml(pl);/ List list = new ArrayList();/ list.add(new Person();/return list;return null; WebMethodpublic String getPersonInfo(String PROP_EMP_DISTINCT_NO) DetachedCriteria dc = DetachedCriteria.forClass(Employee.class);dc.add(Restrictions.eq(Employee.PROP_EMP_DISTINCT_NO, PR

13、OP_EMP_DISTINCT_NO);List employee= employeeDAO.findByCriteria(dc);if(employee!=null&employee.size()0) String name=employee.get(0).getEmpName(); String tel=employee.get(0).getEmpWorkPhone(); Person p=new Person(); p.setName(name); p.setTel(tel); System.out.println(1111=+p.getName()+2222=+p.getTel();

14、return new com.service.DataSyncXml().personInfoXml(p);return null;注意以上CharacterSetToolkit这个方法，主要是当时传中文参数的时候，服务器端为乱码，当时花费了我好大的劲才解决的，先将中文转换成unicode编码，再将unicode编码换成中文就ok了package com.service;public class CharacterSetToolkit /* Creates a new instance of CharacterSetToolkit */ public CharacterSetToolkit()

15、 private static final char hexDigit = 0,1,2,3,4,5,6,7,8,9,A,B,C,D,E,F ; private static char toHex(int nibble) return hexDigit(nibble & 0xF); /* * 将字符串编码成 Unicode 。 * param theString 待转换成Unicode编码的字符串。 * param escapeSpace 是否忽略空格。 * return 返回转换后Unicode编码的字符串。 */ public static String toUnicode(String t

16、heString, boolean escapeSpace) int len = theString.length(); int bufLen = len * 2; if (bufLen 0) bufLen = Integer.MAX_VALUE; StringBuffer outBuffer = new StringBuffer(bufLen); for(int x=0; x 61) & (aChar 127) if (aChar = ) outBuffer.append(); outBuffer.append(); continue; outBuffer.append(aChar); co

17、ntinue; switch(aChar) case : if (x = 0 | escapeSpace) outBuffer.append(); outBuffer.append( ); break; case t:outBuffer.append(); outBuffer.append(t); break; case n:outBuffer.append(); outBuffer.append(n); break; case r:outBuffer.append(); outBuffer.append(r); break; case f:outBuffer.append(); outBuf

18、fer.append(f); break; case =: / Fall through case : / Fall through case #: / Fall through case !: outBuffer.append(); outBuffer.append(aChar); break; default: if (aChar 0x007e) outBuffer.append(); outBuffer.append(u); outBuffer.append(toHex(aChar 12) & 0xF); outBuffer.append(toHex(aChar 8) & 0xF); o

19、utBuffer.append(toHex(aChar 4) & 0xF); outBuffer.append(toHex( aChar & 0xF); else outBuffer.append(aChar); return outBuffer.toString(); /* * 从 Unicode 码转换成编码前的特殊字符串。 * param in Unicode编码的字符数组。 * param off 转换的起始偏移量。 * param len 转换的字符长度。 * param convtBuf 转换的缓存字符数组。 * return 完成转换，返回编码前的特殊字符串。 */ public

20、 static String fromUnicode(char in, int off, int len, char convtBuf) if (convtBuf.length len) int newLen = len * 2; if (newLen 0) newLen = Integer.MAX_VALUE; convtBuf = new charnewLen; char aChar; char out = convtBuf; int outLen = 0; int end = off + len; while (off end) aChar = inoff+; if (aChar = )

21、 aChar = inoff+; if (aChar = u) / Read the xxxx int value = 0; for (int i = 0; i 4; i+) aChar = inoff+; switch (aChar) case 0: case 1: case 2: case 3: case 4: case 5: case 6: case 7: case 8: case 9: value = (value 4) + aChar - 0; break; case a: case b: case c: case d: case e: case f: value = (value

22、4) + 10 + aChar - a; break; case A: case B: case C: case D: case E: case F: value = (value 4) + 10 + aChar - A; break; default: throw new IllegalArgumentException( Malformed uxxxx encoding.); outoutLen+ = (char) value; else if (aChar = t) aChar = t; else if (aChar = r) aChar = r; else if (aChar = n)

23、 aChar = n; else if (aChar = f) aChar = f; outoutLen+ = aChar; else outoutLen+ = (char) aChar; return new String(out, 0, outLen); 最后将返回的东西，封装成xml就行package com.service;import java.util.List;import org.dom4j.Document;import org.dom4j.DocumentHelper;import org.dom4j.Element;public class DataSyncXml /模糊

24、查询返回人员列表public String personListXml(List pl)Document doc = DocumentHelper.createDocument();Element personList = doc.addElement(PersonList);for(int i=0;ipl.size();i+)Person person = (Person)pl.get(i);Element p = personList.addElement(Person);p.addElement(NAME).addText(object2String(person.getName();p

25、.addElement(CODE).addText(object2String(person.getCode();p.addElement(TEL).addText(object2String(person.getTel();return doc.asXML(); /返回人员信息public String personInfoXml(Person p)Document doc = DocumentHelper.createDocument();Element personInfo = doc.addElement(PersonInfo);Element person = personInfo.

26、addElement(Person);person.addElement(NAME).addText(object2String(p.getName();person.addElement(TEL).addText(object2String(p.getTel();return doc.asXML();private String object2String(Object o)return o=null?:o.toString();怎样在服务器端进行webservice的测试呢，首先在浏览器的地址栏中输入webservice的地址http:/192.168.5.xxx:8080/xxx/ser

27、vice/PersonService?wsdl如果出现你所学的方法名称，这说明你的webservice外围环境搭建成功，现在看一下你写的返回xml是否正确（我这是以返回对象0bject测试的）一下是我写的mian方法，public class SpringUsersWsClient public static void main(String args) throws UnsupportedEncodingException 通过登录的用户名（工号）查询用户的姓名和办公电话 JaxWsProxyFactoryBean factory = new JaxWsProxyFactoryBean();

28、 factory.setServiceClass(PersonService.class); factory.setAddress(http:/192.168.xxx.xxx:8080/xxx/service/PersonService); PersonService service = (PersonService) factory.create(); Person p=service.getPersonInfo(TH505); String name=p.getName(); String tel=p.getTel(); System.out.println(人员姓名=+name+办公电话

29、=+tel); JaxWsProxyFactoryBean factory = new JaxWsProxyFactoryBean(); factory.setServiceClass(PersonService.class); factory.setAddress(http:/192.xxx.xxx.xxx:8080/xxx/service/PersonService); PersonService service = (PersonService) factory.create(); String inputsth=张; String uname =new String( inputsth

30、.getBytes(Charset.forName(GB2312) ); String uname=CharacterSetToolkit.toUnicode(inputsth, true); System.out.println(uname=+uname); List personlist=service.getPersonList(uname); System.out.println(人员姓名总量22222=+personlist.size(); for(int i=0;ipersonlist.size();i+) System.out.println(人员姓名2222222=+perso

31、nlist.get(i).getName(); 在客户端调用刚刚所写的webservicepublic class SpringWsClient /返回人员列表public static List getPersonName(String inputsth)throws UnsupportedEncodingException, ServiceException, MalformedURLException, RemoteException, DocumentException ClassLoader cl = Thread.currentThread().getContextClassLoa

32、der(); DynamicClientFactory dcf = DynamicClientFactory.newInstance(); Client client = dcf.createClient(http:/192.168.5.xxx:8080/xxx/service/PersonService?wsdl); Thread.currentThread().setContextClassLoader(cl); Object reply = null; /String inputsth=张; String uname=CharacterSetToolkit.toUnicode(input

33、sth, true); try reply =client.invoke(getPersonList, uname); catch (Exception e) e.printStackTrace(); String result=(String) reply0;/ System.out.println(2222222www=+result); Document document = DocumentHelper.parseText(result); List listObject = document.selectNodes(/PersonList/Person); List pl = new

34、 ArrayList(); for (int i = 0; i listObject.size(); i+) Element personElement = (Element) listObject.get(i); String name = personElement.element(NAME).getText(); String code = personElement.element(CODE).getText(); String tel = personElement.element(TEL).getText(); /System.out.println(人员姓名=+name); Person p=new Person(); p.setName(name); p.setCode(code); p.setTel(tel); pl.add(p); return pl;/返回人员信息public static Person getPersonInfo(St