spring cloud 入门系列二：使用Eureka 进行服务治理

谁借莪１个温暖的怀抱￠ 2022-05-18 02:38 205阅读 0赞

服务治理可以说是微服务架构中最为核心和基础的模块，它主要用来实现各个微服务实例的自动化注册和发现。

Spring Cloud Eureka是Spring Cloud Netflix 微服务套件的一部分，主要负责完成微服务架构中的服务治理功能。

本文通过简单的小例子来分享下如何通过Eureka进行服务治理：

*  搭建服务注册中心
 *  注册服务提供者
 *  服务发现和消费

==========我是华丽的分割线========================

**一、搭建服务注册中心**

**　　**先列出完整目录结构：

**　　![1345071-20180426191904343-1384966815.png][]**

搭建过程如下：

1.  创建maven工程：eureka(具体实现略)
2.  修改pom文件，引入依赖
    
    ![复制代码][copycode.gif]
    
        <project xmlns="http://maven.apache.org/POM/4.0.0"
            xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
            xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
            <modelVersion>4.0.0</modelVersion>
            <groupId>com.sam</groupId>
            <artifactId>eureka</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        
            <parent>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-parent</artifactId>
                <version>1.5.1.RELEASE</version>
            </parent>
        
            <properties>
                <javaVersion>1.8</javaVersion>
            </properties>
            
            <dependencyManagement>
                <dependencies>
                    <dependency>
                        <groupId>org.springframework.cloud</groupId>
                        <artifactId>spring-cloud-dependencies</artifactId>
                        <version>Camden.SR6</version>
                        <type>pom</type>
                        <scope>import</scope>
                    </dependency>
                </dependencies>
        
            </dependencyManagement>
        
            <dependencies>
                
                <dependency>
                    <groupId>org.springframework.cloud</groupId>
                    <artifactId>spring-cloud-starter-eureka-server</artifactId>
                </dependency>
        
            </dependencies>
        
        </project>
    
    ![复制代码][copycode.gif]
3.  创建启动类
    
    ![复制代码][copycode.gif]
    
        /**
         * 
         * @EnableEurekaServer
         * 用来指定该项目为Eureka的服务注册中心
         */
        @EnableEurekaServer
        @SpringBootApplication
        public class EurekaApp {
        
            public static void main(String[] args) {
                SpringApplication.run(EurekaApp.class, args);
            }
        }
    
    ![复制代码][copycode.gif]
4.  配置application.properties文件
    
    ![复制代码][copycode.gif]
    
        #设置tomcat服务端口号
        server.port=1111
        #设置服务名称
        spring.application.name=eureka-service
        
        eureka.instance.hostname=localhost
        #注册中心不需要注册自己
        eureka.client.register-with-eureka=false
        #注册中心不需要去发现服务
        eureka.client.fetch-registry=false
        #设置服务注册中心的URL
        eureka.client.serviceUrl.defaultZone=http://${eureka.instance.hostname}:${server.port}/eureka
    
    ![复制代码][copycode.gif]
5.  启动服务并访问，我们会看到这样的画面：
    
    ![1345071-20180426192453375-449301906.png][]

**二、注册服务提供者**

先列出完整目录结构：

![1345071-20180426192754908-221819504.png][]

搭建过程如下：

1.  创建maven工程：hello-service(具体实现略)
2.  修改pom文件，引入依赖
    
    ![复制代码][copycode.gif]
    
        <project xmlns="http://maven.apache.org/POM/4.0.0"
            xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
            xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
            <modelVersion>4.0.0</modelVersion>
            <groupId>com.sam</groupId>
            <artifactId>hello-service</artifactId>
            <version>0.0.1-SNAPSHOT</version>
            <parent>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-parent</artifactId>
                <version>1.5.1.RELEASE</version>
            </parent>
        
            <properties>
                <javaVersion>1.8</javaVersion>
            </properties>
        
            <dependencyManagement>
                <dependencies>
                    <dependency>
                        <groupId>org.springframework.cloud</groupId>
                        <artifactId>spring-cloud-dependencies</artifactId>
                        <version>Camden.SR6</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>
        </project>
    
    ![复制代码][copycode.gif]
