Eureka 服务提供者与消费者

作者: 良辰美景TT | 来源:发表于2018-07-04 11:08 被阅读11次

Eureka 集群架构如下图所示:


image.png

我们需要实现服务提供者(Provider)与服务调用者(Consumer)

服务提供者

1:修改pom.xml文件,引入依赖包,代码如下:

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

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

2: 修改配置文件:

server.port=8000
spring.application.name=provider
eureka.instance.hostname=localhost 
eureka.client.serviceUrl.defaultZone=http://localhost:8761/eureka/

3:在启动类上加上EnableEurekaClient注解

package com.ivan.provider;

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

/**
 * 
 * 功能描述:
 * 
 * @version 2.0.0
 * @author zhiminchen
 */
@SpringBootApplication
@EnableEurekaClient
public class App {
    public static void main(String[] args) {
        new SpringApplicationBuilder(App.class).run(args);
    }
}

4:编写具体服务提供Controller类

package com.ivan.provider.controller;

import java.util.Date;

import org.apache.http.client.utils.DateUtils;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class ProviderController {
    
    
    @RequestMapping(value="/provider", method={RequestMethod.GET})
    public String getProvider(){               
        String date = DateUtils.formatDate(new Date(), "yyyy-MM-dd hh:mm:ss");
        System.out.println(date);
        return date;
    }
    
    
}

服务消费者

1:修改pom.xml文件,与服务提供都不同的是这里需要引入spring-cloud-starter-ribbon 用于做负载均衡。服务提供都可能会部署多个实例,调用过程就涉及到负载均衡问题了。

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

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

2:修改application.propertiest文件,跟服务端的配置差不多。

server.port=9000
spring.application.name=consumer
eureka.instance.hostname=localhost
eureka.client.serviceUrl.defaultZone=http://localhost:8761/eureka/

3:编写启动类,注意这里需要 EnableDiscoveryClient注解。这个注解同样有将服务注册到Eureka注册中心的功能。

package com.ivan.consumer;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;

/**
 * 
 * 功能描述: 
 * 
 * @version 2.0.0
 * @author zhiminchen
 */

@SpringBootApplication
@EnableDiscoveryClient
public class App 
{
    public static void main( String[] args )
    {
        SpringApplication.run(App.class, args);
    }
}

4:编写服务调用者,这里的Configuration注解用于将RestTemplate 类注入到Spring IOC容器中。LoadBalanced注解提供负载均衡。注意http://provider/provider 这个URL中第一个provider指的是 服务提供者的应用名称,第二个provider指的是提供者提供的url。这里没有不需要指定具体服务的端口号

package com.ivan.consumer.controller;

import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
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
@Configuration
public class ConsumerController {

    @Bean
    @LoadBalanced
    public RestTemplate getRestTemplate() {
        return new RestTemplate();
    }

    @RequestMapping(value = "/consumer", method = RequestMethod.GET)
    public String consumer() {
        RestTemplate template = getRestTemplate();
        // 根据应用名称调用服务
        String json = template.getForObject("http://provider/provider", String.class);
        return json;
    }
}

其它配置

  • eureka.instance.leaseRenewalInSeconds=5 发送心跳间隔的时间, 单位为秒。
  • eureka.instance.leaseExpirationDurationInSeconds=30 #30秒没有发送续约请求的话,就会将该实例进行下线处理
  • eureka.client.registry-fetch-interval-seconds=30 #拉取Eureka Server提供的服务的时间间隔。

相关文章

  • 断路器(Hystrix Ribbon)

    【服务中心】集群,Eureka Server 【服务提供者】集群,Eureka Client 【服务消费者】应用,...

  • 服务发现(Feign)

    【服务中心】集群,Eureka Server 【服务提供者】集群,Eureka Client 【服务消费者】,Eu...

  • Spring Cloud系列--Spring Cloud Eur

    Eureka 核心要素 服务注册中心:提供服务注册与发现功能。 服务提供者:提供服务的应用。 服务消费者:消费者从...

  • Eureka详解

    Eureka的三个核心角色:服务注册中心、服务提供者和服务消费者 基础架构 -服务注册中心:Eureka提供的服务...

  • Eureka注册中心

    一、原理分析 1、消费者该如何获取服务提供的具体信息 服务提供者启动时向Eureka注册自己的信息,Eureka保...

  • Eureka的健康检测和高可用

    Eureka的健康检测和高可用 Eureka是微服务中的服务发现组件,微服务消费者和提供者在启动的时候会将自己的信...

  • Eureka 快速配置

    Eureka netflex旗下,服务注册中心 eureka server 服务提供者,客户端通过eureka进行...

  • Eureka服务发现

    Eureka服务发现 服务发现概述 服务发现机制是为了解决硬网络编码问题,服务消费者使用这种机制获取服务提供者网络...

  • 深入理解 Spring Cloud 核心组件与底层原理

    一、Spring Cloud核心组件:Eureka Netflix Eureka Eureka详解 1、服务提供者...

  • 深入理解Spring Cloud核心组件与底层原理

    一、Spring Cloud核心组件:Eureka Netflix Eureka Eureka详解 1、服务提供者...

网友评论

    本文标题:Eureka 服务提供者与消费者

    本文链接:https://www.haomeiwen.com/subject/qppjuftx.html