homepage 第六期:user 微服务搭建,单元测试,可用性测试准备

本贴最后更新于 1817 天前,其中的信息可能已经时移俗易

1.首先创建服务层接口 IUserService,里边包含了三个方法,即创建用户,根据 id 获取用户,和根据 id 获取用户和用户的课程信息

package cn.chenforcode.homepage.service;

import cn.chenforcode.homepage.UserInfo;
import cn.chenforcode.homepage.vo.CreateUserRequest;
import cn.chenforcode.homepage.vo.UserCourseInfo;

/**
 * @author <a href="http://www.chenforcode.cn">PKUCoder</a>
 * @date 2019/11/13 2:33 下午
 * @description 用户服务的服务层接口
 */
public interface IUserService {
    /**
     * @Author <a href="http://www.chenforcode.cn">PKUCoder</a>
     * @Date 2019/11/13 2:35 下午
     * @Param [request]
     * @Return cn.chenforcode.homepage.UserInfo
     * @Description 创建一个user
     **/
    UserInfo creatUser(CreateUserRequest request);

    /**
     * @Author <a href="http://www.chenforcode.cn">PKUCoder</a>
     * @Date 2019/11/13 2:36 下午
     * @Param [id]
     * @Return cn.chenforcode.homepage.UserInfo
     * @Description 根据id获取userinfo信息
     **/
    UserInfo getUserInfo(Long id);

    /**
     * @Author <a href="http://www.chenforcode.cn">PKUCoder</a>
     * @Date 2019/11/13 2:36 下午
     * @Param [id]
     * @Return cn.chenforcode.homepage.vo.UserCourseInfo
     * @Description 获取用户的信息和课程信息
     **/
    UserCourseInfo getUserCourseInfo(Long id);
}

2.对该接口进行实现,这里对大部分的代码都进行了注释。但是要注意一点,在获取用户的课程信息的时候是调用了课程微服务,所以需要把 courseClient 也注入进来。但是从 userClient 获取 courseInfo 的时候注意调用函数所需要的参数。

package cn.chenforcode.homepage.service.impl;

import cn.chenforcode.homepage.CourseInfo;
import cn.chenforcode.homepage.CourseInfosRequest;
import cn.chenforcode.homepage.UserInfo;
import cn.chenforcode.homepage.client.CourseClient;
import cn.chenforcode.homepage.entity.HomepageUser;
import cn.chenforcode.homepage.entity.HomepageUserCourse;
import cn.chenforcode.homepage.repository.HomepageUserCourseRepository;
import cn.chenforcode.homepage.repository.HomepageUserRepository;
import cn.chenforcode.homepage.service.IUserService;
import cn.chenforcode.homepage.vo.CreateUserRequest;
import cn.chenforcode.homepage.vo.UserCourseInfo;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;

import java.util.Collections;
import java.util.List;
import java.util.Optional;
import java.util.stream.Collectors;

/**
 * @author <a href="http://www.chenforcode.cn">PKUCoder</a>
 * @date 2019/11/13 2:37 下午
 * @description 用户服务服务层实现类
 */
@Slf4j
@Service
public class UserServiceImpl implements IUserService {
    @Autowired
    private HomepageUserRepository userRepository;

    @Autowired
    private HomepageUserCourseRepository userCourseRepository;

    @Autowired
    private CourseClient courseClient;

    @Override
    public UserInfo creatUser(CreateUserRequest request) {
        //首先判断request是否合法
        if (!request.validate()) {
            return UserInfo.invalid();
        }
        HomepageUser oldUser = userRepository.findByUsername(request.getUsername());
        //判断是否已经存在了这个用户名的用户
        if (null == oldUser) {
            return UserInfo.invalid();
        }

        HomepageUser newUser = userRepository.save(
                new HomepageUser(request.getUsername(), request.getEmail())
        );
        return new UserInfo(newUser.getId(), newUser.getUsername(), newUser.getEmail());
    }

    @Override
    public UserInfo getUserInfo(Long id) {
        Optional<HomepageUser> user = userRepository.findById(id);
        //如果不存在这个id的用户
        if (!user.isPresent()) {
            return UserInfo.invalid();
        }
        HomepageUser curUser = user.get();
        return new UserInfo(curUser.getId(), curUser.getUsername(), curUser.getEmail());
    }

