Spring-cloud 服务发现与消费(以ribbon为例)

2025-05-29 0 37

说明:

ribbon是spring-cloud中作为服务消费者的一种角色,客户端可以通过它来对服务提供者的服务进行消费,

比如本例中是服务提供者注册到注册中心,服务提供者提供了一个服务接口,返回一个hello字符串,我们通过ribbon将这个接口调用,再不暴露真实服务提供者的地址的同时,获取服务提供者的服务

前提:

按照之前几个教程,搭建出注册中心、服务提供者。这里可以使用分片的注册中心,也可以不使用,这里暂时定为使用之前搭好的分片注册中心,服务提供者仅提供一个即可。

准备工作:

1、启动注册中心

按照之前的教程,分别使用peer1和peer2进行启动两个分片的注册中心,如果是单节点直接启动项目即可

Spring-cloud 服务发现与消费(以ribbon为例)

启动后可以查看下localhost:1111或localhost:1112,如图

Spring-cloud 服务发现与消费(以ribbon为例)Spring-cloud 服务发现与消费(以ribbon为例)

2、启动服务提供者

这里为了查看负载均衡的情况,所以需要启动两个服务提供者

按照之前教程中,分别开启两个terminal进行指定端口启动(两个相同的服务也可以在各自的配置文件中配置不同的端口),两个终端指令分别如下:

?

1

2
cd target

java -jar springclouddemo-0.0.1-snapshot.jar --server.port=8080

?

1

2
cd target

java -jar springclouddemo-0.0.1-snapshot.jar --server.port=8081

启动结果:

Spring-cloud 服务发现与消费(以ribbon为例)

至此,准备工作已经完成

正文:

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

@springbootapplication

public 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

*/

@restcontroller

public 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消费者应用已经注册到注册中心中了

Spring-cloud 服务发现与消费(以ribbon为例)

访问http://localhost:9000/ribbon-customer

Spring-cloud 服务发现与消费(以ribbon为例)

还记得服务提供者项目中的如图方法中如果有访问则会打印信息,因为启动了两个服务提供者,这里可以测试ribbon的负载均衡

Spring-cloud 服务发现与消费(以ribbon为例)

查看服务提供者输出

Spring-cloud 服务发现与消费(以ribbon为例)

而第二个终端没有,依旧显示到resolving eureka endpoints via configuration这行

刷新页面查看终端,由于ribbon的默认负载均衡的实现是轮询的,所以可能出现多次访问同一服务,多刷新几次页面,一定会在另一个termical中显示的!

Spring-cloud 服务发现与消费(以ribbon为例)

结语:

ribbon作为服务消费者,可以在用户获取到服务提供者提供的服务的同时,不向用户暴露接口地址。可以看到,这里调用服务接口的时候使用的是服务提供者的服务名代替主机名,这在服务治理框架中,这种特性很重要。

由于本人之前是先学的jhipster生成器,所以,提前预报一下,之后还会有一种名为feign的技术可以替代ribbon,本系列博客均为学习笔记,实际操作中,可能会存在一个应用既是服务提供者又是服务消费者的情况。

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持快网idc。

原文链接:http://www.cnblogs.com/hellxz/p/8862209.html

收藏 (0) 打赏

感谢您的支持,我会继续努力的!

打开微信/支付宝扫一扫,即可进行扫码打赏哦,分享从这里开始,精彩与您同在
点赞 (0)

声明:本站所有文章,如无特殊说明或标注,均为本站原创发布。任何个人或组织,在未征得本站同意时,禁止复制、盗用、采集、发布本站内容到任何网站、书籍等各类媒体平台。如若本站内容侵犯了原著者的合法权益,可联系我们进行处理。

快网idc优惠网 建站教程 Spring-cloud 服务发现与消费(以ribbon为例) https://www.kuaiidc.com/112038.html

相关文章

发表评论
暂无评论