国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 開發(fā) > Java > 正文

Spring-cloud 服務(wù)發(fā)現(xiàn)與消費(fèi)(以ribbon為例)

2024-07-14 08:40:18
字體:
供稿:網(wǎng)友

說明:

ribbon是spring-cloud中作為服務(wù)消費(fèi)者的一種角色,客戶端可以通過它來對服務(wù)提供者的服務(wù)進(jìn)行消費(fèi),

比如本例中是服務(wù)提供者注冊到注冊中心,服務(wù)提供者提供了一個(gè)服務(wù)接口,返回一個(gè)hello字符串,我們通過ribbon將這個(gè)接口調(diào)用,再不暴露真實(shí)服務(wù)提供者的地址的同時(shí),獲取服務(wù)提供者的服務(wù)

前提:

按照之前幾個(gè)教程,搭建出注冊中心、服務(wù)提供者。這里可以使用分片的注冊中心,也可以不使用,這里暫時(shí)定為使用之前搭好的分片注冊中心,服務(wù)提供者僅提供一個(gè)即可。

準(zhǔn)備工作:

1、啟動(dòng)注冊中心

按照之前的教程,分別使用peer1和peer2進(jìn)行啟動(dòng)兩個(gè)分片的注冊中心,如果是單節(jié)點(diǎn)直接啟動(dòng)項(xiàng)目即可

spring,cloud,ribbon

啟動(dòng)后可以查看下localhost:1111或localhost:1112,如圖

spring,cloud,ribbonspring,cloud,ribbon

2、啟動(dòng)服務(wù)提供者

這里為了查看負(fù)載均衡的情況,所以需要啟動(dòng)兩個(gè)服務(wù)提供者

按照之前教程中,分別開啟兩個(gè)terminal進(jìn)行指定端口啟動(dòng)(兩個(gè)相同的服務(wù)也可以在各自的配置文件中配置不同的端口),兩個(gè)終端指令分別如下:

cd targetjava -jar SpringCloudDemo-0.0.1-SNAPSHOT.jar --server.port=8080
cd targetjava -jar SpringCloudDemo-0.0.1-SNAPSHOT.jar --server.port=8081

啟動(dòng)結(jié)果:

spring,cloud,ribbon

至此,準(zhǔn)備工作已經(jīng)完成

正文:

1、ribbon服務(wù)搭建

新建一個(gè)maven項(xiàng)目,不使用模板即可。項(xiàng)目名為robbin-customer,導(dǎo)入依賴參考如下:

<?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啟動(dòng)類,將RestTemplate交給Spring容器進(jìn)行管理

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: 消費(fèi)應(yīng)用 * @Date : 2018/4/16 15:45 */@EnableDiscoveryClient@SpringBootApplicationpublic class CustomerApplication {  @Bean //將此Bean交給spring容器  @LoadBalanced //通過此注解開啟負(fù)載均衡  RestTemplate restTemplate(){    return new RestTemplate();  }  public static void main(String[] args) {    SpringApplication.run(CustomerApplication.class, args);  }}

在src/resources目錄下創(chuàng)建一個(gè)application.yml進(jìn)行配置注冊信息相關(guān),本文使用了分片的注冊中心,單節(jié)點(diǎn)請配置一個(gè)defaltZone即可

server: port: 9000  #為ribbon-customer指定服務(wù)端口spring: application:  name: ribbon-customer #指定應(yīng)用名#指定eureka注冊中心地址eureka: client:  serviceUrl:   defaultZone: http://peer1:1111/eureka/,http://peer2:1112/eureka/

在啟動(dòng)類同級(jí)目錄創(chuàng)建CustomerController,注入RestTemplate進(jìn)行調(diào)用服務(wù)接口

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: 消費(fèi)者應(yīng)用 * @Date : 2018/4/16 15:54 */@RestControllerpublic class CustomerController {  @Autowired  //注入restTemplate  private RestTemplate restTemplate;  @RequestMapping(value="/ribbon-customer", method=RequestMethod.GET)  public String helloCustomer(){    //這里注釋掉,因?yàn)橹跋氘?dāng)然使用了直鏈訪問服務(wù)提供者的接口,這樣是不會(huì)返回結(jié)果的,而且會(huì)報(bào)錯(cuò)    //return restTemplate.getForEntity("http://localhost:8080/hello",String.class).getBody();    //使用restTemplate調(diào)用微服務(wù)接口    return restTemplate.getForEntity("http://hello-service/hello", String.class).getBody();  }}

注意:上述代碼第24行給出了一個(gè)錯(cuò)誤的演示,如果出現(xiàn)訪問ribbon接口報(bào)錯(cuò),出現(xiàn)白色報(bào)錯(cuò)頁面,請檢查這里

至此ribbon消費(fèi)者應(yīng)用搭建完成,啟動(dòng)測試

測試:

訪問http://localhost:1111/ 我們發(fā)現(xiàn)這個(gè)ribbon消費(fèi)者應(yīng)用已經(jīng)注冊到注冊中心中了

spring,cloud,ribbon

訪問http://localhost:9000/ribbon-customer

spring,cloud,ribbon

還記得服務(wù)提供者項(xiàng)目中的如圖方法中如果有訪問則會(huì)打印信息,因?yàn)閱?dòng)了兩個(gè)服務(wù)提供者,這里可以測試ribbon的負(fù)載均衡

spring,cloud,ribbon

查看服務(wù)提供者輸出

spring,cloud,ribbon

而第二個(gè)終端沒有,依舊顯示到Resolving eureka endpoints via configuration這行

刷新頁面查看終端,由于ribbon的默認(rèn)負(fù)載均衡的實(shí)現(xiàn)是輪詢的,所以可能出現(xiàn)多次訪問同一服務(wù),多刷新幾次頁面,一定會(huì)在另一個(gè)Termical中顯示的!

spring,cloud,ribbon

結(jié)語:

Ribbon作為服務(wù)消費(fèi)者,可以在用戶獲取到服務(wù)提供者提供的服務(wù)的同時(shí),不向用戶暴露接口地址。可以看到,這里調(diào)用服務(wù)接口的時(shí)候使用的是服務(wù)提供者的服務(wù)名代替主機(jī)名,這在服務(wù)治理框架中,這種特性很重要。

由于本人之前是先學(xué)的jhipster生成器,所以,提前預(yù)報(bào)一下,之后還會(huì)有一種名為Feign的技術(shù)可以替代Ribbon,本系列博客均為學(xué)習(xí)筆記,實(shí)際操作中,可能會(huì)存在一個(gè)應(yīng)用既是服務(wù)提供者又是服務(wù)消費(fèi)者的情況。

以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持VeVb武林網(wǎng)。


注:相關(guān)教程知識(shí)閱讀請移步到JAVA教程頻道。
發(fā)表評論 共有條評論
用戶名: 密碼:
驗(yàn)證碼: 匿名發(fā)表
主站蜘蛛池模板: 西乌珠穆沁旗| 曲阳县| 冕宁县| 德庆县| 西乌珠穆沁旗| 宁武县| 崇信县| 上思县| 南乐县| 潍坊市| 泰顺县| 保亭| 武城县| 乌恰县| 宁夏| 樟树市| 崇礼县| 丽江市| 吉安县| 伊吾县| 若尔盖县| 泽州县| 大悟县| 桂平市| 临漳县| 团风县| 宜川县| 都安| 黎城县| 五寨县| 桂东县| 阿尔山市| 阜阳市| 延吉市| 阿城市| 沙田区| 日喀则市| 探索| 平昌县| 延津县| 新和县|