Java 类org.apache.commons.io.FileDeleteStrategy 实例源码

@Override
public void validate(String name, String value) throws ParameterException {
    File file = new File(value);
    ParameterException exception = new ParameterException("File " + file.getAbsolutePath() + " does not exist and cannot be created.");
    try {

        if (!file.exists()) {
            boolean canCreate = file.createNewFile();
            if (canCreate) {
                FileDeleteStrategy.FORCE.delete(file);
            } else {
                throw exception;
            }

        }
    } catch (IOException exc) {
        throw exception;
    }

}

@Override
public void validate(String name, String value) throws ParameterException {
    File file = new File(value);
    ParameterException exception = new ParameterException("File " + file.getAbsolutePath() + " does not exist and cannot be created.");
    try {

        if (!file.exists()) {
            boolean canCreate = file.createNewFile();
            if (canCreate) {
                FileDeleteStrategy.FORCE.delete(file);
            } else {
                throw exception;
            }

        }
    } catch (IOException exc) {
        throw exception;
    }

}

/**
 * Deletes the folder of the world
 */
public void deleteArena() {
    if (Bukkit.getServer().unloadWorld(fileName, false)) {
        try {
            FileDeleteStrategy.FORCE.delete(new File(fileName));
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

private void prepareEnvironment() throws IOException {
    if (Files.exists(Paths.get("data"))) {
        FileDeleteStrategy.FORCE.delete(new File("data"));
    }

    Files.createDirectory(Paths.get("data"));
}

private void extractResourcesFromJarFile() throws Exception {
    String classUrl = Main.class.getResource("Main.class").toString();

    URL url = Main.class.getResource("/resources.zip");
    //System.out.println("JAR Resource Zip URL: " + url.toString());
    InputStream inputStream = url.openStream();


    if (config.serverMode) {
        newResourceZip = config.serverInitialResourceZip;
        newResourceFolder = Paths.get("data", "resources").toFile();
    } else {
        newResourceZip = Paths.get(config.outputDirectory, "webresume-resources.zip").toFile();
        newResourceFolder = Paths.get(config.outputDirectory, config.resourceDirectory).toFile();
    }

    if (!newResourceFolder.exists()) {
        newResourceFolder.mkdirs();
    }

    if (newResourceZip.exists()) {
        FileDeleteStrategy.FORCE.delete(newResourceZip);
    }

    Files.copy(inputStream, newResourceZip.toPath());

    ZipFile zipFile = new ZipFile(newResourceZip);
    zipFile.extractAll(newResourceFolder.getAbsolutePath());
}

@Override
public boolean execute(String[] args)
{
    instance.getLogger().info("Checking servers...");
    File[] files = this.instance.getServerFolder().listFiles();
    for(File file : files)
    {
        String name = file.getName();

        MinecraftServerC serverC = instance.getServerManager().getServerByName(name);
        if(serverC == null)
        {
            instance.getConnectionManager().sendPacket(new MinecraftServerUpdatePacket(instance, name, MinecraftServerUpdatePacket.UType.END));
            instance.getLogger().info("Server: " + name + " not found. Sending shutdown to hydro.");
            try{
                FileDeleteStrategy.FORCE.delete(file);
                instance.getLogger().info("Deleted folder!");
            }catch(Exception e)
            {
                e.printStackTrace();
                instance.getLogger().info("Can't delete folder!");
            }
        }
    }
    instance.getLogger().info("Check done !");
    return true;
}

public MinecraftServerC(HydroangeasClient instance,
                        MinecraftServerSyncPacket serverInfos,
                        int port)
{
    super(serverInfos.getMinecraftUUID(),
            serverInfos.getGame(),
            serverInfos.getMap(),
            serverInfos.getMinSlot(),
            serverInfos.getMaxSlot(),
            serverInfos.getOptions(),
            serverInfos.getStartupOptions()
            );
    this.instance = instance;

    this.coupaingServer = serverInfos.isCoupaingServer();

    this.hubID = serverInfos.getHubID();

    this.templateID = serverInfos.getTemplateID();

    this.timeToLive = serverInfos.getTimeToLive();

    this.serverFolder = new File(this.instance.getServerFolder(), serverInfos.getServerName());
    try
    {
        FileDeleteStrategy.FORCE.delete(serverFolder);
        FileUtils.forceDeleteOnExit(serverFolder);
    } catch (IOException e)
    {
        getLogger().warning(serverFolder + " will not be able to be deleted during JVM shutdown!");
    }
    this.port = port;

    this.weight = serverInfos.getWeight();
}

public boolean stopServer()
{
    try
    {
        try{
            if (remoteControl != null)
                remoteControl.disconnect();
        }catch (Exception ignored)
        {

        }

        instance.getServerManager().onServerStop(this);
        Hydroangeas.getInstance().getAsClient().getLogManager().saveLog(getServerName(), getTemplateID());
        container.removeContainer();

    } catch (Exception e)
    {
        this.instance.log(Level.SEVERE, "Can't stop the server " + getServerName() + "!");
        e.printStackTrace();
        return false;
    }finally {
        try
        {
            FileDeleteStrategy.FORCE.delete(serverFolder);
            FileUtils.forceDelete(serverFolder);
        } catch (IOException e1)
        {
        }
    }
    return true;
}

private void prepareEnvironment() throws IOException {
    if (Files.exists(Paths.get("data"))) {
        FileDeleteStrategy.FORCE.delete(new File("data"));
    }

    Files.createDirectory(Paths.get("data"));
}

private void extractResourcesFromJarFile() throws Exception {
    String classUrl = Main.class.getResource("Main.class").toString();

    URL url = Main.class.getResource("/resources.zip");
    //System.out.println("JAR Resource Zip URL: " + url.toString());
    InputStream inputStream = url.openStream();


    if (config.serverMode) {
        newResourceZip = config.serverInitialResourceZip;
        newResourceFolder = Paths.get("data", "resources").toFile();
    } else {
        newResourceZip = Paths.get(config.outputDirectory, "webresume-resources.zip").toFile();
        newResourceFolder = Paths.get(config.outputDirectory, config.resourceDirectory).toFile();
    }

    if (!newResourceFolder.exists()) {
        newResourceFolder.mkdirs();
    }

    if (newResourceZip.exists()) {
        FileDeleteStrategy.FORCE.delete(newResourceZip);
    }

    Files.copy(inputStream, newResourceZip.toPath());

    ZipFile zipFile = new ZipFile(newResourceZip);
    zipFile.extractAll(newResourceFolder.getAbsolutePath());
}

private void clearProjectBuildDirectory(File buildDirectory) throws IOException {
    for(File file : buildDirectory.listFiles()){
        if(file.isDirectory()){
            File directory = file;
            clearProjectBuildDirectory(directory);
            directory.delete();
        } else {
            FileDeleteStrategy.FORCE.delete(file);
        }
    }
}

private File createAndTrackTempFile(FormItem item) throws IOException {
    if (tmpPathForRequest == null) {
        if (Files.notExists(tempRepoPath)) {
            Files.createDirectory(tempRepoPath);
        }
        tmpPathForRequest = Files.createTempDirectory(tempRepoPath, "tmp");
    }
    Path path = Paths.get(tmpPathForRequest.toString(), item.getName());
    File file = path.toFile();
    StreamUtil.copy(item.openStream(), new FileOutputStream(file), true);
    fileCleaningTracker.track(file, file);
    fileCleaningTracker.track(tmpPathForRequest.toFile(), file, FileDeleteStrategy.FORCE);
    return file;
}

/**
    * It deletes the folder whose path is given by the argument folderPath.
    * It deletes each folder forcefully even if it contains files underneath it.
    * 
    *
    * @param folderPath the folder path
    */
public void delete(String folderPath) {
    FileDeleteStrategy file = FileDeleteStrategy.FORCE;
    try {

        file.delete(new File(folderPath));
    } catch (Exception fileDeleteException) {
        logger.severe(StackTrace.asString(fileDeleteException));
    }

}

@Override
public void deleteTemplate(String fileName) {
    FileDeleteStrategy file = FileDeleteStrategy.FORCE;
    try{
        file.delete(new File( pathToTemplate + fileName.toString() + ".xml")); 
    } catch(IOException fileDeleteException){
        fileDeleteException.printStackTrace();
        throw new RuntimeException("Cannot delete template!");
    }    
}

/**
 * 
 * @param firefoxProfile 
 */
public void shutdownFirefoxProfile(FirefoxProfile firefoxProfile) {
    try {
        if (deleteProfileData) {
            FileDeleteStrategy.FORCE.delete(new File(netExportPathMap.get(firefoxProfile)));
        }
    } catch (IOException ex) {
        Logger.getLogger(this.getClass()).error(ex);
    }
    netExportPathMap.remove(firefoxProfile);
}

public void cleanup()
{
    try
    {
        FileDeleteStrategy.FORCE.delete(config.getDbStorageDirectory());
    }
    catch (IOException e)
    {
        logger.fatal("Unable to clean up db storage directory: " + e.getMessage());
        System.exit(1);
    }
}

@Override
protected void tearDown() throws Exception {
    super.tearDown();
    try {
        store.close();
        environment.close();
    } finally {
        FileDeleteStrategy.FORCE.delete(tempDir);
    }
}

@Override
protected void tearDown() throws Exception {
    super.tearDown();
    try {
        if(bdbStorage != null)
            bdbStorage.close();
    } finally {
        FileDeleteStrategy.FORCE.delete(bdbMasterDir);
    }
}

@Override
protected void setUp() throws Exception {
    super.setUp();

    bdbMasterDir = TestUtils.createTempDir();
    FileDeleteStrategy.FORCE.delete(bdbMasterDir);
}

@Override
protected void tearDown() throws Exception {
    super.tearDown();
    try {
        if(bdbStorage != null)
            bdbStorage.close();
    } finally {
        FileDeleteStrategy.FORCE.delete(bdbMasterDir);
    }
}

public boolean startServer()
{
    try
    {
        JsonObject startupOptionsObj = startupOptions.getAsJsonObject();
        String maxRAM = startupOptionsObj.get("maxRAM").getAsString();

        container = new DockerContainer(
                getServerName(),
                serverFolder,
                port,
                new String[]{"/usr/bin/java",
                        //"-Duser.dir " + serverFolder.getAbsolutePath(),
                        "-Xmx" + maxRAM,
                        "-Xms" + startupOptionsObj.get("minRAM").getAsString(),
                        "-Xmn" + startupOptionsObj.get("edenRAM").getAsString(),
                        "-XX:+UseG1GC",
                        "-XX:+UnlockExperimentalVMOptions",
                        "-XX:MaxGCPauseMillis=50",
                        "-XX:+DisableExplicitGC",
                        "-XX:G1HeapRegionSize=4M",
                        "-XX:TargetSurvivorRatio=90",
                        "-XX:G1NewSizePercent=50",
                        "-XX:G1MaxNewSizePercent=80",
                        "-XX:InitiatingHeapOccupancyPercent=10",
                        "-XX:G1MixedGCLiveThresholdPercent=50",
                        "-XX:+AggressiveOpts",
                        "-XX:+UseLargePagesInMetaspace",
                        "-Djava.net.preferIPv4Stack=true",
                        "-Dcom.sun.management.jmxremote",
                        "-Dcom.sun.management.jmxremote.port=" + (getPort()+1),
                        "-Dcom.sun.management.jmxremote.local.only=false",
                        "-Dcom.sun.management.jmxremote.authenticate=false",
                        "-Dcom.sun.management.jmxremote.ssl=false",
                        "-jar", serverFolder.getAbsolutePath()+"/spigot.jar", "nogui"},
                maxRAM
        );
        Hydroangeas.getLogger().info(container.createContainer());

        getLogger().info("Starting server " + getServerName());

        remoteControl = new RemoteControl(this, "blackmesa", (getPort()+1));
    } catch (Exception e)
    {
        this.instance.log(Level.SEVERE, "Can't start the server " + getServerName() + "!");
        e.printStackTrace();
        try
        {
            FileDeleteStrategy.FORCE.delete(serverFolder);
            FileUtils.forceDelete(serverFolder);
        } catch (IOException e1)
        {
        }

        return false;
    }

    return true;
}

@After
public void after() throws IOException {
    FileDeleteStrategy.FORCE.delete(tempLocation);
}

/**
 * Removes all files in the test generation directory.
 * 
 * @throws IOException
 */
private static void deleteGen() throws IOException {
    for (File file : generationDirectory.listFiles()) {
        FileDeleteStrategy.FORCE.delete(file);
    }
}

@Override
protected void setUp() throws Exception {
    super.setUp();
    bdbMasterDir = TestUtils.createTempDir();
    FileDeleteStrategy.FORCE.delete(bdbMasterDir);
}

@Override
public void setUp() throws Exception {
    super.setUp();
    if(null != tempDir && tempDir.exists())
        FileDeleteStrategy.FORCE.delete(tempDir);
}

@Override
public void tearDown() throws Exception {
    super.tearDown();
    if(null != tempDir && tempDir.exists())
        FileDeleteStrategy.FORCE.delete(tempDir);
}

/**
 * It deletes each file from the system. specification of an rule to be
 * deleted is given by argument path and filename respectively to identify
 * each rule before deleting it.
 * 
 * Precondition: Rule file must exists on the System. Postcondition: Rule
 * file does not in the System any more. Invariant: System remains in the
 * consistent change.
 * 
 * It deletes each file forcefully from the System just to avoid exceptions
 * that generates if file is being used by another programs.
 * 
 * @param path
 *            the path
 * @param fileName
 *            the file name
 */
public void delete(String path, UUID fileName) {
    FileDeleteStrategy file = FileDeleteStrategy.FORCE;
    try {
        file.delete(new File(path + "/" + fileName.toString()
                + FILE_EXTENSION));
    } catch (Exception fileDeleteException) {
        logger.severe(StackTrace.asString(fileDeleteException));
        ;
    }
}

/**
 * It deletes each file from the system. specification of an meeting to be
 * deleted is given by argument path and filename respectively to identify
 * each meeting before deleting it.
 * 
 * It deletes each file forcefully from the System just to avoid exceptions
 * that generates if file is being used by another programs.
 *
 * @param path the path
 * @param fileName the file name
 */
public void delete(String path, UUID fileName) {
    FileDeleteStrategy file = FileDeleteStrategy.FORCE;
    try {
        file.delete(new File(path + "/" + fileName.toString()
                + FILE_EXTENSION));
    } catch (Exception fileDeleteException) {
        logger.severe(StackTrace.asString(fileDeleteException));
    }
}

/**
 * It deletes each file from the system.
 * specification of an email to be deleted is given by
 * argument path and filename respectively to identify each email before deleting it.
 *  
 * It deletes each file forcefully from the System just to avoid exceptions that generates if file
 * is being used by another programs.
 * 
 * @param path the path
 * @param fileName the file name
 */
public void delete(String path, UUID fileName){
      FileDeleteStrategy file = FileDeleteStrategy.FORCE;
      try{
       file.delete(new File(path+"/"+fileName.toString()+FILE_EXTENSION));
      }catch(Exception fileDeleteException){
       logger.severe(StackTrace.asString(fileDeleteException));;
      }             
}