SpringCloud服务消费有哪几种方式？ / 憋错料

一、使用LoadBalancerClient
LoadBalancerClient接口的命名中，可以看出这是一个负载均衡客户端的抽象定义，spring提供了一个实现
org.springframework.cloud.netflix.ribbon.RibbonLoadBalancerClient
1、pom.xml
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.1.7.RELEASE</version>
<relativePath /> 
</parent>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter</artifactId>
</dependency>

<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.47</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-thymeleaf</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
</dependencies>
2、application.yml
server:
#服务端口号
port: 8080
spring:
application:
#服务名称
name: vis-basic-report
thymeleaf:
cache: false
cloud:
consul:
host: 192.168.12.125
port: 8500
discovery:
#是否需要注册到consul中
register: true
#服务地址直接为IP地址
hostname: 192.168.12.1
management:
endpoints:
web:
exposure:
include: ‘*‘
3、启动类
package com.wzl.springcloud.basic.report;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.web.servlet.ServletRegistrationBean;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.context.annotation.Bean;
import com.netflix.hystrix.contrib.metrics.eventstream.HystrixMetricsStreamServlet;br/>@SpringBootApplication
@EnableDiscoveryClient
public class ReportServerApplication {
public static void main(String[] args) {
SpringApplication.run(ReportServerApplication.class, args);
}
}
4、相关实现类
package com.wzl.springcloud.basic.report.service;
import java.util.List;
import com.wzl.springcloud.basic.report.vo.City;
import com.wzl.springcloud.basic.report.vo.WeatherResponse;
public interface WeatherReportService {
// 根据城市ID同步天气
WeatherResponse getDataByCityId(String cityId);
// 根据城市name同步天气
WeatherResponse getDataByCityName(String cityName);
// 获取所有城市列表
List<City> getDataByCities();
}
package com.wzl.springcloud.basic.report.service.impl;
import java.util.List;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.loadbalancer.LoadBalancerClient;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;
import com.alibaba.fastjson.JSON;
import com.wzl.springcloud.basic.report.service.WeatherReportService;
import com.wzl.springcloud.basic.report.vo.City;
import com.wzl.springcloud.basic.report.vo.WeatherResponse;
/**

LoadBalancer客户端br/>*/
@Service
public class WeatherReportServiceLoadBalancerClientImpl implements WeatherReportService {br/>@Autowired
private LoadBalancerClient loadBalancer;

@Override
public WeatherResponse getDataByCityId(String cityId) {
WeatherResponse weatherResponse = null;
ServiceInstance serviceInstance = loadBalancer.choose("vis-basic-weather");
String uri = serviceInstance.getUri().toString() + "/weather/cityId/" + cityId;
// 调用服务接口来获取
ResponseEntity<String> respString = new RestTemplate().getForEntity(uri, String.class);
// 判断ResponseEntity的状态码是否为200，为200时取出strBody
if (respString.getStatusCodeValue() == 200) {
String jsonStr = respString.getBody();
weatherResponse = JSON.parseObject(jsonStr, WeatherResponse.class);
}
return weatherResponse;br/>}
@Override
public WeatherResponse getDataByCityName(String cityName) {
WeatherResponse weatherResponse = null;
ServiceInstance serviceInstance = loadBalancer.choose("vis-basic-weather");
String uri = serviceInstance.getUri().toString() + "/weather/cityName/" + cityName;
// 调用服务接口来获取
ResponseEntity<String> respString = new RestTemplate().getForEntity(uri, String.class);
// 判断ResponseEntity的状态码是否为200，为200时取出strBody
if (respString.getStatusCodeValue() == 200) {
String jsonStr = respString.getBody();
weatherResponse = JSON.parseObject(jsonStr, WeatherResponse.class);
}
return weatherResponse;
}
function(){ //AxiTrader返佣：www.kaifx.cn/broker/axitrader.html br/>@Override
public List<City> getDataByCities() {
List<City> cityList = null;
ServiceInstance serviceInstance = loadBalancer.choose("vis-basic-city");
String uri = serviceInstance.getUri().toString() + "/cities/getList";
// 调用服务接口来获取
ResponseEntity<String> respString = new RestTemplate().getForEntity(uri, String.class);
// 判断ResponseEntity的状态码是否为200，为200时取出strBody
if (respString.getStatusCodeValue() == 200) {
String jsonStr = respString.getBody();
cityList = JSON.parseArray(jsonStr, City.class);
}
return cityList;
}
}
二、使用Ribbon
Spring Cloud Ribbon是基于Netflix Ribbon实现的一套客户端负载均衡的工具。它是一个基于HTTP和TCP的客户端负载均衡器。它可以通过在客户端中配置ribbonServerList来设置服务端列表去轮询访问以达到均衡负载的作用。
1、pom.xml
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.1.7.RELEASE</version>
<relativePath /> 
</parent>

<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud</artifactId>
</dependency>

<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.47</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-thymeleaf</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
</dependencies>
2、application.yml
server:
#服务端口号
port: 8080
spring:
application:
#服务名称
name: vis-basic-report
thymeleaf:
cache: false
cloud:
consul:
host: 192.168.12.125
port: 8500
discovery:
#是否需要注册到consul中
register: true
#服务地址直接为IP地址
hostname: 192.168.12.1
management:
endpoints:
web:
exposure:
include: ‘*‘
3、启动类 & RestConfiguration
package com.wzl.springcloud.basic.report;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.openfeign.EnableFeignClients;br/>@SpringBootApplication
@EnableFeignClients
public class ReportServerApplication {
public static void main(String[] args) {
SpringApplication.run(ReportServerApplication.class, args);
}
}
package com.wzl.springcloud.basic.report.config;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.web.client.RestTemplateBuilder;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;br/>@Configuration
public class RestConfiguration {br/>@Autowired
private RestTemplateBuilder builder;br/>@Bean
@LoadBalanced
public RestTemplate restTemplate() {
return builder.build();br/>}
}
@LoadBalanced注解表明这个restRemplate开启负载均衡的功能，用LoadBalancerClient配置，并且会替换URL中的服务名称为具体的IP地址
4、相关实现类
package com.wzl.springcloud.basic.report.service;
import java.util.List;
import com.wzl.springcloud.basic.report.vo.City;
import com.wzl.springcloud.basic.report.vo.WeatherResponse;
public interface WeatherReportService {
// 根据城市ID同步天气
WeatherResponse getDataByCityId(String cityId);
// 根据城市name同步天气
WeatherResponse getDataByCityName(String cityName);
// 获取所有城市列表
List<City> getDataByCities();
}
package com.wzl.springcloud.basic.report.service.impl;
import java.util.List;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;
import com.alibaba.fastjson.JSON;
import com.wzl.springcloud.basic.report.service.WeatherReportService;
import com.wzl.springcloud.basic.report.vo.City;
import com.wzl.springcloud.basic.report.vo.WeatherResponse;
/**

Ribbon客户端 br/>*/
@Service
public class WeatherReportServiceRibbonImpl implements WeatherReportService {br/>@Autowired
// 对rest客户端的封装
private RestTemplate restTemplate;
@Override
public WeatherResponse getDataByCityId(String cityId) {
WeatherResponse weatherResponse = null;
String uri = "http://vis-basic-weather/weather/cityId/" + cityId;
// 调用服务接口来获取
ResponseEntity<String> respString = restTemplate.getForEntity(uri, String.class);
// 判断ResponseEntity的状态码是否为200，为200时取出strBody
if (respString.getStatusCodeValue() == 200) {
String jsonStr = respString.getBody();
weatherResponse = JSON.parseObject(jsonStr, WeatherResponse.class);
}
return weatherResponse;br/>}
@Override
public WeatherResponse getDataByCityName(String cityName) {
WeatherResponse weatherResponse = null;
String uri = "http://vis-basic-weather/weather/cityName/" + cityName;
// 调用服务接口来获取
ResponseEntity<String> respString = restTemplate.getForEntity(uri, String.class);
// 判断ResponseEntity的状态码是否为200，为200时取出strBody
if (respString.getStatusCodeValue() == 200) {
String jsonStr = respString.getBody();
weatherResponse = JSON.parseObject(jsonStr, WeatherResponse.class);
}
return weatherResponse;br/>}
@Override
public List<City> getDataByCities() {
List<City> cityList = null;
String uri = "http://vis-basic-city/cities/getList";
// 调用服务接口来获取
ResponseEntity<String> respString = restTemplate.getForEntity(uri, String.class);
// 判断ResponseEntity的状态码是否为200，为200时取出strBody
if (respString.getStatusCodeValue() == 200) {
String jsonStr = respString.getBody();
cityList = JSON.parseArray(jsonStr, City.class);
}
return cityList;
}
}

原文地址：https://blog.51cto.com/14511863/2440284

时间： 2024-10-11 17:35:45

XFire构建服务端Service的两种方式

android客户端与服务端交互的三种方式

kbmmw 做REST 服务签名认证的一种方式

WCF服务使用（IIS+Http）和（Winform宿主+Tcp）两种方式进行发布

hive三种方式区别和搭建、HiveServer2环境搭建、HWI环境搭建和beeline环境搭建

springcloud 服务调用的两种方式

Spring Cloud Alibaba基础教程：支持的几种服务消费方式（RestTemplate、WebClient、Feign）

Linux中设置服务自启动的三种方式

不停止MySQL服务增加从库的两种方式

SpringCloud服务消费有哪几种方式？

SpringCloud服务消费有哪几种方式？的相关文章