Spring cloud restTemplate 복잡 한 매개 변 수 를 전달 하 는 방식(여러 대상)
13507 단어 springcloudresttemplate매개 변수
여기 서 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);
}
// 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", " ");
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", " ");
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;
}
@FeignClient(value = "frame-service",path = "/excelApi/v1")
public interface ExcelFreign extends ExcelApi {
}
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);
}
@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(" ");
}
}
}
/**
*
* @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);
} 서비스 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(" ");
}
}
/**
*
* @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 가 복잡 한 매개 변 수 를 전달 하 는 방식(여러 대상)입 니 다.여러분 에 게 도움 이 되 기 를 바 랍 니 다.궁금 한 점 이 있 으 시 면 메 시 지 를 남 겨 주세요.소 편 은 제때에 답 해 드 리 겠 습 니 다.여기 서도 저희 사이트 에 대한 여러분 의 지지 에 감 사 드 립 니 다!
이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:
thymeleaf로 HTML 페이지를 동적으로 만듭니다 (spring + gradle)지난번에는 에서 화면에 HTML을 표시했습니다. 이번에는 화면을 동적으로 움직여보고 싶기 때문에 입력한 문자를 화면에 표시시키고 싶습니다. 초보자의 비망록이므로 이상한 점 등 있으면 지적 받을 수 있으면 기쁩니다! ...
텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.
좋은 웹페이지 즐겨찾기
