文章目录

• 一、简介
• 二、客户端负载均衡
• 三、RestTemplate详解
• GET请求
• POST请求
• PUT请求
• DELETE请求

一、简介

​

Spring Cloud Ribbon

远程服务负载均衡

二、客户端负载均衡

​ 负载均衡是在一个架构中非常重要，而且不得不去实施的内容。因为负载均衡对系统的高可用，网络压力的缓解和处理能力扩容的重要手段之一。通常负载均衡分为两种：

硬件负载均衡

软件负载均衡

​ 硬件负载均衡的设备和软件负载均衡的模块都会维护一个

下挂可用的服务清单

心跳检测

剔除故障的服务节点

​ 而客户端负载均衡和服务端负载均衡最大的不同点在于上面所提到

服务清单的存储位置

​ 通过Spring Cloud Ribbon的封装，我们在微服务架构中使用负载均衡就比较简单，只需要下面两步：

• 服务提供者

  只需要启动多个服务实例并注册到一个注册中心或是多个相关联的服务注册中心

• 服务消费者

  直接调用被@LoadBalanced注解修饰过的RestTemplate来实现面向服务的接口调用。

三、RestTemplate详解

​ 在上一章中，我们已经引入了Spring Cloud Ribbon实现了客户端负载均衡的一个简单的实例，其中，我们使用了一个非常有用的对象

RestTemplate

@LoadBalanced

负载均衡

准备工作

在上一篇博客中，我们搭建了

一个注册中心

一个服务提供者

一个ribbon消费者客户端

GET请求

在RestTemplate中，对GET请求可以通过如下两个方法进行调用实现。

第一种：

getForEntity()

ResponseEntity

HttpEntity

HttpHeaders

它的一般形式有三种：

/*
* url是远程服务端的路径，responseType是返回值类型，urlVariables是可变参数，给服务端传递的参数
*/
getForEntity(String url, Class<T> responseType, Object... urlVariables)

/*
* 可以使用Map封装参数传递给客户端
*/
getForEntity(String url, Class<T> responseType, Map<String, ?> urlVariables)

/*
* 也是一直接使用uri地址
*/
getForEntity(URI url, Class<T> responseType) throws RestClientException

/*
* getForObject 用法和getForEntity基本相同
*/
getForObject(String url, Class<T> responseType, Object... urlVariables) throws RestClientException

getForObject(String url, Class<T> responseType, Map<String, ?> urlVariables) throws RestClientException

getForObject(URI url, Class<T> responseType) throws RestClientException

URI 和 URL 的关系：

URI : 统一资源标志符

URL: 统一资源定位符

URN : 统一资源名称

一般用法

• getForEntity

Ribbon 消费者

/**
* 文章基于spring-boot-starter-parent 1.3.7 版本
* 如果读者使用1.5.9 以上的版本，可以用GetMapping
* @return
*/
@RequestMapping(value = "/ribbon-consumer1", method = RequestMethod.GET)
public ResponseEntity<String> helloUser(){
// 返回值是String类型，所以对应第一个逗号后面的类型
// /user/{1} 中的{1}表示的是第一个参数，传的值是didi
// 也可以用getForEntity().getBody() 方法，此时返回值就只是一个String类型
return restTemplate.getForEntity("http://server-provider/user/{1}",String.class,"didi");
}

@RequestMapping(value = "/ribbon-consumer2", method = RequestMethod.GET)
public ResponseEntity<User> helloUser2(){
// 返回值是一个User类型
// 多个参数之间用& 隔开
return restTemplate.getForEntity("http://server-provider/user2?id=001&name=didi",User.class);
}

// 传递一个Map类型的对象
@RequestMapping(value = "/ribbon-consumer3", method = RequestMethod.GET)
public ResponseEntity<String> helloUser3(){
Map params = new HashMap();
params.put("name","data");
// {name}表示的是params中的key
return restTemplate.getForEntity("http://server-provider/user3?name={name}", String.class,params);
}

