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

Posted 2020-11-03 ljhseocom

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了pring-cloud 服务发现与消费(以ribbon为例)相关的知识，希望对你有一定的参考价值。

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

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

前提：

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

准备工作：

1、启动注册中心

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

技术分享图片

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

技术分享图片

2、启动服务提供者

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

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

cd target
java -jar SpringCloudDemo-0.0.1-SNAPSHOT.jar --server.port=8080

复制代码

cd target
java -jar SpringCloudDemo-0.0.1-SNAPSHOT.jar --server.port=8081

复制代码

启动结果：

技术分享图片

至此，准备工作已经完成

正文：

1、ribbon服务搭建

新建一个maven项目，不使用模板即可。项目名为robbin-customer，导入依赖参考如下：

<?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容器进行管理

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 {
[url=home.php?mod=space&uid=4377]@Bean[/url] //将此Bean交给spring容器
@LoadBalanced //通过此注解开启负载均衡
RestTemplate restTemplate(){
return new RestTemplate();
}
public static void main(String[] args) {
SpringApplication.run(CustomerApplication.class, args);
}
}

复制代码

在src/resources目录下创建一个application.yml进行配置注册信息相关，本文使用了分片的注册中心，单节点请配置一个defaltZone即可

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进行调用服务接口

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接口报错，出现白色报错页面，请检查这里

http://www.ljhseo.com/
http://www.xyrjkf.net/
http://www.xyrjkf.cn/
http://www.xyrjkf.com.cn/
http://www.zjdygsi.cn/
http://www.zjdaiyun.cn/
http://www.jsdygsi.cn/
http://www.xyrjkf.top/
http://www.xyrjkf.com/
http://www.daiyunzj.cn/
http://ljhseo.com/
http://xyrjkf.net/
http://xyrjkf.cn/
http://xyrjkf.com.cn/
http://zjdygsi.cn/
http://zjdaiyun.cn/
http://jsdygsi.cn/
http://xyrjkf.top/
http://xyrjkf.com/
http://daiyunzj.cn/