SpringCloud搭建netflix-eureka微服務集群的方法

這篇“SpringCloud搭建netflix-eureka微服務集群的方法”文章的知識點大部分人都不太理解，所以小編給大家總結了以下內容，內容詳細，步驟清晰，具有一定的借鑒價值，希望大家閱讀完這篇文章能有所收獲，下面我們一起來看看這篇“SpringCloud搭建netflix-eureka微服務集群的方法”文章吧。

新建項目

打開網址：https://start.spring.io/

選擇需要引入的組件，然后下載下來即可

更改項目結構

為了測試的方便，需將項目結構更改為多模塊的項目。

步驟如下：

(1) 依次新建子模塊register-center/provider/consumer，刪除父模塊中多余的src、target等文件夾

(2) 修改父模塊的pom文件：僅保留<dependencyManagement>配置節，<dependencies>配置節全部注釋掉，因為可在子模塊按需添加依賴。

(3) 修改register-center的pom中的依賴配置

<dependencies>
        <!-- Eureka注冊中心 -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
        </dependency>
    </dependencies>

(4) 修改provider和consumer的pom中依賴配置

<dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
    </dependencies>

新建相應的測試類和配置文件

1 register-center模塊

啟動類

package com.hdwang.springcloudtest.registercenter;

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

@SpringBootApplication
@EnableEurekaServer
public class Application {

    /**
     * 運行點對點模式（集群模式）時，通過添加VM參數啟動不同的注冊中心節點實例
     * 例如：-Dspring.profiles.active=peer2
     *
     * @param args
     */
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }

}

yml配置

spring:
  application:
    #應用名
    name: register-center
  freemarker:
    template-loader-path: classpath:/templates/
    prefer-file-system-access: false
  #激活的配置，可運行時添加參數進行修改 -Dspring.profiles.active=peer2
  profiles:
    active: peer1

# #Eureka獨立模式配置，僅有一個注冊中心節點
#server:
#  port: 8090
#eureka:
#  instance:
#    hostname: localhost
#  client:
#    #僅僅作為注冊中心，既不提供服務也不訂閱服務
#    registerWithEureka: false
#    fetchRegistry: false
#    #注冊中心地址
#    serviceUrl:
#      defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/


# Eureka點對點模式，保證注冊中心高可用，注冊的實例信息會在點與點之間相互同步
eureka:
  client:
    serviceUrl:
      defaultZone: http://peer1.com:8091/eureka/,http://peer2.com:8092/eureka/,http://peer3.com:8093/eureka/

---
#每個注冊中心節點不同的配置
spring:
  profiles: peer1
server:
  port: 8091
eureka:
  instance:
    #在本機hosts中配置即可
    hostname: peer1.com

---
spring:
  profiles: peer2
server:
  port: 8092
eureka:
  instance:
    hostname: peer2.com

---
spring:
  profiles: peer3
server:
  port: 8093
eureka:
  instance:
    hostname: peer3.com

2 provider模塊

啟動類

package com.hdwang.springcloudtest.provider;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class Application {

    /**
     * 運行時添加VM參數: -Dserver.port=8082可以啟動多個provider實例
     *
     * @param args
     */
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }

}

服務注冊類

package com.hdwang.springcloudtest.provider.restservice;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * 注冊的服務
 */
@RestController
public class RestService {
    /**
     * 日志
     */
    private static final Logger LOG = LoggerFactory.getLogger(RestService.class);

    @RequestMapping("/sayHello")
    public String sayHello(String name) {
        LOG.info("sayHello was called");
        return "hello, " + name;
    }
}

yml配置

spring:
  application:
    #應用名，也是eureka的服務名
    name: provider
  freemarker:
    template-loader-path: classpath:/templates/
    prefer-file-system-access: false

server:
  #運行時，添加參數-Dserver.port=8082運行新的provider實例
  port: 8081

eureka:
  client:
    #注冊中心地址
    serviceUrl:
      #注冊中心獨立模式
      #defaultZone: http://localhost:8090/eureka/
      #注冊中心點對點模式
      defaultZone: http://peer1.com:8091/eureka/,http://peer2.com:8092/eureka/,http://peer3.com:8093/eureka/

3 consumer配置

啟動類

package com.hdwang.springcloudtest.consumer;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class Application {

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

}

服務調用測試類

package com.hdwang.springcloudtest.consumer.controller;

import com.netflix.appinfo.InstanceInfo;
import com.netflix.discovery.EurekaClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.util.LinkedMultiValueMap;
import org.springframework.util.MultiValueMap;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

import java.util.*;

/**
 * 測試
 */
@RestController
public class TestController {

    /**
     * 使用服務名才能負載均衡，不能使用直接使用地址
     */
    private static final String REST_URL_PREFIX = "http://provider";

    @Autowired
    private EurekaClient discoveryClient;

    @Autowired
    private RestTemplate restTemplate;