// 其实最核心的就是通过uri进行调用，上面所有的写法都会转换为下面这种写法
// 也就是说下面这种写法是最根本的。
@RequestMapping(value = "/ribbon-consumer4", method = RequestMethod.GET)
public ResponseEntity<String> helloUser4(){
UriComponents uriComponents = UriComponentsBuilder.fromUriString(
"http://server-provider/user4?name={name}")
.build()
.expand("lx")
.encode();
URI uri = uriComponents.toUri();
return restTemplate.getForEntity(uri,String.class);
}

User 对象

public class User {

private Integer id;
private String name;

public User(){}
public User(Integer id, String name) {
this.id = id;
this.name = name;
}
get and set...
}

服务提供者

来看一下服务提供者的代码：

// 返回的类型是String
@RequestMapping(value = "/user/{name}", method = RequestMethod.GET)
public String helloUser(@PathVariable("name") String name){
return "Hello " + name;
}

// 返回的类型是User
@RequestMapping(value = "/user2", method = RequestMethod.GET)
public User helloUser(User user){
return user;
}

@RequestMapping(value = "/user3", method = RequestMethod.GET)
public String helloUser1(@RequestParam("name") String name){
return "Hello " + name;
}

@RequestMapping(value = "/user4", method = RequestMethod.GET)
public String helloUser2(@RequestParam("name") String name){
return "Hello " + name;
}

• getForObject()

Ribbon 消费者

@RequestMapping(value = "/ribbonGet", method = RequestMethod.GET)
public String ribbonGet(){
// {1} 和 {2} 都是占位符，分别代表着 001 和 lx的值
return restTemplate.getForObject("http://server-provider/ribbon?id={1}&name={2}",String.class,
new Object[]{"001","lx"});
}

// 和上面用法基本相同
@RequestMapping(value = "/ribbonGet2", method = RequestMethod.GET)
public String ribbonGet2(){
Map params = new HashMap();
params.put("id","001");
params.put("name","lx");
return restTemplate.getForObject("http://server-provider/ribbon?id={id}&name={name}",String.class,
params);
}

@RequestMapping(value = "/ribbonGet3", method = RequestMethod.GET)
public String ribbonGet3(){
UriComponents uriComponents = UriComponentsBuilder.fromUriString(
"http://server-provider/ribbon?id={id}&name={name}")
.build()
.expand("001","lx")
.encode();
URI uri = uriComponents.toUri();
return restTemplate.getForObject(uri,String.class);
}

服务提供者

// 上面所有的url共用下面一个方法
@RequestMapping(value = "/ribbon", method = RequestMethod.GET)
public String acceptRibbon(@RequestParam("id")String id,
@RequestParam("name") String name){

System.out.println("id = " + id + "name = " + name);
return "Hello " + id + " World " + name;
}

POST请求

了解完GET请求后，再来看一下POST请求：

在

RestTemplate

// postForEntity
postForEntity(String url, Object request, Class<T> responseType, Object... uriVariables)
postForEntity(String url, Object request, Class<T> responseType, Map<String, ?> uriVariables)
postForEntity(URI url, Object request, Class<T> responseType) throws RestClientException

// postForObject
postForObject(String url, Object request, Class<T> responseType, Object... uriVariables)
postForObject(String url, Object request, Class<T> responseType, Map<String, ?> uriVariables)
postForObject(URI url, Object request, Class<T> responseType) throws RestClientException

// postForLocation
postForLocation(String url, Object request, Object... urlVariables) throws RestClientException
postForLocation(String url, Object request, Map<String, ?> urlVariables) throws RestClientException
postForLocation(URI url, Object request) throws RestClientException

Ribbon服务端

/**
* 文章基于spring-boot-starter-parent 1.3.7 版本
* 如果读者使用1.5.9 以上的版本，可以用 PostMapping
* @return
*/
@RequestMapping(value = "/ribbonPost", method = RequestMethod.POST)
public User ribbonPost(){
User user = new User(001,"lx");
return restTemplate.postForEntity("http://server-provider/rpost",user,User.class)
.getBody();
}

@RequestMapping(value = "/ribbonPost2", method = RequestMethod.POST)
public User ribbonPost2(){
User user = new User(001,"lx");
UriComponents uriComponents = UriComponentsBuilder.fromUriString("http://server-provider/location")
.build()
.expand(user)
.encode();
URI uri = uriComponents.toUri();
return restTemplate.postForEntity(uri,user,User.class).getBody();
}

