1、Config
package com.lianlife.sync;
import java.text.SimpleDateFormat;
import java.util.Date;
public class Config {
public static final String ftpPath="/PIftp/Yzps/ps001/ps";
//public static final String ftpPath="/PIftp/test01/ps";
public static final String c1 = "17:30:00";
public static final  String c2 = "17:29:00";
public static final String ftpIP = "10.20.28.138";
public static final int ftpPort = 21;
public static final String ftpuser = "ftpuser";
public static final String ftpassword = "ftpuser";
//public static String localDirPath="H:\\yx1\\yq\\ps20150309";
public static String localDirPath="I:\\影像2\\ps2015030923";
public static String date = "20040901";
public static String date2 = "20150926";
public static final String url = "jdbc:mysql://10.20.28.138:3306/mysql";
public static final String driver = "com.mysql.jdbc.Driver";
public static final String user = "root";
public static final String password = "123";
public static boolean isUploadTimePeriod()
{
SimpleDateFormat df = new SimpleDateFormat("HH:mm:ss");
String timenow = df.format(new Date());
if (timenow.compareTo(Config.c1) > 0
|| timenow.compareTo(Config.c2) < 0){
return true;
}
return false ;
}
}
2、DbUtil
package com.lianlife.sync;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
public class DbUtil {
public static Connection getConnection()
{
try {
Class.forName(Config.driver);//指定连接类型
} catch (Throwable e) {
throw new RuntimeException(e);
}
try {
return DriverManager.getConnection(Config.url, Config.user, Config.password);//获取连接
} catch (Throwable e) {
e.printStackTrace();
try {
return DriverManager.getConnection(Config.url, Config.user, Config.password);//获取连接
} catch (Throwable e2) {
e2.printStackTrace();
try {
return DriverManager.getConnection(Config.url, Config.user, Config.password);//获取连接
} catch (Throwable e3) {
throw new RuntimeException(e3);
}
}
}
}
public static  void close(Connection c)
{
if(c!=null)
{
try {
c.close();
} catch (Throwable e) {
e.printStackTrace();
}
}
}
public static  void close(PreparedStatement c)
{
if(c!=null)
{
try {
c.close();
} catch (Throwable e) {
e.printStackTrace();
}
}
}
public static  void close(ResultSet c)
{
if(c!=null)
{
try {
c.close();
} catch (Throwable e) {
e.printStackTrace();
}
}
}
}
3、
原文：http://liu16.blog.51cto.com/6494747/1720718

1 存文件到本地指定路径
public static void mywrite(String str){

File file = new File(str);    //1、建立连接

OutputStream os = null;

try {

//2、选择输出流,以追加形式(在原有内容上追加) 写出文件 必须为true 否则为覆盖

os = new FileOutputStream(file,true);

//            //和上一句功能一样，BufferedInputStream是增强流，加上之后能提高输出效率，建议

//            os = new BufferedOutputStream(new FileOutputStream(file,true));

String string = “Programmer say : Hello World!”;

byte[] data = string.getBytes();    //将字符串转换为字节数组,方便下面写入
        os.write(data, 0, data.length);    //3、写入文件
        os.flush();    //将存储在管道中的数据强制刷新出去
    } catch (FileNotFoundException e) {
        e.printStackTrace();
        System.out.println("文件没有找到！");
    } catch (IOException e) {
        e.printStackTrace();
        System.out.println("写入文件失败！");
    }finally {
        if (os != null) {
            try {
                os.close();
            } catch (IOException e) {
                e.printStackTrace();
                System.out.println("关闭输出流失败！");
            }
        }
    }
}

public static void main(String[] args) {

mywrite(“F:/Tool/nginx/nginx-1.12.2/html/hello/1.txt”);
}

本地成功的创建了1.txt文件
2 取到本地的文件内容
File file = new File(“F:/Tool/nginx/nginx-1.12.2/html/hello/1.txt”);