    @Override
    public UserCourseInfo getUserCourseInfo(Long id) {
        Optional<HomepageUser> user = userRepository.findById(id);
        //如果不存在这个id的用户
        if (!user.isPresent()) {
            return UserCourseInfo.invalid();
        }
        HomepageUser homepageUser = user.get();
        //得到userInfo
        UserInfo userInfo = new UserInfo(homepageUser.getId(), homepageUser.getUsername(), homepageUser.getEmail());

        //开始拿到课程信息
        //拿到userCourse的信息,即用户和课程的一一对应信息
        List<HomepageUserCourse> homepageUserCourses = userCourseRepository.findAllByUserId(
                homepageUser.getId()
        );
        //如果这个人没有课程,就返回一个只有用户信息和空列表的userCourseInfo
        if (CollectionUtils.isEmpty(homepageUserCourses)) {
            return new UserCourseInfo(userInfo, Collections.emptyList());
        }
        //理解一下这里,首先如果要拿到courseInfos就需要一个courseInfosRequest对象,然后这个对象里的属性是一个ids,即
        //所有的课程id的list,那么这个list就从homepageUser的list用lambda表达式拿到
        List<CourseInfo> courseInfos = courseClient.getCourseInfos(
                new CourseInfosRequest(homepageUserCourses.stream()
                        .map(HomepageUserCourse::getId)
                        .collect(Collectors.toList()))
        );
        return new UserCourseInfo(userInfo, courseInfos);
    }
}

3.用户服务 controller 层

package cn.chenforcode.homepage.controller;

import cn.chenforcode.homepage.UserInfo;
import cn.chenforcode.homepage.service.IUserService;
import cn.chenforcode.homepage.vo.CreateUserRequest;
import cn.chenforcode.homepage.vo.UserCourseInfo;
import com.alibaba.fastjson.JSON;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;


/**
 * @author <a href="http://www.chenforcode.cn">PKUCoder</a>
 * @date 2019/11/13 4:21 下午
 * @description 用户服务对外接口
 */
@Slf4j
@RestController
public class HomepageUserController {
    @Autowired
    private IUserService userService;

    @PostMapping("/create/user")
    public UserInfo createUser(@RequestBody CreateUserRequest request) {
        log.info("<homepage-user> : create user -> {}", JSON.toJSONString(request));
        return userService.creatUser(request);
    }

    @GetMapping("/get/user")
    public UserInfo getUser(Long id) {
        log.info("<homepage-user> : get user -> {}", id);
        return userService.getUserInfo(id);
    }

    @GetMapping("/get/user/course")
    public UserCourseInfo getUserCourseInfo(Long id) {
        log.info("<homepage-user> : get user course info -> {}", id);
        return userService.getUserCourseInfo(id);
    }
}

4.完成相关功能性测试,创建 test resources 目录,并将 main 目录的配置文件拷贝进来。但是由于想要在测试用例中调用其他的 feign 接口,需要吧 course 服务单独启动起来,那么我们现在先不这样做,我们只是测试一下 user 的功能。所以在配置文件中删除 feign 相关的配置

5.建立测试启动类

package cn.chenforcode.homepage;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.openfeign.EnableFeignClients;

/**
 * @author <a href="http://www.chenforcode.cn">PKUCoder</a>
 * @date 2019/11/13 4:58 下午
 * @description user服务测试启动类
 */
@EnableFeignClients(basePackages = {"cn.chenforcode.homepage"})
@SpringBootApplication
public class Application {
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

6.测试增加用户

@Test
    @Transactional
    public void testCreateUser() {
        System.out.println(userService.createUser(
                new CreateUserRequest("pkucoder", "pkucoder@qq.com")
        ));
    }

@Transactional 是 org.springframework.transaction.annotation.Transactional 包下的,作用是测试用例执行完之后对数据库进行回滚

6.测试获取用户信息

