一、什么是Eureka?

        Eureka是用来实现微服务中的服务治理功能的部分,Spring Cloud Eureka是Spring Cloud Netflix微服务套件的一部分,基于Netflix做了二次封装。除了Eureka我们还可以使用Consul、Etcd、Zookeeper等等来作为服务的治理中心。但是一般我们使用SpringCloud作为微服务框架的话就用Eureka来作为服务的治理中心,而Dubbo一般使用Zookeeper来作为服务治理中心。

        Eureka是符合AP原则的,也即是服务可用性、网络分区容错性。Zookeeper则是符合CP原则,也即是数据一致性和网络分区容错性。CAP这三个特性任何分布式系统都不能同时满足。

二、搭建Eureka服务治理中心

这里我们简单搭建一个Eureka服务治理中心,这个中心需要创建三个maven项目,分别是:1.注册中心服务(eureka-server)、2.服务提供者(eureka-provider)、3.服务消费者(eureka-costumer)。

注册中心服务的角色相当于淘宝平台,二服务提供者相当于淘宝上的买家,服务消费者相当于买家

1.使用Eureka编写注册中心服务

首先创建一个Maven项目,取名为eureka-server,在pom.xml中配置Eureka的依赖信息,如下:

<!-- Spring boot-->

<parent>

        <groupId>org.springframework.boot</groupId>

        <artifactId>spring-boot-starter-parent</artifactId>

        <version>2.0.6.RELEASE</version>

</parent>

<dependencies>

        <dependency>

                <groupId>org.springframework.cloud</groupId>

                <artifactId>spring-cloud-starter-netflix-eureka-server</artfactld>

        </dependency>

</dependencies>

<dependencyManagement>

        <dependencies>

                <dependency>

                        <groupId>org.springframework.cloud</groupId>

                        <artifactId>spring-cloud-dependencies</artfactId>

                        <version>Finchley.SR2</version>

                        <type>pom</type>

                        <scope>import</scope>

                </dependencies>

        </dependencies>

</dependencyManagement>

创建启动类EurekaApplication,如下:

@EnableEurekaServer//开启Eureka Server

@SpringBootApplication

public class EurekaApplication{

        public static void main(String[] args){

                SpringApplication.run(EurekaApplication.class,args);

        }

}

 在src/main/resources下面创建一个application.properties属性文件,增加下面的配置:

spring.application.name=eureka-server

server.port=8761

eureka.client.register-with-eureka=false//设置为false,表示不用向注册中心注册自己

eureka.client.fetch-registry=false//作为注册中心,不需要去检索服务,只需要维护服务实例

 写到这里就可以直接启动项目了,在浏览器地址中输入:http://localhost:8761/就可以看到eureka提供的Web控制台

2.编写服务提供者

首先创建Maven项目,然后在pom.xml中添加相关依赖如下:

<parent>

        <groupId>org.springframework.boot</groupId>

        <artifactId>spring-boot-starter-parent</artifactId>

        <version>2.0.6.RELEASE</version>

</parent>

<dependencies>

        <dependency>

                <groupId>org.springframework.cloud</groupId>

<!-- 只有下面这个地方和注册中心的依赖不同,表示客户端-->

                <artifactId>spring-cloud-starter-netflix-eureka-client</artfactld>

        </dependency>

</dependencies>

<dependencyManagement>

        <dependencies>

                <dependency>

                        <groupId>org.springframework.cloud</groupId>

                        <artifactId>spring-cloud-dependencies</artfactId>

                        <version>Finchley.SR2</version>

                        <type>pom</type>

                        <scope>import</scope>

                </dependencies>

        </dependencies>

</dependencyManagement>

 然后创建启动类App:

 @SpringBootApplication

@EnableDiscoveryClient//表示开启Eureka客户端

public class App{

        public static void main(String[] args){

                SpringApplication.run(App.class,args);

        }

}

同时在目下下创建一个Controller类 ,提供一个接口给其他服务查询,如下:

@RestController

public class ProviderController{

        @GetMapping("/provider/hello")

        public String hello(){

                return "hello eureka";

        }

}

 在resources目录下,创建application.properties属性文件,添加一下配置:

spring.application.name=eureka-provider

server.port=8081

eureka.client.serviceUrl.defaultZone=http://localhost:8761/eureka/---------采用IP注册

eureka.instance.preferIpAddress=true

eureka.instance.instance-id=${spring.application.name}:${spring.cloud.client.ip-address}:${server.port}

然后启动项目,在浏览器中输入地址http://localhost:8081/provider/hello,如果能看到返回的字符串hello eureka,则表明接口提供成功。同时在注册中心可以看到相应的项目信息,表明注册成功。

3.编写服务消费者 

创建Maven项目eureka-costumer,其中的启动类和依赖与上面的服务提供者一样,不同的一点就是配置信息:

spring.application.name=eureka-costumer

server.port=8082

eureka.client.serviceUrl.defaultZone=http://localhost:8761/eureka/---------采用IP注册

eureka.instance.preferIpAddress=true

eureka.instance.instance-id=${spring.application.name}:${spring.cloud.client.ip-address}:${server.port}

接下来我们使用RestTemplate来调用接口,RestTemplate是Spring提供的用于访问Rest服务的客户端,提供了很多访问Http服务的方法,创建BeanConfiguration类:

@Configuration

public class BeanConfiguration{

        @Bean

        @LoadBalanced//自动构造LoadBalancerClient接口的实现类并注册

        public RestTemplate getRestTemplate(){

                return new RestTemplate();

        }

创建Controller类,在该类中调服务提供者提供的接口 :

@RestController

public class Controller{

        @Autowired

        private RestTemplate restTemplate;

        @GetMapping("/callHello")

        public String callHello(){

                return restTemplate.getForObject("http://localhost:8081/provider/hello",String.class);

        }

}

 启动项目,访问http://localhost:8082/callHello。如果有返回证明调用成功。

到此时,可以看到注册中心控制页面出现了两个客户端的信息,表明搭建Eureka服务成功了。

更多推荐