欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

SpringCloud搭建netflix-eureka微服務(wù)集群的過程詳解

 更新時(shí)間:2021年04月08日 09:16:16   作者:追極  
這篇文章主要介紹了SpringCloud搭建netflix-eureka微服務(wù)集群的過程詳解,本文給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下

1.打開官網(wǎng)稍微學(xué)習(xí)一下,了解一下spring cloud是個(gè)什么東西,大概有哪些組件等

https://spring.io/projects/spring-cloud

https://docs.spring.io/spring-cloud-netflix/docs/current/reference/html/

2.新建項(xiàng)目

打開網(wǎng)址:https://start.spring.io/

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

3.更改項(xiàng)目結(jié)構(gòu)

為了測(cè)試的方便,需將項(xiàng)目結(jié)構(gòu)更改為多模塊的項(xiàng)目。

步驟如下:

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

(2) 修改父模塊的pom文件:僅保留<dependencyManagement>配置節(jié),<dependencies>配置節(jié)全部注釋掉,因?yàn)榭稍谧幽K按需添加依賴。

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

<dependencies>
        <!-- Eureka注冊(cè)中心 -->
        <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>

4.新建相應(yīng)的測(cè)試類和配置文件

4.1 register-center模塊

啟動(dòng)類

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 {

    /**
     * 運(yùn)行點(diǎn)對(duì)點(diǎn)模式(集群模式)時(shí),通過添加VM參數(shù)啟動(dòng)不同的注冊(cè)中心節(jié)點(diǎn)實(shí)例
     * 例如:-Dspring.profiles.active=peer2
     *
     * @param args
     */
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }

}

yml配置

spring:
  application:
    #應(yīng)用名
    name: register-center
  freemarker:
    template-loader-path: classpath:/templates/
    prefer-file-system-access: false
  #激活的配置,可運(yùn)行時(shí)添加參數(shù)進(jìn)行修改 -Dspring.profiles.active=peer2
  profiles:
    active: peer1

# #Eureka獨(dú)立模式配置,僅有一個(gè)注冊(cè)中心節(jié)點(diǎn)
#server:
#  port: 8090
#eureka:
#  instance:
#    hostname: localhost
#  client:
#    #僅僅作為注冊(cè)中心,既不提供服務(wù)也不訂閱服務(wù)
#    registerWithEureka: false
#    fetchRegistry: false
#    #注冊(cè)中心地址
#    serviceUrl:
#      defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/


# Eureka點(diǎn)對(duì)點(diǎn)模式,保證注冊(cè)中心高可用,注冊(cè)的實(shí)例信息會(huì)在點(diǎn)與點(diǎn)之間相互同步
eureka:
  client:
    serviceUrl:
      defaultZone: http://peer1.com:8091/eureka/,http://peer2.com:8092/eureka/,http://peer3.com:8093/eureka/

---
#每個(gè)注冊(cè)中心節(jié)點(diǎn)不同的配置
spring:
  profiles: peer1
server:
  port: 8091
eureka:
  instance:
    #在本機(jī)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

4.2 provider模塊

啟動(dòng)類

package com.hdwang.springcloudtest.provider;

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

@SpringBootApplication
public class Application {

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

}

服務(wù)注冊(cè)類

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;

/**
 * 注冊(cè)的服務(wù)
 */
@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:
    #應(yīng)用名,也是eureka的服務(wù)名
    name: provider
  freemarker:
    template-loader-path: classpath:/templates/
    prefer-file-system-access: false

server:
  #運(yùn)行時(shí),添加參數(shù)-Dserver.port=8082運(yùn)行新的provider實(shí)例
  port: 8081

eureka:
  client:
    #注冊(cè)中心地址
    serviceUrl:
      #注冊(cè)中心獨(dú)立模式
      #defaultZone: http://localhost:8090/eureka/
      #注冊(cè)中心點(diǎn)對(duì)點(diǎn)模式
      defaultZone: http://peer1.com:8091/eureka/,http://peer2.com:8092/eureka/,http://peer3.com:8093/eureka/

4.3 consumer配置

啟動(dòng)類

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);
    }

}

服務(wù)調(diào)用測(cè)試類

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.*;

/**
 * 測(cè)試
 */
@RestController
public class TestController {

    /**
     * 使用服務(wù)名才能負(fù)載均衡,不能使用直接使用地址
     */
    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負(fù)責(zé)均衡配置類

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 {

    /**
     * 構(gòu)建有負(fù)載均衡功能的RestTemplate實(shí)例對(duì)象
     *
     * @return RestTemplate實(shí)例對(duì)象
     */
    @Bean
    @LoadBalanced
    RestTemplate restTemplate() {
        return new RestTemplate();
    }
}

yml配置

spring:
  application:
    #應(yīng)用名,也是Eureka的服務(wù)名
    name: cosumer

server:
  port: 8088

eureka:
  client:
    #注冊(cè)中心地址
    serviceUrl:
      #注冊(cè)中心獨(dú)立模式
      #defaultZone: http://localhost:8090/eureka/
      #注冊(cè)中心點(diǎn)對(duì)點(diǎn)模式
      defaultZone: http://peer1.com:8091/eureka/,http://peer2.com:8092/eureka/,http://peer3.com:8093/eureka/

5.運(yùn)行測(cè)試

5.1本機(jī)hosts配置

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

5.2 編輯運(yùn)行配置

三個(gè)注冊(cè)中心節(jié)點(diǎn)運(yùn)行配置

兩個(gè)服務(wù)提供者的運(yùn)行配置

5.3 運(yùn)行程序

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

依次啟動(dòng)RegisterCenter1->RegisterCenter2->RegisterCenter3,啟動(dòng)成功后,可訪問http://localhost:8091/ 或http://localhost:8092/ 或http://localhost:8093/ 查看是否啟動(dòng)成功

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

依次啟動(dòng)Provider1->Provider2, 隨便訪問一個(gè)注冊(cè)中心地址首頁(yè)即可查看狀態(tài),如下圖

(3) 啟動(dòng)消費(fèi)者cosumer

(4) 在瀏覽器中進(jìn)行測(cè)試

測(cè)試地址:http://localhost:8088/testPost / http://localhost:8088/testGet

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

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

恭喜!至此,Spring Clound 微服務(wù)集群框架您已經(jīng)搭建成功!

附錄

github地址:https://github.com/hdwang123/springcloudtest

參考文章:

https://www.zhihu.com/question/283286745/answer/763040709

https://www.cnblogs.com/qdhxhz/p/9357502.html

https://www.cnblogs.com/cjsblog/p/8005766.html

https://blog.csdn.net/weixin_44448094/article/details/88535475

到此這篇關(guān)于SpringCloud搭建netflix-eureka微服務(wù)集群的過程詳解的文章就介紹到這了,更多相關(guān)SpringCloud搭建netflix-eureka集群內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!

相關(guān)文章

