说明：
ribbon是spring-cloud中作为服务消费者的一种角色，客户端可以通过它来对服务提供者的服务进行消费，
比如本例中是服务提供者注册到注册中心，服务提供者提供了一个服务接口，返回一个hello字符串，我们通过ribbon将这个接口调用，再不暴露真实服务提供者的地址的同时，获取服务提供者的服务
前提：
按照之前几个教程，搭建出注册中心、服务提供者。这里可以使用分片的注册中心，也可以不使用，这里暂时定为使用之前搭好的分片注册中心，服务提供者仅提供一个即可。
准备工作：
1、启动注册中心
按照之前的教程，分别使用peer1和peer2进行启动两个分片的注册中心，如果是单节点直接启动项目即可
启动后可以查看下localhost:1111或localhost：1112，如图
2、启动服务提供者
这里为了查看负载均衡的情况，所以需要启动两个服务提供者
按照之前教程中，分别开启两个terminal进行指定端口启动（两个相同的服务也可以在各自的配置文件中配置不同的端口），两个终端指令分别如下：
|
1
2
|
cd targetjava -jar springclouddemo-0.0.1-snapshot.jar --server.port=8080 |
|
1
2
|
cd targetjava -jar springclouddemo-0.0.1-snapshot.jar --server.port=8081 |
启动结果：
至此，准备工作已经完成
正文：
1、ribbon服务搭建
新建一个maven项目，不使用模板即可。项目名为robbin-customer，导入依赖参考如下：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
|
<?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.hellxz</groupid> <artifactid>ribbon-customer</artifactid> <version>1.0-snapshot</version> <parent> <groupid>org.springframework.boot</groupid> <artifactid>spring-boot-starter-parent</artifactid> <version>1.5.9.release</version> <relativepath/> </parent> <dependencies> <dependency> <groupid>org.springframework.boot</groupid> <artifactid>spring-boot-starter-web</artifactid> </dependency> <dependency> <groupid>org.springframework.cloud</groupid> <artifactid>spring-cloud-starter-eureka</artifactid> <version>release</version> </dependency> <dependency> <groupid>org.springframework.cloud</groupid> <artifactid>spring-cloud-starter-ribbon</artifactid> <version>release</version> </dependency> </dependencies> <dependencymanagement> <dependencies> <dependency> <groupid>org.springframework.cloud</groupid> <artifactid>spring-cloud-dependencies</artifactid> <version>release</version> <scope>import</scope> <type>pom</type> </dependency> </dependencies> </dependencymanagement></project> |
新建springboot启动类，将resttemplate交给spring容器进行管理
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
|
package com.cnblogs.hellxz;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;/** * @author : hellxz * @description: 消费应用 * @date : 2018/4/16 15:45 */@enablediscoveryclient@springbootapplicationpublic class customerapplication { @bean //将此bean交给spring容器 @loadbalanced //通过此注解开启负载均衡 resttemplate resttemplate(){ return new resttemplate(); } public static void main(string[] args) { springapplication.run(customerapplication.class, args); }} |
在src/resources目录下创建一个application.yml进行配置注册信息相关，本文使用了分片的注册中心，单节点请配置一个defaltzone即可
|
1
2
3
4
5
6
7
8
9
10
11
12
|
server: port: 9000 #为ribbon-customer指定服务端口spring: application: name: ribbon-customer #指定应用名#指定eureka注册中心地址eureka: client: serviceurl: defaultzone: http://peer1:1111/eureka/,http://peer2:1112/eureka/ |
在启动类同级目录创建customercontroller，注入resttemplate进行调用服务接口
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
|
package com.cnblogs.hellxz;import org.springframework.beans.factory.annotation.autowired;import org.springframework.web.bind.annotation.requestmapping;import org.springframework.web.bind.annotation.requestmethod;import org.springframework.web.bind.annotation.restcontroller;import org.springframework.web.client.resttemplate;/** * @author : hellxz * @description: 消费者应用 * @date : 2018/4/16 15:54 */@restcontrollerpublic class customercontroller { @autowired //注入resttemplate private resttemplate resttemplate; @requestmapping(value="/ribbon-customer", method=requestmethod.get) public string hellocustomer(){ //这里注释掉，因为之前想当然使用了直链访问服务提供者的接口，这样是不会返回结果的，而且会报错 //return resttemplate.getforentity("http://localhost:8080/hello",string.class).getbody(); //使用resttemplate调用微服务接口 return resttemplate.getforentity("http://hello-service/hello", string.class).getbody(); }} |
注意：上述代码第24行给出了一个错误的演示，如果出现访问ribbon接口报错，出现白色报错页面，请检查这里
至此ribbon消费者应用搭建完成，启动测试
测试：
访问http://localhost:1111/ 我们发现这个ribbon消费者应用已经注册到注册中心中了
访问http://localhost:9000/ribbon-customer
还记得服务提供者项目中的如图方法中如果有访问则会打印信息，因为启动了两个服务提供者，这里可以测试ribbon的负载均衡
查看服务提供者输出
而第二个终端没有，依旧显示到resolving eureka endpoints via configuration这行
刷新页面查看终端，由于ribbon的默认负载均衡的实现是轮询的，所以可能出现多次访问同一服务，多刷新几次页面，一定会在另一个termical中显示的！
结语：
ribbon作为服务消费者，可以在用户获取到服务提供者提供的服务的同时，不向用户暴露接口地址。可以看到，这里调用服务接口的时候使用的是服务提供者的服务名代替主机名，这在服务治理框架中，这种特性很重要。
由于本人之前是先学的jhipster生成器，所以，提前预报一下，之后还会有一种名为feign的技术可以替代ribbon，本系列博客均为学习笔记，实际操作中，可能会存在一个应用既是服务提供者又是服务消费者的情况。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持服务器之家。
原文链接：http://www.cnblogs.com/hellxz/p/8862209.html
