专栏首页java、Spring、技术分享Eureka 服务提供者与消费者

Eureka 服务提供者与消费者

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提供的服务的时间间隔。

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

我来说两句

0 条评论
登录 后参与评论

相关文章

  • Ribbon与Spring cloud整合源码分析

    Ribbon是一种客户端的负载均衡器。提供了多种负载均衡的算法,支持多种协议(HTTP,TCP,UDP),并提供了故障容错的能力。官方网址为:https://g...

    良辰美景TT
  • Feign与Spring Cloud源码解析

      在Feign的官方文档上, 我们可以看到Feign最重要的一句话是:Feign makes writing java http clients easier...

    良辰美景TT
  • Spring Boot读取配置文件与配置文件优先级

    1)通过注入ApplicationContext 或者 Environment对象来读取配置文件里的配置信息。

    良辰美景TT
  • Spring Cloud微服务技术栈(五):客户端负载均衡Spring Cloud Ribbon部分源码分析

    为了使客户端具备负载均衡的能力,我们在代码中将RestTemplate交给Spring管理的时候,会加上@LoadBalanced注解,如下代码所示:

    itlemon
  • mybatis+springboot+druid多数据源配置

    加上这段annotation@SpringBootApplication(exclude = {DataSourceAutoConfiguration.clas...

    gfu
  • spring中通过配置文件注入的方法

    2.通过配置文件注入的方法 上面的注入方法是通过@Service的注解方法。类似的还有@Repository、@Component、@Constroller,功...

    马克java社区
  • 资源读取配置 原

    南郭先生
  • Spring Boot整合Ehcache实现缓存功能

    这里介绍Spring Boot结合JPA,MySQL和Ehcache实现缓存功能,提高程序访问效率。

    itlemon
  • SpringCloud系列第05节之服务消费Ribbon和Feign

    它可以在客户端配置 ribbonServerList(服务端列表),然后轮询请求以实现均衡负载

    wuweixiang
  • SpringCloud系列第06节之断路器Hystrix

    这样就有可能出现一个单元因为网络原因或自身问题而出现故障或延迟,导致调用方的对外服务也出现延迟

    wuweixiang

扫码关注云+社区

领取腾讯云代金券