SpringCloud搭建netflix-eureka微服务集群的过程详解

1.打开官网稍微学习一下,了解一下spring cloud是个什么东西,大概有哪些组件等

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

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

2.新建项目

打开网址:https://start.spring.io/

选择需要引入的组件,然后下载下来即可

3.更改项目结构

为了测试的方便,需将项目结构更改为多模块的项目。

步骤如下:

(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>

4.新建相应的测试类和配置文件

4.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

4.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/

4.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/

5.运行测试

5.1本机hosts配置

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

5.2 编辑运行配置

三个注册中心节点运行配置

两个服务提供者的运行配置

5.3 运行程序

(1) 启动注册中心

依次启动RegisterCenter1->RegisterCenter2->RegisterCenter3,启动成功后,可访问http://localhost:8091/ 或http://localhost:8092/ 或http://localhost:8093/ 查看是否启动成功

(2)启动服务提供者provider

依次启动Provider1->Provider2, 随便访问一个注册中心地址首页即可查看状态,如下图

(3) 启动消费者cosumer

(4) 在浏览器中进行测试

测试地址:http://localhost:8088/testPost / http://localhost:8088/testGet

(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

恭喜!至此,Spring Clound 微服务集群框架您已经搭建成功!

附录

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

到此这篇关于SpringCloud搭建netflix-eureka微服务集群的过程详解的文章就介绍到这了,更多相关SpringCloud搭建netflix-eureka集群内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们!

(0)

相关推荐

  • 使用Idea简单快速搭建springcloud项目的图文教程

    前言: 开发工具:IntelliJ IDEA 2020版 (Ultimate Edition) 框架:spring boot .spring cloud 搭建一套spring cloud微服务系统,实现服务之间的调用. 需要搭建一个父工程springcloud-test,一个服务注册中心eureka-server,两个微服务cloud-client,cloud-provider. 两个微服务均注册到服务注册中心. 一.搭建父项目 2. 3. (1)删掉src目录 (2)定义pom.xml文件 <

  • SpringCloud入门实验环境搭建

    微服务 个人理解: 所谓微服务是指每个模块都可以独立完成自己的核心业务,某一个模块的崩溃不影响其他模块的运行, 每个微服务有自己单独的一个数据库 每一个微小的服务组成了一个复杂的软件系统 微服务架构 微服务指的是服务的大小,关注的是完成一个具体的服务(医院的科室) 微服务架构是一种架构模式 ,它提倡将单一应用程序划分成一组小的服务,服务之间互相协调.互相 配合,为用户提供最终价值.一种将一个单一应用程序开发为一组小型服务的方法,每个服务都在其运行 的进程中.(整个医院) 优点: 针对特定服务发布

  • 5分钟搭建SpringCloud Eureka服务注册中心的实现

    创建父级项目 只需保留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=&qu

  • Springcloud seata nacos环境搭建过程图解

    最近学习了一下seata,由于nacos现在也挺火,于是学习了seata注册到nacos,然后集成springcloud 1.nacos配置(自行上官网下载) 将nacos/conf/nacos-mysql.sql导入自己的数据库 2.配置修改nacos/conf/application.properties spring.datasource.platform=mysql db.num=1 db.url.0=jdbc:mysql://127.0.0.1:3306/nacos?character

  • 详解Idea SpringBoot搭建SpringCloud的准备工作(推荐)

    1.编码设置 2.开启注解(让注解生效) 3.本项目编译运行版本 4.把不需要的文件隐藏(注意可以不用做,做了可以让项目看起来更加整洁干净清晰明了) 以上就是搭建一个SpringCloud之前的步骤. 二.SpringCloud父工程的依赖 <groupId>org.example</groupId> <artifactId>spring-cloud</artifactId> <version>1.0-SNAPSHOT</version&g

  • SpringCloud基本Rest微服务工程搭建过程

    1. 父工程构建 1.1 Maven项目搭建 环境 版本JDK1.8Maven3.6+Maven模板maven-archetype-size删除父工程src文件 环境 版本 JDK 1.8 Maven 3.6+ Maven模板 maven-archetype-size 删除父工程src文件 1.2 父工程pom文件 回顾: ① Maven中dependencyManagement和dependencies的区别 ​ Maven使用dependencyManagement元素来提供一种管理依赖版本

  • 从零开始搭建springboot+springcloud+mybatis本地项目全过程(图解)

    记录一下从零开始搭建一个springboot+springcloud+mybatis本地项目的demo的过程.纯代码小白一枚,若有不足或错误之处,欢迎广大朋友指出! 开发环境准备: IDE:IntelliJ Idea 2019.3 数据库:mysql 8.0.2.2 SpringBoot版本:2.2.0.RELEASE SpringCloud版本:Hoxton.RELEASE 一.创建一个新的Idea项目 打开Idea,单击New->File->Project,选择Maven,直接下一步 输入

  • SpringCloud2020版本配置与环境搭建教程详解

    1.maven父子工程搭建 项目使用maven工程搭建,下面是工程的结构图.SpringCloud2020是父工程,仅负责依赖的管理,eureka是注册中心的服务端,testclient是测试的客户端. 1.1 父工程pom <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi=&qu

  • SpringCloud搭建netflix-eureka微服务集群的过程详解

    1.打开官网稍微学习一下,了解一下spring cloud是个什么东西,大概有哪些组件等 https://spring.io/projects/spring-cloud https://docs.spring.io/spring-cloud-netflix/docs/current/reference/html/ 2.新建项目 打开网址:https://start.spring.io/ 选择需要引入的组件,然后下载下来即可 3.更改项目结构 为了测试的方便,需将项目结构更改为多模块的项目. 步骤

  • CentOS 7下安装 redis 3.0.6并配置集群的过程详解

    安装依赖 [root@centos7-1 ~]# yum -y install gcc openssl-devel libyaml-devel libffi-devel readline-devel zlib-devel gdbm-devel ncurses-devel gcc-c++ automake autoconf 安装 redis [root@centos7-1 ~]# wget http://download.redis.io/releases/redis-3.0.6.tar.gz [

  • 微服务和分布式的区别详解

    分布式架构是分布式计算技术的应用和工具,目前成熟的技术包括J2EE, CORBA和.NET(DCOM),这些技术牵扯的内容非常广,相关的书籍也非常多,也没有涉及这些技术的细节,只是从各种分布式系统平台产生的背景和在软件开发中应用的情况来探讨它们的主要异同. 微服务架构是一项在云中部署应用和服务的新技术.大部分围绕微服务的争论都集中在容器或其他技术是否能很好的实施微服务,而红帽说API应该是重点. 微服务可以在"自己的程序"中运行,并通过"轻量级设备与HTTP型API进行沟通&

  • ASP.NET Core WebSocket集群实现思路详解

    目录 前言 实现 nginx配置 一对一发送 群组发送 发送所有人 整合到一起 一对一处理 群组处理 全员消息处理 示例源码 总结 前言 提到WebSocket相信大家都听说过,它的初衷是为了解决客户端浏览器与服务端进行双向通信,是在单个TCP连接上进行全双工通讯的协议.在没有WebSocket之前只能通过浏览器到服务端的请求应答模式比如轮询,来实现服务端的变更响应到客户端,现在服务端也可以主动发送数据到客户端浏览器.WebSocket协议和Http协议平行,都属于TCP/IP四层模型中的第四层

  • java开发Dubbo负载均衡与集群容错示例详解

    目录 负载均衡与集群容错 Invoker 服务目录 RegistryDirectory 获取Invoker列表 监听注册中心 刷新Invoker列表 StaticDirectory 服务路由 Cluster FailoverClusterInvoker FailfastClusterInvoker FailsafeClusterInvoker FailbackClusterInvoker ForkingClusterInvoker BroadcastClusterInvoker Abstract

  • Go 微服务开发框架DMicro设计思路详解

    目录 背景 概述 架构 设计理念 面向接口设计 会话 Session 消息 Message 协议 Proto 编码 Codec 连接 Socket 有机的组合 插件 Plugin 组件 未来展望 背景 DMicro 诞生的背景,是因为我写了 10 来年的 PHP,想在公司内部推广 Go, 公司内部的组件及 rpc 协议都是基于 swoole 定制化开发的.调研了市面上的各种框架,包括 beego,goframe,gin,go-micro,go-zero,erpc 等等,可能是我当时技术能力有限,

  • Redis集群的相关详解

    注意!要求使用的都是redis3.0以上的版本,因为3.0以上增加了redis集群的功能. 1.redis介绍 1.1什么是redis Redis是用C语言开发的一个开源的高性能键值对(key-value)的非关系型数据库.通过多种键值数据类型来适应不同场景下的存储需求,目前支持的键值数据类型有: 字符串,散列,列表,集合,有序集合 2.2应用场景 缓存(数据查询.短连接.新闻内容.商品内容等等).(最多使用) 分布式集群架构中的session分离. 聊天室的在线好友列表. 任务队列.(秒杀.抢

  • Rainbond对微服务进行请求速率限制详解

    目录 前置条件 操作流程 常见问题 Rainbond 默认支持基于 envoy 的全局速率限制.在 Rainbond 默认提供的综合网络治理插件中呈现.本文我们将一个用例呈现 Rainbond 中全局速率限制的使用方式. 前置条件 Rainbond平台已部署完成. 在Rainbond中部署可访问的 Demo 业务. 为此组件开通综合网络治理插件. 参考视频 https://player.bilibili.com/player.html?aid=540728010 Rainbond 速率限制设置参

  • SEATA事务服务DOCKER部署的过程详解

    1.创库授权语句 > create database seata: > grant all on seata.* to seata_user@'%' identified by '123455' 2.数据库建表语句 cat create_seata_table.sql -- -------------------------------- The script used when storeMode is 'db' -------------------------------- -- the

  • SpringBoot服务端数据校验过程详解

    这篇文章主要介绍了SpringBoot服务端数据校验过程详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 对于任何一个应用而言,客户端做的数据有效性验证都不是安全有效的,而数据验证又是一个企业级项目架构上最为基础的功能模块,这时候就要求我们在服务端接收到数据的时候也对数据的有效性进行验证.为什么这么说呢?往往我们在编写程序的时候都会感觉后台的验证无关紧要,毕竟客户端已经做过验证了,后端没必要在浪费资源对数据进行验证了,但恰恰是这种思维最为容易

随机推荐