一、RestTemplate 简介
在微服务都是以HTTP接口的形式暴露自身服务的,因此在调用远程服务时就必须使用HTTP客户端。我们可以使用JDK原生的URLConnection、Apache的Http Client、Netty的异步HTTP Client, Spring的RestTemplate。但是,用起来最方便、最优雅的还是要属Feign了。这里介绍的是RestTemplate。
1. 什么是RestTemplate?
RestTemplate是Spring提供的用于访问Rest服务的客户端,
RestTemplate提供了多种便捷访问远程Http服务的方法,能够大大提高客户端的编写效率。
调用RestTemplate的默认构造函数,RestTemplate对象在底层通过使用java.net包下的实现创建HTTP 请求,
可以通过使用ClientHttpRequestFactory指定不同的HTTP请求方式。
ClientHttpRequestFactory接口主要提供了两种实现方式
1) 一种是SimpleClientHttpRequestFactory,使用J2SE提供的方式(既java.net包提供的方式)创建底层的Http请求连接。
2) 一种方式是使用HttpComponentsClientHttpRequestFactory方式,底层使用HttpClient访问远程的Http服务,使用HttpClient可以配置连接池和证书等信息。
二、RestTemplate 基本使用
RestTemplate默认是使用SimpleClientHttpRequestFactory,内部是调用jdk的HttpConnection,默认超时为-1
- 服务提供
@GetMapping("/getUserName")
public String getUserName(String username) {
return "用户名为:" + username;
}
@GetMapping("/getUserData")
public User getUserData(@RequestParam String username) {
User user=new User();
user.setUsername(username);
user.setPassword("1223456");
user.setId(1);
return user;
}
@PostMapping("/getUpdateUser")
public User getUpdateUser(User user) {
return user;
}
- 服务消费
@GetMapping("/getUserName")
public String getUserName() {
String username = "张三";
String message = restTemplate.getForObject("http://USER-SERVICE/getUserName?username=" + username, String.class);
log.info(message);
return message;
}
@GetMapping("/getUserData")
public String getUserData() {
String username = "李四";
ResponseEntity<User> userResponseEntity = restTemplate.getForEntity("http://USER-SERVICE/getUserData?username=" + username, User.class);
log.info(userResponseEntity.getBody().toString());
return userResponseEntity.getBody().toString();
}
@GetMapping("/getUpdateUser")
public String getUpdateUser() {
// 封装参数,千万不要替换为Map与HashMap,否则参数无法传递
MultiValueMap<String, Object> params = new LinkedMultiValueMap<>();
params.add("username", "李四");
params.add("password", "123456");
params.add("id", "2");
ResponseEntity<User> userResponseEntity = restTemplate.postForEntity("http://USER-SERVICE/getUpdateUser", params, User.class);
log.info(userResponseEntity.getBody().getUsername());
return userResponseEntity.getBody().getUsername();
}
- GET方式传参说明:
如果是get请求,又想要把参数封装到map里面进行传递的话,Map需要使用HashMap,且url需要使用占位符。
RestTemplate restTemplate2 = new RestTemplate();
String url = "http://127.0.0.1:8081/interact/getData?dt={dt}&ht={ht}";
// 封装参数,这里是HashMap
Map<String, Object> paramMap = new HashMap<String, Object>();
paramMap.put("dt", "20181116");
paramMap.put("ht", "10");
//1、使用getForObject请求接口
String result1 = template.getForObject(url, String.class, paramMap);
1、调用postForObject方法
2、使用postForEntity方法
3、调用exchange方法
postForObject和postForEntity方法的区别主要在于可以在postForEntity方法中设置header的属性,当需要指定header的属性值的时候,使用postForEntity方法。exchange方法和postForEntity类似,但是更灵活,exchange还可以调用get请求。
RestTemplate template = new RestTemplate();
String url = "http://192.168.2.40:8081/channel/channelHourData/getHourNewUserData";
// 封装参数,千万不要替换为Map与HashMap,否则参数无法传递
MultiValueMap<String, Object> paramMap = new LinkedMultiValueMap<String, Object>();
paramMap.add("dt", "20180416");
HttpHeaders headers = new HttpHeaders();
HttpEntity<MultiValueMap<String, Object>> httpEntity = new HttpEntity<MultiValueMap<String, Object>>(paramMap,headers);
// 使用exchange请求接口
ResponseEntity<String> response3 = template.exchange(url, HttpMethod.POST, httpEntity, String.class);
System.out.println("result3====================" + response3.getBody());
附:
import static java.lang.String.format;
@Autowired
private LoadBalancerClient loadBalancerClient;
# 通过注册中心,1.获取host+port,2.获取uri 并发出请求
//服务会自己选择一个服务接口发送请求,负载均衡的方式选择有很多,比如随机,顺序等等
ServiceInstance instance=client.choose("PRODUCT");
#%s 不占位符
String url= format("http://%s:%s",instance.getHost(),instance.getPort())+"/products";
String second_type_1=restTemplate.getForObject(url,String.class);