SpringCloud-服务间通信方式

java1234

共 6218字,需浏览 13分钟

 ·

2020-12-13 00:49

点击上方蓝色字体,选择“标星公众号”

优质文章,第一时间送达

  作者 |  山丘i 

来源 |  urlify.cn/FNbUvi

66套java从入门到精通实战课程分享

接下来在整个微服务架构中,我们比较关心的就是服务间的服务改如何调用,有哪些调用方式?

总结:在springcloud中服务间调用方式主要是使用 http restful方式进行服务间调用


1. 1基于RestTemplate的服务调用

在上面的基础上,使用的是consul注册,pom.xml文件

"1.0" encoding="UTF-8"?>
"http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    4.0.0
    
        org.springframework.boot
        spring-boot-starter-parent
        2.2.5.RELEASE
         
    


    com.md
    04-products9998
    0.0.1-SNAPSHOT
    04-products9998
    Demo project for Spring Boot

    
        1.8
        Hoxton.SR6
    


    
        
            org.springframework.boot
            spring-boot-starter-web
        


        
            org.springframework.boot
            spring-boot-devtools
            runtime
            true
        

        
            org.projectlombok
            lombok
            true
        

        
            org.springframework.boot
            spring-boot-starter-test
            test
        


        
        
            org.springframework.cloud
            spring-cloud-starter-consul-discovery
        


        
        
            org.springframework.boot
            spring-boot-starter-actuator
        




    


    
    
        
            
                org.springframework.cloud
                spring-cloud-dependencies
                ${spring-cloud.version}
                <type>pomtype>
                import
            

        

    


    
        
            
                org.springframework.boot
                spring-boot-maven-plugin
            

        

    





1. 说明


  • spring框架提供的RestTemplate类可用于在应用中调用rest服务,它简化了与http服务的通信方式,统一了RESTful的标准,封装了http链接, 我们只需要传入url及返回值类型即可。相较于之前常用的HttpClient,RestTemplate是一种更优雅的调用RESTful服务的方式。


