| | |
| | | import java.net.ServerSocket;
|
| | | import java.net.Socket;
|
| | | import java.net.UnknownHostException;
|
| | | import java.text.SimpleDateFormat;
|
| | | import java.util.Arrays;
|
| | | import java.util.Comparator;
|
| | | import java.util.Date;
|
| | | import java.util.zip.ZipEntry;
|
| | | import java.util.zip.ZipInputStream;
|
| | | import java.util.zip.ZipOutputStream;
|
| | |
| | | }
|
| | | }
|
| | | socket.close();
|
| | | SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
| | | System.out.println("Backup MySql OK at " + sdf.format(new Date()));
|
| | | ISNEEDDELETE = true;
|
| | | } catch (UnknownHostException e) {
|
| | | e.printStackTrace();
|
| | |
| | | if(file.exists()) {
|
| | | File[] files = file.listFiles();
|
| | | Arrays.sort(files, new CompratorByLastModified());
|
| | | if(files.length>=filecount && filecount>0) {
|
| | | if(files.length>filecount && filecount>0) {
|
| | | //System.out.println("文件夹个数:"+files.length + "\t 最大笔数:"+filecount);
|
| | | for(int i=(filecount-1);i<files.length;i++) {
|
| | | for(int i=filecount;i<files.length;i++) {
|
| | | deleteDir(files[i]);
|
| | | }
|
| | | }
|
| | |
| | | DeleteRegularThread deletethread = server.createDeleteRegularThreadStructure();
|
| | | deletethread.start(); //启动删除多余备份数据库线程
|
| | |
|
| | | SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
| | | |
| | | System.out.println("MySql BackUpThread Start at "+sdf.format(new Date()));
|
| | | while(true) {
|
| | | Socket s = serveracept.accept();
|
| | | //System.out.println("监听到客户端连接");
|
| | | server = new HzipServer(s);
|
| | | server.start();
|
| | | try {
|
| | | Socket s = serveracept.accept();
|
| | | //System.out.println("监听到客户端连接");
|
| | | server = new HzipServer(s);
|
| | | server.start();
|
| | | } catch (Exception e) {
|
| | | e.printStackTrace();
|
| | | }
|
| | | }
|
| | |
|
| | |
|