ssm框架实现计划任务【飞机宏观系统项目总结】
作者：互联网
ssm框架实现计划任务
一、需要更改的配置都在配置文件springmvc.xml里面：
1、需要在<beans //(需要添加xmlns以及xsi)>中添加
下面是项目中的源码：
<beans xmlns:task="http://www.springframework.org/schema/task"
xsi:schemaLocation="http://www.springframework.org/schema/task
http://www.springframework.org/schema/task/spring-task-3.2.xsd">
2、beans标签中还需要添加：
<task:annotation-driven/>
3、计划任务执行的注解为：@Scheduled(cron = “0/60 * * * * ?”)里面是cron表达式，可以去cron
表达式生成器里面去配置计划任务执行的时间，以下是项目中每60秒向地面端推送飞机端填写数据的源码：
package com.cm.controller;
import com.alibaba.fastjson.JSONArray;
import com.cm.HttpUtil.HttpUtil;
import com.cm.model.FlightRecordModel;
import com.cm.model.JobInformationModel;
import com.cm.model.ObservationalInformationModel;
import com.cm.service.FlightService;
import com.cm.service.JobService;
import com.cm.service.ObserveService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@Component
public class TimePushData {
@Autowired
private FlightService flightService;
@Autowired
private JobService jobService;
@Autowired
private ObserveService observeService;
@Scheduled(cron = "0/60 * * * * ?")//每隔60秒隔行一次
public void pushData(){
try{
String lastId = flightService.getLastRecordId();
String lastRecord_Id =flightService.getLastRecord_id();
List<FlightRecordModel> unfinished = flightService.getUnfinished();
List<JobInformationModel> unfinishedJob = jobService.getJobFromRecordId(lastRecord_Id);
List<ObservationalInformationModel> unfinishedObs = observeService.getUnfinishedObs(lastRecord_Id);
String flightData = JSONArray.toJSONString(unfinished);
String jobData = JSONArray.toJSONString(unfinishedJob);
String obsData = JSONArray.toJSONString(unfinishedObs);
String gourdUrl = "http://192.168.125.6:8080/Bg/flightRecord/sync";
int connectTimeout = 10000;
int readTimeout =10000;
String charset ="utf-8";
Map map = new HashMap();
map.put("flight",flightData);
map.put("job",jobData);
map.put("obs",obsData);
HttpUtil.post(gourdUrl,map,connectTimeout,readTimeout,charset);
}catch (Exception e){
e.printStackTrace();
}
}
}
附加：
调用接口，我使用的是工具类HttpUtil，需要注意的是，要设置要超时时间，顺便收藏下工具类，使用工具类调用接口就可以直接调用工具类里面的方法；
package com.cm.HttpUtil;
import org.apache.log4j.Logger;
import java.io.*;
import java.net.ConnectException;
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.Map;
import java.util.Set;
/**
* Created by Conkis-tp on 2017/6/8.
*/
public class HttpUtil {
/**
* logger
*/
private static Logger logger = Logger.getLogger(HttpUtil.class);
/**
* 支持的Http method
*/
private static enum HttpMethod {
POST, DELETE, GET, PUT, HEAD;
}
;
@SuppressWarnings({"unchecked", "rawtypes"})
private static String invokeUrl(String url, Map params, Map<String, String> headers, int connectTimeout, int readTimeout, String encoding, HttpMethod method) {
//构造请求参数字符串
StringBuilder paramsStr = null;
if (params != null) {
paramsStr = new StringBuilder();
Set<Map.Entry> entries = params.entrySet();
for (Map.Entry entry : entries) {
String value = (entry.getValue() != null) ? (String.valueOf(entry.getValue())) : "";
paramsStr.append(entry.getKey() + "=" + value + "&");
}
//只有POST方法才能通过OutputStream(即form的形式)提交参数
if (method != HttpMethod.POST) {
url += "?" + paramsStr.toString();
}
}
URL uUrl = null;
HttpURLConnection conn = null;
BufferedWriter out = null;
BufferedReader in = null;
try {
//创建和初始化连接
uUrl = new URL(url);
conn = (HttpURLConnection) uUrl.openConnection();
conn.setRequestProperty("content-type", "application/x-www-form-urlencoded");
conn.setRequestMethod(method.toString());
conn.setDoOutput(true);
conn.setDoInput(true);
//设置连接超时时间
conn.setConnectTimeout(connectTimeout);
//设置读取超时时间
conn.setReadTimeout(readTimeout);
//指定请求header参数
if (headers != null && headers.size() > 0) {
Set<String> headerSet = headers.keySet();
for (String key : headerSet) {
conn.setRequestProperty(key, headers.get(key));
}
}
if (paramsStr != null && method == HttpMethod.POST) {
//发送请求参数
out = new BufferedWriter(new OutputStreamWriter(conn.getOutputStream(), encoding));
out.write(paramsStr.toString());
out.flush();
}
//接收返回结果
StringBuilder result = new StringBuilder();
in = new BufferedReader(new InputStreamReader(conn.getInputStream(), encoding));
if (in != null) {
String line = "";
while ((line = in.readLine()) != null) {
result.append(line);
}
}
return result.toString();
} catch (ConnectException e) {
logger.error("访问地址[" + url + "]失败，连接超时！参数：" + params);
//处理错误流，提高http连接被重用的几率
try {
byte[] buf = new byte[100];
InputStream es = conn.getErrorStream();
if (es != null) {
while (es.read(buf) > 0) {
;
}
es.close();
}
} catch (Exception e1) {
e1.printStackTrace();
}
} catch (Exception e) {
logger.error("访问地址[" + url + "]失败！参数：" + params);
} finally {
try {
if (out != null) {
out.close();
}
} catch (Exception e) {
e.printStackTrace();
}
try {
if (in != null) {
in.close();
}
} catch (Exception e) {
e.printStackTrace();
}
//关闭连接
if (conn != null) {
conn.disconnect();
}
}
return null;
}
/**
* POST方法提交Http请求，语义为“增加” <br/>
* 注意：Http方法中只有POST方法才能使用body来提交内容
*
* @param url 资源路径（如果url中已经包含参数，则params应该为null）
* @param params 参数
* @param connectTimeout 连接超时时间（单位为ms）
* @param readTimeout 读取超时时间（单位为ms）
* @param charset 字符集（一般该为“utf-8”）
* @return
*/
public static String post(String url, Map params, int connectTimeout, int readTimeout, String charset) {
return invokeUrl(url, params, null, connectTimeout, readTimeout, charset, HttpMethod.POST);
}
/**
* POST方法提交Http请求，语义为“增加” <br/>
* 注意：Http方法中只有POST方法才能使用body来提交内容
*
* @param url 资源路径（如果url中已经包含参数，则params应该为null）
* @param params 参数
* @param headers 请求头参数
* @param connectTimeout 连接超时时间（单位为ms）
* @param readTimeout 读取超时时间（单位为ms）
* @param charset 字符集（一般该为“utf-8”）
* @return
*/
public static String post(String url, Map params, Map<String, String> headers, int connectTimeout, int readTimeout, String charset) {
return invokeUrl(url, params, headers, connectTimeout, readTimeout, charset, HttpMethod.POST);
}
/**
* GET方法提交Http请求，语义为“查询”
*
* @param url 资源路径（如果url中已经包含参数，则params应该为null）
* @param params 参数
* @return
*/
public static String get(String url, Map params) {
return invokeUrl(url, params, null, 5000, 5000, "utf-8", HttpMethod.GET);
}
/**
* GET方法提交Http请求，语义为“查询”
*
* @param url 资源路径（如果url中已经包含参数，则params应该为null）
* @param params 参数
* @param connectTimeout 连接超时时间（单位为ms）
* @param readTimeout 读取超时时间（单位为ms）
* @param charset 字符集（一般该为“utf-8”）
* @return
*/
public static String get(String url, Map params, int connectTimeout, int readTimeout, String charset) {
return invokeUrl(url, params, null, connectTimeout, readTimeout, charset, HttpMethod.GET);
}
/**
* GET方法提交Http请求，语义为“查询”
*
* @param url 资源路径（如果url中已经包含参数，则params应该为null）
* @param params 参数
* @param headers 请求头参数
* @param connectTimeout 连接超时时间（单位为ms）
* @param readTimeout 读取超时时间（单位为ms）
* @param charset 字符集（一般该为“utf-8”）
* @return
*/
public static String get(String url, Map params, Map<String, String> headers, int connectTimeout, int readTimeout, String charset) {
return invokeUrl(url, params, headers, connectTimeout, readTimeout, charset, HttpMethod.GET);
}
/**
* PUT方法提交Http请求，语义为“更改” <br/>
* 注意：PUT方法也是使用url提交参数内容而非body，所以参数最大长度收到服务器端实现的限制，Resin大概是8K
*
* @param url 资源路径（如果url中已经包含参数，则params应该为null）
* @param params 参数
* @param connectTimeout 连接超时时间（单位为ms）
* @param readTimeout 读取超时时间（单位为ms）
* @param charset 字符集（一般该为“utf-8”）
* @return
*/
public static String put(String url, Map params, int connectTimeout, int readTimeout, String charset) {
return invokeUrl(url, params, null, connectTimeout, readTimeout, charset, HttpMethod.PUT);
}
/**
* PUT方法提交Http请求，语义为“更改” <br/>
* 注意：PUT方法也是使用url提交参数内容而非body，所以参数最大长度收到服务器端实现的限制，Resin大概是8K
*
* @param url 资源路径（如果url中已经包含参数，则params应该为null）
* @param params 参数
* @param headers 请求头参数
* @param connectTimeout 连接超时时间（单位为ms）
* @param readTimeout 读取超时时间（单位为ms）
* @param charset 字符集（一般该为“utf-8”）
* @return
*/
public static String put(String url, Map params, Map<String, String> headers, int connectTimeout, int readTimeout, String charset) {
return invokeUrl(url, params, headers, connectTimeout, readTimeout, charset, HttpMethod.PUT);
}
/**
* DELETE方法提交Http请求，语义为“删除”
*
* @param url 资源路径（如果url中已经包含参数，则params应该为null）
* @param params 参数
* @param connectTimeout 连接超时时间（单位为ms）
* @param readTimeout 读取超时时间（单位为ms）
* @param charset 字符集（一般该为“utf-8”）
* @return
*/
public static String delete(String url, Map params, int connectTimeout, int readTimeout, String charset) {
return invokeUrl(url, params, null, connectTimeout, readTimeout, charset, HttpMethod.DELETE);
}
/**
* DELETE方法提交Http请求，语义为“删除”
*
* @param url 资源路径（如果url中已经包含参数，则params应该为null）
* @param params 参数
* @param headers 请求头参数
* @param connectTimeout 连接超时时间（单位为ms）
* @param readTimeout 读取超时时间（单位为ms）
* @param charset 字符集（一般该为“utf-8”）
* @return
*/
public static String delete(String url, Map params, Map<String, String> headers, int connectTimeout, int readTimeout, String charset) {
return invokeUrl(url, params, headers, connectTimeout, readTimeout, charset, HttpMethod.DELETE);
}
/**
* HEAD方法提交Http请求，语义同GET方法 <br/>
* 跟GET方法不同的是，用该方法请求，服务端不返回message body只返回头信息，能节省带宽
*
* @param url 资源路径（如果url中已经包含参数，则params应该为null）
* @param params 参数
* @param connectTimeout 连接超时时间（单位为ms）
* @param readTimeout 读取超时时间（单位为ms）
* @param charset 字符集（一般该为“utf-8”）
* @return
*/
public static String head(String url, Map params, int connectTimeout, int readTimeout, String charset) {
return invokeUrl(url, params, null, connectTimeout, readTimeout, charset, HttpMethod.HEAD);
}
/**
* HEAD方法提交Http请求，语义同GET方法 <br/>
* 跟GET方法不同的是，用该方法请求，服务端不返回message body只返回头信息，能节省带宽
*
* @param url 资源路径（如果url中已经包含参数，则params应该为null）
* @param params 参数
* @param headers 请求头参数
* @param connectTimeout 连接超时时间（单位为ms）
* @param readTimeout 读取超时时间（单位为ms）
* @param charset 字符集（一般该为“utf-8”）
* @return
*/
public static String head(String url, Map params, Map<String, String> headers, int connectTimeout, int readTimeout, String charset) {
return invokeUrl(url, params, headers, connectTimeout, readTimeout, charset, HttpMethod.HEAD);
}
public static void main(String[] args) {
//Map params = new HashMap();
//params.put("phoneNo", "中文");
//String str = HttpUtil.get("http://localhost:9092/elis_smp_als_dmz/do/app/activitySupport/demo", params, 3000, 3000, "UTF-8");
//System.out.println(str);
}
}
标签：总结,String,框架,url,param,ssm,params,readTimeout,connectTimeout 来源： https://blog.csdn.net/weixin_43212670/article/details/100933952