干货实操：微服务Spring Cloud 系列（二） Eureka服务发现与服务注册(strand alone)

此篇主要实操Eureka 服务端的服务注册，以及服务发现，并需要认证才能访问控制中心。

zhm6422107

8148人浏览 · 2017-06-24 10:59:40

zhm6422107 · 2017-06-24 10:59:40 发布

此篇主要实操Eureka 服务端的服务注册，以及服务发现，并需要认证才能访问控制中心。

分五个部分说明：

一. 认识 Eureka

二. Eureka 服务端开发

三. Eureka 客户端开发

四. 多客户端情况查看

五. 下节预告（多个服务提供后，怎么消费）

(一）认识 Eureka

1. 怎么读

Eureka英文读音[juə'ri:kə]，中文读音：尤里卡，古希腊词语，词性为感叹词，意思是“我找到了！我发现了！”

2. what is Eureka?

尤里卡是一个基于REST服务,主要是用于做服务注册与服务发现的。

3. Eureka 架构

图分析下：有2个角色，Eureka Server和Eureka Client。可以理解成，服务都注册在哪里，哪里就可称为Eureka Server，注册中心的意思。

注册在注册中心可以是服务的提供者（Applicaton Service）或者服务的消费者（Application Client），这两类都被称为Eureka client。

每个区域有一个Eureka集群，并且每个区域至少有一个eureka服务器可以处理区域故障，以防服务器瘫痪。

Eureka Client向Eureka Server注册，并将自己的一些客户端信息发送Eureka Server。

然后，Eureka Client(application service)通过向Eureka Serve发送心跳（每30秒）来续约服务的。

如果客户端持续不能续约，那么，它将在大约90秒内从服务器注册表中删除。注册信息和续订被复制到集群中的Eureka Serve所有节点。

来自任何区域的Eureka Client(Application Client)都可以查找注册表信息（每30秒发生一次）。根据这些注册表信息，Application Client可以远程调用Applicaton Service来消费服务。

二. Eureka 服务端开发

1. 服务端代码结构

2. gradle 构建源码：

import java.text.SimpleDateFormat

group 'com.angus'
version '1.0-SNAPSHOT'

buildscript {
    ext {
        springBootVersion = '1.5.2.RELEASE'
    }
    repositories {
        jcenter {url 'http://jcenter.bintray.com/'}
//        maven{ url 'http://maven.aliyun.com/nexus/content/groups/public'}
        mavenLocal()
        mavenCentral()
    }
    dependencies {
        classpath "org.springframework.boot:spring-boot-gradle-plugin:$springBootVersion"
        classpath 'org.springframework:springloaded:1.2.4.RELEASE'
        classpath 'org.hidetake:gradle-ssh-plugin:2.0.0'
        classpath "io.spring.gradle:dependency-management-plugin:0.5.6.RELEASE"
    }
}


apply plugin: 'java'
apply plugin: 'maven'
apply plugin: 'idea'
apply plugin: 'org.springframework.boot'
apply plugin: 'war'
apply plugin: 'application'
apply plugin: 'org.hidetake.ssh'
apply plugin: "io.spring.dependency-management"

def env = System.getProperty("env") ?: "prd"


sourceSets {
    main {
        resources {
            srcDirs = ["src/main/resources","src/main/profile/$env"]
        }
    }
}

def date = new SimpleDateFormat("yyyy-MM-dd").format(new Date())
jar {
    baseName = "eureka-$env"
    version = '1.0-RELEASE'

}
war {
    baseName = "eureka-$env"
    version = '1.0-RELEASE'
}



repositories {
    maven{ url 'http://maven.aliyun.com/nexus/content/groups/public'}
    mavenLocal()
    mavenCentral()
}

distZip {
    archiveName "$baseName-$version-$date-$env-RELEASE.zip"
}

dependencyManagement {
    imports {
        mavenBom "org.springframework.cloud:spring-cloud-dependencies:Camden.SR5"
    }
}
dependencies {
    compile "org.springframework.boot:spring-boot-starter-web:$springBootVersion"
    compile 'org.springframework.cloud:spring-cloud-starter-eureka-server'
    compile 'org.springframework.boot:spring-boot-starter-security'

}


springBoot {
    mainClass = "com.angus.eureka.BaseApplication"
}

3. Eureka 配置说明（application.properties)

server.port = 8001
server.sessionTimeout=15
server.tomcat.max-threads = 800
server.tomcat.uri-encoding = UTF-8

#服务Eureka Server的身份验证
security.basic.enabled=true
security.user.name=root
security.user.password=angus

#是否将eureka自身作为应用注册到eureka注册中心
eureka.client.registerWithEureka=false
#为true时，可以启动，但报异常：Cannot execute request on any known server
eureka.client.fetchRegistry=false

eureka.client.serviceUrl.defaultZone=http://root:angus@localhost:8001/eureka/

4. 应用启动

package com.angus.eureka;

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

/**
 * Created by Angus on 2017-5-31.
 */
@EnableEurekaServer
@SpringBootApplication
public class BaseApplication {

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

}

启动：bootRun -Denv=test

5. 启动效果：

打开浏览器： http://localhost:8001

三. Eureka 客户端开发

1. Eureka Client(Application Server)代码结构

2. gradle 构建源码：

eureka client:

import java.text.SimpleDateFormat

group 'com.angus'
version '1.0-SNAPSHOT'

buildscript {
    ext {
        springBootVersion = '1.5.2.RELEASE'
    }
    repositories {
        jcenter {url 'http://jcenter.bintray.com/'}
//        maven{ url 'http://maven.aliyun.com/nexus/content/groups/public'}
        mavenLocal()
        mavenCentral()
    }
    dependencies {
        classpath "org.springframework.boot:spring-boot-gradle-plugin:$springBootVersion"
        classpath 'org.springframework:springloaded:1.2.4.RELEASE'
        classpath 'org.hidetake:gradle-ssh-plugin:2.0.0'
        classpath "io.spring.gradle:dependency-management-plugin:0.5.6.RELEASE"
    }
}


apply plugin: 'java'
apply plugin: 'maven'
apply plugin: 'idea'
apply plugin: 'org.springframework.boot'
apply plugin: 'war'
apply plugin: 'application'
apply plugin: 'org.hidetake.ssh'
apply plugin: "io.spring.dependency-management"

def env = System.getProperty("env") ?: "prd"



sourceSets {
    main {
        resources {
            srcDirs = ["src/main/resources","src/main/profile/$env"]
        }
    }
}

def date = new SimpleDateFormat("yyyy-MM-dd").format(new Date())
jar {
    baseName = "eureka-client-$env"
    version = '1.0-RELEASE'

}
war {
    baseName = "eureka-client-$env"
    version = '1.0-RELEASE'
}



repositories {
//    maven{ url 'http://maven.aliyun.com/nexus/content/groups/public'}
    mavenLocal()
    mavenCentral()
}

distZip {
    archiveName "$baseName-$version-$date-$env-RELEASE.zip"
}

dependencyManagement {
    imports {
        mavenBom "org.springframework.cloud:spring-cloud-dependencies:Camden.SR5"
    }
}
dependencies {
    compile "org.springframework.boot:spring-boot-starter-web:$springBootVersion"
    compile 'org.springframework.cloud:spring-cloud-starter-eureka'
    compile 'org.springframework.boot:spring-boot-starter-actuator'

}


springBoot {
    mainClass = "com.angus.BaseApplication"
}

3. Eureka client 配置说明

server.port = 8888
server.sessionTimeout=15
server.tomcat.max-threads = 800
server.tomcat.uri-encoding = UTF-8


spring.application.name=sayHelloServer
#为true时，可以启动，但报异常：Cannot execute request on any known server
eureka.client.fetchRegistry=false
 # 指定服务注册中心的地址
eureka.client.serviceUrl.defaultZone=http://root:angus@localhost:8001/eureka/

4. 应用启动

package com.angus;

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

/**
 * Created by Angus on 2017-5-31.
 */
@EnableEurekaClient
@SpringBootApplication
public class BaseApplication {

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

}

区别： @EnableEurekaClient && @EnableDiscoveryClient

SpringCloud中的“Discovery Service”有多种实现，比如：eureka, consul, zookeeper。@EnableDiscoveryClient注解是基于spring-cloud-commons依赖，并且在classpath中实现； @EnableEurekaClient注解是基于spring-cloud-netflix依赖，只能为eureka作用；

5. 服务提供代码：

package com.angus.web;

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

/**
 * Created with eureka-client.
 * User: anguszhu
 * Date: Jun,22 2017
 * Time: 16:25
 * description:
 */
@RestController
public class HelloController {

    @RequestMapping("/name/{who}")
    public String sayHello(@PathVariable String who){
        return "Hey "+who+", what's up man!";
    }
}

一个简单的 http请求服务

6. 启动：

修改application.properties 的server.port 为8889 ，再启动一个，然后到控制台查看。

7. 启动一个服务，启动两个服务后，效果分别是：

两个服务如下：

四. 多客户端情况查看

上图可以看到，同一个应用，有两个服务提供者，分别是8889 端口与8888 端口

五. 下节预告（多个服务提供后，怎么消费）

这节实操了Eureka 服务注册，但是没有描述怎么玩服务消费，下节再写吧，通过Spring Cloud Ribbon 负载调动不同的服务提供者。

向您推荐>>Eolink开发者社区

权威｜前沿｜技术｜干货｜国内首个API全生命周期开发者社区

更多推荐

ELK实现containerd的容器日志采集展示【基于logging的全栈监测】

企业级ELK Stack构建介绍

云原生

深入理解 Mocha 测试框架：从零实现一个 Mocha

前言什么是自动化测试自动化测试在很多团队中都是Devops环节中很难执行起来的一个环节，主要原因在于测试代码的编写工作很难抽象，99%的场景都需要和业务强绑定，而且写测试代码的编写工作量往往比编写实际业务代码的工作量更多。在一些很多业务场景中投入产出比很低，适合写自动化测试的应该是那些中长期业务以及一些诸如组件一样的基础库。自动化测试是个比较大的概念，其中分类也比较多，比如单元测试，端对端测试，集

云原生

(20200916 Solved)docker-compose up创建容器自动退出

问题描述如题，创建容器后自动退出了。并且docker start container无效解决方案原因是缺失了控制终端的配置，需要在docker-compose.yml中增加tty:true ，有时候这样也不行，需要再增加一个command:/bin/bash，命令不一定是这个，需要是一个不会退出的命令，然后用-d后台启动容器。Referencesdocker-compose启动容器后自动退出...

云原生

所有评论(0)

查看更多评论

zhm6422107

@zhm6422107

已为社区贡献1条内容