SpringCloud 備忘 3 - Ribbon 風格消費者 Consumer Ribbon 服務搭建

1、在父工程 “microservicecloud” 下建立一個 Module，名稱為 “consumer-robbin-8401”

2、修改 pom.xml 檔案

<?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">
    <parent>
        <artifactId>microservicecloud</artifactId>
        <groupId>com.lakey.springcloud</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>consumer-ribbon-8401</artifactId>
    <name>consumer-ribbon-8401</name>
    <description>Consumer With Ribbon 8401</description>

    <dependencies>
        <!-- Eureka 用戶端依賴 -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
        <!-- SpringBoot Web 容器依賴 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!-- Ribbon 依賴 -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
        </dependency>
    </dependencies>

</project>
           

3、在 java 路徑下建立目錄 “com.lakey.springcloud” 并添加啟動類 ConsumerRibbon8401Application.java

package com.lakey.springcloud;

import org.springframework.boot.Banner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;

@SpringBootApplication
@EnableEurekaClient // 本服務啟動後會自動注冊進eureka服務中
@EnableDiscoveryClient // 開啟服務發現，尋找服務提供者
public class ConsumerRibbon8401Application {

    public static void main(String[] args) {
        SpringApplication application = new SpringApplication(ConsumerRibbon8401Application.class);
        application.setBannerMode(Banner.Mode.OFF);// 不輸出Banner
        application.run(args);
        System.out.println(" ____    ___   ____    ____     ___    _   _    ___    _  _      ___    _ \n" +
                " |  _ \\  |_ _| | __ )  | __ )   / _ \\  | \\ | |  ( _ )  | || |    / _ \\  / |\n" +
                " | |_) |  | |  |  _ \\  |  _ \\  | | | | |  \\| |  / _ \\  | || |_  | | | | | |\n" +
                " |  _ <   | |  | |_) | | |_) | | |_| | | |\\  | | (_) | |__   _| | |_| | | |\n" +
                " |_| \\_\\ |___| |____/  |____/   \\___/  |_| \\_|  \\___/     |_|    \\___/  |_|");
    }

}
           

4、在 resources 路徑下添加配置檔案 application.yml

# 伺服器配置
server:
  port: 8401

# Spring 配置
spring:
  application:
    name: consumer-ribbon

# Eureka 配置
eureka:
  client: # 用戶端注冊進 Eureka 服務清單
    serviceUrl:
      defaultZone: http://localhost:8101/eureka/
  instance:
      instance-id: consumer-ribbon-8401   # 自定義服務名稱資訊
      prefer-ip-address: true     # 通路路徑可以顯示 IP 位址

# Eureka 微服務詳細資訊配置
info:
  app.name: consumer-ribbon-8401
  company.name: www.lakey.com
  build.artifactId: microservicecloud
  build.version: 1.0-SNAPSHOT
           

5、在目錄 “com.lakey.springcloud” 下建立一個配置檔案夾 “cfgbeans” 并添加配置類 ConfigBean.java

package com.lakey.springcloud.cfgbeans;

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;

/**
 * 服務配置類
 *
 * @author liming
 * @date 2019-05-07
 */
@Configuration
public class ConfigBean {

    @Bean
    @LoadBalanced // 使用 Ribbon 自帶的負載均衡，預設負載方式為輪詢
    public RestTemplate getRestTemplate() {
        return new RestTemplate();
    }
}
           

6、在目錄 “com.lakey.springcloud” 下建立一個服務層檔案夾 “service” 并添加服務調用類 HelloService.java 請求生産者服務接口

package com.lakey.springcloud.service;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;

/**
 * 服務調用類
 *
 * @author liming
 * @date 2019-05-07
 */
@Service
public class HelloService {

    @Autowired
    private RestTemplate restTemplate;

    /**
     * 調用 Eureka 服務清單下指定名稱的服務方法
     *
     * @param name
     * @return
     */
    public String sayHello(String name) {
        return restTemplate.getForObject("http://provider/hello?name=" + name, String.class);
    }
}
           

7、在目錄 “com.lakey.springcloud” 下建立一個控制層檔案夾 “controller” 并添加控制類 HelloController.java 對使用者暴露接口

package com.lakey.springcloud.controller;

import com.lakey.springcloud.service.HelloService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

/**
 * 測試控制器
 *
 * @author liming
 * @date 2019-05-07
 */
@RestController
public class HelloController {

    @Autowired(required = false)
    private HelloService helloService;

    /**
     * 測試入口
     * 
     * @param name
     * @return
     */
    @GetMapping(value = "/hello")
    public String sayHello(@RequestParam String name) {
        return helloService.sayHello(name);
    }
}
           

8、目錄結構截圖：

9、程式運作截圖：

10、參考文章：

https://github.com/forezp/SpringCloudLearning

11、碼雲源碼：

https://gitee.com/nangongyanya/microservicecloud