2. 程式人生 > >SpringCloud總結--SpringCloud簡單使用以及Ribbon和Feign的使用

SpringCloud總結--SpringCloud簡單使用以及Ribbon和Feign的使用

阿新 • • 發佈：2018-11-12

SpringCloud是基於SpringBoot的一整套實現微服務的框架。他提供了微服務開發所需的配置管理、服務發現、斷路器、智慧路由、微代理、控制匯流排、全域性鎖、決策競選、分散式會話和叢集狀態管理等元件。最重要的是，跟spring boot框架一起使用的話，會讓你開發微服務架構的雲服務非常好的方便。SpringCloud也是基於RPC遠端呼叫協議，所以也是需要一個註冊中心，註冊中心可以使用Eureka，zk（Zookeeper）等。

SpringCloud特點：

   1、SpringCloud 是基於SpringBoot的，所以擁有SpringBoot的所以特點
   2.約定優於配置
   3、開箱即用、快速啟用
   4、適用於各種環境
   5、輕量級的元件
   6、元件否支援很豐富，功能很齊全
   7、選型中立

下面就對SpringCloud的使用以及結合Ribbon的使用（註冊中心使用Eureka）

 

一、註冊中心Eureka的使用（這邊加入了Eureka的認證）

   a、pom.xml依賴

<parent>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-parent</artifactId>
      <version>1.5.2.RELEASE</version>
      <relativePath/> <!-- lookup parent from repository -->
  </parent>
  <dependencies>
		<dependency>
			<groupId>org.springframework.cloud</groupId>
			<artifactId>spring-cloud-starter-eureka-server</artifactId>
			<version>1.3.5.RELEASE</version>
		</dependency>
		
		<dependency>
		    <groupId>org.springframework.boot</groupId>
		    <artifactId>spring-boot-starter-security</artifactId>
		</dependency>
		
  </dependencies>

    b、application.yml

security:
  user:
    password: zj123
    name: user
  basic:
    enabled: true
server:
  port: 8761
eureka:
  client: 
    register-with-eureka: false
    fetch-registry: false
    defaultZone: http://user:[email protected]:8761/eureka

      eureka.client.register-with-eureka=false    ##當前Eureke只做服務，不作為客戶端，因為在高可用的環境下Eureka是服務也是客戶端，用於Eureka的同步
      eureka.client.fetch-registry=false          ##當前Eureke只做服務，不作為客戶端，因為在高可用的環境下Eureka是服務也是客戶端，用於Eureka的同步

c、啟動類

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;

@SpringBootApplication
@EnableEurekaServer
public class EurekaApplication {
  public static void main(String[] args) {
    SpringApplication.run(EurekaApplication.class, args);
  }
}

注：啟動後訪問http://localhost:8761 ，使用者名稱密碼：user，zj123（根據security的配置）

二、服務釋出者

1.pom.xml依賴（這邊添加了Mybaits的依賴）

<parent>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-parent</artifactId>
      <version>1.5.2.RELEASE</version>
      <relativePath/> <!-- lookup parent from repository -->
  </parent>

<properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <java.version>1.8</java.version>
    <mybatis-spring-boot.version>1.2.0</mybatis-spring-boot.version>
    <mysql-connector.version>5.1.39</mysql-connector.version>
</properties>

<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>1.3.5.RELEASE</version>
	</dependency>
    <dependency>
        <groupId>org.mybatis.spring.boot</groupId>
        <artifactId>mybatis-spring-boot-starter</artifactId>
        <version>${mybatis-spring-boot.version}</version>
    </dependency>
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
    </dependency>

2、application.yml

server:
  port: 8098
spring:
  application:
    name: provider-user
  datasource:
    url: jdbc:mysql://localhost:3306/spring-cloud
    username: root
    password: zj123456
    driver-class-name: com.mysql.jdbc.Driver