3.  创建启动类
    
    ![复制代码][copycode.gif]
    
        /***
         * 
         * @EnableDiscoveryClient
         * 让服务使用eureka服务器
         * 实现服务注册和发现
         *
         */
        @EnableDiscoveryClient
        @SpringBootApplication
        public class HelloApp {
        
            public static void main(String[] args) {
        
                SpringApplication.run(HelloApp.class, args);
            }
        
        }
    
    ![复制代码][copycode.gif]
4.  创建controller
    
    ![复制代码][copycode.gif]
    
        @RestController
        public class HelloController {
        
            Logger logger = LoggerFactory.getLogger(HelloController.class);
        
            @Autowired
            DiscoveryClient discoveryClient;
            
            @RequestMapping("/hello")
            public String hello() {
                ServiceInstance instance = discoveryClient.getLocalServiceInstance();
                //打印服务的服务id
                logger.info("*********" + instance.getServiceId());
                return "hello,this is hello-service";
            }
        }
    
    ![复制代码][copycode.gif]
5.  配置application.properties文件
    
        server.port=9090
        #设置服务名
        spring.application.name=hello-service
        #设置服务注册中心的URL，本服务要向该服务注册中心注册自己
        eureka.client.serviceUrl.defaultZone=http://localhost:1111/eureka
6.  启动并测试
    
    1.  ）启动后再hello-service的控制台会有这种字样(xxx代表你的PC名)
        
            Registered instance HELLO-SERVICE/xxx:hello-service:9090 with status UP (replication=false)
        
        eureka的控制台会打印出如下字样(xxx代表你的PC名)
        
            Registered instance HELLO-SERVICE/xxx:hello-service:9090 with status UP (replication=false)
    2.  ）再次访问localhost:1111,会发现有服务注册到注册中心了![1345071-20180629095759925-1889861980.png][]

**三、服务发现和消费**

完整目录结构如下：

![1345071-20180426194259692-1694813721.png][]

搭建过程：

1.  创建maven工程(具体实现略)
2.  修改pom文件，引入依赖
    
    ![复制代码][copycode.gif]
    
        <project xmlns="http://maven.apache.org/POM/4.0.0"
            xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
            xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
            <modelVersion>4.0.0</modelVersion>
            <groupId>com.sam</groupId>
            <artifactId>hello-consumer</artifactId>
            <version>0.0.1-SNAPSHOT</version>
            <parent>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-parent</artifactId>
                <version>1.5.1.RELEASE</version>
            </parent>
        
            <properties>
                <javaVersion>1.8</javaVersion>
            </properties>
        
            <dependencyManagement>
                <dependencies>
                    <dependency>
                        <groupId>org.springframework.cloud</groupId>
                        <artifactId>spring-cloud-dependencies</artifactId>
                        <version>Camden.SR6</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>
        </project>
        
        这里比hello-service服务提供者，多了ribbon的依赖
    
    ![复制代码][copycode.gif]
3.  创建启动类
    
    ![复制代码][copycode.gif]
    
        @EnableDiscoveryClient
        @SpringBootApplication
        public class ConsumerApp {
        
        
            //@Bean 应用在方法上，用来将方法返回值设为为bean
            @Bean
            @LoadBalanced  //@LoadBalanced实现负载均衡
            public RestTemplate restTemplate() {
                return new RestTemplate();
            }
            
            public static void main(String[] args) {
                SpringApplication.run(ConsumerApp.class, args);
            }
        }
    
        这里也要用到@EnableDiscoveryClient， 让服务使用eureka服务器， 实现服务注册和发现
    
         
    
    ![复制代码][copycode.gif]
4.  创建controller
    
    ![复制代码][copycode.gif]
    
        @RestController
        public class ConsumerController {
        
            //这里注入的restTemplate就是在com.sam.ConsumerApp中通过@Bean配置的实例
            @Autowired
            RestTemplate restTemplate;
        
            @RequestMapping("/hello-consumer")
            public String helloConsumer() {
                //调用hello-service服务，注意这里用的是服务名，而不是具体的ip+port
                restTemplate.getForObject("http://hello-service/hello", String.class);
                return "hello consumer finish !!!";
            }
        }
    
    ![复制代码][copycode.gif]
