Spring Boot 功能整合的實現
如果根據之前做的 Nest.js 后端項目功能為標準的話，那么 Spring Boot 項目需要幾種功能進行整合，好在生態豐富，集成也不算困難。所以打算根據之前的項目使用 Spring Boot 重寫個新的項目：
Restful API CRUD 功能實現 數據庫對象關系映射功能持久化支持 OpenAPI 文檔支持 參數校驗判斷業務 redis 緩存 ... 數據庫持久化支持目前數據庫持久化主要是 Spring Boot Jpa 和 Spring Boot Mybatis 。如果看過 JPA 的業務過程會發現和 Nodejs 中的 TypeORM 及其相似。Mybatis 主要可以靈活調試動態 Sql 。不管怎么說根據自己項目業務需求選定其中功能吧。
安裝 MyBatis 教程可以官方文檔查閱：mybatis-spring-boot-autoconfigure
Swagger 文檔支持集成 Swagger UI 文檔支持也非常簡單，生態中的 springfox 做的不錯，添加依賴：
<dependency> <groupId>io.springfox</groupId> <artifactId>springfox-boot-starter</artifactId> <version>3.0.0</version></dependency>
這里需要指定版本，不指定拉取依賴會報錯。
然后在啟動方法添加注解：
@EnableOpenApipublic class YasuoApplication {public static void main(String[] args) { // ...}}
然后在 Controller 類上添加標識：
@Api(value = 'global', tags = '全局接口')@RestController@RequestMapping('/')public class AppController {}
在然后在方法里添加詳細信息：
@Api(value = 'global', tags = '全局接口')@RestController@RequestMapping('/')public class AppController { UserService userService; @ApiOperation(value = '用戶登錄', notes = '系統用戶登錄') @PostMapping('login') public JSONObject login(@RequestParam('username') String username, @RequestParam('password') String password) {System.out.println(username);System.out.println(password);JSONObject info = new JSONObject();return info; }}
啟動項目訪問：http://localhost:8080/swagger-ui 即可訪問。值得注意是如果你在 application 添加 server.servlet.contextPath 選項的時候記得添加對應的字段。
參數校驗 JSR303從 springboot-2.3 開始，校驗包被獨立成了一個 starter 組件：
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-validation</artifactId></dependency>
比如在 DTO 類里：
package com.iiong.yasuo.dto;import lombok.Data;import javax.validation.constraints.NotEmpty;/** * Author: Jaxson * Description: 請求用戶登錄參數 * Date: 2021-05-26 */@Datapublic class UserLoginRequestDTO { @NotEmpty(message = '登錄名稱不得為空！') private String username; @NotEmpty(message = '登錄密碼不得為空！') private String password;}
內置的校驗注解可以查看官方文檔，然后進行參數校驗：
@ApiOperation(value = '用戶登錄', notes = '系統用戶登錄')@PostMapping('login')public RestfulModel<UserLoginResponseDTO> login(@RequestBody @Validated UserLoginRequestDTO userLoginRequestDTO) { System.out.println(userLoginRequestDTO); UserLoginResponseDTO userLoginResponseDTO = new UserLoginResponseDTO(); userLoginResponseDTO.setId(1013401346173L); userLoginResponseDTO.setLoginName('112233'); userLoginResponseDTO.setName('系統管理員'); userLoginResponseDTO.setToken('test'); return new RestfulModel<>(0, '登錄成功！', userLoginResponseDTO);}
不過默認返回的異常信息并不是很友好，需要再次簡化，所以需要做個全局異常處理。如果需要可以使用 @RestControllerAdvice 注解來表示全局處理類：
/** * Author: Jaxson * Description: 全局異常處理類 * Date: 2021-05-26 */@ControllerAdvicepublic class ExceptionHandlerConfig { /** * 統一處理參數校驗異常 * @param bindException 捕捉到的異常 * @return 返回數據 */ @ExceptionHandler(value = BindException.class) @ResponseBody public RestfulModel<Object> validExceptionHandler(BindException bindException) {String exceptionMsg = bindException.getBindingResult().getAllErrors().get(0).getDefaultMessage();return new RestfulModel<>(1000, exceptionMsg, null); }}
當然這里面還可以處理一些系統級別的異常，自己拋出即可。
跨域解決解決跨域問題也很簡單，只需要實現接口 WebMvcConfigurer 重寫方法即可：
/** * Author: Jaxson * Description: 運行跨域 * Date: 2021-05-26 */@Configurationpublic class WebMvcConfig implements WebMvcConfigurer { @Override public void addCorsMappings(CorsRegistry corsRegistry) {corsRegistry.addMapping('/**').allowedOriginPatterns('*').allowedHeaders(CorsConfiguration.ALL).allowedMethods(CorsConfiguration.ALL).allowCredentials(true).maxAge(3600); // 1小時內不需要再預檢（發OPTIONS請求） }}整合MongoDB實現文件上傳下載刪除
引入pom依賴
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-mongodb</artifactId></dependency>
配置yml
spring: data: mongodb: host: *.*.*.* username: *** password: *** database: *** port: 27017 # 設置文件上傳的大小限制 servlet: multipart: max-file-size: 10MB max-request-size: 50MB
上傳下載刪除
/** * @author Mr.Horse * @version 1.0 * @description: MongoDB的文件上傳、下載、刪除等基本操作(集合HuTool工具庫) * @date 2021/4/29 9:53 */@Validated@Controller@RequestMapping('/mongo')public class MongoUploadController { private static Logger logger = LoggerFactory.getLogger(MongoUploadController.class); @Autowired private GridFsTemplate gridFsTemplate; @Autowired private MongoTemplate mongoTemplate; private static final List<String> CONTENT_TYPES = Arrays.asList('image/gif', 'image/jpeg', 'image/jpg', 'image/png'); /** * MongoDB文件上傳(圖片上傳) * * @param file * @return */ @PostMapping('/upload') public ResponseEntity<String> fileUpload(@RequestParam('file') MultipartFile file) {try { // 校驗文件信息(文件類型,文件內容) String originalFilename = file.getOriginalFilename(); if (StrUtil.isBlank(originalFilename)) {return ResponseEntity.badRequest().body('參數錯誤'); } String contentType = file.getContentType(); if (!CONTENT_TYPES.contains(contentType)) {return ResponseEntity.badRequest().body('文件類型錯誤'); } InputStream inputStream = file.getInputStream(); BufferedImage bufferedImage = ImageIO.read(inputStream); if (ObjectUtil.isEmpty(bufferedImage)) {return ResponseEntity.badRequest().body('文件內容錯誤'); } // 文件重命名 String suffix = FileNameUtil.getSuffix(originalFilename); String fileName = IdUtil.simpleUUID().concat('.').concat(suffix); // 文件上傳,返回ObjectId ObjectId objectId = gridFsTemplate.store(inputStream, fileName, contentType); return StrUtil.isBlank(String.valueOf(objectId)) ? ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).body('文件上傳失敗') : ResponseEntity.ok(String.valueOf(objectId));} catch (IOException e) { return ResponseEntity.badRequest().body('文件上傳異常');} } /** * 根據ObjectId讀取文件并寫入響應流,頁面進行進行相關操作,可以進行文件的下載和展示 * * @param objectId */ @GetMapping('/read') public void queryFileByObjectId(@RequestParam('objectId') @NotBlank(message = 'ObjectId不能為空') String objectId, HttpServletResponse response) {// 根據objectId查詢文件GridFSFile file = gridFsTemplate.findOne(new Query(Criteria.where('_id').is(objectId)));// 創建一個文件桶GridFSBucket gridFsBucket = GridFSBuckets.create(mongoTemplate.getDb());InputStream inputStream = null;OutputStream outputStream = null;try { if (ObjectUtil.isNotNull(file)) {// 打開下載流對象GridFSDownloadStream fileStream = gridFsBucket.openDownloadStream(file.getObjectId());// 創建girdFsResource，傳入下載流對象，獲取流對象GridFsResource gridFsResource = new GridFsResource(file, fileStream);// 寫入輸出流inputStream = gridFsResource.getInputStream();outputStream = response.getOutputStream();byte[] bytes = new byte[1024];if (inputStream.read(bytes) != -1) { outputStream.write(bytes);} }} catch (IOException e) { logger.error('文件讀取異常: {}', e.getMessage());} finally { IoUtil.close(outputStream); IoUtil.close(inputStream);} } /** * 根據ObjectId刪除文件 * * @param objectId * @return */ @DeleteMapping('/remove') public ResponseEntity<String> removeFileByObjectId(@RequestParam('objectId') @NotBlank(message = 'ObjectId不能為空') String objectId) {gridFsTemplate.delete(new Query(Criteria.where('_id').is(objectId)));return ResponseEntity.ok('刪除成功'); }}
如果需要實現在瀏覽器頁面下載此資源的功能，可結合js進行操作（文件類型根據具體業務需求而定）。主要實現代碼如下所示：
downloadNotes(noteId) { axios({url: this.BASE_API + ’/admin/mongo/file/query/’ + noteId,method: ’get’,responseType: ’arraybuffer’,params: { type: ’download’ } }).then(res => {// type類型可以設置為文本類型，這里是pdf類型const pdfUrl = window.URL.createObjectURL(new Blob([res.data], { type: `application/pdf` }))const fname = noteId // 下載文件的名字const link = document.createElement(’a’)link.href = pdfUrllink.setAttribute(’download’, fname)document.body.appendChild(link)link.click()URL.revokeObjectURL(pdfUrl) // 釋放URL 對象 }) }
以上就是Spring Boot 功能整合的實現的詳細內容，更多關于Spring Boot 功能整合的資料請關注好吧啦網其它相關文章！
相關文章：
網公網安備