@PostMapping("addList") public AjaxResult addList(@RequestBody List<TblSmtzInfo> tblSmtzInfo, HttpServletRequest request) { if (FskAppKey.equals(request.getHeader("appKey")) && FskAppSecret.equals(request.getHeader("appSecret"))) { for (TblSmtzInfo t : tblSmtzInfo) { t.setCreatedTime(new DateTime()); t.setAppSecret("福寿康"); } return AjaxResult.success(this.tblSmtzInfoService.saveBatch(tblSmtzInfo)); } else if (YjAppKey.equals(request.getHeader("appKey")) && YjAppSecret.equals(request.getHeader("appSecret"))) { for (TblSmtzInfo t : tblSmtzInfo) { t.setCreatedTime(new DateTime()); t.setAppSecret("颐家"); } return AjaxResult.success(this.tblSmtzInfoService.saveBatch(tblSmtzInfo)); } else { return AjaxResult.error(); } }优化代码

时间: 2024-03-20 15:44:45 浏览: 91

Java-多线程异步请求统一响应结果.docx

Java-多线程异步请求统一响应结果多线程异步请求是指在多个线程同时发起请求，并且在请求过程中不阻塞主线程的执行。这样可以提高程序的并发能力和响应速度。需要注意的是，在实际的异步请求中，可能需要使用Future或其他方式来等待请求的完成，并获取返回结果。上面的示例只是演示了如何使用多线程来执行异步请求，具体的处理逻辑需要根据实际需求进行修改 ### Java-多线程异步请求统一响应结果 #### 多线程异步请求概念在Java编程语言中，多线程异步请求是一种高级编程技术，它允许开发者通过创建多个独立运行的线程来同时处理不同的任务或请求。与同步请求相比，这种异步方法的主要优势在于它能够显著提升应用程序的性能，尤其是在需要处理大量并发请求的情况下。通过避免阻塞主线程，程序可以更快地响应新的请求并提高整体吞吐量。 #### 异步请求的关键特点 1. **并发性**：多个线程可以同时执行任务，提高处理能力。 2. **非阻塞性**：主线程不会因为某个子线程的任务而被阻塞，可以继续执行其他任务。 3. **资源高效利用**：合理管理线程池大小可以避免资源浪费，确保系统稳定运行。 #### 实现异步请求的方法在Java中，有多种实现异步请求的方式，包括但不限于`Future`、`Callable`接口、`ExecutorService`以及`CompletableFuture`等。 ### 使用Future与Callable `Future`和`Callable`是Java中实现异步任务的基础组件之一。`Callable`是一个可以返回结果的接口，而`Future`则是用于获取这些结果的接口。 #### 示例代码解析 ```java //示例一 int threadNum = 3; List<Future<String>> futureList = new ArrayList<>(); ExecutorService executorService = Executors.newFixedThreadPool(threadNum); for (int i = 0; i < threadNum; i++) { Future<String> future = executorService.submit(new Callable<String>() { @Override public String call() throws Exception { // 模拟耗时操作 Thread.sleep(3000); // 调用业务方法 AjaxResult ajaxResult = apiService.appLogin(req); String data = ajaxResult.get("data").toString(); return "我是任务结果:" + data; } }); futureList.add(future); } for (int i = 0; i < futureList.size(); i++) { String s = futureList.get(i).get(); System.out.println(s); } ``` 在这段代码中，首先创建了一个固定大小的线程池`ExecutorService`，然后通过`submit`方法提交了三个异步任务。每个任务都是一个实现了`Callable`接口的匿名类，该接口要求实现一个`call`方法，这个方法将被线程执行并返回一个结果。最终通过调用`future.get()`方法来获取每个任务的结果。 #### 注意事项 1. `Thread.sleep(3000)`仅用于模拟耗时操作，在实际应用中应替换为真实的业务逻辑。 2. `future.get()`方法会阻塞主线程直到得到结果。如果需要避免主线程阻塞，可以使用`future.get(timeout, unit)`指定超时时间。 3. 在使用完线程池后，应通过`executorService.shutdown()`关闭线程池，释放资源。 ### 使用CompletableFuture `CompletableFuture`是Java 8引入的一个新特性，它提供了更简洁、强大的异步编程模型，支持流式API风格的编程，易于理解和维护。 #### 示例代码解析 ```java //示例二 int threadNum = 3; List<CompletableFuture> objects = Collections.synchronizedList(new ArrayList<>()); ExecutorService es = Executors.newFixedThreadPool(threadNum); for (int i = 0; i < threadNum; i++) { objects.add(CompletableFuture.supplyAsync(() -> { Thread.sleep(1000); AjaxResult ajaxResult = null; try { ajaxResult = apiService.appLogin(req); } catch (Exception e) { e.printStackTrace(); } String data = ajaxResult.get("data").toString(); return "我是任务结果:" + data; }, es).handle((result, e) -> { System.out.println("结果和异常信息" + result + "-error:" + e); return result; })); } CompletableFuture<Void> voidCompletableFuture = CompletableFuture.allOf(objects.toArray(new CompletableFuture[objects.size()])); List<Object> collect = objects.stream().map(CompletableFuture::join).collect(Collectors.toList()); System.out.println("全部执行结果：" + collect); System.out.println("是否全部完成：" + voidCompletableFuture.isDone()); // 关闭线程池 es.shutdown(); ``` 这段代码同样创建了一个固定大小的线程池，但使用了`CompletableFuture`来构建异步任务。每个任务都是通过`supplyAsync`方法提交到线程池中的。此外，还使用了`handle`方法来处理每个任务的结果（包括可能出现的异常）。通过`CompletableFuture.allOf`来等待所有任务的完成，并通过`join`方法获取每个任务的结果。 #### 注意事项 1. `CompletableFuture`支持链式调用，可以通过组合多个方法来构建复杂的异步流程。 2. `handle`方法允许在结果可用时对结果进行处理，即使发生异常也能正常执行。 3. `CompletableFuture.allOf`可以用来等待一组`CompletableFuture`的完成，这对于合并多个异步操作的结果非常有用。 ### 总结多线程异步请求是Java中一个重要的编程技术，它可以极大地提高程序的并发性和响应速度。通过使用`Future`、`Callable`接口、`ExecutorService`以及`CompletableFuture`等工具，开发者可以轻松地实现高效的异步编程模式。理解这些概念和技术对于编写高性能的应用程序至关重要。

