CFX构建webservice实例,与Spring整合

1:需要的jar包

antlr-2.7.6.jar

axis-ant.jar

axis.jar

commons-beanutils-1.8.3.jar

commons-collections-3.1.jar

commons-discovery-0.2.jar

commons-lang-2.5.jar

commons-logging-1.1.1.jar

cxf-2.6.1.jar

ezmorph-1.0.6.jar

gson-1.5.jar

jaxrpc.jar

json-lib-2.4-jdk15.jar

jxl.jar

log4j-1.2.17.jar

neethi-3.0.2.jar

ognl-3.0.6.jar

wsdl4j-1.5.1.jar

xmlschema-core-2.0.2.jar

jetty-continuation-8.1.15.v20140411.jar

jetty-http-8.1.15.v20140411.jar

jetty-io-8.1.15.v20140411.jar

jetty-security-8.1.15.v20140411.jar

jetty-server-8.1.15.v20140411.jar

jetty-util-8.1.15.v20140411.jar

 

2：配置web.xml

<!-- webservice接口 -->
<servlet>
<servlet-name>cxf</servlet-name>
<servlet-class>org.apache.cxf.transport.servlet.CXFServlet</servlet-class>
<load-on-startup>1</load-on-startup>
</servlet>

<servlet-mapping>
<servlet-name>cxf</servlet-name>
<url-pattern>/webservice/*</url-pattern>
</servlet-mapping>

 

3:定义接口

 

package com.vrv.ccp.service;

import javax.jws.WebService;

/**
*     <B>说明</B>：
*
*     @author  作者  名：段文杰<br/>
*     @version版  本  号：V1.0.12.0<br/>
*             创建时间：   2017年7月11日上午9:26:11
*     @email   duanwenjie@vrvmail.com.cn
*
*/
@WebService
public interfaceDeviceInfoAllService {

String sayHiToUser(String str);

/**
* 查询所有设备信息
*/
String queryAllDeviceInfo();

/**
* 查询存在超密文件数
*/
String queryFileIllegalCount();
}

4：定义实现类

 

package com.vrv.ccp.service.impl;

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

import javax.annotation.Resource;
import javax.jws.WebService;

import net.sf.json.JSONArray;

import org.apache.log4j.Logger;
import org.springframework.context.ApplicationContext;

import com.vrv.ccp.domain.Device;
import com.vrv.ccp.domain.DeviceInfoAllBean;
import com.vrv.ccp.domain.DeviceUser;
import com.vrv.ccp.service.CheckReportService;
import com.vrv.ccp.service.DeviceInfoAllService;
import com.vrv.ccp.service.DeviceService;
import com.vrv.ccp.service.DeviceUserService;

/**
*     <B>说明</B>：
*
*     @author  作者  名：段文杰<br/>
*     @version版  本  号：V1.0.12.0<br/>
*             创建时间：   2017年7月11日上午9:27:56
*     @email   duanwenjie@vrvmail.com.cn
*
*/
@WebService(endpointInterface="com.vrv.ccp.service.DeviceInfoAllService",serviceName="DeviceInfoAllService",targetNamespace="http://service.ccp.vrv.com/")
public classDeviceInfoAllServiceImpl implements DeviceInfoAllService {

// publicApplicationContext applicationContext;
//
// publicDeviceInfoAllServiceImpl(ApplicationContext applicationContext){
//    this.applicationContext= applicationContext;
// }
@Resource
private DeviceUserService deviceUserService;
@Resource
private DeviceService deviceService;
@Resource
private CheckReportService checkReportService;

private Logger logger = Logger.getLogger(DeviceInfoAllServiceImpl.class);
@Override
public StringsayHiToUser(String str) {
// TODO Auto-generated method stub
logger.info("=========DeviceInfoAllService接口=========="+str);
return "DeviceInfoAllService接口";
}

@Override
public StringqueryAllDeviceInfo() {

// 查询所有台账并封装map集合
Map<Long,DeviceUser> deviceUserMap = new HashMap<Long, DeviceUser>();
//    DeviceUserServicedeviceUserService = (DeviceUserService)applicationContext.getBean(DeviceUserService.class);
List<DeviceUser>deviceUserList = deviceUserService.queryAll();
for (DeviceUser du :deviceUserList) {
if(du.getDevice()!=null){
deviceUserMap.put(du.getDevice().getId(),du);
}
}
//查询所有的设备信息
//    DeviceServicedeviceService = (DeviceService)applicationContext.getBean(DeviceService.class);
List<Device>deviceList = deviceService.queryAll();
List<DeviceInfoAllBean>deviceInfoAllBeanList = new ArrayList<DeviceInfoAllBean>();
SimpleDateFormatdf = newSimpleDateFormat("yyyy-MM-dd HH:mm:ss");
//遍历并封装
for(Devicedevice:deviceList){
DeviceInfoAllBeandeviceInfoAllBean = new DeviceInfoAllBean();
DeviceUserdeviceUser = deviceUserMap.get(device.getId());
deviceInfoAllBean.setIp(device.getIp());
if (null != deviceUser) {
deviceInfoAllBean.setDeviceUser(deviceUser.getName());
}
deviceInfoAllBean.setOrgName(device.getCurOrgName());
deviceInfoAllBean.setSecretDegree(device.getSecretDegree());
deviceInfoAllBean.setClientVersion(device.getClientVersion());
deviceInfoAllBean.setOnlineActive(device.getOnlineActive());
deviceInfoAllBean.setoTime(device.getoTime());
deviceInfoAllBean.setRegisterTime(df.format(device.getRegisterTime()));
deviceInfoAllBeanList.add(deviceInfoAllBean);
}
JSONArrayjsonarray = JSONArray.fromObject(deviceInfoAllBeanList);
return jsonarray.toString();
}

@Override
public StringqueryFileIllegalCount() {
// TODO Auto-generated method stub
//查询违规文件个数
//    CheckReportServicecheckReportService = (CheckReportService)applicationContext.getBean(CheckReportService.class);
int count = checkReportService.queryIllegalCount();
Stringjson = "[{'count':'"+count+"'}]";
return json;
}

}

