SpringCloud-Eureka注册与发现

2023-08-04 10:41:58

这两年可以说微服务是热词，也是新领域，学习的成本也较高，基础东西太多比如什么Dubbo，zookeeper，Springboot等等。Dubbo也是实现服务治理又是阿里出的一套开源RPC框架，但是SpringCloud出现后便立即热火朝天，当然阿里也加入了SpringCloud的孵化。

什么是微服务，分布式？

分布式：不同的模块部署在不同的服务器上，可以更好的解决网站高并发。

微服务：架构设计概念,各服务间隔离（分布式也是隔离）,自治（分布式依赖整体组合）其它特性(单一职责,边界,异步通信,独立部署)是分布式概念的跟严格执行 SOA到微服务架构的演进过程。简单的说把项目拆分成各各模块，用注册中心的方式把服务都链接在一起

服务提供者与消费关系

服务提供者：提供服务被人调用

消费者：调用服务

今天我们说下SpringCloud的Eureka注册中心

官方：

Eureka是Netflix开发的服务发现框架，本身是一个基于REST的服务，主要用于定位运行在AWS域中的中间层服务，以达到负载均衡和中间层服务故障转移的目的。SpringCloud将它集成在其子项目spring-cloud-netflix中，以实现SpringCloud的服务发现功能。

Eureka包含两个组件：Eureka Server和Eureka Client。

Eureka Server提供服务注册服务，各个节点启动后，会在Eureka Server中进行注册，这样EurekaServer中的服务注册表中将会存储所有可用服务节点的信息，服务节点的信息可以在界面中直观的看到。

Eureka Client是一个java客户端，用于简化与Eureka Server的交互，客户端同时也就是一个内置的、使用轮询(round-robin)负载算法的负载均衡器。

在应用启动后，将会向Eureka Server发送心跳,默认周期为30秒，如果Eureka Server在多个心跳周期内没有接收到某个节点的心跳，Eureka Server将会从服务注册表中把这个服务节点移除(默认90秒)。

Eureka Server之间通过复制的方式完成数据的同步，Eureka还提供了客户端缓存机制，即使所有的Eureka Server都挂掉，客户端依然可以利用缓存中的信息消费其他服务的API。综上，Eureka通过心跳检查、客户端缓存等机制，确保了系统的高可用性、灵活性和可伸缩性。

环境搭建:

本次环境用Gradle+IDEA

1.先搭建注册中心

2.主项目Gradle

group 'com.wang'

version '1.0-SNAPSHOT'

apply plugin: 'java'

sourceCompatibility = 1.8

buildscript {

    ext {//定义一个变量，统一规定springboot的版本

        springBootVersion = '1.5.10.RELEASE'

    }

    repositories {

        maven { url 'http://maven.aliyun.com/nexus/content/groups/public/' }

        jcenter()

        mavenCentral()

        //Spring repo

        maven { url "http://repo.spring.io/snapshot" }

        maven { url "http://repo.spring.io/milestone" }

        maven { url "http://repo.spring.io/release" }

        maven { url 'http://repo.spring.io/plugins-snapshot' }

    }

    dependencies {//用来打包

        classpath("org.springframework.boot:spring-boot-gradle-plugin:${springBootVersion}")

    }

}

//设定当前所有的项目的配置

allprojects {

    group 'com.ssx'

    version '1.0-SNAPSHOT'

    ext {

        springCloudVersion = 'Edgware.SR2'

    }

    repositories {

        maven { url 'http://maven.aliyun.com/nexus/content/groups/public/' }

        jcenter()

        mavenCentral()

        //Spring repo

        maven { url "http://repo.spring.io/snapshot" }

        maven { url "http://repo.spring.io/milestone" }

        maven { url "http://repo.spring.io/release" }

        maven { url 'http://repo.spring.io/plugins-snapshot' }

    }

}

//设定当前模块项目中的配置

subprojects {

    apply plugin: 'java'

    apply plugin: 'idea'

    apply plugin: 'spring-boot'

    dependencies {

        //使用springboot-web组件，但是排除tomcat组件

        compile ('org.springframework.boot:spring-boot-starter-web'){

            exclude module:"spring-boot-starter-tomcat"

        }

        //使用undertow作为应用服务,作为servlet容器

        compile 'org.springframework.boot:spring-boot-starter-undertow'

        //使用健康检查组件

        compile 'org.springframework.boot:spring-boot-starter-actuator'

        testCompile(

                group: 'junit', name: 'junit', version: '4.12'

        )

    }

    dependencyManagement {

        imports {

            //加上此配置后，如果需要引用springcloud的组件，就不需要再提供版本信息

            mavenBom "org.springframework.cloud:spring-cloud-dependencies:${springCloudVersion}"

        }

    }

}