StringBuilder localStrBulider = new StringBuilder();

if (file.isFile() && file.exists()) {

try {

InputStreamReader inputStreamReader = new InputStreamReader(new FileInputStream(file), “utf-8”);

BufferedReader bufferReader = new BufferedReader(inputStreamReader);

String lineStr = null;

try {

while ((lineStr = bufferReader.readLine()) != null) {

localStrBulider.append(lineStr);

}

bufferReader.close();

inputStreamReader.close();

} catch (IOException e) {

// TODO Auto-generated catch block

System.out.println(“file read error!”);

e.printStackTrace();

}

} catch (UnsupportedEncodingException e) {

// TODO Auto-generated catch block

System.out.println(“file catch unsupported encoding!”);

e.printStackTrace();

} catch (FileNotFoundException e) {

// TODO Auto-generated catch block

System.out.println(“file not found!”);

e.printStackTrace();

}

} else {

System.out.println(“file is not a file or file is not existing!”);

return null;

}

System.out.println(“localStrBulider.toString():” + localStrBulider.toString());



读取成功！

一、概述

调用第一个接口时，先将多张图片存到本地；再调用第二个接口，将图片统一上传到图片服务器上。

二、应用场景

根据类别，上传多张图片



三、代码实现

1、controller层

@ApiOperation("临时上传图片")
    @PostMapping("/img/temp")
    public JsonResult uploadFileBufferToLocal(@NotNull @RequestParam @ApiParam("图片所属种类)") String photoType,
                                      @NotNull @Image @ApiParam("不超过10M,请上传jpg和png文件") MultipartFile file) {
        return service.uploadFileBufferToLocal(photoType, file);
    }

 @ApiOperation("上传照片")
    @PostMapping("/upload")
    public JsonResult upload(@NotNull @RequestParam @ApiParam("图片类别") Integer type) {
        return service.upload(type);
    }

2、serviceImpl层

缓存到本地的功能实现

public JsonResult uploadFileBufferToLocal(String photoType, MultipartFile file) {
        //将文件缓存到本地
        MultipartFile localFile = createLocalFile(photoType, file);
        if (localFile == null) {
            log.error("Create local file failed!");
            return JsonResult.faild("Create local file failed!");
        }
        log.info("Create local file successfully");
        return JsonResult.success("Create local file successfully");
    }

    /**
     * 通过上传的文件名，缓冲到本地，后面才能解压、验证
     *
     * @param photoType 图片类型
     * @param file
     */
    public MultipartFile createLocalFile(String photoType, MultipartFile file) {
        String filePath = "C:/upload/temp/";
        File localFile = new File(filePath);
        //先创建目录
        localFile.mkdirs();
        String originalFilename = file.getOriginalFilename();
        if (originalFilename.contains(",")) {
            originalFilename = originalFilename.replace(",", "");
        }
        if (originalFilename.contains(" ")) {
            originalFilename = originalFilename.replace(" ", "");
        }
        String newname = photoType + "_" + originalFilename;
        String path = filePath + "/" + newname;
        log.info("createLocalFile path = {}", path);
        localFile = new File(path);
        FileOutputStream fos = null;
        InputStream in = null;
        try {
            if (localFile.exists()) {
                //如果文件存在删除文件
                boolean delete = localFile.delete();
                if (delete == false) {
                    log.error("Delete exist file \"{}\" failed!!!", path, new Exception("Delete exist file \"" + path + "\" failed!!!"));
                }
            }
            //创建文件
            if (!localFile.exists()) {
                //如果文件不存在，则创建新的文件
                localFile.createNewFile();
                log.info("Create file successfully,the file is {}", path);
            }
            //创建文件成功后，写入内容到文件里
            fos = new FileOutputStream(localFile);
            in = file.getInputStream();
            byte[] bytes = new byte[1024];
            int len = -1;
            while ((len = in.read(bytes)) != -1) {
                fos.write(bytes, 0, len);
            }
            FileInputStream fileInputStream = new FileInputStream(localFile);
            MultipartFile multipartFile = new MockMultipartFile(localFile.getName(), localFile.getName(),
                    ContentType.APPLICATION_OCTET_STREAM.toString(), fileInputStream);
            fos.flush();
            log.info("Reading uploaded file and buffering to local successfully!");
            return multipartFile;
        } catch (FileNotFoundException e) {
            e.printStackTrace();
            return null;
        } catch (IOException e) {
            e.printStackTrace();
            return null;
        } finally {
            try {
                if (fos != null) {
                    fos.close();
                }
                if (in != null) {
                    in.close();
                }
            } catch (IOException e) {
                log.error("InputStream or OutputStream close error : {}", e);
                return null;
            }
        }
    }