5：配置applicationContext-webservice.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:jaxws="http://cxf.apache.org/jaxws"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://cxf.apache.org/jaxwshttp://cxf.apache.org/schemas/jaxws.xsd">
<!--
手动添加的内容：
xmlns:jaxws="http://cxf.apache.org/jaxws" http://cxf.apache.org/jaxwshttp://cxf.apache.org/schemas/jaxws.xsd" -->

<import resource="classpath:META-INF/cxf/cxf.xml" />
<import resource="classpath:META-INF/cxf/cxf-extension-soap.xml"/>
<import resource="classpath:META-INF/cxf/cxf-servlet.xml"/>

<jaxws:endpoint id="helloWorld" implementor="com.vrv.ccp.service.impl.HelloWorldImpl"address="/helloWorld" />

<jaxws:endpoint id="deviceInfoAllServiceName" implementor="com.vrv.ccp.service.impl.DeviceInfoAllServiceImpl"address="/deviceInfoAllService" />
</beans>

6：重启并访问
http://192.168.118.130:8088/CCP/webservice/deviceInfoAllService?wsdl
 

7：客户端调用webservice2种方式;

 

http请求：

package client;

import java.util.List;

import net.sf.json.JSONArray;
import net.sf.json.JSONObject;

import org.apache.cxf.endpoint.Client;
importorg.apache.cxf.jaxws.endpoint.dynamic.JaxWsDynamicClientFactory;

import com.google.gson.Gson;
import com.google.gson.reflect.TypeToken;

/**
*    <B>说明 </B>：
*
*    @author  作 者  名 ：段文杰<br/>
*    @version 版  本  号 ：V1.0.12.0<br/>
*             创建时间：   2017年7月11日 上午9:48:47
*    @email   duanwenjie@vrvmail.com.cn
*
*/

