web service CXF工作中使用总结

Apache CXF 是一个开放源代码框架，提供了用于方便地构建和开发 Web 服务的可靠基础架构。它允许创建高性能和可扩展的服务，您可以将这样的服务部署在 Tomcat 和基于 Spring 的轻量级容器中，以及部署在更高级的服务器上，例如 Jboss、IBM® WebSphere® 或 BEA WebLogic。

依赖的包： commons-logging-1.1.jar
geronimo-activation_1.1_spec-1.0-M1.jar (or Sun's Activation jar)
geronimo-annotation_1.0_spec-1.1.jar (JSR 250)
geronimo-javamail_1.4_spec-1.0-M1.jar (or Sun's JavaMail jar)
geronimo-servlet_2.5_spec-1.1-M1.jar (or Sun's Servlet jar)
geronimo-ws-metadata_2.0_spec-1.1.1.jar (JSR 181)
jaxb-api-2.1.jar
jaxb-impl-2.1.6.jar
jaxws-api-2.1.jar
jetty-6.1.5.jar
jetty-util-6.1.5.jar
neethi-2.0.jar
saaj-api-1.3.jar
saaj-impl-1.3.jar
stax-api-1.0.1.jar
wsdl4j-1.6.1.jar
wstx-asl-3.2.1.jar
XmlSchema-1.2.jar
xml-resolver-1.2.jar

spring jar 包， 用来支持xml配置：

aopalliance-1.0.jar
spring-core-2.0.4.jar
spring-beans-2.0.4.jar
spring-context-2.0.4.jar
spring-web-2.0.4.jar

CXF jar包：

cxf-2.1.jar

以上jar 包 可从apache官方网站下载 apache-cxf-2.1.2.zip， 然后从apache-cxf-2.1.2/lib 目录中获得

1、首先在web.xml中配置

<!-- CXF -->
<servlet>
<servlet-name>CXFServlet</servlet-name>
<servlet-class>
org.apache.cxf.transport.servlet.CXFServlet
</servlet-class>
<load-on-startup>1</load-on-startup>
</servlet>
<servlet-mapping>
<servlet-name>CXFServlet</servlet-name>
<url-pattern>/services/*</url-pattern>
</servlet-mapping>
<!-- CXF end -->

2、创建一个spring-module.xml 如下：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:jaxrs="http://cxf.apache.org/jaxrs"
xmlns:jaxws="http://cxf.apache.org/jaxws" xmlns:aop="http://www.springframework.org/schema/aop"
xmlns:security="http://www.springframework.org/schema/security"
xmlns:http-conf = "http://cxf.apache.org/transports/http/configuration"
xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd http://www.springframework.org/schema/security http://www.springframework.org/schema/security/spring-security-2.0.4.xsd http://cxf.apache.org/jaxrs http://cxf.apache.org/schemas/jaxrs.xsd http://cxf.apache.org/jaxws http://cxf.apache.org/schemas/jaxws.xsd http://cxf.apache.org/transports/http/configuration http://cxf.apache.org/schemas/configuration/http-conf.xsd">

<http-conf:conduit name="*.http-conduit">
<http-conf:client ConnectionTimeout="10000" ReceiveTimeout="20000"/>
</http-conf:conduit>

<!-- 索为系统集成计划反馈信息 -->
<jaxws:endpoint id="planFeedBackWsService" address="/planFeedBackWsService"
implementorClass="avicit.bt.webservice.service.PlanFeedBackWsService">
<jaxws:implementor>
<bean id="planFeedBackWsServiceImpl"
class="avicit.bt.webservice.service.impl.PlanFeedBackWsServiceImpl">
</bean>
</jaxws:implementor>
</jaxws:endpoint>
</beans>

@WebService(targetNamespace = "http://planFeedBackWsService.webservice.bt.avicit/")
public interface PlanFeedBackWsService{
/**
* 从索为系统进行对进展监控信息的更新
* @param newPassword 新密码
* @param unitCode 集团编码
* @return 成功：succeed；失败：error:错误信息。
*/
public String receiveFeedBack(String feedBackPlan);
/**
*
* @param feedBackPlan
* @return
* 在与别的项目集成中发现不能用@WebParam这个注解，否则会报这里要强调，service端不可以用webservice的相关注解，如WebMethod，Webresult，Webparam等注解。否则会出现unexpected element (uri:"", local:"args0").错误
*/
public String receiveDeliver(String feedBackDeliver);

}

@WebService
public class PlanFeedBackWsServiceImpl extends ServiceBase implements PlanFeedBackWsService {

@Autowired(required = true)
private SysUserProcessI sysUserService;

@Autowired(required = true)
private SysUserProcessI sysUserProcessI;

@Autowired(required = true)
private BtPmTaskInfoService pmTaskInfoService;

SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");

@Override
public void delete(BeanBase arg0) throws DaoException {
}

@Override
public void insert(BeanBase arg0) throws DaoException {
}

@Override
public void update(BeanBase arg0) throws DaoException {
}

@Override
public String receiveFeedBack(String feedBackPlan) {
String returnString = "";
if (null == feedBackPlan || "".equals(feedBackPlan)) {
returnString = "反馈信息为空！";
} else {
// 解析json字符串
JSONObject jsonObject = JSONObject.fromObject(feedBackPlan);
// 得到计划的id
String ID = (String) jsonObject.get("ID");
BigDecimal ACTUAL_PROGRESS = null;
BigDecimal ACTUAL_WORKHOURS = null;
if (null != ID || !"".equals(ID)) {
try {
// 取出反馈后的信息并进行更新
// hibernateDao.update(sysUser);
BtPmTaskInfo taskInfo = pmTaskInfoService.getPmTaskInfoById(ID);
if (null != taskInfo) {
if (taskInfo.getPlanNature() != null && !"".equals(taskInfo.getPlanNature())) {
if ("6".equals(taskInfo.getPlanNature())) {

// 进展状态
if (jsonObject.get("ACTUAL_PROGRESS") != null && !"".equals(jsonObject.get("ACTUAL_PROGRESS"))) {

ACTUAL_PROGRESS = BigDecimal.valueOf(Double.parseDouble(jsonObject.get("ACTUAL_PROGRESS").toString()));
}
taskInfo.setActualProgress(ACTUAL_PROGRESS);
// 实际开始时间
if (jsonObject.get("ACTUAL_S_DATE") != null && !"".equals(jsonObject.get("ACTUAL_S_DATE"))
&& !"null".equals(jsonObject.get("ACTUAL_S_DATE"))) {

SimpleDateFormat sfEnd = new SimpleDateFormat("yyyy-MM-dd");
SimpleDateFormat sfStart = new SimpleDateFormat("EEE MMM dd HH:mm:ss zzz yyyy", java.util.Locale.ENGLISH);
Date ACTUAL_S_DATE = null;
String aceDate = sfEnd.format(sfStart.parse(jsonObject.get("ACTUAL_S_DATE").toString()));
ACTUAL_S_DATE = sdf.parse(aceDate);
taskInfo.setActualSDate(ACTUAL_S_DATE);
}
// 实际完成时间
if (jsonObject.get("ACTUAL_E_DATE") != null && !"".equals(jsonObject.get("ACTUAL_E_DATE"))
&& !"null".equals(jsonObject.get("ACTUAL_E_DATE"))) {
// 索为传递过来的结束日期与开始日期格式不一致所以要进行转换
SimpleDateFormat sfEnd = new SimpleDateFormat("yyyy-MM-dd");
SimpleDateFormat sfStart = new SimpleDateFormat("EEE MMM dd HH:mm:ss zzz yyyy", java.util.Locale.ENGLISH);
Date ACTUAL_E_DATE = null;
String aceDate = sfEnd.format(sfStart.parse(jsonObject.get("ACTUAL_E_DATE").toString()));
ACTUAL_E_DATE = sdf.parse(aceDate);
taskInfo.setActualEDate(ACTUAL_E_DATE);
}
// 实际工时
if (jsonObject.get("ACTUAL_WORKHOURS") != null && !"".equals(jsonObject.get("ACTUAL_WORKHOURS"))) {

ACTUAL_WORKHOURS = BigDecimal.valueOf(Double.parseDouble(jsonObject.get("ACTUAL_WORKHOURS").toString()));
taskInfo.setActualWorkhours(ACTUAL_WORKHOURS);
}

// 改变信息并进行更新
hibernateDao.update(taskInfo);
returnString = "success";

}
}
} else {
returnString = "在MPM系统中不存在ID为【" + ID + "】的计划！";
}

} catch (Exception e) {
e.printStackTrace();
}
}
}
return returnString;
}

@Override
public String receiveDeliver(String feedBackDeliver) {
String returnString = "";
if (null == feedBackDeliver || "".equals(feedBackDeliver)) {
returnString = "交付物信息为空！";
} else {
// 解析json字符串
JSONObject jsonObject = JSONObject.fromObject(feedBackDeliver);
// 得到交付物的id
String ID = (String) jsonObject.get("BILL_ID");
// 得到计划的idTASK_ID
String TASK_ID = (String) jsonObject.get("TASK_ID");

String url = "http://198.168.100.2:80/sysware/download/";
if (null != ID || !"".equals(ID)) {
try {
// 取出反馈后的信息并进行更新
BtPmTaskDeliver btPmTaskDeliver = pmTaskInfoService.getPmTaskDeliverById(ID);
BtPmTaskInfo taskInfo = pmTaskInfoService.getPmTaskInfoById(TASK_ID);
if (btPmTaskDeliver != null) {
// 交付物名称
if (jsonObject.get("BILL_NAME") != null && !"".equals(jsonObject.get("BILL_NAME"))) {
btPmTaskDeliver.setPdmurl(jsonObject.get("BILL_NAME").toString());
}
if (jsonObject.get("BILL_STATE") != null && !"".equals(jsonObject.get("BILL_STATE"))) {
String BILL_STATE = jsonObject.get("BILL_STATE").toString();
if ("0".equals(BILL_STATE)) {
BILL_STATE = "正常";
} else if ("1".equals(BILL_STATE)) {
BILL_STATE = "锁定";
}
btPmTaskDeliver.setDeliverableState(BILL_STATE);
}
if (jsonObject.get("PDMURL") != null && !"".equals(jsonObject.get("PDMURL"))) {
// String
// adapterUrl=url+"?ID="+jsonObject.get("PDMURL").toString()+"&&DIS=false&___ifr=true";
btPmTaskDeliver.setPdmurl(jsonObject.get("PDMURL").toString());
}
// 修改人
if (jsonObject.get("UPDATER") != null && !"".equals(jsonObject.get("UPDATER"))) {

btPmTaskDeliver.setLastUpdatedBy(jsonObject.get("UPDATER").toString());
}
// 更新计划实际开始时间
btPmTaskDeliver.setDeliverActualStartDate(taskInfo.getActualSDate());
btPmTaskDeliver.setLastUpdateDate(new Date());
// 改变信息并进行更新交付物
hibernateDao.update(btPmTaskDeliver);

returnString = "更新交付物成功";
} else {

// 执行新增
String BILL_ID = jsonObject.get("BILL_ID").toString();
if (null == taskInfo) {
returnString = "新增交付物的计划ID=【" + ID + "】在MPM不存在";
} else {
// 执行新增
String BILL_NAME = jsonObject.get("BILL_NAME").toString();
String CREATOR = jsonObject.get("CREATOR").toString();
String BILL_STATE = jsonObject.get("BILL_STATE").toString();
String PDMURL = jsonObject.get("PDMURL").toString();
String adapterUrl = "";
BtPmTaskDeliver deliver = new BtPmTaskDeliver();
if (BILL_ID != null && !"".equals(BILL_ID)) {
deliver.setId(BILL_ID);
}
if (null != BILL_NAME && !"".equals(BILL_NAME)) {
deliver.setDeliverableName(BILL_NAME);
}
if (PDMURL != null && !"".equals(PDMURL)) {
// adapterUrl=url+"?ID="+PDMURL+"&&DIS=false&___ifr=true";
deliver.setPdmurl(PDMURL);
}
if (null != CREATOR && !"".equals(CREATOR)) {
deliver.setCreatedBy(CREATOR);
}
if (null != BILL_STATE && !"".equals(BILL_STATE)) {
if ("0".equals(BILL_STATE)) {
BILL_STATE = "正常";
} else if ("1".equals(BILL_STATE)) {
BILL_STATE = "锁定";
}
deliver.setDeliverableState(BILL_STATE);
}
if (null != TASK_ID && !"".equals(TASK_ID)) {
deliver.setTaskId(TASK_ID);
}
// 默认文件类型
deliver.setDeliverType("WJ");
// 设置实际开始时间
deliver.setDeliverActualStartDate(taskInfo.getActualSDate());

// 设置计划实际完成时间
deliver.setDeliverAcutalEndDate(new Date());

PojoUtil.setSysProperties(deliver, OpType.insert);
this.hibernateDao.save(deliver);
hibernateDao.flush();
SysLogUtil.log(deliver, null, OpType.insert, OpResult.success);

// hibernateDao.save(deliver);
// 保存数据
returnString = "新增交付物成功！";
}

}

} catch (Exception e) {
e.printStackTrace();
}
}

}
return returnString;
}

public static void main(String[] args) throws Exception {

//方法一
/* JaxWsProxyFactoryBean factory = new JaxWsProxyFactoryBean();
String address = "http://127.0.0.1:8080/MPM/services";
factory.setAddress(address+"/changePasswordWsService");
factory.setServiceClass(ChangePasswordWsService.class);
factory.getInInterceptors().add(new LoggingInInterceptor());
factory.getOutInterceptors().add(new LoggingOutInterceptor());
ChangePasswordWsService service = (ChangePasswordWsService) factory.create();
try{
String xml = service.changePassword("D24D5274BC5787A8CE551BFD7C5CE784", "28101129");
System.out.println(xml);
}catch(Exception e){
e.printStackTrace();
}*/
// 方法二动态调用
String wsdlUrl = "http://127.0.0.1:8080/MPM/services/planFeedBackWsService?wsdl";
String wsNameSpace = "http://planFeedBackWsService.webservice.bt.avicit/";

JaxWsDynamicClientFactory dcf = JaxWsDynamicClientFactory.newInstance();
Client client = dcf.createClient(wsdlUrl);
String json="{'ID':'111'}" ;
QName name = new QName(wsNameSpace,"receiveFeedBack");
Object[] xml = null;
try {
//xml = client.invoke(name, "D24D5274BC5787A8CE551BFD7C5CE784", "28101129");
//xml = client.invoke(name, new Object[]{"A","b"});
xml = client.invoke(name, json);

} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println("xml="+xml[0]);