5.  配置application.properties文件
    
    ![复制代码][copycode.gif]
    
        server.port=9999
        
        spring.application.name=hello-consumer
        eureka.client.serviceUrl.defaultZone=http://localhost:1111/eureka
        
        
        #这里的配置项目和服务提供者hello-service一样
    
    ![复制代码][copycode.gif]
6.  启动，测试
    
    1.  ）启动eureka。为了展示负责均衡的效果，我们的hello-service启动两个服务，启动两个服务的具体步骤如下
        
        1.  ![1345071-20180426195212338-805559983.png][]
            
            ![1345071-20180426195327136-397391223.png][]
            
            ![1345071-20180426195428349-831253214.png][]
            
            ![1345071-20180426195502772-1507437993.png][]
            
            以上是hello-service1的启动步骤，端口号为9090；同样方法设置hello-service2，端口号为9091(具体实现略)。
    2.  ）启动hello-consumer
    3.  ）再次访问http://localhost:1111/，会发现有2个hello-service服务（端口号一个是9090，一个是9091），1个hello-consume服务
    4.  )   多次访问http://localhost:9999/hello-consumer，会发现hello-service1和hello-service2会轮流被调用（已经实现了负责均衡），可以通过两者的控制台打印内容确认（还记得我们在hello-service的controller中有个loggerlogger.info("\*\*\*\*\*\*\*\*\*" + instance.getServiceId());吗？对，就是这个打印）![1345071-20180426200341672-1034693374.png][]
        
        ![1345071-20180426200400206-1950194916.png][]
        
        ![1345071-20180426200421470-20498103.png][]
        
        ![1345071-20180426200424641-582674468.png][]

**四、总结**

以上实例实现了基本的服务治理：

*  通过spring-cloud-starter-eureka-server和@EnableEurekaServer实现服务注册中心
 *  通过spring-cloud-starter-eureka和@EnableDiscoveryClient使用并注册到服务注册中心
 *  通过spring-cloud-starter-eureka和@EnableDiscoveryClient使用注册中心并发现服务，通过spring-cloud-starter-ribbon来实现负载均衡消费服务

PS：这里说明下，我用的IDE是Spring Tool Suite，是spring定制版的eclipse，方便我们使用spring进行开发，有兴趣的朋友可以自行百度了解下。

[1345071-20180426191904343-1384966815.png]: /images/20220518/40e66c91ec924103863eb076d444e6fa.png
[copycode.gif]: /images/20220518/0b02ab90d3fe437185d735512652b939.png
[1345071-20180426192453375-449301906.png]: /images/20220518/dd6af188ca8b47afa59c732be6e47a81.png
[1345071-20180426192754908-221819504.png]: /images/20220518/636c9efdc8eb46bc825c82f566191a5e.png
[1345071-20180629095759925-1889861980.png]: /images/20220518/87e19f7ab08a4693a0e3e5a206cd03ef.png
[1345071-20180426194259692-1694813721.png]: /images/20220518/2b8a4c0b87f84d01851bc704f3ba12d5.png
[1345071-20180426195212338-805559983.png]: /images/20220518/4da87a0119d146d0b993b69e39353cd2.png
[1345071-20180426195327136-397391223.png]: /images/20220518/986891ee26254ed791351dfff62e172c.png
[1345071-20180426195428349-831253214.png]: /images/20220518/842bd627d4e84e59a3b9e62e67e73caf.png
[1345071-20180426195502772-1507437993.png]: /images/20220518/0ab9accca38e4b60932475b147e4f604.png
[1345071-20180426200341672-1034693374.png]: /images/20220518/70de908784514b97bfc8ca4dd619c4ee.png
[1345071-20180426200400206-1950194916.png]: /images/20220518/559f187f350c461d8eabfe0eed56d736.png
[1345071-20180426200421470-20498103.png]: /images/20220518/f1aded4126c74365a3d3e65c4fb3408e.png
[1345071-20180426200424641-582674468.png]: /images/20220518/0c10fe5252b340debf563cfa34596df6.png