转载

springcloud超简单的入门2--Eureka服务治理

Eureka服务治理

下面请听第一个话题，母。。。咳咳，拿错书了。

Eureka简介

eureka是什么呢？

简单来说呢，当我的微服务应用多了起来，一个一个写死再程序里是件很不优雅的事情，而且同一服务可能会多个实例存在，来对服务分流，就是负载均衡。

所以，我们需要一个位置来存放服务的访问列表，以供消费端来使用，这个东西呢，就可以用eureka来实现。

我们来看一下eureka的相关概念：

相关概念
- 服务注册(Register)
  
  eureka客户端向Eureka服务器注册时，它提供自身的元数据，比如IP地址，端口信息
- 服务续约(Renew)
  
  客户端每隔30秒发送一次心跳来进行服务续约。
- 服务下线(Cancel)
  
  客户端在程序关闭时向服务器发送取消请求，成功该实例将会从服务器注册列表中删除
- 服务剔除(Eviction)
  
  默认情况下，当客户端连续90秒没有发送心跳请求，服务器就会将该服务实例从服务列表中删除，剔除该服务
- 获取服务注册列表信息(Fetch Registriers)
  
  客户端从服务器获取服务注册列表信息，并将其缓存在本地。列表信息定期(30秒)更新一次。

不太理解也没关系，我们可以先把架子搭建起来，之后慢慢悟把。

Eureka角色

Eureka中存在三种角色，注册中心，服务提供者，服务消费者。

其中注册中心是Eureka服务端，服务提供者与服务消费者都是客户端。

注册中心服务器

主要进行，服务注册，服务续约和服务下线。就是维护服务列表的东东啦。

让我们一步一步的开始把

相关依赖

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

启动类配置，使用 @EnableEurekaServer 注解，启用Eureka服务

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

}

属性配置

server:
  port: 9090 ##UI界面端口
eureka:
  instance:
    hostname: localhost  ##主机名称
  client:
    register-with-eureka: false  ##是否注册到服务中心，因为本身就是服务中心，不需要注册
    fetch-registry: false  ##是否发现服务
    service-url:          ##注册中心服务地址
      defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/

启动服务，这样一个简单的注册中心就启动起来，浏览器访问http://localhost:9090 就可以看到eureka的监控界面了。

服务提供者

eureka客户端，向外提供服务

相关依赖，作为Euraka客户端

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

启动类配置，使用 @EnableEurekaClient 注解，启动Eureka客户端

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

属性配置(单机时可以通过设置不同端口，来启动多个服务)

server:
  port: 8080
eureka:
  instance:
    prefer-ip-address: true  ##使用IP注册服务
  client:
    register-with-eureka: true  #默认就是true,可以不用设置
    fetch-registry: true  #默认是true，可以不用设置
    service-url:
      defaultZone: http://localhost:9090/eureka/
spring:
  application:
    name: microservice-provider

服务接口

@RestController
@RequestMapping("/")
public class TestController {

    @GetMapping("hi/{name}")
    public String hi(@PathVariable String name, HttpServletRequest request){
        try {
            Thread.sleep(2010);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return "hi,welcome "+name+" from port:"+request.getServerPort();
    }
}

服务消费者

本质上与提供者为同一类客户端，会在本地缓存一份服务列表信息，会定期更新缓存

相关依赖

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

启动类配置

@SpringBootApplication
public class App {

    public static void main(String[] args) {
        SpringApplication.run(App.class,args);
    }
    @Bean
    public RestTemplate getRestTemplate(){
        return new RestTemplate();
    }
}

属性配置

server:
  port: 8090
eureka:
  client:
    service-url:
      defaultZone: http://localhost:9090/eureka/
    register-with-eureka: false ##仅仅作为消费者
    fetch-registry: true  #默认是true，可以不用设置

  ## 多说几句，服务者跟消费者不是绝对的，他们可以同时作为两种角色存在
  ## register-with-eureka: true
  ## fetch-registry: true  
  ## 当这两个熟悉都为true的时候，就可以作为两种角色同时存在了，即可以作为提供者，向外提供服务
  ## 又可以作为消费者，消费服务

服务消费，都在代码里，我干了，你随意。

@RestController
@RequestMapping("/")
public class TestController {


    // 服务只有一个实例运行的时候，一个服务提供者，
    // 就算不注册到eureka，我们也可以使用这种方式就行调用
    @Resource
    RestTemplate restTemplate;
    @GetMapping("hi")
    public String hi() {
        return restTemplate.getForObject("http://localhost:8090/hi/consumer", String.class);
    }

    //当服务有多个实例的时候，我们就可以使用服务发现或获取服务列表，并取其中一个实例进行调用
    // 这样才是实际场景，当然还用更简洁的使用方式，我们下次说
    @Resource
    DiscoveryClient discoveryClient;
    //通过服务发现，获取注册中心上注册的服务，获取调用地址，然后调用服务
    @GetMapping("hi2")
    public String hi2() {
        List<ServiceInstance> serviceInstances = discoveryClient
                .getInstances("microservice-provider");
        if (serviceInstances.size() == 0) return "service has down";
        // 这里就是取第一个服务来消费
        return restTemplate.getForObject(String.format("%s/hi/consumer", serviceInstances.get(0).getUri()),
                String.class);
    }
}

原文 http://www.cnblogs.com/justalittlecoder/p/11519922.html

正文到此结束