【SpringCloud项目实战】RestTemplate

ゝ一世哀愁。 2022-11-25 13:28 162阅读 0赞

**目录**

一. 什么是RestTemplate

二.一个简单的例子。

三、SpringCloud中RestTemplate的用法：

--------------------

# 一. 什么是RestTemplate #

优雅的HTTP请求：

传统情况下在java代码里访问restful服务，一般使用Apache的HttpClient。不过此种方法使用起来太过繁琐。

spring提供了一种简单便捷的模板类来进行操作，这就是RestTemplate。

# 二.一个简单的例子。 #

定义一个简单的restful接口

@RestControllerpublic class TestController

@RequestMapping(value = "testPost", method = RequestMethod.POST)

public ResponseBean testPost(@RequestBody RequestBean requestBean)

ResponseBean responseBean = new ResponseBean();

responseBean.setRetCode("0000");

responseBean.setRetMsg("succ");

return responseBean;

\}\}

使用RestTemplate访问该服务

//请求地址

String url = "http://localhost:8080/testPost";

//入参

RequestBean requestBean = new RequestBean();

requestBean.setTest1("1");

requestBean.setTest2("2");

requestBean.setTest3("3");

RestTemplate restTemplate = new RestTemplate();

ResponseBean responseBean = restTemplate.postForObject(url, requestBean, ResponseBean.class);

从这个例子可以看出，使用restTemplate访问restful接口非常的 **简单粗暴无脑**。(url, requestMap, ResponseBean.class)这三个参数分别代表 请求地址、请求参数、HTTP响应转换被转换成的对象类型。

RestTemplate方法的名称遵循命名约定，第一部分指出正在调用什么HTTP方法，第二部分指示返回的内容。本例中调用了restTemplate.postForObject方法，post指调用了HTTP的post方法，Object指将HTTP响应转换为您选择的 **对象类型**。还有其他很多类似的方法，有兴趣的同学可以 [参考官方api][api]。

**以上demo作者：白驹过隙\_忽然而已**

**链接：[https://www.jianshu.com/p/90ec27b3b518][https_www.jianshu.com_p_90ec27b3b518]**

# **三、SpringCloud中****RestTemplate****的用法：** #

继续上篇：Eureka

现有两个服务提供端：8001；8002 ，服务名字都是CLOUD\_PAYMENT\_SERVICE

服务调用端在调用的时候，需要进行负载均衡，通过轮询，随机等方式对服务提供方进行调用

> **80Controller层**
> 
>  
> 
> // 直接服务提供方的服务的名字
> 
> public static final String PAY\_URL="http://CLOUD-PAYMENT-SERVICE";
> 
> **@Resource**
> 
> **public RestTemplate restTemplate;**
> 
>  
> 
>  
> 
> @GetMapping("/consumer/payment/get/\{id\}")
> 
> public CommonResult<Payment> getPaymentById(@PathVariable("id") Long id)\{ 
> 
>     return **restTemplate.getForObject**(PAY\_URL+"/payment/get/"+id,CommonResult.class);
> 
> \}

*PS：下段代码需要参考Springbean注入、配置方式*

**工具类： RestTemplate定义为bean；这样在@Resource的时候才能注入Controller层的类**

> @Configuration
> 
> public class ApplicationContextConfig \{ 
> 
>     @Bean
> 
>    ** @LoadBalanced**
> 
>     public RestTemplate getRestTemplate()\{ 
> 
>       return  new RestTemplate();
> 
>     \}
> 
> \}

SpringCloud-common包提供的注解 ： **@LoadBalanced 可以实现轮序调用不同的服务提供服务**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3htbDE5OTY_size_16_color_FFFFFF_t_70][]

**模拟轮询的底层实现：**

**通过原子类+CAS实现**

