041 用户注册功能01--搭建微服务和数据验证功能

Posted 2022-12-26 luckyplj

1.创建用户中心微服务

用户搜索到自己心仪的商品，接下来就要去购买，但是购买必须先登录。所以接下来我们编写用户中心，实现用户的登录和注册功能。

用户中心的提供的服务：

• 用户的注册

• 用户登录

这里我们暂时先实现基本的：注册和登录功能。

因为用户中心的服务其它微服务也会调用，因此这里我们做聚合。

leyou-user：父工程，包含2个子工程：

• leyou-user-interface：实体及接口

• leyou-user-service：业务和服务

(1)创建父module

 

(2)创建leyou-user-interface

在leyou-user下，创建module：

pom文件：

<?xml version="1.0" encoding="UTF-8"?>
<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">
    <parent>
        <artifactId>leyou-user</artifactId>
        <groupId>lucky.leyou.user</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <groupId>lucky.leyou.user</groupId>
    <artifactId>leyou-user-interface</artifactId>


</project>

(3)创建leyou-user-service

注意：创建leyou-user-service过程与创建leyou-user-interface过程类似

pom文件：

<?xml version="1.0" encoding="UTF-8"?>
<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">
    <parent>
        <artifactId>leyou-user</artifactId>
        <groupId>lucky.leyou.user</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <groupId>lucky.leyou.user</groupId>
    <artifactId>leyou-user-service</artifactId>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jdbc</artifactId>
        </dependency>
        <!-- mybatis启动器 -->
        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</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>lucky.leyou.user</groupId>
            <artifactId>leyou-user-interface</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
        </dependency>
    </dependencies>


</project>

启动器类：

package lucky.leyou;

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
@EnableDiscoveryClient
@MapperScan("lucky.leyou.user.mapper")
public class LeyouUserApplication 

    public static void main(String[] args) 
        SpringApplication.run(LeyouUserApplication.class, args);
    

配置：

server:
  port: 8085
spring:
  application:
    name: user-service
  datasource:
      url: jdbc:mysql://localhost:3306/leyou?serverTimezone=UTC&useSSL=false
      username: root
      password: plj824
      driver-class-name: com.mysql.jdbc.Driver
eureka:
  client:
    service-url:
      defaultZone: http://127.0.0.1:10086/eureka
  instance:
    lease-renewal-interval-in-seconds: 5
    lease-expiration-duration-in-seconds: 15

mybatis:
  type-aliases-package: lucky.leyou.user.domain

父工程leyou-user的pom：

<?xml version="1.0" encoding="UTF-8"?>
<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">
    <parent>
        <artifactId>leyou</artifactId>
        <groupId>lucky.leyou.parent</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <groupId>lucky.leyou.user</groupId>
    <artifactId>leyou-user</artifactId>
    <packaging>pom</packaging>
    <modules>
        <module>leyou-user-interface</module>
        <module>leyou-user-service</module>
    </modules>


</project>

(4)添加网关路由

我们修改leyou-gateway，添加路由规则，对leyou-user-service进行路由:

 

server:
  port: 10010
spring:
  application:
    name: leyou-gateway
eureka:
  client:
    registry-fetch-interval-seconds: 5
    service-url:
      defaultZone: http://localhost:10086/eureka
