Spring Cloud（2）Eureka概述

mjjackey

 关注

阅读 81

2022-01-28

要求

查询数据库中的用户数据并输出到浏览器。

在这里一共需要创建三个工程：

  1. 父工程springcloud：添加springboot父坐标，及管理其他组件依赖

  2. 用户服务工程user-service：整合mybatis，查询数据库中用户的数据；并提供查询用户服务

  3. 服务消费工程consumer-demo：利用查询用户服务获取用户数据并输出到浏览器

		<!-- springCloud -->
  	         <dependency>
	                <groupId>org.springframework.cloud</groupId>
	                <artifactId>spring-cloud-dependencies</artifactId>
         	        <version>${spring-cloud.version}</version>
        	        <type>pom</type>
        	        <scope>import</scope>
       	     </dependency>

配置user-service工程（服务提供者）

要求

配置user-service工程并能够根据用户id查询数据库中的用户数据，即通过浏览器服务http://localhost:9091/user/8输出用户数据

实现步骤

1 添加驱动器依赖(web、通用Mapper）

user-service工程pom依赖坐标：

<artifactId>user-service</artifactId>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!-- 通用Mapper启动器 -->
        <dependency>
            <groupId>tk.mybatis</groupId>
            <artifactId>mapper-spring-boot-starter</artifactId>
        </dependency>
        <!-- mysql驱动 -->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
    </dependencies>

2 创建启动引导类和配置文件

启动引导类

package com.yy.user;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import tk.mybatis.spring.annotation.MapperScan;

@SpringBootApplication
@MapperScan("com.yy.user.mapper")
public class UserApplication {
    public static void main(String[] args) {
        SpringApplication.run(UserApplication.class, args);
    }
}

配置文件application.yml

server:
  port: 9091
spring:
  datasource:
    driver-class-name: com.mysql.jdbc.Driver
    url: jdbc://localhost:3306/xueqiutest
    username: root
    password: root
# 使用了通用mapper，所以需要指定一下别名包的扫描
mybatis:
  type-aliases-package: com.yy.user.pojo

实体类的创建：


import lombok.Data;
import tk.mybatis.mapper.annotation.KeySql;

import javax.persistence.Id;
import javax.persistence.Table;
import java.util.Date;

@Data
@Table(name = "tb_user")
public class User{
    // id
    @Id
    //开启主键自动回填
    @KeySql(useGeneratedKeys = true)
    private Long id;

    // 用户名
    private String userName;

    // 密码
    private String password;
}

创建的数据库

3 修改配置文件中的参数

4 测试代码

需求：需要可以通过UserMapper去操作数据库，通过UserService实现查询业务，通过UserController实现处理的请求

mapper接口

package com.yy.user.mapper;

import com.yy.user.pojo.User;
import tk.mybatis.mapper.common.Mapper;

public interface UserMapper extends Mapper<User> {
}

service：

package com.yy.user.service;

import com.yy.user.mapper.UserMapper;
import com.yy.user.pojo.User;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class UserService {

    @Autowired
    private UserMapper userMapper;

    /**
     * 根据主键查询用户
     * @param id 用户id
     * @return 用户
     */
    public User queryById(Long id){
        return userMapper.selectByPrimaryKey(id);
    }
}

controller:

package com.yy.user.controller;

import com.yy.user.pojo.User;
import com.yy.user.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/user")
public class UserController {

    @Autowired
    private UserService userService;

    @GetMapping("/{id}")
    public User queryById(@PathVariable Long id){
        return userService.queryById(id);
    }
}

启动引导类后，测试结果便是上面数据库里面的数据的json格式

配置consumer-demo工程（服务调用者）

需求

编写测试类使用restTemplate访问user-service的路径根据id查询用户

访问http://localhost:8080/consumer/8使用RestTemplate获取http:/localhost:9091/user/8的数据

实现步骤

1 添加启动器依赖;

pom依赖

<dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
</dependencies>

2 创建启动引导类(注册RestTemplate)和配置文件;

启动引导类

package com.yy.consumer;

import org.springframework.boot.SpringApplication;
import org.springframework.cloud.client.SpringCloudApplication;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;

@SpringCloudApplication
public class ConsumerApplication {
    public static void main(String[] args) {
        SpringApplication.run(ConsumerApplication.class, args);
    }

    //注册RestTemplate
    @Bean
    public RestTemplate restTemplate(){
        return new RestTemplate();
    }
}

配置文件

3 编写测试代码(ConsumerController中使用restTemplate访问服务获取数据)

user实体类：只是接收数据，不对这些属性进行映射

package com.yy.consumer.pojo;

import lombok.Data;

@Data
public class User {
    private Long id;

    // 用户名
    private String userName;

    // 密码
    private String password;


}

ConsumerController

package com.yy.consumer.controller;

import com.yy.consumer.pojo.User;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

@RestController
@RequestMapping("/consumer")
public class ConsumerController {

    @Autowired
    private RestTemplate restTemplate;
    @GetMapping("/{id}")
    public String queryById(Long id){      
        String url = "http://localhost:9091/user/8";
        return restTemplate.getForObject(url, User.class);
    }
}

测试结果：

上面的两种方式的问题

上面的两种方法是分布式服务的测试，可以得出下面的这些问题：

  1. 在consumer中，我们把url地址硬编码到了代码中，不方便后期维护
  2. consumer需要记忆user-service的地址，如果出现变更，可能得不到通知，地址将失效
  3. consumer不清楚user-service的状态，服务宕机也不知道
  4. user-service只有1台服务，不具备高可用性
  5. 即便user-service形成集群，consumer还需自己实现负载均衡

解决这些问题的方法：SpringCloud

  1. 服务管理
  2. 服务如何实现负载均衡
  3. 服务如何解决容灾问题
  4. 服务如何实现统一配置

Eureka注册中心

Eureka作用（概述）

Eureka负责管理、记录服务提供者的信息。

服务调用者无需自己寻找服务，而是把自己的需求告诉Eureka，然后Eureka会把符合你需求的服务告诉你。

同时，服务提供方与Eureka之间通过 “心跳” 机制进行监控，当某个服务提供方出现问题，Eureka自然会把它从服务列表中剔除。

这就实现了服务的自动注册、发现、状态监控。

Eureka原理

在这里插入图片描述

实现步骤：从服务提供方开始

  1. 实例化服务
  2. 将实例化的服务注册到Eureka注册中心
  3. Eureka注册中心将服务记录，记录方式如下：
    user-service
	http://localhost:9091
	http://localhost:9091
	......
  4. 消费者从Eureka注册中心获取到服务列表
  5. 消费端会从服务列表中获取服务，均匀负载均衡算法从地址列表选择一个服务地址调用服务
  6. 这时候，服务消费者会定期发送服务是否存活，即定期发送心跳
  7. 注册中心检查那些没有定期发送心跳的服务，并将其在一定时间内剔除服务地址列表（消费者获取的服务列表基本上都是可以使用的）

相关推荐

Spring Cloud Eureka

岛上码农 55 0 0

Spring Cloud Eureka配置

沐之轻语 75 0 0

新Spring Cloud（2）Eureka注册中心详解

青乌 167 0 0

Spring Cloud学习--Spring Cloud Eureka服务注册

产品喵dandan米娜 126 0 0

Spring Cloud学习--Spring Cloud Eureka服务下线

东言肆语 181 0 0

Spring Cloud Netflix 之 Eureka

搬砖的小木匠 40 0 0

【Spring Cloud】002-Spring Cloud概述

40dba2f2a596 113 0 0

Spring Cloud Eureka 原理分析

booksmg2014 191 0 0

【Spring Cloud】Eureka注册中心

三维控件研究 126 0 0

【spring cloud学习】2、Eureka服务注册与发现

蒸熟的土豆 65 0 0

精彩评论（0）

0 0 举报