From 5883ed93d759e6eb23d736a0929a84ca0cad5a3c Mon Sep 17 00:00:00 2001 From: GaoShen Date: Thu, 8 May 2014 15:08:55 +0800 Subject: [PATCH] Update JsonFilePipeline.java MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit JsonFilePipeline可以自动新建尚不存在的文件夹 --- .../java/us/codecraft/webmagic/pipeline/JsonFilePipeline.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/webmagic-extension/src/main/java/us/codecraft/webmagic/pipeline/JsonFilePipeline.java b/webmagic-extension/src/main/java/us/codecraft/webmagic/pipeline/JsonFilePipeline.java index b6c55afc..256e430e 100644 --- a/webmagic-extension/src/main/java/us/codecraft/webmagic/pipeline/JsonFilePipeline.java +++ b/webmagic-extension/src/main/java/us/codecraft/webmagic/pipeline/JsonFilePipeline.java @@ -38,7 +38,7 @@ public class JsonFilePipeline extends FilePersistentBase implements Pipeline { public void process(ResultItems resultItems, Task task) { String path = this.path + "/" + task.getUUID() + "/"; try { - PrintWriter printWriter = new PrintWriter(new FileWriter(new File(path + DigestUtils.md5Hex(resultItems.getRequest().getUrl()) + ".json"))); + PrintWriter printWriter = new PrintWriter(new FileWriter(getFile(path + DigestUtils.md5Hex(resultItems.getRequest().getUrl()) + ".json"))); printWriter.write(JSON.toJSONString(resultItems.getAll())); printWriter.close(); } catch (IOException e) {