 //{"email":"pkucoder@qq.com","id":10,"username":"pkucoder"}
    @Test
    public void testGetUserInfo() {
        System.out.println(JSON.toJSONString(
                userService.getUserInfo(10L)
        ));
    }

7.由于测试获取课程需要先启动课程服务,在单元测试中不好实现,所以需要在后续的 postman 中直接用 http 的方式去测试,所以在这里先预先加入一些 mock 数据,即增加 homepageUserCourse

@Test
    public void testCreateHomepageUserCourse() {
        HomepageUserCourse userCourse1 = new HomepageUserCourse();
        userCourse1.setUserId(10L);
        userCourse1.setCourseId(8L);

        HomepageUserCourse userCourse2 = new HomepageUserCourse();
        userCourse2.setUserId(10L);
        userCourse2.setCourseId(9L);
        System.out.println(userCourseRepository.saveAll(Arrays.asList(userCourse1, userCourse2)).size());
    }

8.可用性测试之前的准备,配置网关服务,修改 zuul 的 application.yml
增加如下内容,
@1.prefix 的意思是所有的网关访问如下服务需要带上 chenforcode 的前缀,这个前缀可有可无
@2.course 和 user 是随便起的,但是尽量和服务相关
@3.path 代表所有带上这个前缀的服务都会被发送到 serviceId 所指定的服务中
@4.strip-prefix 代表是否去除请求的前缀,置为 false

zuul:
  prefix: /chenforcode
  routes:
    course:
      path: /homepage-course/**
      serviceId: eureka-client-homepage-course
      strip-prefix: false
    user:
      path: /homepage-user/**
      serviceId: eureka-client-homepage-user
      strip-prefix: false
  • Java

    Java 是一种可以撰写跨平台应用软件的面向对象的程序设计语言,是由 Sun Microsystems 公司于 1995 年 5 月推出的。Java 技术具有卓越的通用性、高效性、平台移植性和安全性。

    3184 引用 • 8212 回帖 • 1 关注
  • 云计算
    78 引用 • 91 回帖 • 1 关注
  • homepage系列
    7 引用

相关帖子

欢迎来到这里!

我们正在构建一个小众社区,大家在这里相互信任,以平等 • 自由 • 奔放的价值观进行分享交流。最终,希望大家能够找到与自己志同道合的伙伴,共同成长。

注册 关于
请输入回帖内容 ...

推荐标签 标签

  • Openfire

    Openfire 是开源的、基于可拓展通讯和表示协议 (XMPP)、采用 Java 编程语言开发的实时协作服务器。Openfire 的效率很高,单台服务器可支持上万并发用户。

    6 引用 • 7 回帖 • 96 关注
  • Kubernetes

    Kubernetes 是 Google 开源的一个容器编排引擎,它支持自动化部署、大规模可伸缩、应用容器化管理。

    110 引用 • 54 回帖 • 4 关注
  • Webswing

    Webswing 是一个能将任何 Swing 应用通过纯 HTML5 运行在浏览器中的 Web 服务器,详细介绍请看 将 Java Swing 应用变成 Web 应用

    1 引用 • 15 回帖 • 619 关注
  • Angular

    AngularAngularJS 的新版本。

    26 引用 • 66 回帖 • 533 关注
  • AngularJS

    AngularJS 诞生于 2009 年,由 Misko Hevery 等人创建,后为 Google 所收购。是一款优秀的前端 JS 框架,已经被用于 Google 的多款产品当中。AngularJS 有着诸多特性,最为核心的是:MVC、模块化、自动化双向数据绑定、语义化标签、依赖注入等。2.0 版本后已经改名为 Angular。

    12 引用 • 50 回帖 • 475 关注
  • Node.js

    Node.js 是一个基于 Chrome JavaScript 运行时建立的平台, 用于方便地搭建响应速度快、易于扩展的网络应用。Node.js 使用事件驱动, 非阻塞 I/O 模型而得以轻量和高效。

    139 引用 • 269 回帖 • 49 关注
  • 自由行
    2 关注
  • jQuery

    jQuery 是一套跨浏览器的 JavaScript 库,强化 HTML 与 JavaScript 之间的操作。由 John Resig 在 2006 年 1 月的 BarCamp NYC 上释出第一个版本。全球约有 28% 的网站使用 jQuery,是非常受欢迎的 JavaScript 库。

    63 引用 • 134 回帖 • 725 关注
  • wolai

    我来 wolai:不仅仅是未来的云端笔记!

    2 引用 • 14 回帖
  • 支付宝

    支付宝是全球领先的独立第三方支付平台,致力于为广大用户提供安全快速的电子支付/网上支付/安全支付/手机支付体验,及转账收款/水电煤缴费/信用卡还款/AA 收款等生活服务应用。

    29 引用 • 347 回帖
  • 国际化

    i18n(其来源是英文单词 internationalization 的首末字符 i 和 n,18 为中间的字符数)是“国际化”的简称。对程序来说,国际化是指在不修改代码的情况下,能根据不同语言及地区显示相应的界面。

    8 引用 • 26 回帖 • 1 关注
  • Hadoop

    Hadoop 是由 Apache 基金会所开发的一个分布式系统基础架构。用户可以在不了解分布式底层细节的情况下,开发分布式程序。充分利用集群的威力进行高速运算和存储。

    86 引用 • 122 回帖 • 618 关注
  • sts
    2 引用 • 2 回帖 • 193 关注
  • Rust

    Rust 是一门赋予每个人构建可靠且高效软件能力的语言。Rust 由 Mozilla 开发,最早发布于 2014 年 9 月。

    58 引用 • 22 回帖 • 3 关注
  • Swift

    Swift 是苹果于 2014 年 WWDC(苹果开发者大会)发布的开发语言,可与 Objective-C 共同运行于 Mac OS 和 iOS 平台,用于搭建基于苹果平台的应用程序。

    36 引用 • 37 回帖 • 532 关注
  • 外包

    有空闲时间是接外包好呢还是学习好呢?

    26 引用 • 232 回帖
  • 微服务

    微服务架构是一种架构模式,它提倡将单一应用划分成一组小的服务。服务之间互相协调,互相配合,为用户提供最终价值。每个服务运行在独立的进程中。服务于服务之间才用轻量级的通信机制互相沟通。每个服务都围绕着具体业务构建,能够被独立的部署。

    96 引用 • 155 回帖
  • 知乎

    知乎是网络问答社区,连接各行各业的用户。用户分享着彼此的知识、经验和见解,为中文互联网源源不断地提供多种多样的信息。

    10 引用 • 66 回帖
  • 微信

    腾讯公司 2011 年 1 月 21 日推出的一款手机通讯软件。用户可以通过摇一摇、搜索号码、扫描二维码等添加好友和关注公众平台,同时可以将自己看到的精彩内容分享到微信朋友圈。

    130 引用 • 793 回帖
  • OkHttp

    OkHttp 是一款 HTTP & HTTP/2 客户端库,专为 Android 和 Java 应用打造。

    16 引用 • 6 回帖 • 60 关注
  • 禅道

    禅道是一款国产的开源项目管理软件,她的核心管理思想基于敏捷方法 scrum,内置了产品管理和项目管理,同时又根据国内研发现状补充了测试管理、计划管理、发布管理、文档管理、事务管理等功能,在一个软件中就可以将软件研发中的需求、任务、bug、用例、计划、发布等要素有序的跟踪管理起来,完整地覆盖了项目管理的核心流程。

    6 引用 • 15 回帖 • 129 关注
  • Netty

    Netty 是一个基于 NIO 的客户端-服务器编程框架,使用 Netty 可以让你快速、简单地开发出一个可维护、高性能的网络应用,例如实现了某种协议的客户、服务端应用。

    49 引用 • 33 回帖 • 20 关注
  • B3log

    B3log 是一个开源组织,名字来源于“Bulletin Board Blog”缩写,目标是将独立博客与论坛结合,形成一种新的网络社区体验,详细请看 B3log 构思。目前 B3log 已经开源了多款产品:SymSoloVditor思源笔记

    1063 引用 • 3453 回帖 • 202 关注
  • Gitea

    Gitea 是一个开源社区驱动的轻量级代码托管解决方案,后端采用 Go 编写,采用 MIT 许可证。

    4 引用 • 16 回帖
  • Log4j

    Log4j 是 Apache 开源的一款使用广泛的 Java 日志组件。

    20 引用 • 18 回帖 • 30 关注
  • RYMCU

    RYMCU 致力于打造一个即严谨又活泼、专业又不失有趣,为数百万人服务的开源嵌入式知识学习交流平台。

    4 引用 • 6 回帖 • 53 关注
  • Hprose

    Hprose 是一款先进的轻量级、跨语言、跨平台、无侵入式、高性能动态远程对象调用引擎库。它不仅简单易用,而且功能强大。你无需专门学习,只需看上几眼,就能用它轻松构建分布式应用系统。

    9 引用 • 17 回帖 • 614 关注