随着计算机软件技术的发展进步,面向用户的大型计算机软件也越来越多。用户在使用软件进行工作时,总会存在着一些问题:软件之间需要进行链接以完成工作项目或是在软件a中开发出来的产品需要到软件b中进行下一步加工操作。而这些软件开发商不同,它们的数据结构也不同。计算机软件数据接口就可以很好地解决这种因为软件之间数据结构不同而引起的问题。本文针对计算机软件数据接口的分析案例进行了分析。
数据接口主要的作用是解决软件之间的数据共享与数据转换的问题。因为各软件开发商擅长研究领域的不同,注重点不同,针对数据格式的处理方式各不同。而用户在开发产品时往往需要用到一个以上的软件对产品进行操作。
webService接口程序开发实例
webService接口程序开发实例job调度功能(工作记录以后参考和改进):
项目A中的JOB 调度项目B中的JOB(用同一个quratz用户),启动两个项目的JOB
项目A(客服端):CommonJob.class
package comon.job;
import java.net.MalformedURLException;
import java.net.URL;
import org.codehaus.xfire.client.Client;
import org.quartz.Job;
import org.quartz.JobDataMap;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import comon.util.StaticUtils;
public class CommonJob implements Job {
private Client client = null;
public Client getClient(){
if( client == null ) {
try {
System.out.println("客服端中对smct_job 调度开始建立会话之前查询调度地址URl!");
//String smctJobInvokeUrl ="";
//String smctJobInvokeUrl ="";
String smctJobInvokeUrl = StaticUtils.getSmctJobInvokeWsdlURL();//可以配置在perporties文件中/数据库中
System.out.println("smctJobInvokeUrl:"+smctJobInvokeUrl);
System.out.println("客服端中对smct_job 调度开始建立会话之前查询调度地址为:!"+smctJobInvokeUrl);
client = new Client( new URL(smctJobInvokeUrl) );
client.setTimeout( 5000 );
System.out.println("客服端中对smct_job 调度成功建立会话!");
} catch (MalformedURLException e) {
e.printStackTrace();
System.out.println("客服端中对smct_job 调度建立会话失败!");
} catch (Exception e) {
e.printStackTrace();
System.out.println("客服端中对smct_job 调度建立会话失败!");
}
}
return client;
}
public void execute(JobExecutionContext context) throws JobExecutionException {
String result = "";
try {
JobDataMap jobDataMap = context.getMergedJobDataMap();
String clazz = jobDataMap.getString("clazz");
System.out.println("客服端对 SMCT JOB 使用类 方法"+clazz+": invokeMethodAutoExcute 调度结束:"+result);
Object[] objs = getClient().invoke("invokeMethodAutoExcute", new String[]{clazz});
if( objs != null && objs.length == 1 ){
result = objs[0].toString();
}
System.out.println("客服端对 SMCT JOB 使用类 方法: invokeMethodAutoExcute 调度结束:"+result);
} catch (Exception e) {
System.out.println("客服端对 SMCT JOB 使用类: invokeMethodAutoExcute 调度失败:"+result);
e.printStackTrace();
}
}
}
项目A中配置job类Action method:
public void addAutoJob(HttpServletRequest request, HttpServletResponse response) throws RemoteException,Exception{
response.setContentType("text/json;charset=GBK");
String jobname = request.getParameter("jobName");
String jobgroup = request.getParameter("jobGroup");
String trigname = request.getParameter("triggerName");
String triggroup = request.getParameter("triggerGroup");
String clazz = request.getParameter("className");
String expression = request.getParameter("CronExpression");
JSONObject json = new JSONObject();
try {
ServiceManager.getSession().startTransaction();
SchedulerFactory sf = new StdSchedulerFactory();
Scheduler sched = sf.getScheduler();
JobDetail jobDetail =
new JobDetail (jobName,jobGroup,comon.job.CommonJob.class);
jobDetail.getJobDataMap().put("clazz", clazz);
CronTrigger cronTrigger =
new CronTrigger(trigName, trigGroup, jobName, jobGroup, expression,TimeZone.getTimeZone( "Asia/Shanghai" ));
sched.addJob(jobDetail, true);
sched.scheduleJob(cronTrigger);
sched.start();
ServiceManager.getSession().commitTransaction();
json.put("retVal", "Y");
json.put("retMsg", "设置调度成功");
} catch (Exception e) {
e.printStackTrace();
try {
ServiceManager.getSession().rollbackTransaction();
} catch (Exception e2) {
} finally {
json.put("retVal", "N");
json.put("retMsg", "设置调度失败");
}
}
response.getWriter().print(json.toString());
}
项目B接口函数(服务器端):
public class ParseWebserviceSVImpl implements IParseWebserviceSV {
public String invokeMethodAutoExcute(String clazz) {
String flag = "failure";
try {
System.out.println("============smct_JOB webService Start=================");
System.out.println(" 进入接口类ParseWebserviceSVImpl对 smct_JOB 调度类反射,创建job实例开始.");
System.out.println(" 进入接口类ParseWebserviceSVImpl对 smct_JOB 调度类反射,创建job实例开始.");
Job job = (Job)Class.forName(clazz).newInstance();
System.out.println(" 进入接口类ParseWebserviceSVImpl对 smct_JOB 调度类反射,创建job实例结束.");
System.out.println(" 进入接口类ParseWebserviceSVImpl对 smct_JOB 调度开始执行开始!");
job.execute( null );
flag = "success";
} catch (Exception e) {
e.printStackTrace();
}
System.out.println("接口类ParseWebserviceSVImpl对 smct_JOB 调度开始执行结果标示符('failure'或者'success')为:"+flag);
System.out.println("=========smct_JOB webService end=====================");
return flag;
}
}
项目B配置文件:1、引入xfire插件
2、services.xml
< xml version="1.0" encoding="UTF-8" >
<beans xmlns="">
<service>
<name>jobInterfaces</name>
<namespace>com.asiainfo.bomc.smct</namespace>
<serviceClass>
connector.webservices.interfaces.IParseWebserviceSV
</serviceClass>
<implementationClass>
connector.webservices.impl.ParseWebserviceSVImpl
</implementationClass>
</service>
</beans>
项目B中被调度的job,按照普通的job写。