Spring Boot 与 Kotlin 上传文件的示例代码
作者:quanke 发布时间:2022-08-24 10:24:08
标签:Spring,Boot,Kotlin,上传
如果我们做一个小型的web站,而且刚好选择的kotlin 和Spring Boot技术栈,那么上传文件的必不可少了,当然,如果你做一个中大型的web站,那建议你使用云存储,能省不少事情。
构建工程
如果对于构建工程还不是很熟悉的可以参考《我的第一个Kotlin应用》
完整 build.gradle 文件
group 'name.quanke.kotlin'
version '1.0-SNAPSHOT'
buildscript {
ext.kotlin_version = '1.2.10'
ext.spring_boot_version = '1.5.4.RELEASE'
repositories {
mavenCentral()
}
dependencies {
classpath "org.jetbrains.kotlin:kotlin-gradle-plugin:$kotlin_version"
classpath("org.springframework.boot:spring-boot-gradle-plugin:$spring_boot_version")
// Kotlin整合SpringBoot的默认无参构造函数,默认把所有的类设置open类插件
classpath("org.jetbrains.kotlin:kotlin-noarg:$kotlin_version")
classpath("org.jetbrains.kotlin:kotlin-allopen:$kotlin_version")
}
}
apply plugin: 'kotlin'
apply plugin: "kotlin-spring" // See https://kotlinlang.org/docs/reference/compiler-plugins.html#kotlin-spring-compiler-plugin
apply plugin: 'org.springframework.boot'
jar {
baseName = 'chapter11-5-6-service'
version = '0.1.0'
}
repositories {
mavenCentral()
}
dependencies {
compile "org.jetbrains.kotlin:kotlin-stdlib-jre8:$kotlin_version"
compile "org.springframework.boot:spring-boot-starter-web:$spring_boot_version"
compile "org.springframework.boot:spring-boot-starter-thymeleaf:$spring_boot_version"
testCompile "org.springframework.boot:spring-boot-starter-test:$spring_boot_version"
testCompile "org.jetbrains.kotlin:kotlin-test-junit:$kotlin_version"
}
compileKotlin {
kotlinOptions.jvmTarget = "1.8"
}
compileTestKotlin {
kotlinOptions.jvmTarget = "1.8"
}
创建文件上传controller
import name.quanke.kotlin.chaper11_5_6.storage.StorageFileNotFoundException
import name.quanke.kotlin.chaper11_5_6.storage.StorageService
import org.springframework.beans.factory.annotation.Autowired
import org.springframework.core.io.Resource
import org.springframework.http.HttpHeaders
import org.springframework.http.ResponseEntity
import org.springframework.stereotype.Controller
import org.springframework.ui.Model
import org.springframework.web.bind.annotation.*
import org.springframework.web.multipart.MultipartFile
import org.springframework.web.servlet.mvc.method.annotation.MvcUriComponentsBuilder
import org.springframework.web.servlet.mvc.support.RedirectAttributes
import java.io.IOException
import java.util.stream.Collectors
/**
* 文件上传控制器
* Created by http://quanke.name on 2018/1/12.
*/
@Controller
class FileUploadController @Autowired
constructor(private val storageService: StorageService) {
@GetMapping("/")
@Throws(IOException::class)
fun listUploadedFiles(model: Model): String {
model.addAttribute("files", storageService
.loadAll()
.map { path ->
MvcUriComponentsBuilder
.fromMethodName(FileUploadController::class.java, "serveFile", path.fileName.toString())
.build().toString()
}
.collect(Collectors.toList()))
return "uploadForm"
}
@GetMapping("/files/{filename:.+}")
@ResponseBody
fun serveFile(@PathVariable filename: String): ResponseEntity<Resource> {
val file = storageService.loadAsResource(filename)
return ResponseEntity
.ok()
.header(HttpHeaders.CONTENT_DISPOSITION, "attachment; filename=\"" + file.filename + "\"")
.body(file)
}
@PostMapping("/")
fun handleFileUpload(@RequestParam("file") file: MultipartFile,
redirectAttributes: RedirectAttributes): String {
storageService.store(file)
redirectAttributes.addFlashAttribute("message",
"You successfully uploaded " + file.originalFilename + "!")
return "redirect:/"
}
@ExceptionHandler(StorageFileNotFoundException::class)
fun handleStorageFileNotFound(exc: StorageFileNotFoundException): ResponseEntity<*> {
return ResponseEntity.notFound().build<Any>()
}
}
上传文件服务的接口
import org.springframework.core.io.Resource
import org.springframework.web.multipart.MultipartFile
import java.nio.file.Path
import java.util.stream.Stream
interface StorageService {
fun init()
fun store(file: MultipartFile)
fun loadAll(): Stream<Path>
fun load(filename: String): Path
fun loadAsResource(filename: String): Resource
fun deleteAll()
}
上传文件服务
import org.springframework.beans.factory.annotation.Autowired
import org.springframework.core.io.Resource
import org.springframework.core.io.UrlResource
import org.springframework.stereotype.Service
import org.springframework.util.FileSystemUtils
import org.springframework.util.StringUtils
import org.springframework.web.multipart.MultipartFile
import java.io.IOException
import java.net.MalformedURLException
import java.nio.file.Files
import java.nio.file.Path
import java.nio.file.Paths
import java.nio.file.StandardCopyOption
import java.util.stream.Stream
@Service
class FileSystemStorageService @Autowired
constructor(properties: StorageProperties) : StorageService {
private val rootLocation: Path
init {
this.rootLocation = Paths.get(properties.location)
}
override fun store(file: MultipartFile) {
val filename = StringUtils.cleanPath(file.originalFilename)
try {
if (file.isEmpty) {
throw StorageException("Failed to store empty file " + filename)
}
if (filename.contains("..")) {
// This is a security check
throw StorageException(
"Cannot store file with relative path outside current directory " + filename)
}
Files.copy(file.inputStream, this.rootLocation.resolve(filename),
StandardCopyOption.REPLACE_EXISTING)
} catch (e: IOException) {
throw StorageException("Failed to store file " + filename, e)
}
}
override fun loadAll(): Stream<Path> {
try {
return Files.walk(this.rootLocation, 1)
.filter { path -> path != this.rootLocation }
.map { path -> this.rootLocation.relativize(path) }
} catch (e: IOException) {
throw StorageException("Failed to read stored files", e)
}
}
override fun load(filename: String): Path {
return rootLocation.resolve(filename)
}
override fun loadAsResource(filename: String): Resource {
try {
val file = load(filename)
val resource = UrlResource(file.toUri())
return if (resource.exists() || resource.isReadable) {
resource
} else {
throw StorageFileNotFoundException(
"Could not read file: " + filename)
}
} catch (e: MalformedURLException) {
throw StorageFileNotFoundException("Could not read file: " + filename, e)
}
}
override fun deleteAll() {
FileSystemUtils.deleteRecursively(rootLocation.toFile())
}
override fun init() {
try {
Files.createDirectories(rootLocation)
} catch (e: IOException) {
throw StorageException("Could not initialize storage", e)
}
}
}
自定义异常
open class StorageException : RuntimeException {
constructor(message: String) : super(message)
constructor(message: String, cause: Throwable) : super(message, cause)
}
class StorageFileNotFoundException : StorageException {
constructor(message: String) : super(message)
constructor(message: String, cause: Throwable) : super(message, cause)
}
配置文件上传目录
import org.springframework.boot.context.properties.ConfigurationProperties
@ConfigurationProperties("storage")
class StorageProperties {
/**
* Folder location for storing files
*/
var location = "upload-dir"
}
启动Spring Boot
/**
* Created by http://quanke.name on 2018/1/9.
*/
@SpringBootApplication
@EnableConfigurationProperties(StorageProperties::class)
class Application {
@Bean
internal fun init(storageService: StorageService) = CommandLineRunner {
storageService.deleteAll()
storageService.init()
}
companion object {
@Throws(Exception::class)
@JvmStatic
fun main(args: Array<String>) {
SpringApplication.run(Application::class.java, *args)
}
}
}
创建一个简单的 html模板 src/main/resources/templates/uploadForm.html
<html xmlns:th="http://www.thymeleaf.org">
<body>
<div th:if="${message}">
<h2 th:text="${message}"/>
</div>
<div>
<form method="POST" enctype="multipart/form-data" action="/">
<table>
<tr>
<td>File to upload:</td>
<td><input type="file" name="file"/></td>
</tr>
<tr>
<td></td>
<td><input type="submit" value="Upload"/></td>
</tr>
</table>
</form>
</div>
<div>
<ul>
<li th:each="file : ${files}">
<a th:href="${file}" rel="external nofollow" th:text="${file}"/>
</li>
</ul>
</div>
</body>
</html>
配置文件 application.yml
spring:
http:
multipart:
max-file-size: 128KB
max-request-size: 128KB
更多Spring Boot 和 kotlin相关内容,欢迎关注 《Spring Boot 与 kotlin 实战》
源码:
https://github.com/quanke/spring-boot-with-kotlin-in-action/
参考:
https://spring.io/guides/gs/uploading-files/
来源:https://www.jianshu.com/p/d4952e71360b
0
投稿
猜你喜欢
- @RequestBody的作用@RequestBody主要用来接收前端传递给后端的json字符串中的数据的(请求体中的数据的),所以只能发送
- 背景使用flowable自带的flowable-ui制作流程图使用springboot开发流程使用的接口完成流程的业务功能一、flowabl
- 工厂方法模式(Factory Method):定义一个用于创建对象的接口,让子类决定实例化哪一个类。工厂方法使一个类的实例化延迟到其子类。工
- Gson是一个Java库,用来实现Json和Java对象之间的相互转换。Gson是一个托管在https://github.com/googl
- 项目中用到用户定义运算公式进行就算的需求,这样需要进行字符串四则运算解析,下面提供字符串公式四则运算解析与计算工具类,需要的同学可参考。工具
- 有时候我们需要在一个ArrayList的for循环中动态删除元素的需求, 废话不多说看代码List<Integer> list
- 本文实例讲述了C#多线程学习之生产者和消费者用法。分享给大家供大家参考。具体实分析如下:前面的文章说过,每个线程都有自己的资源,但是代码区是
- Spring Boot1.为什么要使用 Spring Boot因为Spring, SpringMVC 需要使用的大量的配置文件 (xml文件
- SpringBoot的web项目,在每一次修改了java文件或者是resource的时候,都必须去重启一下项目,这样的话浪费了很多的时间,实
- 代码import javax.mail.internet.InternetAddress;import javax.mail.interne
- Spring Security支持在响应中添加各种安全头默认相应安全头:Cache-Control: no-cache, no-store,
- //构造文件File类File f=new File(fileName);//判断是否为目录f.isDirectory();//获取目录下的
- JDK 1.5开始提供ScheduledThreadPoolExecutor类,ScheduledThreadPoolExecutor类继承
- 背景:Spring Boot是由Pivotal团队提供的全新框架,其设计目的是用来简化新Spring应用的初始搭建以及开发过程。该框架使用了
- 测试参数设置:1、循环调用new A()实现堆溢出,java.lang.OutOfMemoryError: Java heap space,
- 今天遇到pom中添加dependency时相关的jar会自动下载,但是左边的External Libraries中一直获取不到添加的jar问
- 1、static是什么意思?static 关键字表明一个成员变量或者是成员方法可以在没有所属的类的实例变量的情况下被访问。例如Main类pa
- Spring整合mybatis的mapper生成过程mapperScannerConfigurer实现了BeandifinitionRegi
- 一、项目简述功能: 前后用户的登录注册,婚纱照片分类,查看,摄影师预 订,后台订单管理,图片管理等等。二、项目运行环境配置: Jdk1.8
- 1 请求映射 在SpringBoot中使用@XxxMapping注解完成前端请求与后端方法的一个映射。以前的时候,通常使用url映射命名的