1.2RestTemplate 服务调用


  1. 创建两个服务并注册到consul注册中心中

  • users 代表用户服务 端口为 9999

  • products 代表商品服务 端口为 9998
    `注意:这里服务仅仅用来测试,没有实际业务意义



1.3 在商品服务中提供服务方法

@RestController
@Slf4j
public class ProductController {
    @Value("${server.port}")
    private int port;
    @GetMapping("/product/findAll")
    public Map findAll(){
        log.info("商品服务查询所有调用成功,当前服务端口:[{}]",port);
        Map map = new HashMap();
        map.put("msg","服务调用成功,服务提供端口为: "+port);
        map.put("status",true);
        return map;
    }
}



1.4在用户服务中使用restTemplate进行调用


@RestController
@Slf4j
public class UserController {
    @GetMapping("/user/findAll")
    public String findAll(){
        log.info("调用用户服务...");
        //1. 使用restTemplate调用商品服务
        RestTemplate restTemplate = new RestTemplate();
        // get请求getxxx,post请求postxxx
        // 参数1:请求路径,参数2:返回的类型是String的
        String forObject = restTemplate.getForObject("http://localhost:9998/product/findAll"
                                                     String.class);
        return forObject;
    }
}


1.5启动服务





1.6测试服务调用


  • 浏览器访问用户服务 http://localhost:9999/user/findAll


1.7 总结


  • rest Template是直接基于服务地址调用没有在服务注册中心获取服务,也没有办法完成服务的负载均衡如果需要实现服务的负载均衡需要自己书写服务负载均衡策略。
    restTemplate直接调用存在问题

  • 1.直接使用restTemplate方式调用没有经过服务注册中心获取服务地址,代码写死不利于维护,当服务宕机时不能高效剔除

  • 2.调用服务时没有负载均衡需要自己实现负载均衡策略



2. 基于Ribbon的服务调用


2.0说明


  • 官方网址: https://github.com/Netflix/ribbon

  • Spring Cloud Ribbon是一个基于HTTP和TCP的客户端负载均衡工具,它基于Netflix Ribbon实现。通过Spring Cloud的封装,可以让我们轻松地将面向服务的REST模版请求自动转换成客户端负载均衡的服务调用。

再创建一个服务类,和上面的服务类一样,只有端口不同

server.port=9997
spring.application.name=products
spring.cloud.consul.port=8500
spring.cloud.consul.host=localhost


其他一样

@RestController
@Slf4j
public class ProductController {
    @Value("${server.port}")
    private int port;
    @GetMapping("/product/findAll")
    public Map findAll(){
        log.info("商品服务查询所有调用成功,当前服务端口:[{}]",port);
        Map map = new HashMap();
        map.put("msg","服务调用成功,服务提供端口为: "+port);
        map.put("status",true);
        return map;
    }
}

2.1Ribbon 服务调用

# 1.项目中引入依赖
- 说明: 
 1.如果使用的是eureka client 和 consul client,无须引入依赖,因为在eureka,consul中默认集成了ribbon组件
 2.如果使用的client中没有ribbon依赖需要显式引入如下依赖



  org.springframework.cloud
  spring-cloud-starter-netflix-ribbon


# 2.查看consul client中依赖的ribbon

# 3.使用restTemplate + ribbon进行服务调用
- 使用discovery client  进行客户端调用
- 使用loadBalanceClient 进行客户端调用
- 使用@loadBalanced     进行客户端调用

# 3.1 使用discovery Client形式调用

@Autowired
private DiscoveryClient discoveryClient;

//获取服务列表,返回全部的,服务id,上面的products
List products = discoveryClient.getInstances("服务ID");
for (ServiceInstance product : products) {
  log.info("服务主机:[{}]",product.getHost());
  log.info("服务端口:[{}]",product.getPort());
  log.info("服务地址:[{}]",product.getUri());
  log.info("====================================");
}

# 3.2 使用loadBalance Client形式调用

@Autowired
private LoadBalancerClient loadBalancerClient;
//根据负载均衡策略选取某一个服务调用,服务id=products
ServiceInstance product = loadBalancerClient.choose("服务ID");//地址  默认轮询策略
log.info("服务主机:[{}]",product.getHost());
log.info("服务端口:[{}]",product.getPort());
log.info("服务地址:[{}]",product.getUri());

# 3.3 使用@loadBalanced(常用)

//1.整合restTemplate + ribbon
@Configuration
public class RestTemplateConfig {

    // 在工厂中创建一个restTemplate对象
    @Bean
    // 加上这个注解代表当前的restTemplate对象带有ribbon负载均衡
    @LoadBalanced
    public RestTemplate getRestTemplate(){
        return new RestTemplate();
    }
}

//2.调用controller服务位置注入RestTemplate
// 此时的restTemplate就具有了负载均衡的功能
@Autowired
private RestTemplate restTemplate;

//3.调用
@RestController
@Slf4j
public class UserController {
    @Autowired
 private RestTemplate restTemplate;
    
    @GetMapping("/user/findAll")
    public String findAll(){
        // 服务id就是在配置文件中的当前服务名products
        String forObject = restTemplate.getForObject("http://服务ID/product/findAll"
                                                     String.class);
        return forObject;
    }
}

默认的轮训策略,也就是当前访问的9998,之后是9997,循环访问


2.2Ribbon负载均衡策略

ribbon负载均衡算法

  • RoundRobinRule 轮训策略 按顺序循环选择 Server

  • RandomRule 随机策略 随机选择 Server

  • AvailabilityFilteringRule 可用过滤策略
    `会先过滤由于多次访问故障而处于断路器跳闸状态的服务,还有并发的连接数量超过阈值的服务,然后对剩余的服务列表按照轮询策略进行访问

  • WeightedResponseTimeRule 响应时间加权策略
    `根据平均响应的时间计算所有服务的权重,响应时间越快服务权重越大被选中的概率越高,刚启动时如果统计信息不足,则使用RoundRobinRule策略,等统计信息足够会切换到

  • RetryRule 重试策略
    `先按照RoundRobinRule的策略获取服务,如果获取失败则在制定时间内进行重试,获取可用的服务。

  • BestAviableRule 最低并发策略
    `会先过滤掉由于多次访问故障而处于断路器跳闸状态的服务,然后选择一个并发量最小的服务


2.3修改服务的默认负载均衡策略

# 1.修改服务默认随机策略
- 服务id.ribbon.NFLoadBalancerRuleClassName=com.netflix.loadbalancer.RandomRule
 `下面的products为服务的唯一标识

products.ribbon.NFLoadBalancerRuleClassName=com.netflix.loadbalancer.RandomRule



2.4Ribbon停止维护

# 1.官方停止维护说明
- https://github.com/Netflix/ribbon




粉丝福利:Java从入门到入土学习路线图

???

?长按上方微信二维码 2 秒


感谢点赞支持下哈 


浏览 10
点赞
评论
收藏
分享

手机扫一扫分享

分享
举报
评论
图片
表情
推荐
点赞
评论
收藏
分享

手机扫一扫分享

分享
举报