spring-cloud(二)服務消費者(rest+ribbon)(Finchley版本)
在微服務架構中,業務都會被拆分成一個獨立的服務,服務與服務的通訊是基於http restful的。Spring cloud有兩種服務呼叫方式,一種是ribbon+restTemplate,另一種是feign
ribbon是一個負載均衡客戶端,可以很好的控制http和tcp的一些行為。Feign預設集成了ribbon。
ribbon 已經預設實現了這些配置bean:
- IClientConfig ribbonClientConfig: DefaultClientConfigImpl
- IRule ribbonRule: ZoneAvoidanceRule
- IPing ribbonPing: NoOpPing
- ServerList ribbonServerList: ConfigurationBasedServerList
- ServerListFilter ribbonServerListFilter: ZonePreferenceServerListFilter
- ILoadBalancer ribbonLoadBalancer: ZoneAwareLoadBalancer
啟動 eureka-server 埠8761 啟動eureka-client 埠8762 啟動eureka-client 埠8763
這樣eureka-client 在eureka-server中註冊了兩個例項 埠分別為8762 8763
新建服務消費者 ribbon-server
在主工程下新建module ribbon-server
在它的pom.xml繼承了父pom檔案,並引入了以下依賴
<?xml version="1.0" encoding="UTF-8"?> <project xmlns="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 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>com.xuxu</groupId> <artifactId>ribbon-server</artifactId> <version>0.0.1-SNAPSHOT</version> <packaging>jar</packaging> <name>ribbon-server</name> <description>Demo project for Spring Boot</description> <parent> <groupId>com.xuxu</groupId> <artifactId>springcloud01</artifactId> <version>1.0-SNAPSHOT</version> </parent> <dependencies> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-ribbon</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> </dependencies> </project>
配置檔案application.yml如下
server:
port: 8764
eureka:
client:
serviceUrl:
defaultZone: http://localhost:8761/eureka/
spring:
application:
name: ribbon-server
啟動類上加入註解@EnableEurekaClient @EnableDiscoveryClient 並且通過@Bean注入RestTemplate,通過@LoadBalanced開啟負載均衡
@SpringBootApplication
@EnableEurekaClient
@EnableDiscoveryClient
public class RibbonServerApplication {
public static void main(String[] args) {
SpringApplication.run(RibbonServerApplication.class, args);
}
@Bean
@LoadBalanced
public RestTemplate restTemplate(){
return new RestTemplate();
}
}
通過之前注入ioc容器的restTemplate來消費rureka-client服務的“/hi”介面,在這裡我們直接用的程式名替代了具體的url地址,在ribbon中它會根據服務名來選擇具體的服務例項,根據服務例項在請求的時候會用具體的url替換掉服務名
@Service
public class HelloService {
@Autowired
private RestTemplate restTemplate;
public String hello(String name){
return restTemplate.getForObject("http://eureka-client/hi?name="+name,String.class);
}
}
restTemplate.getForObject("http://eureka-client/hi?name="+name,String.class);
代表以GET形式請求指定URL,返回string型別 這裡由ribbon通過服務名稱選擇例項,然後替換成對應的url
建立controller
@RestController
public class HelloController {
@Autowired
private HelloService helloService;
@GetMapping(value = "/hi")
public String hello(@RequestParam(value = "name") String name){
return helloService.hello(name);
}
}
啟動服務
檢視eureka-server中的例項
通過瀏覽器訪問http://localhost:8764/hi?name=123
發現該請求交替訪問8762 和 8763的服務
這說明當我們通過呼叫restTemplate.getForObject("http://eureka-client/hi?name="+name,String.class)方法時,已經做了負載均衡,訪問了不同的埠的服務例項
此時架構圖