为了同步数据,需要将数据文件,也就是前几篇中生成的sql文件上传至服务器并执行。这里在服务端简单写了个文件上传接口,客户端调用curl来上传文件,上传完毕后,也使用curl发出一个指令,在服务端执行一个bat文件,将数据导入到服务端的数据中。在客户端定时执行这些curl命令,达到本地和远端数据库的同步。
public void doPost(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
response.setContentType("text/html");
response.setCharacterEncoding("UTF-8");
response.setHeader("Pragma", "No-cache");
response.setHeader("Cache-Control", "no-cache");
response.setDateHeader("Expires", 0);
PrintWriter out = response.getWriter();
String fileName = "";
try {
if (ServletFileUpload.isMultipartContent(request)) {
DiskFileItemFactory dff = new DiskFileItemFactory();// 创建该对象
ServletFileUpload sfu = new ServletFileUpload(dff);// 创建该对象
sfu.setHeaderEncoding("utf-8");
dff.setSizeThreshold(1024000);// 指定在内存中缓存数据大小,单位为byte
sfu.setFileSizeMax(5000000);// 指定单个上传文件的最大尺寸
FileItemIterator fii = sfu.getItemIterator(request);// 解析request请求,并返回FileItemIterator集合
while (fii.hasNext()) {
FileItemStream fis = fii.next();// 从集合中获得一个文件流
if (fis.isFormField() ) {//获得普通form的值
String fieldName = fis.getFieldName().trim();
if(fieldName.equals("runNow")){
//执行批处理文件
String strcmd="cmd /c start D:\\test.bat";
Runtime rt = Runtime.getRuntime();
Process ps = null;
ps = rt.exec(strcmd);
ps.waitFor();
int i = ps.exitValue();
if (i == 0) {
System.out.println("执行完成.") ;
}else{
System.out.println("执行失败.") ;
}
ps.destroy();
ps = null;
}
}else{
fileName = fis.getName().substring(fis.getName().lastIndexOf("\\")+1);
BufferedInputStream inStream = new BufferedInputStream(fis.openStream());// 获得文件输入流
BufferedOutputStream outStream = new BufferedOutputStream(new FileOutputStream(new File("c:\\"+fileName)));// 获得文件输出流
Streams.copy(inStream, outStream, true);// 开始把文件写到你指定的上传文件夹
}
}
}
out.println("File upload successfully!!! -LY");// 终于成功了,
} catch (Exception e) {
e.printStackTrace();
}
out.flush();
out.close();
}
#上传文件,请注意那个@一定要有
curl -v -F upload=@c:\file001.sql http://127.0.0.1:8080/LIMS2/servlet/UploadFile
curl -v -F upload=@c:\file002.sql http://127.0.0.1:8080/LIMS2/servlet/UploadFile
curl -v -F upload=@c:\file003.sql http://127.0.0.1:8080/LIMS2/servlet/UploadFile
curl -v -F upload=@c:\file004.sql http://127.0.0.1:8080/LIMS2/servlet/UploadFile
。。。。。。
#让服务端执行
curl -F runNow=1 http://127.0.0.1:8080/LIMS2/servlet/UploadFile
本方法适用于定时上传文件至服务器进行一些同步、更新、维护操作。
初期使用了wget上传,但是总是不成功,主要是在MultipartContent方面的参数总是不正确,使用curl以后直接解决了。