3.注册中心启动类

package org.gw.reigster.conter;

import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;

import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;

/**

 * @DATA 2019-02-27 19:56

 * @Author 张国伟  WeChat:17630376104

 * @Description TODO

 */

@EnableEurekaServer #这个是表示这个项目作为euraka注册中心

@SpringBootApplication

public class ReigsterConterProvider {

    public static void main(String[] args) {

        SpringApplication.run(ReigsterConterProvider.class,args);

    }

}

4.注册中心yml

server:

  port: 8888

spring:

  application:

    name: reigster-conter

eureka:

  client:

    register-with-eureka: false #启动时不注册 本来就是注册中心 表示自己是注册中心

    fetch-registry: false  #不向注册中心拉取数据

  server:

    enable-self-preservation: false #关闭自我保护 测试环境用 生产环境一般不用

5.启动注册中心访问8888

这个为Eureka的信息页面可以看到这个时候 Instances currently registered with Eureka里面是No instances available 也就是这个时候还没有服务注册进来，下面我们写注册方

这个模块为solr

package org.gw.solr;

import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;

import org.springframework.cloud.netflix.eureka.EnableEurekaClient;

/**

 * @DATA 2019-02-27 20:38

 * @Author 张国伟  WeChat:17630376104

 * @Description TODO

 */

@EnableEurekaClient   #这里为Eureka客户端也就是服务

@SpringBootApplication

public class ProjectSolrProvider {

    public static void main(String[] args) {

        SpringApplication.run(ProjectSolrProvider.class, args);

    }

}

yml

server:

  port: 10002

spring:

  application:

    name: project-solr

eureka:

  client:

    service-url:

      defaultZone: http://localhost:8888/eureka/

  instance:

    prefer-ip-address: true

这时候我们启动这个服务

这个时候可以看到有个服务已经注册进来

这个就是实现了注册也发现，那我们紧接这如何实现服务与服务之间调用呢？我现在想project-shopping-mall模块的controller调用solr的controller如何实现呢

package org.gw.shopping.mall;

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.context.annotation.Bean;

import org.springframework.web.client.RestTemplate;

/**

 * @DATA 2019-02-27 20:24

 * @Author 张国伟  WeChat:17630376104

 * @Description TODO

 */

@EnableEurekaClient

@SpringBootApplication

public class ShoppingMallProvider {

    @LoadBalanced

    @Bean

    public RestTemplate resultTemplate() {

        RestTemplate template = new RestTemplate();

        return template;

    }

    public static void main(String[] args) {

        SpringApplication.run(ShoppingMallProvider.class, args);

    }

}

RestTemplate表示网络请求在启动类里把他实例

package org.gw.shopping.mall.controller;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Controller;

import org.springframework.ui.Model;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RestController;

import org.springframework.web.client.RestTemplate;

/**

 * @DATA 2019-02-27 20:45

 * @Author 张国伟  WeChat:17630376104

 * @Description TODO

 */

@Controller

public class ShopController {

    @Autowired

    private RestTemplate restTemplate;

    @RequestMapping("/toIndex")

    public String toIndex(Model model) {

        String msg = restTemplate.getForEntity("http://PROJECT-SOLR/solrSearc", String.class).getBody();

        model.addAttribute("msg", msg);

        return "index";

    }

}

这个为调用solr的controller根据名字调用

package org.gw.solr.controller;

import org.springframework.stereotype.Controller;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RestController;

/**

 * @DATA 2019-02-27 20:40

 * @Author 张国伟  WeChat:17630376104

 * @Description TODO

 */

@RestController

public class SolrSearchController {

    @RequestMapping("/solrSearc")

    public String solrSearc(){

        return "从solr查询到数据";

    }

}

意思就是说我在shop里调用solr的controller他会返回一个从solr查询到数据

我们来尝试下

shop模块里有thymeleaf模板展示数据

<!DOCTYPE html>

<html lang="en" xmlxs:th="http://www.thymeleaf.org" xmlns:xmlxs="http://www.w3.org/1999/xhtml"

      xmlns:th="http://www.w3.org/1999/xhtml">

<head>

    <meta charset="UTF-8"/>

    <title>Title</title>

</head >

<body>

<h1>欢迎进入商城</h1>

<h2>从solr微服务中查到的数据::::<span th:text="${msg}"></span></h2>

</body>

</html>

可以看到已经成功拿到数据

到这里，我们已经实现服务的注册与发现，下章说链路跟踪，有问题请及时评论。

码农公寓

相关文章