@RequestMapping(value = "/ribbonPost3", method = RequestMethod.POST)
public String ribbonPost3(){
User user = new User(001,"lx");
// 占位符石str, 服务端可以用 @PathVariable获取
return restTemplate.postForEntity("http://server-provider/rbPost/{str}",user,String.class,"hello")
.getBody();
}

@RequestMapping(value = "/ribbonPost4", method = RequestMethod.POST)
public String ribbonPost4(){
Map<String,String> params = new HashMap<>();
params.put("id","001");
params.put("name","lx");
return restTemplate.postForEntity("http://server-provider/mapPost",params,String.class).getBody();
}

/**
*  restTemplate.postForObject()方法与上面用法几乎相同
*  postForEntity(String url, Object request, Class<T> responseType, Object... uriVariables)
*  postForEntity(String url, Object request, Class<T> responseType, Map<String, ?> uriVariables)
*  postForEntity(URI url, Object request, Class<T> responseType)
*
*. postForLocation 也相似，这里就不再举例说明了
*/

服务提供者

@RequestMapping(value = "/rpost", method = RequestMethod.POST)
public User accpetRibbonPost(@RequestBody User user){
log.info("id = " + user.getId() + " name = " + user.getName());
return user;
}

@RequestMapping(value = "/location", method = RequestMethod.POST)
public User acceptRibbonPost2(@RequestBody User user){
log.info("id = " + user.getId() + " name = " + user.getName());
return user;
}

@RequestMapping(value = "/rbPost/{str}", method = RequestMethod.POST)
public String accpetRibbonPost3(@PathVariable String str, @RequestBody User user){
log.info("str = " + str);
log.info("id = " + user.getId() + " name = " + user.getName());
return str + " " + user.getId() + " " + user.getName();
}

@RequestMapping(value = "/mapPost", method = RequestMethod.POST)
public String acceptRibbonPost4(@RequestBody Map map){
String id = (String)map.get("id");
String name = (String)map.get("name");
return "id = " + id + " name = " + name;
}

PUT请求

Restful中的put请求经常用来修改某些属性的值，他和POST请求相似

一般形式

/*
* 它的形式比较少，只有一种比较形式
*/
put(String url, Object request, Object... urlVariables) throws RestClientException
put(String url, Object request, Map<String, ?> urlVariables) throws RestClientException
put(URI url, Object request) throws RestClientException

Ribbon服务端

@RequestMapping(value = "/putRibbon", method = RequestMethod.PUT)
public void putRibbon(){
restTemplate.put("http://server-provider/ribbonPut",new User(21,"lx"));
}

这里只采用了一种简单形式，用法和Post很相似，没有再详细说明

PUT请求没有返回值，可以理解为只把需要的值传过去就可以，修改成功不成功与我没有关系

服务提供者

@RequestMapping(value = "/ribbonPut", method = RequestMethod.PUT)
public void acceptRibbonPut(@RequestBody User user){
log.info("user.id = " + user.getId() + " user.name = " + user.getName());
}

DELETE请求

delete请求在Restful API中一般用于根据id删除某条信息，用法也比较简单，没有返回值

一般形式

delete(String url, Object... urlVariables) throws RestClientException
delete(String url, Map<String, ?> urlVariables) throws RestClientException
delete(URI url) throws RestClientException

Ribbon服务端

@RequestMapping(value = "/deleteRibbon", method = RequestMethod.DELETE)
public void deleteUser(){
User user = new User(21,"lx");
restTemplate.delete("http://server-provider/ribbonDelete/{1}",user.getId());
}

服务提供者

@RequestMapping(value = "/ribbonDelete/{id}", method = RequestMethod.DELETE)
public void deleteRibbon(@PathVariable Integer id){
log.info("delete user " + id);
}

参考资料：

https://www.jb51.net/article/138563.htm#comments

《Spring Cloud 微服务实战》

欢迎关注

• 点赞 1
• 收藏
• 分享
• 文章举报