在Spring-Boot項目開發中,存在着本模塊的代碼須要訪問外面模塊接口,或外部url連接的需求, 好比調用外部的地圖API或者天氣API。java
最全的Java後端知識體系 https://www.pdai.tech, 天天更新中...。web
在代碼中採用原生的http請求,代碼參考以下:spring
@RequestMapping("/doPostGetJson") public String doPostGetJson() throws ParseException { //此處將要發送的數據轉換爲json格式字符串 String jsonText = "{id:1}"; JSONObject json = (JSONObject) JSONObject.parse(jsonText); JSONObject sr = this.doPost(json); System.out.println("返回參數:" + sr); return sr.toString(); } public static JSONObject doPost(JSONObject date) { HttpClient client = HttpClients.createDefault(); // 要調用的接口方法 String url = "http://192.168.1.101:8080/getJson"; HttpPost post = new HttpPost(url); JSONObject jsonObject = null; try { StringEntity s = new StringEntity(date.toString()); s.setContentEncoding("UTF-8"); s.setContentType("application/json"); post.setEntity(s); post.addHeader("content-type", "text/xml"); HttpResponse res = client.execute(post); String response1 = EntityUtils.toString(res.getEntity()); System.out.println(response1); if (res.getStatusLine().getStatusCode() == HttpStatus.SC_OK) { String result = EntityUtils.toString(res.getEntity());// 返回json格式: jsonObject = JSONObject.parseObject(result); } } catch (Exception e) { throw new RuntimeException(e); } return jsonObject; }
一、在maven項目中添加依賴json
<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-feign</artifactId> <version>1.2.2.RELEASE</version> </dependency>
二、編寫接口,放置在service層後端
這裏的decisionEngine.url 是配置在properties中的 是ip地址和端口號
decisionEngine.url=http://10.2.1.148:3333/decision/person 是接口名字app
@FeignClient(url = "${decisionEngine.url}",name="engine") public interface DecisionEngineService { @RequestMapping(value="/decision/person",method= RequestMethod.POST) public JSONObject getEngineMesasge(@RequestParam("uid") String uid,@RequestParam("productCode") String productCode); }
三、在Java的啓動類上加上@EnableFeignClientsmaven
@EnableFeignClients //參見此處 @EnableDiscoveryClient @SpringBootApplication @EnableResourceServer public class Application implements CommandLineRunner { private static final Logger LOGGER = LoggerFactory.getLogger(Application.class); @Autowired private AppMetricsExporter appMetricsExporter; @Autowired private AddMonitorUnitService addMonitorUnitService; public static void main(String[] args) { new SpringApplicationBuilder(Application.class).web(true).run(args); } }
四、在代碼中調用接口便可spring-boot
@Autowired private DecisionEngineService decisionEngineService ; // ... decisionEngineService.getEngineMesasge("uid" , "productCode");
在Spring-Boot開發中,RestTemplate一樣提供了對外訪問的接口API,這裏主要介紹Get和Post方法的使用。Get請求提供了兩種方式的接口getForObject 和 getForEntity,getForEntity提供以下三種方法的實現。post
該方法提供了三個參數,其中url爲請求的地址,responseType爲請求響應body的包裝類型,urlVariables爲url中的參數綁定,該方法的參考調用以下:ui
// http://USER-SERVICE/user?name={name) RestTemplate restTemplate=new RestTemplate(); Map<String,String> params=new HashMap<>(); params.put("name","dada"); // ResponseEntity<String> responseEntity=restTemplate.getForEntity("http://USERSERVICE/user?name={name}",String.class,params);
該方法使用URI對象來替代以前的url和urlVariables參數來指定訪問地址和參數綁定。URI是JDK java.net包下的一個類,表示一個統一資源標識符(Uniform Resource Identifier)引用。參考以下:
RestTemplate restTemplate=new RestTemplate(); UriComponents uriComponents=UriComponentsBuilder.fromUriString("http://USER-SERVICE/user?name={name}") .build() .expand("dodo") .encode(); URI uri=uriComponents.toUri(); ResponseEntity<String> responseEntity=restTemplate.getForEntity(uri,String.class).getBody();
getForObject方法能夠理解爲對getForEntity的進一步封裝,它經過HttpMessageConverterExtractor對HTTP的請求響應體body內容進行對象轉換,實現請求直接返回包裝好的對象內容。getForObject方法有以下:
getForObject(String url,Class responseType,Object...urlVariables) getForObject(String url,Class responseType,Map urlVariables) getForObject(URI url,Class responseType)
Post請求提供有三種方法,postForEntity、postForObject和postForLocation。其中每種方法都存在三種方法,postForEntity方法使用以下:
RestTemplate restTemplate=new RestTemplate(); User user=newUser("didi",30); ResponseEntity<String> responseEntity=restTemplate.postForEntity("http://USER-SERVICE/user",user,String.class); //提交的body內容爲user對象,請求的返回的body類型爲String String body=responseEntity.getBody();
postForEntity存在以下三種方法的重載
postForEntity(String url,Object request,Class responseType,Object... uriVariables) postForEntity(String url,Object request,Class responseType,Map uriVariables) postForEntity(URI url,Object request,Class responseType)
postForEntity中的其它參數和getForEntity的參數大致相同在此不作介紹。