[微服务系列] 3. 服务治理 2 --- Eureka集群

一、 高可用注册中心

在上一篇[微服务系列] 服务治理—Eureka文章中,介绍了服务注册中心的单节点搭建部署。然而在常用的微服务结构设计中,一般都是采用分布式的环境,以避免单机故障导致服务调用不可用,所以需要对微服务中的各个组件进行高可用的部署,服务治理中的服务注册中心也是一样。

二、 服务的发现与消费

在上一篇文章中,我们仅仅对服务发现与消费做了简单的流程说明,在本文中,将基于已构建好的注册中心和服务生产者,来构建服务消费者。通过服务消费者,来发现注册在注册中心的服务并消费服务。本章将结合以下的拓扑图构建高可用的服务治理。

三、 快速实践

01

1. 构建高可用注册中心

Eureka的高可用就是将自己作为服务想其他服务注册中心注册自己,这样就可以形成一组互相注册的服务注册中心,已实现服务清单的互相同步,达到高可用的目的。

基于上一节创建的项目,将配置文件application.properties修改为application-peer1.properties,同时修改配置内容如下:

spring.application.name=eureka-server
server.port=1111

eureka.instance.hostname=registry1
# 向注册中心注册自己
eureka.client.register-with-eureka=false
# 允许使用IP地址的形式来定义注册中心地址
eureka.instance.ip-address=true
# 关闭保护机制
eureka.server.enable-self-preservation=false
# 检索服务
eureka.client.fetch-registry=true
# 将serviceUrl指向其他的注册中心
eureka.client.service-url.defaultZone=http://127.0.0.1:1112/eureka

再创建一个配置文件application-peer2.properties,配置内容如下:

spring.application.name=eureka-server
server.port=1112

eureka.instance.hostname=registry2
# 向注册中心注册自己
eureka.client.register-with-eureka=false
# 允许使用IP地址的形式来定义注册中心地址
eureka.instance.ip-address=true
# 关闭保护机制
eureka.server.enable-self-preservation=false
# 检索服务
eureka.client.fetch-registry=true
# 将serviceUrl指向其他的注册中心
eureka.client.service-url.defaultZone=http://127.0.0.1:1111/eureka

使用Maven命令clean package将项目eureka-server打包成Jar包,并使用如下两个命令来别调用不同的配置文件,并启动项目:

java -jar eureka-server-0.0.1-SNAPSHOT.jar --spring.profiles.active=peer1
java -jar eureka-server-0.0.1-SNAPSHOT.jar --spring.profiles.active=peer2

02

2. 服务的发现与消费

1. 生产服务

服务发现与消费主要涉及到两个内容:一是发现服务,而是对发现的服务进行消费(即调用)。服务的发现由Eureka的客户端完成,服务的消费则有Ribbon完成。

首先,通过java -jar xxx.jar --server.port=xxxx的方式在不同端口启动之前搭建的hello-service服务。

java -jar springbootdemo-0.0.1-SNAPSHOT.jar --server.port=8088 --management.port=60000
java -jar springbootdemo-0.0.1-SNAPSHOT.jar --server.port=8089 --management.port=60001

如下图,启动hello-service之后在注册中心的出现了两个实例单元。

2. 消费服务

服务消费者采用Ribbon负载均衡器来实现。重新构建一个基于SpringBoot的基础工程ribbon-consumer来实现服务消费者,并且在pom.xml文件中添加如下的依赖文件。

<dependencies>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-start-eureka</artifactId>
    </dependency>

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-ribbon</artifactId>
        </dependency>
</dependencies>

<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-dependencies</artifactId>
            <version>Brixton.SR5</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>

在主类上添加@EnableDiscoveryClient注解,使其作为Eureka客户端,已获取服务发现的能力。在主类中注入RestTemplateJavaBean,并使用@LoadBalanced注解,使其开启客户端负载均衡能力。

@EnableDiscoveryClient
@SpringBootApplication
public class ConsumerApplication {

    @Bean
    @LoadBalanced
    RestTemplate restTemplate(){
        return  new RestTemplate();
    };

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

在配置文件application.yml中配置注册中心地址并设置服务的名称和端口

# 服务名称
spring:
  application:
    name: hello-consumer
# 服务端口号
server:
  port: 9000
# 注册中心地址
eureka:
  client:
    service-url:
      defaultZone: http://localhost:3333/eureka

创建ConsumerController并在一个接口方法中调用HELLO-SERVICE中的/hello接口,具体如下:

import org.apache.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

@RestController
public class ConsumerController {    
    
    private Logger logger=Logger.getLogger(ConsumerController.class);    @Autowired
    private RestTemplate restTemplate;    
    
    @RequestMapping(value = "helloConsume",method = RequestMethod.GET)    
    public String helloConsume(){
    logger.info("============Start consume========");        
    return restTemplate.getForEntity("http://HELLO-SERVICE/hello",String.class).getBody();
    }
}

启动服务,并查看注册中心信息面板,可以看到服务已经被注册进了注册中心:

java -jar consumer-0.0.1-SNAPSHOT.jar --server.port=9000

访问地址localhost:9000/helloConsume可以看到输出结果。

四、小结

通过本文简单介绍了Eureka集群的配置中以及如何在集群中发布服务和消费服务。

原文发布于微信公众号 - 瞎说开发那些事(jsj201501)

原文发表时间:2017-11-14

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏AndroidTv

读书笔记--Android Gradle权威指南(上)前言笔记

1514
来自专栏别先生

Oozie如何和安装部署

1、Oozie的简单介绍: 1、Oozie是一个工作流引擎服务器,用于运行hadoop map/reduce和hive等任务工作流,同时Oozie还是一个Jav...

4979
来自专栏Linyb极客之路

SpringBoot一些很实用的功能

然后这个图案是可以自定义的,在src/main/resource下新建一个banner.txt文件,然后去http://patorjk.com/software...

4052
来自专栏后端之路

Jenkins小坑之执行Shell

背景 之前使用jenkins的大概率是作为远程部署,通常使用over ssh plugin作部署 ? 问题 我们正常使用ssh时当Java应用运行时没有问题 但...

6615
来自专栏程序猿DD

【译】Spring官方教程:使用STS的入门指南

原文:Working a Getting Started guide with STS 译者:hanbin 校对:Mr.lzc 这个指南引导您使用 Spring...

2718
来自专栏nnngu

JSP 和 Servlet 的工作原理和生命周期

JSP的英文名叫Java Server Pages,翻译为中文是Java服务器页面的意思,其底层就是一个简化的Servlet设计,是由sum公司主导参与建立的一...

2864
来自专栏世界第一语言是java

springboot2新版springcloud微服务全家桶实战

本篇文章是springboot2.x升级后的升级springcloud专贴,因为之前版本更新已经好久了,好多人评论可不可以出个新版本,大家一定要注意,这是spr...

2.5K2
来自专栏SpringBoot

springmvc+freemarker环境搭建(超简单)

1181
来自专栏菩提树下的杨过

JBOSS EAP 6.0+ Standalone模式安装成Windows服务

网上有一些文章介绍用JavaService.exe来实现,但是到EAP 6以上版本,我试过好象没成功,幸好JBoss官方已经推出了专门的工具。 一、先到官网下载...

2288
来自专栏JackieZheng

Spring Boot系列——日志配置

日志,通常不会在需求阶段作为一个功能单独提出来,也不会在产品方案中看到它的细节。但是,这丝毫不影响它在任何一个系统中的重要的地位。

2192

扫码关注云+社区