Spring cloud restTemplate 傳遞復雜參數(shù)的方式(多個對象)
更新時間：2018年05月21日 16:06:23 作者：MatrixCod
這篇文章主要介紹了Spring cloud restTemplate 傳遞復雜參數(shù)的方式(多個對象),需要的朋友可以參考下
使用微服務的時候往往服務之間調用比較麻煩，spring cloud提供了Feign接口調用，RestTemplate調用的方式
這里我探討下RestTemplate調用的方式：
服務A:接收三個對象參數(shù) 這三個參數(shù)的是通過數(shù)據(jù)庫查詢出來的
服務B:要調用服務A 服務B提供了查詢三個參數(shù)的方法，后面要使用三個參數(shù)
對于服務A,處理的方式有兩中
1. 服務B提供一個Feign接口將查詢三個參數(shù)的方法公開，服務A直接引用Feign來查詢參數(shù)，服務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
//引入Feign接口
private ExcelFreign excelFreign;
public Map<String,String> importExcel(String filePath, String busiCode,Map<String, String> params,UserInfo user ) {
Map<String,String> result=new HashMap<String,String>();
excelFreign = SpringTool.getApplicationContext().getBean(ExcelFreign.class);
CmdImportConfigDto configDto = excelFreign.getCmdImportConfigByBusiCode(busiCode);
CmdImportDto importDto=new CmdImportDto();
importDto.setImportConfigId(configDto.getId());
importDto.setExcelPath(filePath);
importDto.setParam(new GsonBuilder().create().toJson(params));
importDto.setLog("");
Long impId=null;
try {
impId= Long.valueOf(excelFreign.saveCmdImportDto(importDto));
} catch (Exception e1) {
e1.printStackTrace();
result.put("error", "保存出現(xiàn)異常");
result.put("message", e1.getMessage());
return result;
}
try{
excelFreign.updateImportStatus(impId, ImportConstant.ImportStatus.SUBMIT, "提交成功");
}catch(Exception e){
e.printStackTrace();
}
ValidateTask validateTask=new ValidateTask();
validateTask.init(impId,filePath, busiCode, params,user);
String message;
try {
message = validateTask.call();
} catch (Exception e) {
e.printStackTrace();
result.put("error", "驗證出現(xiàn)異常");
result.put("message", e.getMessage());
return result;
}
if(message!=null){
result.put("error", "驗證不通過");
result.put("message", message);
return result;
}
PersistTask persistTask=new PersistTask();
persistTask.init(impId,filePath, busiCode, params,user);
result.putAll(ImportQueue.submit(persistTask));
return result;
}
服務B 提供的B-Fegin
@FeignClient(value = "frame-service",path = "/excelApi/v1")
public interface ExcelFreign extends ExcelApi {
}
服務B api層 B-api
public interface ExcelApi {
/**
* 更新狀態(tài)
* @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 實現(xiàn)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);
}
/**
* 更新狀態(tài)
* @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("系統(tǒng)出現(xiàn)異常");
}
}
}
服務B 調用服務A action層
/**
*
* @param busicode 導出的業(yè)務編碼 能確定某個模塊做導出操作
* @param values 請求參數(shù)
*
* 通過restTemplate 傳遞復雜參數(shù)
* @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("參數(shù)錯誤,請檢查參數(shù)是否正確,busicode ?");
}
// 獲取執(zhí)行過程
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將查詢出來的參數(shù)直接傳遞給服務A
服務A:
/**
* 接收參數(shù)傳遞
* 分別接收下面三種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 導出的業(yè)務編碼 能確定某個模塊做導出操作
* @param values 請求參數(shù)
*
* 通過restTemplate 傳遞復雜參數(shù)
* @return
* 返回 文件流 讓瀏覽器彈出下載 目前需要解決 將字節(jié)流響應到瀏覽器的控制臺了 后面均采用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("參數(shù)錯誤,請檢查參數(shù)是否正確,busiCode ?");
}
// 獲取執(zhí)行過程
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);
}
/**
* 執(zhí)行請求調用
* @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("沒有導出配置無法導出");
}
//根據(jù)導出配置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);
}
設置瀏覽器頭
/**
* 根據(jù)不同的瀏覽器類型設置下載文件的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 傳遞復雜參數(shù)的方式(多個對象)，希望對大家有所幫助，如果大家有任何疑問請給我留言，小編會及時回復大家的。在此也非常感謝大家對腳本之家網(wǎng)站的支持！
相關文章
這篇文章主要介紹了Java用list儲存，遍歷，查詢指定信息過程詳解,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2019-10-10
縮短 URL 是現(xiàn)代應用程序中常見的需求,通常用于減少長 URL 的長度,使其更易于分享,URL 縮短服務的核心思路是將長 URL 映射到一個唯一的短代碼,本文主要介紹了springboot中縮短一個url鏈接的實現(xiàn),感興趣的可以了解一下2024-09-09
相信很多人都經歷過配置環(huán)境變量失敗的經歷,尤其是很多時候明明按照老師教的步驟或者教程上的方法循規(guī)守矩配置卻還是出錯,下面我們來解決一個非常蹊蹺的問題---輸入Java和Java -version都沒問題,但是輸入Javac報錯,感興趣的朋友一起看看吧2023-11-11
這篇文章主要介紹了Java 如何優(yōu)雅的拋出業(yè)務異常，幫助大家更好的理解和使用Java，感興趣的朋友可以了解下2020-12-12
這篇文章主要介紹了java文件下載代碼實例（單文件下載和多文件打包下載）,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2019-12-12
spring?boot?mybatis日志輸出到控制臺的方法實踐
在開發(fā)過程中我們往往需要打印出SQL語句,這樣就方便我們監(jiān)控問題,本文主要介紹了spring?boot?mybatis日志輸出到控制臺的方法實踐,具有一定的參考價值,感興趣的可以了解一下2024-05-05
SSH框架網(wǎng)上商城項目第23戰(zhàn)之在線支付功能實現(xiàn)
這篇文章主要為大家詳細介紹了SSH框架網(wǎng)上商城項目第23戰(zhàn)之在線支付功能實現(xiàn)，感興趣的小伙伴們可以參考一下2016-06-06
Mybatis關聯(lián)查詢遇到的坑-無主鍵的關聯(lián)數(shù)據(jù)去重問題
這篇文章主要介紹了Mybatis關聯(lián)查詢遇到的坑-無主鍵的關聯(lián)數(shù)據(jù)去重問題，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2023-03-03
socket是一個針對TCP和UDP編程的接口，你可以借助它建立TCP連接等。這篇文章主要介紹了iOS socket網(wǎng)絡編程 ,需要的朋友可以參考下2017-03-03
IntelliJ IDEA連接MySQL數(shù)據(jù)庫詳細圖解
今天小編就為大家分享一篇關于intellij idea連接mysql數(shù)據(jù)庫詳細圖解，小編覺得內容挺不錯的，現(xiàn)在分享給大家，具有很好的參考價值，需要的朋友一起跟隨小編來看看吧2018-10-10