  • java web實(shí)現(xiàn)自動(dòng)登錄

    java web實(shí)現(xiàn)自動(dòng)登錄

    這篇文章主要為大家詳細(xì)介紹了java web實(shí)現(xiàn)自動(dòng)登錄,文中示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下
    2021-08-08
  • Java8新特性之默認(rèn)方法詳解

    Java8新特性之默認(rèn)方法詳解

    JAVA8 所提供的默認(rèn)方法,就是在接口上你可以定義某些方法的實(shí)現(xiàn),下面這篇文章主要給大家介紹了關(guān)于Java8新特性之默認(rèn)方法的相關(guān)資料,文中通過實(shí)例代碼介紹的非常詳細(xì),需要的朋友可以參考下
    2022-02-02
  • Java初學(xué)者入門之繼承和多態(tài)

    Java初學(xué)者入門之繼承和多態(tài)

    Java 面向?qū)ο缶幊逃腥筇匦裕悍庋b、繼承、多態(tài),學(xué)好繼承和多態(tài)是面向?qū)ο箝_發(fā)語言中非常重要的一個(gè)環(huán)節(jié),這篇文章主要給大家介紹了關(guān)于Java初學(xué)者入門之繼承和多態(tài)的相關(guān)資料,需要的朋友可以參考下
    2021-07-07
  • springboot添加多數(shù)據(jù)源的方法實(shí)例教程

    springboot添加多數(shù)據(jù)源的方法實(shí)例教程

    這篇文章主要給大家介紹了關(guān)于springboot添加多數(shù)據(jù)源方法的相關(guān)資料,在實(shí)際開發(fā)中經(jīng)常可能遇到在一個(gè)應(yīng)用中可能要訪問多個(gè)數(shù)據(jù)庫(kù)多的情況,需要的朋友可以參考下
    2023-09-09
  • java多線程復(fù)制文件的實(shí)例代碼

    java多線程復(fù)制文件的實(shí)例代碼

    java多線程復(fù)制文件的實(shí)例代碼,需要的朋友可以參考一下
    2013-03-03
  • Java并發(fā)編程中的synchronized關(guān)鍵字詳細(xì)解讀

    Java并發(fā)編程中的synchronized關(guān)鍵字詳細(xì)解讀

    這篇文章主要介紹了Java并發(fā)編程中的synchronized關(guān)鍵字詳細(xì)解讀,在Java早期版本中,synchronized 屬于 重量級(jí)鎖,效率低下,這是因?yàn)楸O(jiān)視器鎖(monitor)是依賴于底層的操作系統(tǒng)的Mutex Lock來實(shí)現(xiàn)的,Java 的線程是映射到操作系統(tǒng)的原生線程之上的,需要的朋友可以參考下
    2023-12-12
  • Java數(shù)據(jù)結(jié)構(gòu)之線索化二叉樹的實(shí)現(xiàn)

    Java數(shù)據(jù)結(jié)構(gòu)之線索化二叉樹的實(shí)現(xiàn)

    在二叉樹的結(jié)點(diǎn)上加上線索的二叉樹稱為線索二叉樹,對(duì)二叉樹以某種遍歷方式進(jìn)行遍歷,使其變?yōu)榫€索二叉樹的過程稱為對(duì)二叉樹進(jìn)行線索化。本文將詳解如何實(shí)現(xiàn)線索化二叉樹,需要的可以參考一下
    2022-05-05
  • 如何通過Java實(shí)現(xiàn)修改視頻分辨率

    如何通過Java實(shí)現(xiàn)修改視頻分辨率

    Java除了可以修改圖片的分辨率,還可以實(shí)現(xiàn)修改視頻的分辨率,這篇文章就將帶大家學(xué)習(xí)如果編寫這一工具類,感興趣的同學(xué)可以了解一下
    2021-12-12
  • Java 同步鎖(synchronized)詳解及實(shí)例

    Java 同步鎖(synchronized)詳解及實(shí)例

    這篇文章主要介紹了Java 同步鎖(synchronized)詳解及實(shí)例的相關(guān)資料,需要的朋友可以參考下
    2017-03-03
  • Java實(shí)現(xiàn)簡(jiǎn)單的抽牌游戲

    Java實(shí)現(xiàn)簡(jiǎn)單的抽牌游戲

    這篇文章主要為大家詳細(xì)介紹了Java實(shí)現(xiàn)簡(jiǎn)單的抽牌游戲,文中示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下
    2020-04-04

最新評(píng)論