zuul:
  prefix: /api # 路由路径前缀
  routes:
      item-service: /item/**  # 商品微服务的映射路径
      search-service: /search/** #搜索微服务
      user-service: /user/**  #用户微服务

2.后台功能准备

(1)数据结构

CREATE TABLE `tb_user` (
  `id` bigint(20) NOT NULL AUTO_INCREMENT,
  `username` varchar(50) NOT NULL COMMENT ‘用户名‘,
  `password` varchar(32) NOT NULL COMMENT ‘密码，加密存储‘,
  `phone` varchar(20) DEFAULT NULL COMMENT ‘注册手机号‘,
  `created` datetime NOT NULL COMMENT ‘创建时间‘,
  `salt` varchar(32) NOT NULL COMMENT ‘密码加密的salt值‘,
  PRIMARY KEY (`id`),
  UNIQUE KEY `username` (`username`) USING BTREE
) ENGINE=InnoDB AUTO_INCREMENT=28 DEFAULT CHARSET=utf8 COMMENT=‘用户表‘;

数据结构比较简单，因为根据用户名查询的频率较高，所以我们给用户名创建了索引

(2)基本代码

<1>实体类

需要用到实体类注解，pom文件中添加依赖

<dependencies>
        <dependency>
            <groupId>javax.persistence</groupId>
            <artifactId>persistence-api</artifactId>
            <version>1.0</version>
        </dependency>
        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-databind</artifactId>
            <version>2.9.6</version>
        </dependency>
    </dependencies>

实体类：

package lucky.leyou.user.domain;

import com.fasterxml.jackson.annotation.JsonIgnore;

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

@Table(name = "tb_user")
public class User 
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;

    private String username;// 用户名

    @JsonIgnore
    private String password;// 密码

    private String phone;// 电话

    private Date created;// 创建时间

    @JsonIgnore //对象序列化为json字符串时，忽略该属性
    private String salt;// 密码的盐值

    public Long getId() 
        return id;
    

    public void setId(Long id) 
        this.id = id;
    

    public String getUsername() 
        return username;
    

    public void setUsername(String username) 
        this.username = username;
    

    public String getPassword() 
        return password;
    

    public void setPassword(String password) 
        this.password = password;
    

    public String getPhone() 
        return phone;
    

    public void setPhone(String phone) 
        this.phone = phone;
    

    public Date getCreated() 
        return created;
    

    public void setCreated(Date created) 
        this.created = created;
    

    public String getSalt() 
        return salt;
    

    public void setSalt(String salt) 
        this.salt = salt;
    

注意：为了安全考虑。这里对password和salt添加了注解@JsonIgnore，这样在json序列化时，就不会把password和salt返回

<2>mapper

package lucky.leyou.user.mapper;

import lucky.leyou.user.domain.User;
import tk.mybatis.mapper.common.Mapper;

public interface UserMapper extends Mapper<User> 

<3>Service

package lucky.leyou.user.service;

import lucky.leyou.user.mapper.UserMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class UserService 
    @Autowired
    private UserMapper userMapper;

<4>Controller

package lucky.leyou.user.controller;
import lucky.leyou.user.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;

@Controller
public class UserController 
    @Autowired
    private UserService userService;
    

3.数据验证功能

(1)接口说明

实现用户数据的校验，主要包括对：手机号、用户名的唯一性校验。

接口路径：

 

GET /check/data/type

参数说明：

返回结果：

返回布尔类型结果：

• true：可用

• false：不可用

状态码：

• 200：校验成功

• 400：参数有误

• 500：服务器内部异常

(2)controller

因为有了接口，我们可以不关心页面，所有需要的东西都一清二楚：

• 请求方式：GET

• 请求路径：/check/param/type

• 请求参数：param,type

• 返回结果：true或false

/**
     * 校验数据是否可用
     * @param data 占位符参数
     * @param type 占位符参数
     * @return
     */
    @GetMapping("check/data/type")
    public ResponseEntity<Boolean> checkUserData(@PathVariable("data") String data, @PathVariable(value = "type") Integer type) 
        Boolean boo = this.userService.checkUser(data, type);
        if (boo == null) 
            //参数不合法
            return ResponseEntity.badRequest().build();
        
        return ResponseEntity.ok(boo);
    

(3)service

/**
     * 实现用户数据的校验，主要包括对：手机号、用户名的唯一性校验。
     * @param data 占位符参数
     * @param type
     * @return
     */
    public Boolean checkUser(String data, Integer type) 
        User record = new User();
        switch (type) 
            case 1:
                record.setUsername(data);
                break;
            case 2:
                record.setPhone(data);
                break;
            default:
                return null;
        
        return this.userMapper.selectCount(record) == 0;
    

(4)测试

<1>启动nginx

<2>开启微服务

我们在数据库插入一条假数据：

然后在浏览器调用接口，测试：

不经过网关，直接通过端口访问

 

经过网关，通过Nginx代理直接通过端口访问