mybatis:
  mapper-locations: classpath:mapper/*.xml
  type-aliases-package: com.zhuojing.bean
eureka:
  client: 
    serviceUrl:
      defaultZone: http://user:[email protected]:8761/eureka
  instance:
    prefer-ip-address: true
    instance-id: ${spring.application.name}\:${spring.cloud.client.ipAddress}\:${spring.application.instance_id\:${server.port}}

3、Controller介面

@RestController
public class UserController {

	@Autowired
	private UserDao userDao;
	@GetMapping("/simple/{id}")
	public User getUserById(@PathVariable Long id){
		return userDao.getById(id);
	}
}

注：這邊dao使用Mybaits實現的就詳細說明，這邊介面就是根據請求引數請求一張表記錄

4、啟動類

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;

@SpringBootApplication
@EnableEurekaClient
public class ApplocationTest {

	public static void main(String[] args) {
		SpringApplication.run(ApplocationTest.class, args);
	}

}

三、服務消費者使用（這邊使用Ribbon進行呼叫）

1、pom.xml的依賴

<parent>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-parent</artifactId>
      <version>1.5.2.RELEASE</version>
      <relativePath/> <!-- lookup parent from repository -->
  </parent>

<properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <java.version>1.8</java.version>
    <mybatis-spring-boot.version>1.2.0</mybatis-spring-boot.version>
    <mysql-connector.version>5.1.39</mysql-connector.version>
</properties>

<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>1.3.5.RELEASE</version>
	</dependency>
</dependencies>

2、application.yml

server:
  port: 8089
spring:
  application:
    name: customer-user
eureka:
  client: 
    serviceUrl: 
      defaultZone: http://user:[email protected]:8761/eureka
  instance:
    prefer-ip-address: true
    instance-id: ${spring.application.name}:${spring.cloud.client.ipAddress}:${spring.application.instance_id:${server.port}}
provider-user: 
  ribbon: 
    NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule

3、呼叫：使用Ribbon呼叫

import java.util.Arrays;
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.MediaType;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

import com.zhuojing.bean.User;

@RestController
public class UserController {

	@Autowired
	private RestTemplate restTemplate;

	@GetMapping(value="/simple/{id}",produces=MediaType.APPLICATION_JSON_VALUE+";charset=utf-8")
	public User findUserById(@PathVariable Long id){
		//服務提供者地址  microservice-provider-user
		return this.restTemplate.getForObject("http://PROVIDER-USER/simple/"+id, User.class);
	}
	
}

4、啟動類

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.netflix.ribbon.RibbonClient;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.FilterType;
import org.springframework.web.client.RestTemplate;

@SpringBootApplication
@EnableEurekaClient
public class AppCusRibbonPropertiesTest {

	@Bean
	@LoadBalanced
	public RestTemplate restTemplate(){
		return new RestTemplate();
	}
	public static void main(String[] args) {
		SpringApplication.run(AppCusRibbonPropertiesTest.class, args);
	}
}

使用Ribbon即時使用註解@LoadBalanced  使用即可

同時這邊使用基於配置檔案的方式配置了Ribbon的呼叫服務的負載策略：

provider-user: 
  ribbon: 
    NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule

這邊使用的是隨機的方式，Ribbon還提供了多做負載均衡策略如輪詢，選擇最小併發等，同時還可以自定義負載均衡策略，這邊就不詳細介紹，剛興趣的可以自行查閱下資料

四、消費者的使用（使用Feign）

Feign是一個客戶端負載均衡的元件，預設負載均衡策略是輪詢

1、pom.xml 依賴

<parent>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-parent</artifactId>
      <version>1.5.2.RELEASE</version>
      <relativePath/> <!-- lookup parent from repository -->
  </parent>

<properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <java.version>1.8</java.version>
    <mybatis-spring-boot.version>1.2.0</mybatis-spring-boot.version>
    <mysql-connector.version>5.1.39</mysql-connector.version>
</properties>

<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>1.3.5.RELEASE</version>
	</dependency>
	<dependency>
		<groupId>org.springframework.cloud</groupId>
		<artifactId>spring-cloud-starter-feign</artifactId>
		<version>1.3.5.RELEASE</version>
	</dependency>
</dependencies>

2、application.yml

server:
  port: 8089
spring:
  application:
    name: customer-user
eureka:
  client: 
    serviceUrl: 
      defaultZone: http://user:[email protected]:8761/eureka
  instance:
    prefer-ip-address: true
    instance-id: ${spring.application.name}:${spring.cloud.client.ipAddress}:${spring.application.instance_id:${server.port}}

3、編寫feign介面，使用@FeignClient註解

import org.springframework.cloud.netflix.feign.FeignClient;

import com.config.Configuration1;
import com.zhuojing.bean.User;

import feign.Param;
import feign.RequestLine;

@FeignClient(name="provider-user",configuration=Configuration1.class)
public interface UserFeignClient {
  
	
	@RequestMapping(value = "/simple/{id}", method = RequestMethod.GET)
	public User getUserById(@PathVariable("id") Long id); 
// 兩個坑：1. @GetMapping不支援   2. @PathVariable得設定value
}

4、Controller呼叫類

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;

import com.zhuojing.bean.User;
import com.zhuojing.feign.UserFeignClient;

@RestController
public class UserController {

	@Autowired
	private UserFeignClient userFeignClient;

	@GetMapping(value="/simple/{id}",produces=MediaType.APPLICATION_JSON_VALUE+";charset=utf-8")
	public User findUserById(@PathVariable Long id){
		
		return userFeignClient.getUserById(id);
	}
}

4、啟動類

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.netflix.feign.EnableFeignClients;
import org.springframework.cloud.netflix.ribbon.RibbonClient;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.FilterType;
import org.springframework.web.client.RestTemplate;

@SpringBootApplication
@EnableEurekaClient
@EnableFeignClients
public class ApplicationCustomerFeignTest {

	public static void main(String[] args) {
		SpringApplication.run(ApplicationCustomerFeignTest.class, args);
	}
}

注：Feign使用是第一次可能會出現請求超時的問題，針對這個問題，有以下幾種角色方案

 # 解決第一次請求報超時異常的方案：
  hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds: 5000 
# 或者：
  hystrix.command.default.execution.timeout.enabled: false

# 或者：  
  feign.hystrix.enabled: false ## 索性禁用feign的hystrix支援

五、其他說明

服務消費者獲取List結果（坑，先轉化為陣列）
        @GetMapping("/getAllUser")
    public List<User> getAllUser(){
        User[] users = this.restTemplate.getForObject("http://provider-user/getAllUser", User[].class);
        List<User> list = Arrays.asList(users);
        for (User user : list) {
            System.out.println(user.getId());
        }
        return list;
    }

相關推薦

SpringCloud總結--SpringCloud簡單使用以及Ribbon和Feign的使用

SpringCloud是基於SpringBoot的一整套實現微服務的框架。他提供了微服務開發所需的配置管理、服務發現、斷路器、智慧路由、微代理、控制匯流排、全域性鎖、決策競選、分散式會話和叢集狀態管理等元件。最重要的是，跟spring boot框架一起使用的話，會讓你開發微服務架構的雲服務非常好的方

springcloud系列14——Eureka、Ribbon和Feign常見問題和解決

1.修改System Status的Environment和Data Center 如圖： 增加如下配置： eureka: environment: product datacenter: spring cloud 或者在啟動時使用-D

SpringCloud 進階之Ribbon和Feign

bin 選擇服務器 clas cati tar 一個 string etime lis 1. Ribbon 負載均衡 Spring Cloud Ribbon是基於Netflix Ribbon實現的一套客戶端,負載均衡的工具; 1.1 Ribbon 配置初步 1.1.1

springcloud記錄篇3-springcloud客戶端ribbon和feign

一 。客戶端介紹   在springcloud中釋出的服務一般為http服務 使用http服務客戶端即可呼叫 最底層的http協議是使用它tcp協議實現 清晰理解http協議請求響應模型可以 使用Socket來進行請求 這種方式開發成本太大，java.net包提供了 Ht

玩轉SpringCloud 三．斷路器（Hystrix）RestTemplate+Ribbon和Feign兩種方式

 此文章基於： 三．斷路器（Hystrix） 在微服務架構中，根據業務來拆分成一個個的服務，服務與服務之間可以相互呼叫（RPC），在Spring Cloud可以用來呼叫。為了保證其高可用，單個服務通常會叢集部署。由於網路原因或者自身的原因，服務並不能保證100%可用，如果單個服務出現問

SpringCloud微服務呼叫方式之Ribbon和Feign方式

微服務呼叫方式之Ribbon的用法 匯入Ribbon的依賴 <dependency> <groupId>org.springframework.cloud</groupId> <artifactId&

Java後端愛上SpringCloud 第二節:內部負載均衡 Ribbon和Feign

Java後端愛上SpringCloud 第一節:內部負載均衡 Ribbon和Feign 一些連結 Ribbon和Feign的區別和比較 當前架構 建立My-Spring-Ribbon 建立My-Spring-Feign Ribbon呼叫

SpringCloud的Ribbon和Feign

1.Ribbon和Feign都可以負載均衡    a.Ribbon使用（在consumer端）        pom.xml                <!-- Ribbon相關 --> <dependency> <groupId&

springcloudの核心元件Eureka、Ribbon、Feign、Hystrix、Zuul

看了一篇關於springcloud核心元件的例項講解，分析的簡單透徹，更好的明白元件間的關係，記錄下來。 各個元件角色扮演: Eureka：各個服務啟動時，Eureka Client都會將服務註冊到Eureka Server，並且Eureka Client還可以反過來從Eureka

spring cloud學習筆記（3）-- ribbon和feign

1.ribbon客戶端負載均衡介紹及基本使用 負載均衡想必都是比較清除的，在伺服器端的負載均衡主要是通過Nginx實現： 那麼客戶端的負載均衡呢 Ribbon是一個實現了客戶端負載均衡的元件，Netflix開源的，其主要功能是提供客戶端側負載均衡 Ribbon客戶

Spring Cloud學習-Eureka、Ribbon和Feign（轉）

Spring Cloud學習-Eureka、Ribbon和Feign   Talk is cheap，show me the code ， 書上得來終覺淺，絕知此事要躬行。在自己真正實現的過程中，會遇到很多莫名其妙的問題，而正是在解決這些問題的過程中，你會發現自己之前思維的

Eureka、Ribbon和Feign

Talk is cheap，show me the code ， 書上得來終覺淺，絕知此事要躬行。在自己真正實現的過程中，會遇到很多莫名其妙的問題，而正是在解決這些問題的過程中，你會發現自己之前思維的盲點。 引子 看完《微服務設計》後，算是補上了自己在服務化這塊的理論知識，在業界，一般

總結傳統JDBC以及MyBatis和Hibernate的對比

讓我們來總結一下使用傳統JDBC操作資料需要經過哪幾個步驟： 使用JDBC程式設計需要連線資料庫，註冊驅動和資料庫資訊 操作Connection，開啟 Statement 物件 。 通過Statement執行SQL， 返回結果到ResultSet物件。

nacos、ribbon和feign的簡明教程

# nacos簡明教程 ## 為什麼需要nacos？ 在微服務架構中，微服務之間經常要相互通訊和呼叫，而且一個服務往往存在多個例項來降低負荷或保證高可用。我們假定A服務要呼叫B服務，最簡單的方式把B服務的地址和埠儲存在A服務的配置檔案中。然後通過http請求去完成B服務的呼叫。但是B服務可能有好多個例項，而

SpringCloud微服務Eurehe和Ribbon+RestTempale/Feign元件

Spring Cloud微服務 什麼是Spring Cloud Spring體系下的微服務一站式解決方案,通常和Spring Boot整合在一起使用,可非常方便的開發出高效易用的微服務架構,Spring Cloud官方給出了21種元件的開發與支援 SpringCloud是基於

SpringCloud學習系列之二 ----- 服務消費者(Feign)和負載均衡(Ribbon)

n) 描述 servers request 其中 led rac stp 定期 前言 本篇主要介紹的是SpringCloud中的服務消費者(Feign)和負載均衡(Ribbon)功能的實現以及使用Feign結合Ribbon實現負載均衡。 SpringCloud Feign

springcloud入門系列（2）－Feign、Ribbon實現Rest介面請求和負載均衡

前面我們介紹了通過springcloud的eureka服務註冊元件實現，並且實現了多機互備的HA，同時也將之前寫的springboot的服務註冊到了eureka上，今天我們主要來介紹下作為服務使用者如何去使用這些服務介面並且實現基於服務化的軟負載均衡。對於之前實現的springboot的rest介面服務，一般

關於springcloud 使用oauth2 和 feign 的坑

oauth2 pro color 就是 img 網上 alt 攔截 信息 oauth2 框架中，使用 feign 會丟失原來的認證信息，網上很多大神也都發了解決方法，大致就是這樣新建一個攔截器 然後在你 的feign接口處配上就好了 關於 feign 遇到的問題，就是 掃

SpringCloud -- Hystrix 熔斷機制實現（基於 Ribbon、Feign)

一、基於 Ribbon + Hystrix   在入口類 中 加上@EnableHystrix   //表示載入熔斷器功能 package com.springcloud.ribbon; import org.springframework.boot.SpringA

SpringCloud微服務之間的通訊，Feign和RestTemplate概念例項詳解

前言： 在springcloud微服務的實際專案開發中，多個微服務之間不僅是相對獨立的，而且也是相對關聯的；也就是說，微服務之間需要相互訪問，多個微服務之間的介面可能會被互相多次呼叫，我們稱之為微服務之間的通訊； 微服務之間的通訊方式有很多，一般使用以下兩種方法：一種是RestT