SpringCloud-Eureka【服务案例】

╰半夏微凉° 2022-01-26 11:39 177阅读 0赞

上篇文章我们介绍了Eureka的集群环境搭建，本文我们来通过Eureka作为注册中心来实现一个案例，案例结构如下

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70]

# 一、启动Eureka服务 #

在我们部署的Eureka几点上分别指向如下命令，启动Eureka服务

./server.sh start

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 1]

# 二、构建Provider服务 #

## 1.创建SpringBoot项目 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 2]

## 2.修改pom文件 ##

添加相关依赖，注意此处添加的Eureka的依赖不需要加"-server"

<dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-config</artifactId>
                <version>1.4.5.RELEASE</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-eureka</artifactId>
                <version>1.4.6.RELEASE</version>
            </dependency>
        </dependencies>
    
        <dependencyManagement>
            <dependencies>
                <dependency>
                    <groupId>org.springframework.cloud</groupId>
                    <artifactId>spring-cloud-dependencies</artifactId>
                    <version>Dalston.SR5</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
            </dependencies>
        </dependencyManagement>

## 3.修改启动类 ##

在启动类的头部开启Eureka客户端的主键

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 3]

## 4.添加配置信息 ##

在application.properties中添加如下的信息

spring.application.name=eureka-provider
    server.port=9090
    
    # 设置服务注册中心地址，指向另一个注册中心
    eureka.client.serviceUrl.defaultZone=http://eureka1:8761/eureka/,http://eureka2:8761/eureka/

注意eureka1和eureka2我们需要在hosts文件中配置映射如下

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 4]

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 5]

## 5.添加服务 ##

创建pojo

package com.dpb.springcloud_eureka_provider.pojo;
    
    /** * @program: springcloud-eureka-provider * @description: UserBean * @author: 波波烤鸭 * @create: 2019-05-28 17:31 */
    public class User { 
        private int userid;
        private String username;
        private int userage;
    
        public int getUserid() { 
            return userid;
        }
    
        public void setUserid(int userid) { 
            this.userid = userid;
        }
    
        public String getUsername() { 
            return username;
        }
    
        public void setUsername(String username) { 
            this.username = username;
        }
    
        public int getUserage() { 
            return userage;
        }
    
        public void setUserage(int userage) { 
            this.userage = userage;
        }
    
        public User(int userid, String username, int userage) { 
            this.userid = userid;
            this.username = username;
            this.userage = userage;
        }
    
        public User() { 
        }
    }

创建控制器

/** * @program: springcloud-eureka-provider * @description: 服务提供者 * @author: 波波烤鸭 * @create: 2019-05-28 17:30 */
    @RestController
    public class UserController { 
    
        @RequestMapping("/user")
        public List<User> getUsers(){ 
            List<User> list = new ArrayList<>();
            list.add(new User(1,"zhangsan",20));
            list.add(new User(2,"lisi",22));
            list.add(new User(3,"wangwu",20));
            return list;
        }
    }

## 6.启动服务 ##

启动服务,在注册中心我们可以看到我们的服务提供者

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 6]

# 三、构建Consumer服务 #

创建服务的消费者，和提供者差不多。

## 1.创建项目 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 7]

## 2.pom依赖 ##

## 3.启动类 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 8]

## 4.配置文件 ##

spring.application.name=eureka-consumer
    server.port=9091
    #设置服务注册中心地址，指向另一个注册中心
    eureka.client.serviceUrl.defaultZone=http://eureka1:8761/eureka/,http://eureka2:8761/eureka/

## 5.完成服务调用 ##

消费者完成服务端服务的调用

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 9]  
service中代码

/** * @program: springcloud-eureka-consumer * @description: 用户的业务处理 * @author: 波波烤鸭 * @create: 2019-05-28 17:43 */
    @Service
    public class UserService { 
    
        /** * ribbon 负载均衡 * LoadBalancerClient 通过服务名称可以获取对应的服务的相关信息 ip port等 */
        @Autowired
       private LoadBalancerClient loadBalancerClient;
    
        public List<User> getUsers(){ 
            // ServiceInstance 封装的有服务的基本信息 IP和端口等
            ServiceInstance si = this.loadBalancerClient.choose("eureka-provider");
            StringBuilder sb = new StringBuilder();
            sb.append("http://")
                    .append(si.getHost())
                    .append(":")
                    .append(si.getPort())
                    .append("/user");
            // SpringMVC RestTemplate
            RestTemplate rt = new RestTemplate();
            ParameterizedTypeReference<List<User>> type = new ParameterizedTypeReference<List<User>>() { };
            // ResponseEntity:封装了返回值的信息
            ResponseEntity<List<User>> response = rt.exchange(sb.toString(), HttpMethod.GET,null,type);
            List<User> list = response.getBody();
            return list;
        }
    }

<table> 
 <thead> 
  <tr> 
   <th>接口</th> 
   <th align="left">说明</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>LoadBalancerClient</td> 
   <td align="left">负载均衡器，根据服务名称可以获取对应服务的ip和host等信息</td> 
  </tr> 
  <tr> 
   <td>RestTemplate</td> 
   <td align="left">Rest服务模板，可以完成服务的调用</td> 
  </tr> 
 </tbody> 
</table>

控制器代码

/** * @program: springcloud-eureka-consumer * @description: 用户控制器 * @author: 波波烤鸭 * @create: 2019-05-28 17:40 */
    @RestController
    public class UserController { 
    
        @Autowired
        private UserService userService;
        @RequestMapping("/consumer")
        public List<User> getUsers(){ 
            return this.userService.getUsers();
        }
    }

## 6.启动服务 ##

启动服务后我们在eureka注册中心可以发现服务。

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 10]

请求消费者的接口来获取服务提供者提供的数据。

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 11]

案例成功~

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70]: /images/20220126/0dead75533ed4468bbbd541916371f12.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 1]: /images/20220126/1a763f34e0844484b8e8a174ac7b91d6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 2]: /images/20220126/33c83d56d385459289b895c96af076ac.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 3]: /images/20220126/e4a3dc802a6d406ea5357fea809c655f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 4]: /images/20220126/a645fa23d9dd43358dc945b10ff9097e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 5]: /images/20220126/1f143b6a34c34084a4ef2d01b221de57.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 6]: /images/20220126/fb3e8b61d2074f98ab6a3e0620bf82f5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 7]: /images/20220126/4c981b5cc1ce449a98a9c98dfeb27c7f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 8]: /images/20220126/6c6787c3224c420996b489d33cb54951.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 9]: /images/20220126/625324c2d05c42fb89780e85f8f5099b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 10]: /images/20220126/16cc947406bb4cc2ad61501473946e37.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 11]: /images/20220126/8abf8efd969043a2b26c95df00d9e7f2.png