|
//声明
private RestTemplate rsp;
private final HttpHeaders headers;
private TaskRunner() {
? ? rsp = new RestTemplate(); //
?headers = new HttpHeaders();
? ? headers.setContentType(MediaType.parseMediaType("application/json;charset=UTF-8"));
}
//调用代码段
{
List<Object> items;
String jsonStr = JsonMapper.toJsonString(items);
String tmpUrl = "http://localhost:9001/service/base/update";
post(tmpUrl, jsonStr);
}
//基础方法
private void post(String requestUrl, String json){
? ? ActionResult result=this.postObject(requestUrl, json,new ParameterizedTypeReference<ActionResult>(){});
? ? System.out.println(result);
}
private <P,R> R postObject(String url, P param, ParameterizedTypeReference<R> respType){
? ? HttpEntity<P> p=new HttpEntity<P>(param,headers);
? ? ResponseEntity<R> resp=rsp.exchange(url, HttpMethod.POST,p,respType);
? ? return resp.getBody();
}
//被调用接口声明
@RestController
@RequestMapping("/service/base")
@Api(tags = "服务接口")
public class CommonAdapterController {
@PostMapping("/update")
@ApiOperation(value="接收分发信息。",httpMethod = "POST")
@ApiImplicitParam(paramType="body",dataType = "Object",
required = true,name="obj",value="信息")
public ActionResult<String> update(@RequestBody Object obj){
? ?//TODO 待实现
?return null;
}
}
|