whyclj
2019-02-18 9f91e8f854444c02c66264a2780c0ca638659c4e
服务器启动打印以及备份打印时间
1个文件已修改
23 ■■■■ 已修改文件
DataBase_Bakeup_SocketServer/src/com/main/HzipServer.java 23 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
DataBase_Bakeup_SocketServer/src/com/main/HzipServer.java
@@ -8,8 +8,10 @@
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;
@@ -108,6 +110,8 @@
                }
            }
            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();
@@ -183,9 +187,9 @@
            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]);
                    }
                }
@@ -216,11 +220,18 @@
            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();
                }
            }