SpringCloud之Ribbon
【前面的话】书接上文,本文的某些知识依赖我的上一篇文章:SpringCloud之Eureka,如果没有看过可以先移步去看一下。另外在微服务架构中,业务都会被拆分成一个个独立的服务,服务与服务的通讯是基于http restful的。Spring cloud有两种服务调用方式,一种是ribbon+restTemplate,另一种是feign。在这一篇文章首先讲解下基于ribbon+rest。
公司主营业务:网站建设、做网站、移动网站开发等业务。帮助企业客户真正实现互联网宣传,提高企业的竞争能力。成都创新互联公司是一支青春激扬、勤奋敬业、活力青春激扬、勤奋敬业、活力澎湃、和谐高效的团队。公司秉承以“开放、自由、严谨、自律”为核心的企业文化,感谢他们对我们的高要求,感谢他们从不同领域给我们带来的挑战,让我们激情的团队有机会用头脑与智慧不断的给客户带来惊喜。成都创新互联公司推出新兴免费做网站回馈大家。
壹、Ribbon简介
ribbon是一个负载均衡客户端,可以很好的控制htt和tcp的一些行为。Feign默认集成了ribbon。
- ribbon 已经默认实现了这些配置bean:
IClientConfig ribbonClientConfig: DefaultClientConfigImpl
IRule ribbonRule: ZoneAvoidanceRule
IPing ribbonPing: NoOpPing
ServerList ribbonServerList: ConfigurationBasedServerList
ServerListFilter ribbonServerListFilter: ZonePreferenceServerListFilter
ILoadBalancer ribbonLoadBalancer: ZoneAwareLoadBalancer
# 贰、准备工作
- 新建一个ribbon子工程**lovin-ribbon-client**,用于后面的操作。下面是主要的pom依赖
~~~pom
lovincloud
com.eelve.lovincloud
1.0-SNAPSHOT
4.0.0
lovin-ribbon-client
jar
ribbonclient
0.0.1
ribbon的client
org.springframework.cloud
spring-cloud-starter-netflix-eureka-client
org.springframework.boot
spring-boot-starter-security
org.springframework.boot
spring-boot-starter-web
org.springframework.cloud
spring-cloud-starter-netflix-ribbon
org.springframework.boot
spring-boot-maven-plugin
- 这里为了安全,我这里还是添加spring-boot-starter-security
server: port: 8805 # 服务端口号 spring: application: name: lovinribbonclient # 服务名称 security: basic: enabled: true user: name: lovin password: ${REGISTRY_SERVER_PASSWORD:lovin} eureka: client: serviceUrl: defaultZone: http://lovin:lovin@localhost:8881/eureka/ # 注册到的eureka服务地址
- 配置spring-boot-starter-security,这里为了方便我这里放开所有请求
package com.eelve.lovin.cofig;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.annotation.Order;
import org.springframework.security.config.annotation.web.builders.HttpSecurity;
import org.springframework.security.config.annotation.web.configuration.WebSecurityConfigurerAdapter;
/**
- @ClassName SecurityConfig
- @Description TDO
- @Author zhao.zhilue
- @Date 2019/8/16 14:12
@Version 1.0**/
@Configuration
br/>**/
@Configuration
public class WebSecurityConfig extends WebSecurityConfigurerAdapter {@Override
protected void configure(HttpSecurity http) throws Exception {
http.authorizeRequests().anyRequest().permitAll()
.and().csrf().disable();
}
}- 然后向程序的ioc容器中注入一个bean: restTemplate;并通过@LoadBalanced注解表明这个restRemplate开启负载均衡的功能。 ~~~java package com.eelve.lovin;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;
/**
- @ClassName LovinRibbonClientApplication
- @Description TDO
- @Author zhao.zhilue
- @Date 2019/8/15 16:59
@Version 1.0**/
@SpringBootApplication
br/>**/
@SpringBootApplication
public class LovinRibbonClientApplication {public static void main(String[] args) {
SpringApplication.run(LovinRibbonClientApplication.class,args);
}@Bean@LoadBalanced
br/>@LoadBalanced
return new RestTemplate();
}
}- 然后编写一个**HelloService** ~~~java package com.eelve.lovin.service;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;
/**
- @ClassName HelloService
- @Description TDO
- @Author zhao.zhilue
- @Date 2019/8/15 17:02
@Version 1.0**/
@Service
br/>**/
@Service
br/>@Autowiredpublic String getHello() {
//这里的lovineurkaclient是我上一篇文章新建的eureka客户端的名称
return restTemplate.getForObject("http://lovineurkaclient/hello",String.class);
}
}- 再编写一个**HelloController** ~~~java package com.eelve.lovin.controller;
import com.eelve.lovin.service.HelloService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
/**
- @ClassName HelloController
- @Description TDO
- @Author zhao.zhilue
- @Date 2019/8/15 17:05
@Version 1.0**/
@RestController
br/>**/
@RestController@Autowired
HelloService helloService;@RequestMapping("hello")
public String hello(){
return helloService.getHello();
}
}# 叁、启动测试 - 依次启动eureka的服务端和两个客户端,以及新建的lovin-ribbon-client ![我们可以看到服务已经全部启动成功](https://i.loli.net/2019/08/23/pa1X8eByNhltP4C.png) 我们可以看到服务已经全部启动成功 - 然后访问http://localhost:8805/hello ![我们可以看到已经可以通过ribbon调到我们建立的eureka客户端了](https://i.loli.net/2019/08/23/TXoNiuvYhGO9Hc3.png) 我们可以看到已经可以通过ribbon调到我们建立的eureka客户端了 - 再次请求接口观察返回 ![我们可以看到我们调到了通过ribbon负载的另外一个接口](https://i.loli.net/2019/08/23/o9Cm2LgBXb4qjF5.png) 我们可以看到我们调到了通过ribbon负载的另外一个接口了,到这里我们就已经弄好了一个简单的ribbon负载。
肆、网络架构
- 我们可以看到我们调用的服务不再是像再上一篇文章中的直接访问对应的服务,而是通过Ribbon的负载均衡的去调用的,而且这里说明一点,Ribbon的默认机制是轮询。
- 最后的最后是本博客的源码,欢迎关注这一套SpringCloud的实践
网页标题:SpringCloud之Ribbon
链接地址:http://cdiso.cn/article/josigh.html