可以考虑将重复的代码抽取到一个方法中，减少代码冗余。例如： ``` @PostMapping("addList") public AjaxResult addList(@RequestBody List<TblSmtzInfo> tblSmtzInfo, HttpServletRequest request) { String appKey = request.getHeader("appKey"); String appSecret = request.getHeader("appSecret"); String name = ""; if (FskAppKey.equals(appKey) && FskAppSecret.equals(appSecret)) { name = "福寿康"; } else if (YjAppKey.equals(appKey) && YjAppSecret.equals(appSecret)) { name = "颐家"; } else { return AjaxResult.error(); } for (TblSmtzInfo t : tblSmtzInfo) { t.setCreatedTime(new DateTime()); t.setAppSecret(name); } return AjaxResult.success(this.tblSmtzInfoService.saveBatch(tblSmtzInfo)); } ``` 这样代码更加简洁，也减少了重复代码的出错风险。

阅读全文

相关推荐

vue和springboot的上传文件和文件夹中的文件以及下载文件（csdn）————程序.pdf

javaEE企业级开发课程设计—酒店管理系统源码+数据库+说明.zip

@PostMapping public AjaxResult add

@PostMapping("/addMenu") public AjaxResult addMenu(@RequestBody List<Menu> menus) { menuService.addMenu(menus); return AjaxResult.success(); }前端传{ "menus": [{ "name": "红烧土豆", "price": 10.11 },{ "name": "清蒸鲫鱼", "price": 25.11 }] }能不能成功

@PostMapping后面跟AjaxResult方法如何测试

@PostMapping后面跟AjaxResult方法如何调试

@ApiOperation(value = "修改UVA Model",tags = {"UVA"}) @PostMapping("/updateUvaModel") public AjaxResult updateUvaModel(@RequestBody UvaModelEntity modelEntity){ return AjaxResult.success(uvaModelService.updateById(modelEntity)); }

描述这段代码：public AjaxResult importTemplate() { ExcelUtil<UserOperateModel> util = new ExcelUtil<UserOperateModel>(UserOperateModel.class); return util.importTemplateExcel("用户数据"); }

public AjaxResult exportWord(List<T> list, String wordName) 如何确认传的对象是什么，并进行显示转换，代码

最新推荐

GitHub图片浏览插件：直观展示代码中的图像

管理建模和仿真的文件

【OPPO手机故障诊断专家】：工程指令快速定位与解决

求[100，900]之间相差为12的素数对（注：要求素数对的两个素数均在该范围内）的个数

Android IPTV项目：直播频道的实时流媒体实现

"互动学习：行动中的多样性与论文攻读经历"

【OPPO手机工程模式终极指南】：掌握这些秘籍，故障排查不再难！

前端在json文件里写模板，可以换行 有空格现在在文本框的时候

机器学习在医院再入院率预测中的应用分析

关系数据表示学习

前端在json文件里写模板，可以换行有空格现在在文本框的时候