问题描述
我想创建一个 Spring Boot 控制器,它使用来自流的数据创建一个 CSV 文件。我使用 Jackson CSV (jackson-dataformat-csv 2.12.1) 将数据流从数据库写入 streamingresponsebody。
为了简单起见,我用包含 1,2,3
的列表替换了来自数据库的实际数据。我想要一个看起来像这样的 CSV 文件:
1
2
3
但它只包含第一个条目 (1
)。有人可以帮我找出问题所在吗?
请注意,我不想在服务器上的某处创建文件,我想将内容直接流式传输给用户。
我的代码如下:
import com.fasterxml.jackson.dataformat.csv.CsvMapper
import org.springframework.http.MediaType
import org.springframework.http.ResponseEntity
import org.springframework.web.bind.annotation.GetMapping
import org.springframework.web.bind.annotation.RequestMapping
import org.springframework.web.bind.annotation.RestController
import org.springframework.web.servlet.mvc.method.annotation.streamingresponsebody
import javax.servlet.http.HttpServletResponse
@RestController
@RequestMapping(value = ["/test"],produces = [MediaType.TEXT_HTML_VALUE])
class TestController {
@GetMapping("/download",produces = [MediaType.TEXT_EVENT_STREAM_VALUE])
fun download(response: HttpServletResponse): ResponseEntity<streamingresponsebody>? {
response.setHeader("Content-disposition","attachment;filename=download.csv")
response.status = HttpServletResponse.SC_OK
val mapper = CsvMapper()
val schema = mapper.schemaFor(Int::class.java)
val writer = mapper.writer(schema)
val input = listof(1,3).stream()
val stream = streamingresponsebody { outputStream ->
input.forEach { entity ->
writer.writeValue(outputStream,entity)
}
}
return ResponseEntity
.ok()
.header("Content-disposition","attachment;filename=download.csv")
.body(stream)
}
}
解决方法
在 Andriy 评论的帮助下,我找到了原因和解决方案。 Jackson 在完成写入后关闭流,请参阅:ObjectMapper._writeValueAndClose。
要更改此行为,您必须像这样将 JsonGenerator.Feature.AUTO_CLOSE_TARGET
设置为 false:
val jsonFactory = CsvFactory().configure(JsonGenerator.Feature.AUTO_CLOSE_TARGET,false)
val mapper = ObjectMapper(jsonFactory)
val writer = mapper.writer(CsvMapper().schemaFor(Int::class.java))
注意:AUTO_CLOSE_TARGET
没有 CsvGenerator
选项,但使用 JsonGenerator
设置也适用于 CsvFactory
。
在您的代码中写入流时没有看到指定的列格式化程序。您可以尝试以下操作吗:-
CsvMapper mapper = new CsvMapper();
CsvSchema schema = mapper.schemaFor(Dymmy.class);
schema = schema.withColumnSeparator('\t');