时间:2021-05-19
使用微服务的时候往往服务之间调用比较麻烦,spring cloud提供了Feign接口调用,RestTemplate调用的方式
这里我探讨下RestTemplate调用的方式:
服务A:接收三个对象参数 这三个参数的是通过数据库查询出来的
服务B:要调用服务A 服务B提供了查询三个参数的方法,后面要使用三个参数
对于服务A,处理的方式有两中
1. 服务B提供一个Feign接口将查询三个参数的方法公开,服务A直接引用Feign来查询参数,服务B只需要将三个查询关键字传递过去即可
服务A action
@PostMapping("/import/{busiCode}/{filePath}") public Map<String,String> importExcel(@PathVariable("filePath") String filePath,@PathVariable("busiCode") String busiCode,@RequestBody Map<String, String> params, HttpServletRequest request,HttpServletResponse response) { response.setCharacterEncoding("UTF-8"); UserInfo user = UserUtil.getUser(); return excelService.importExcel(filePath,busiCode,params,user); }服务A service
服务B 提供的B-Fegin
@FeignClient(value = "frame-service",path = "/excelApi/v1") public interface ExcelFreign extends ExcelApi { }服务B api层 B-api
public interface ExcelApi { /** * 更新状态 * @param impId * @param importType * @param result */ @PostMapping("/updateImportStatus/{impId}/{importType}/{result}") void updateImportStatus(@PathVariable("impId") Long impId, @PathVariable("importType") String importType, @PathVariable("result") String result) throws Exception; /** * 获取导入配置项 * @param busiCode * @return */ @GetMapping("/getImportConfig/{busicode}") CmdImportConfigDto getCmdImportConfigByBusiCode(@PathVariable("busicode") String busiCode); /** * 保存信息 * @param importDto * @return */ @PostMapping("/saveImport") String saveCmdImportDto(@RequestBody CmdImportDto importDto); }服务B 实现api接口的action
@RestController @RequestMapping("/excelApi/v1") public class ExcelFeignAction implements ExcelApi { @Autowired private CmdExportService exportService; /** * 获取导入配置项 * @param busiCode * @return */ @GetMapping("/getImportConfig/{busicode}") public CmdImportConfigDto getCmdImportConfigByBusiCode(@PathVariable("busicode") String busiCode){ return cmdImportConfigService.getCmdImportConfigByBusiCode(busiCode); } /** * 更新状态 * @param impId * @param importStatus * @param result */ @PostMapping("/updateImportStatus/{impId}/{importType}/{result}") public void updateImportStatus(@PathVariable("impId") Long impId, @PathVariable("importType") String importStatus, @PathVariable("result") String result) throws Exception{ cmdImportService.updateImportStatus(impId,importStatus,new Date() , result); } /** * 保存信息 * @param importDto * @return */ @PostMapping("/saveImport") public String saveCmdImportDto(@RequestBody CmdImportDto importDto){ try{ cmdImportService.saveCmdImportDto(importDto); return importDto.getId(); }catch (Exception e){ e.printStackTrace(); throw new BusinessRuntimeException("系统出现异常"); } } }服务B 调用服务A action层
/** * * @param busicode 导出的业务编码 能确定某个模块做导出操作 * @param values 请求参数 * * 通过restTemplate 传递复杂参数 * @return * 返回 文件流 让浏览器弹出下载 */ @PostMapping(value = "/export/v3/{busicode}") @ResponseBody public ResponseEntity<byte[]> expDownLoadV3(@PathVariable("busicode") String busicode , @RequestBody Map<String,Object> values, HttpServletRequest request)throws Exception { if(StringUtils.isBlank(busicode)){ throw new BusinessRuntimeException("参数错误,请检查参数是否正确,busicode ?"); } // 获取执行过程 Map map = restTemplate.postForObject("http://" + serviceId + "/excelApi/v1/文件名"/"+busicode,values,Map.class); String path = (String)map.get("filepath"); byte[] excel = FastDFSClient.downloadToBytes(path); CmdExportConfigDto cmdExportConfig = exportService.getCmdExportConfigByBusiCode(busicode); //获取文件名 String fileName = cmdExportConfig.getReportName(); // 获取文件后缀名 String extFileName = path.substring(path.lastIndexOf('.')+1); HttpHeaders headers = new HttpHeaders(); // 获取用户浏览器的种类 对不同的浏览器进行编码处理 final String userAgent = request.getHeader("USER-AGENT"); headers.setContentType(MediaType.APPLICATION_OCTET_STREAM); headers.setContentDispositionFormData("attachment", FrameUrlConstants.transFromFileName(userAgent,fileName) + "." + extFileName); return new ResponseEntity<byte[]>(excel,headers,HttpStatus.OK); }2.服务B将查询出来的参数直接传递给服务A
服务A:
/** * 接收参数传递 * 分别接收下面三种key value的键值对 * cmdExportConfig:CmdExportConfigDto * exportFieldList:List<CmdExportFieldConfigDto> * params:Map * @param params * @param request * @param response * @return */ @PostMapping("/export/v2") public ResponseEntity exportExcel(@RequestBody Map<String,Object> params,HttpServletRequest request,HttpServletResponse response) { response.setCharacterEncoding("UTF-8"); try { // 将文件的路径获取到 ObjectMapper mapper = new ObjectMapper(); LinkedHashMap requestParMap = (LinkedHashMap)params.get("cmdExportConfig"); CmdExportConfigDto cmdExportConfigDto = null; List<CmdExportFieldConfigDto> exportFieldList = null; if(requestParMap.size()>0){ cmdExportConfigDto = mapper.convertValue(requestParMap,CmdExportConfigDto.class); } ArrayList arrayList = (ArrayList)params.get("exportFieldList"); if(arrayList.size()>0){ exportFieldList = mapper.convertValue(arrayList, new TypeReference<CmdExportFieldConfigDto>() {}); } Map values = (Map)params.get("params"); String filePath = excelService.exportExcel(cmdExportConfigDto,exportFieldList,params,request.getServletContext().getRealPath("/")); Map<String,String> map = new HashMap<String, String>(); map.put("filepath", filePath); return new ResponseEntity(map,HttpStatus.OK); }catch (IOException e){ throw new RuntimeException("输出文件出错"); } }服务B:
/** * * @param busicode 导出的业务编码 能确定某个模块做导出操作 * @param values 请求参数 * * 通过restTemplate 传递复杂参数 * @return * 返回 文件流 让浏览器弹出下载 目前需要解决 将字节流响应到浏览器的控制台了 后面均采用url下载的方式 */ @PostMapping(value = "/export/v3/{busicode}",produces = MediaType.TEXT_PLAIN_VALUE) @ResponseBody public ResponseEntity<byte[]> expDownLoadV3(@PathVariable("busicode") String busicode , @RequestBody Map<String,Object> values, HttpServletRequest request)throws Exception { String busiCode = values.get("busiCode").toString(); if(StringUtils.isBlank(busiCode)){ throw new BusinessRuntimeException("参数错误,请检查参数是否正确,busiCode ?"); } // 获取执行过程 Map map = excuteRestTemplate(busiCode,values); String path = (String)map.get("filepath"); byte[] excel = FastDFSClient.downloadToBytes(path); CmdExportConfigDto cmdExportConfig = exportService.getCmdExportConfigByBusiCode(busiCode); //获取文件名 String fileName = cmdExportConfig.getReportName(); // 获取文件后缀名 String extFileName = path.substring(path.lastIndexOf('.')+1); HttpHeaders headers = new HttpHeaders();erAgent = request.getHeader("USER-AGENT"); headers.setContentType(MediaType.APPLICATION_OCTET_STREAM); headers.setContentDispositionFormData("attachment", FrameUrlConstants.transFromFileName(userAgent,fileName) + "." + extFileName); return new ResponseEntity<byte[]>(excel,headers,HttpStatus.OK); } /** * 执行请求调用 * @param busiCode * @param variables * @return */ private Map excuteRestTemplate(String busiCode,Map variables){ String serviceId=""; //查询导出配置 CmdExportConfigDto cmdExportConfig = exportService.getCmdExportConfigByBusiCode(busiCode); serviceId = cmdExportConfig.getSystemType(); if(cmdExportConfig==null){ throw new BusinessRuntimeException("没有导出配置无法导出"); } //根据导出配置id获取导出字段信息 List<CmdExportFieldConfigDto> exportFieldList = exportService.getAllCmdExportFieldConfigDtoByConfigId(cmdExportConfig.getId()); if(StringUtils.isBlank(serviceId)){ throw new BusinessRuntimeException("未配置导出的服务"); } Map<String, Object> uriVariables = new HashMap<>(); uriVariables.put("cmdExportConfig",cmdExportConfig); uriVariables.put("exportFieldList",exportFieldList); uriVariables.put("params",variables); return restTemplate.postForObject("http://" + serviceId + "/excelService/export/v2",new HttpEntity(uriVariables),Map.class); }设置浏览器头
/** * 根据不同的浏览器类型设置下载文件的URL编码 * @param userAgent * @param fileName * @return * @throws Exception */ public static String transFromFileName(String userAgent,String fileName) throws Exception{ String finalFileName = ""; if(StringUtils.contains(userAgent, "MSIE")){//IE浏览器 finalFileName = URLEncoder.encode(fileName,"UTF-8"); }else if(StringUtils.contains(userAgent, "Mozilla")){//google,火狐浏览器 finalFileName = new String(fileName.getBytes("GBK"), "ISO8859-1"); }else{ finalFileName = URLEncoder.encode(fileName,"UTF-8");//其他浏览器 } return finalFileName; }总结
以上所述是小编给大家介绍的Spring cloud restTemplate 传递复杂参数的方式(多个对象),希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对网站的支持!
声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。
1.官方文档https://cloud.spring.io/spring-cloud-static/spring-cloud-openfeign/2.2.2.R
文档地址https://github.com/alibaba/spring-cloud-alibaba/blob/master/spring-cloud-ali
1.Python的参数传递Python的参数传递,无法控制引用传递还是值传递。对于不可变对象(数字、字符、元组等)的参数,更类似值传递;对于可变对象(列表、字典
前言相信大家在使用spring的项目中,前台传递参数到后台是经常遇到的事,我们必须熟练掌握一些常用的参数传递方式和注解的使用,本文将给大家介绍关于SpringM
一、RestTemplate说明RestTemplate是Spring提供的用于访问Rest服务的客户端,RestTemplate提供了多种便捷访问远程Http