> public interface **LoadBalancer** \{ 
> 
>     /\*
> 
>      \* 1、自旋，CAS进行获取，请求的次数
> 
>     \* 2、请求的次数 % 根据服务的个数= 求余数，获取轮询的服务的内容serviceInstance
> 
>     \* \*/
> 
>  
> 
>    ServiceInstance **instance**(List<ServiceInstance> serviceInstanceList);
> 
>  
> 
>  
> 
> \}
> 
> /\*\*
> 
> \* @introduce: 轮询
> 
> \* @author: xingMeiLing
> 
> \* @DATE: 2020/6/29
> 
> \*\*/
> 
> @Component
> 
> public class MyLB implements **LoadBalancer** \{ 
> 
> /\*
> 
> \* 1、请求的次数 % 根据服务的个数= 求余数，获取轮询的服务的内容serviceInstance
> 
> \* 2、自旋，CAS进行获取，请求的次数
> 
> \* \*/
> 
>  
> 
> // 用原子数据类型;初始化0
> 
> private AtomicInteger atomicInteger = new AtomicInteger(0);
> 
>  
> 
>  
> 
> /\*\*
> 
> \* 请求的次数 % 根据服务的个数= 求余数 0 或 1
> 
> \*
> 
> \* @author xingMeiLing
> 
> \* @param serviceInstanceList 获取轮询的服务的内容serviceInstance
> 
> \* @return
> 
> \*/
> 
> @Override
> 
> public ServiceInstance **instance**(List<ServiceInstance> serviceInstanceList) \{ 
> 
> int index = this.**getAndInCrement()** % serviceInstanceList.size();
> 
> return serviceInstanceList.get(index);
> 
> \}
> 
> /\*\*
> 
> \* 自旋，CAS进行获取，请求的次数
> 
> \*
> 
> \* @author xingMeiLing
> 
> \* @return next 请求的次数
> 
> \*/
> 
> public final int **getAndInCrement()**\{ 
> 
> int current;
> 
> int next;
> 
> do\{ 
> 
> current = this. atomicInteger.get();
> 
> next = current >= 2147483647 ? 0: current +1;
> 
> \}while (!this.atomicInteger.compareAndSet(current,next));
> 
> System.out.println("次数" + next);
> 
> return next;
> 
> \}
> 
> \}
> 
>

**80主启动类上：**

> @SpringBootApplication
> 
> @EnableEurekaClient
> 
> **@RibbonClient(name = "CLOUD-PAYMENT-SERVICE",configuration = MySelfRule.class)**
> 
> public class OrderMain80 \{ 
> 
>     public static void main(String\[\] args) \{ 
> 
>         SpringApplication.run(OrderMain80.class,args);
> 
>     \}
> 
> \}

**RibbonClient注解是Eureka实现的**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3htbDE5OTY_size_16_color_FFFFFF_t_70 1][]

服务发现的注解@EnableDiscoverClient (在启动类上配置)

**80Controller类：**

> @Resource
> 
> public RestTemplate restTemplate;
> 
> @Resource
> 
> private **DiscoveryClient discoveryClient**;
> 
> @Resource
> 
> private **LoadBalancer** loadBalancer;
> 
> @GetMapping("/consumer/payment/lb")
> 
> public String getPaymentLB()\{ 
> 
>       //  获取服务提供方；服务发现类： DiscoveryClient 是springcloud-common包下的用来查询服务的类
> 
>     List<ServiceInstance> serviceInstances  = **discoveryClient**.getInstances("CLOUD-PAYMENT-SERVICE");
> 
>     if(serviceInstances == null || serviceInstances.size() <=0)\{ 
> 
>         return null;
> 
>     \}
> 
>     ServiceInstance serviceInstance = loadBalancer.instance(serviceInstances);
> 
>     URI uri = serviceInstance.getUri();
> 
>     return restTemplate.getForObject(uri+"/payment/lb",String.class);
> 
> \}

[api]: http://docs.spring.io/spring-framework/docs/4.3.7.RELEASE/javadoc-api/org/springframework/web/client/RestTemplate.html
[https_www.jianshu.com_p_90ec27b3b518]: https://www.jianshu.com/p/90ec27b3b518
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3htbDE5OTY_size_16_color_FFFFFF_t_70]: /images/20221124/a35148fe33d04bcfbd6be75b6193adec.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3htbDE5OTY_size_16_color_FFFFFF_t_70 1]: /images/20221124/62c7914294e041bab6091a17d240d101.png