<dependency>
<groupId>com.github.tobato</groupId>
<artifactId>fastdfs-client</artifactId>
<version>1.27.2</version>
</dependency>
fastdfs.properties
ip=192.168.211.132 port=8888
import com.github.tobato.fastdfs.domain.fdfs.StorePath; import com.github.tobato.fastdfs.service.FastFileStorageClient; import entity.Result; import entity.StatusCode; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.util.StringUtils; import org.springframework.web.bind.annotation.*; import org.springframework.web.multipart.MultipartFile; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.io.UnsupportedEncodingException; import java.util.Properties; @RestController @CrossOrigin @RequestMapping("/upload") public class FileUploadController { @Autowired private FastFileStorageClient fastFileStorageClient; private static String ip; private static String port; static { Properties properties=new Properties(); InputStream inputStream=Object.class.getResourceAsStream("/fastdfs.properties"); InputStreamReader inputStreamReader=null; try { inputStreamReader=new InputStreamReader(inputStream,"GBK"); } catch (UnsupportedEncodingException e) { e.printStackTrace(); } try { properties.load(inputStreamReader); } catch (IOException e) { e.printStackTrace(); } ip = properties.getProperty("ip"); port=properties.getProperty("port"); } /** * 文件上传 */ @PostMapping public Result upload(@RequestParam("file") MultipartFile file) throws IOException { StorePath storePath = fastFileStorageClient.uploadFile(file.getInputStream(), file.getSize(), StringUtils.getFilenameExtension(file.getOriginalFilename()), null); String storePathFullPath = storePath.getFullPath(); String url = "http://"+ip+":"+port+"/" + storePathFullPath; return new Result(true, StatusCode.OK, "上传成功", url); } }
测试