    @GetMapping("/testGet")
    public String testGet() {
        ResponseEntity<String> res = restTemplate.getForEntity(REST_URL_PREFIX + "/sayHello?name={1}", String.class, getName());
        return res.getBody();
    }

    @GetMapping("/testPost")
    public String testPost() {
        MultiValueMap<String, Object> params = new LinkedMultiValueMap<String, Object>();
        params.add("name", getName());

//        HttpHeaders headers = new HttpHeaders();
//        headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);

        HttpEntity< MultiValueMap<String, Object>> request = new HttpEntity<>(params, null);
        ResponseEntity<String> res = restTemplate.postForEntity(REST_URL_PREFIX + "/sayHello", request, String.class);
        return res.getBody();
    }

    private String getName() {
        List<String> greetings = Arrays.asList("Bob", "Alice", "Jack");
        Random rand = new Random();
        int randomNum = rand.nextInt(greetings.size());
        return greetings.get(randomNum);
    }
}

RestTemplate負責均衡配置類

package com.hdwang.springcloudtest.consumer.config;

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;

@Configuration
public class RestTemplateConfig {

    /**
     * 構建有負載均衡功能的RestTemplate實例對象
     *
     * @return RestTemplate實例對象
     */
    @Bean
    @LoadBalanced
    RestTemplate restTemplate() {
        return new RestTemplate();
    }
}

yml配置

spring:
  application:
    #應用名，也是Eureka的服務名
    name: cosumer

server:
  port: 8088

eureka:
  client:
    #注冊中心地址
    serviceUrl:
      #注冊中心獨立模式
      #defaultZone: http://localhost:8090/eureka/
      #注冊中心點對點模式
      defaultZone: http://peer1.com:8091/eureka/,http://peer2.com:8092/eureka/,http://peer3.com:8093/eureka/

運行測試

1本機hosts配置

127.0.0.1 peer1.com
127.0.0.1 peer2.com
127.0.0.1 peer3.com

2 編輯運行配置

三個注冊中心節點運行配置

兩個服務提供者的運行配置

3 運行程序

(1) 啟動注冊中心

依次啟動RegisterCenter1->RegisterCenter2->RegisterCenter3，啟動成功后，可訪問http://localhost:8091/ 或http://localhost:8092/ 或http://localhost:8093/ 查看是否啟動成功

(2)啟動服務提供者provider

依次啟動Provider1->Provider2, 隨便訪問一個注冊中心地址首頁即可查看狀態，如下圖

(3) 啟動消費者cosumer

(4) 在瀏覽器中進行測試

(5) 在Provider1/Provider2的控制臺中可以看到輸出結果

2021-04-07 15:26:56.043  INFO 8796 --- [nio-8081-exec-1] c.h.s.provider.restservice.RestService   : sayHello was called
2021-04-07 15:26:58.860  INFO 8796 --- [nio-8081-exec-2] c.h.s.provider.restservice.RestService   : sayHello was called
2021-04-07 15:26:59.535  INFO 8796 --- [nio-8081-exec-3] c.h.s.provider.restservice.RestService   : sayHello was called
2021-04-07 15:26:59.925  INFO 8796 --- [nio-8081-exec-4] c.h.s.provider.restservice.RestService   : sayHello was called
2021-04-07 15:27:00.266  INFO 8796 --- [nio-8081-exec-5] c.h.s.provider.restservice.RestService   : sayHello was called
2021-04-07 15:27:00.663  INFO 8796 --- [nio-8081-exec-6] c.h.s.provider.restservice.RestService   : sayHello was called
2021-04-07 15:27:00.938  INFO 8796 --- [nio-8081-exec-7] c.h.s.provider.restservice.RestService   : sayHello was called

2021-04-07 15:26:58.602  INFO 17828 --- [nio-8082-exec-1] c.h.s.provider.restservice.RestService   : sayHello was called
2021-04-07 15:26:59.194  INFO 17828 --- [nio-8082-exec-2] c.h.s.provider.restservice.RestService   : sayHello was called
2021-04-07 15:26:59.737  INFO 17828 --- [nio-8082-exec-3] c.h.s.provider.restservice.RestService   : sayHello was called
2021-04-07 15:27:00.109  INFO 17828 --- [nio-8082-exec-4] c.h.s.provider.restservice.RestService   : sayHello was called
2021-04-07 15:27:00.414  INFO 17828 --- [nio-8082-exec-5] c.h.s.provider.restservice.RestService   : sayHello was called
2021-04-07 15:27:00.815  INFO 17828 --- [nio-8082-exec-6] c.h.s.provider.restservice.RestService   : sayHello was called

以上就是關于“SpringCloud搭建netflix-eureka微服務集群的方法”這篇文章的內容，相信大家都有了一定的了解，希望小編分享的內容對大家有幫助，若想了解更多相關的知識內容，請關注億速云行業資訊頻道。