public class DeviceInfoAllServiceClient {

publicstatic void main(String[] args) {
dy2();
//      dy3();
dy4();
}

publicstatic void dyServer(){

}

publicstatic void dy2() {
try{
Gsongson = new Gson();

StringtdsUrl  ="http://192.168.118.130:8088/CCP/webservice/deviceInfoAllService?wsdl";
System.out.println("=========tdsUrl=========="+tdsUrl);
JaxWsDynamicClientFactorydcf = JaxWsDynamicClientFactory.newInstance();
System.out.println("=========dcf=========="+dcf);
Stringmethod = "queryAllDeviceInfo";
Clientclient = dcf.createClient(tdsUrl);
System.out.println("=========client=========="+client);
Object[]res = null;
res= client.invoke(method, "");
if(res != null) {
System.out.println("=========res.length========["+res.length+"]");
Stringresult = res[0].toString();
System.out.println("=========result========"+result);
List<DeviceInfoAllBean>deviceInfoAllBeanList = gson.fromJson(result,
newTypeToken<List<DeviceInfoAllBean>>() {
}.getType());
System.out.println("=========list条数：========["+deviceInfoAllBeanList.size()+"]");
for(DeviceInfoAllBeandeviceInfoAllBean:deviceInfoAllBeanList){
System.out.println(deviceInfoAllBean.getIp());
}
}
}catch (Exception e) {
e.printStackTrace();
}
}

publicstatic void dy4() {
try{
StringtdsUrl  ="http://192.168.118.130:8088/CCP/webservice/deviceInfoAllService?wsdl";
System.out.println("=========tdsUrl=========="+tdsUrl);
JaxWsDynamicClientFactorydcf = JaxWsDynamicClientFactory.newInstance();
System.out.println("=========dcf=========="+dcf);
Stringmethod = "queryFileIllegalCount";
Clientclient = dcf.createClient(tdsUrl);
System.out.println("=========client=========="+client);
Object[]res = null;
res= client.invoke(method, "");
if(res != null) {
System.out.println("=========res.length========["+res.length+"]");
Stringresult = res[0].toString();
System.out.println("=========result========"+result);
JSONArrayjson = JSONArray.fromObject(result);
if(json.size()>0){
for(int i=0;i<json.size();i++){
JSONObject job =json.getJSONObject(i);  // 遍历 jsonarray 数组，把每一个对象转成json 对象
System.out.println(job.get("count"));  // 得到 每个对象中的属性值
}
}
}
}catch (Exception e) {
e.printStackTrace();
}
}

publicstatic void dy3(){
StringtdsUrl="http://192.168.119.174/ntds/WebServer/AssetManagement.asmx?wsdl";
try{
JaxWsDynamicClientFactorydcf = JaxWsDynamicClientFactory
.newInstance();
org.apache.cxf.endpoint.Clientclient = dcf
.createClient(tdsUrl);

intTotalCount = 0;
intpageSize = 1000;
inti = 1;
while(true){
//如果IsPagination为true则解析
if((i-1)*pageSize>TotalCount){
break;
}
//sayHello 为接口中定义的方法名称张三为传递的参数返回一个Object数组
//查询已注册数据
Stringparam = "{'SearchCondition':{'Registered':1},'OrderField':'d.DeviceID','SortType':0,'PageSize':"+pageSize+",'PageIndex':"+i+",'TotalCount':0,'TotalPageCount':0,'IsPagination':true}";
Stringmethod = "GetDeviceAll";
Object[]objects = client.invoke(method, param);
//输出调用结果
System.out.println("==============objects[0].toString()=========["+objects[0].toString()+"]");
JSONObjectjson = JSONObject.fromObject(objects[0].toString());
//解析json 获取数据并入库操作
//                                  TotalCount= parseJson(json);
i++;
System.out.println("==============i=========["+i+"]");
}

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

https请求：

 

package client;
/**
*    <B>说明 </B>：
*
*    @author  作 者  名 ：段文杰<br/>
*    @version 版  本  号 ：V1.0.12.0<br/>
*             创建时间：   2017年7月12日 下午6:22:58
*    @email   duanwenjie@vrvmail.com.cn
*
*/

import javax.xml.namespace.QName;

import org.apache.axis.client.Call;
import org.apache.axis.client.Service;

public class TestEcVoteNotice{

public static void main(String [] args) throws Exception {
System.setProperty("javax.net.ssl.keyStore", "D:\\tomcat证书\\tomcat.keystore");
System.setProperty("javax.net.ssl.keyStorePassword","123456789");
System.setProperty("javax.net.ssl.trustStore","D:\\tomcat证书\\tomcat.truststore");
System.setProperty("javax.net.ssl.trustStorePassword","123456789");

String endpoint ="https://192.168.118.130:8088/CCP/webservice/deviceInfoAllService?wsdl";
Service service = new Service();
Call call = (Call)service.createCall();
call.setTargetEndpointAddress( new java.net.URL(endpoint) );
call.setOperationName(new QName("http://service.ccp.vrv.com/","sayHiToUser"));
String res = (String) call.invoke( new Object[] {} );
call.setOperationName(new QName("http://service.ccp.vrv.com/","queryFileIllegalCount"));
String res2 = (String) call.invoke( new Object[] {} );

System.out.println( res+"/"+res2 );
}
}

8：https请求证书生成

 

使用jdk生成keystore后，导出证书，然后生成truststore文件

前面网上例子很多，就不贴代码

 

生成truststore文件：

keytool -import -file D:\tomcat证书\server.cer-storepass 123456789 -keystore D:\tomcat证书\tomcat.truststore-alias tomcat -noprompt