上传到服务器的功能实现

public JsonResult upload(Integer type) {
        String filepath = "C:/upload/temp/";
        File localFile = new File(filepath);//File类型可以是文件也可以是文件夹
        File[] files = localFile.listFiles();//将该目录下的所有文件放置在一个File类型的数组中
        QueryWrapper<Entity> queryWrapper = new QueryWrapper<>();
        queryWrapper.eq("type", type);
        Entity entity = entityDao.selectOne(queryWrapper);
        String result = "";
        try {
            for (int i = 0; i < files.length; i++) {
                InputStream inputStream = new FileInputStream(files[i]);
                MultipartFile multipartFile = new MockMultipartFile(files[i].getName(), inputStream);
                /*处理传入文件名中的空格及逗号*/
                String originalFilename = multipartFile.getName();
                InputStreamResource isr = new InputStreamResource(multipartFile.getInputStream(),
                        originalFilename);
                Map<String, Object> params = new HashMap<>();
                params.put("file", isr);
                params.put("path", idWorkerUtil.nextId());
                params.put("output", "json");
                params.put("auth_token", fastdfsAuthCode);
                //上传图片到gofastdfs服务器
                result = HttpUtil.post(uploadUrl, params);
              
                //删除本地文件
                files[i].delete();
                entityDao.updateById(entity);
            }
        } catch (IOException e) {
            log.error("错误为=" + e.getMessage(), e);
        }
        return JsonResult.success();
    }

四、感谢

本文中的本地文件储存来源博主的这篇文章，https://blog.csdn.net/weixin_30462049/article/details/97326852，欢迎大家移驾交流学习。

该楼层疑似违规已被系统折叠 隐藏此楼查看此楼
package jiao.down;
/*
* 本类的用处是将url指定的网页打开并保存在本地的html文件
* 在生成本类的实例时构造方法传入url
* 在调用huoqu()能在服务器获取到html的源代码(不包含接收头)
* 通过baocun()将huoqu()中返回的字符串保存成本地的html文件
* */
import java.io.BufferedReader;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.io.UnsupportedEncodingException;
import java.net.HttpURLConnection;
import java.net.URL;
public class DownHtml {
String urlString;
static String name = "lalala";
//
public DownHtml(String urlString,String name) {
this.urlString = urlString;
this.name = name;
}
public String huoqu() throws Exception {
//生成一个URL对象
URL url = new URL(urlString);
//打开URL
HttpURLConnection urlConnection = (HttpURLConnection) url.openConnection();
//得到输入流，即获得了网页的内容
BufferedReader reader = new BufferedReader(new InputStreamReader(urlConnection
.getInputStream()));
String sum = "";
String line;
// 读取输入流的数据，并显示
while ((line = reader.readLine()) != null){
//  System.out.println(line);
sum = sum +line+"\n";
}
//  System.out.println(sum);
return sum;
}
public static void baocun(String date) throws IOException
{
FileWriter fw = new FileWriter(name+".html");
System.out.println("date:*****************************");
System.out.println(date);
System.out.println("date:*****************************");
fw.write(date);
System.out.println("下载成功！！");
}
}