Spring Boot 核心技术Spring-Boot

SpringBoot 入门必学篇(一)

2019-06-06  本文已影响2人  肖赛Soaic

前言

这篇文章主要介绍SpringBoot的必学内容

一、搭建SpringBoot项目

搭建项目前需要配置Java环境，Java环境配置可以在网上都可以找到的，这里就不做太多介绍。使用的开发工具是IntelliJ IDEA集成环境开发工具，其自带创建SpringBoot项目模板，特别方便。

下面就来说下创建的步骤：
(1) 选择菜单File -> New -> Project，弹出New Project 面板，左侧栏选择Spring Initializr，右边选择Default。


(2) 点击Next按钮，进入Project Metadata面板，依次填写Group、Artifact(必须都是小写字母)、Type选择Maven Project，其它基本都是自动选择和配置好的。

(3) 再点击Next按钮，进入Spring包选择面版，选择Dependencies栏中的Web中的Web依赖包，这个包里面编写了自动配置Web项的逻辑。

(4) 继续点Next按钮，进入Finish页面面板，如图14所示，这里可以修改项目名称、项目保存路径以及模块名称等，也可以不做任何修改，使用默认配置，点击Finish按钮完成，SpringBoot项目就创建完成。

(5) 运行。此时直接点击Run运行会提示错误，需要修改HellospringbootApplication代码后再点击右上角绿色Run按钮运行。代码中用到了三个注解，注解@RestController相当于@ResponseBody与@Controller两个注解合在一起的作用，只返回retrun的内容，不会指向到对应的页面，如jsp页面。注解@SpringBootApplication相当于@SpringBootConfiguration、@EnableAutoConfiguration和@ComponentScan三个注解合在器的作用，目的是开启自动配置。注解@RequestMapping作用是用来地址映射，注解在类上则作用在类上，注解在方法则作用在方法上，如果两个都存在则会叠加。 
@RestController
@SpringBootApplication
public class HellospringbootApplication {
    public static void main(String[] args) {
        SpringApplication.run(HellospringbootApplication.class, args);
    }
    @RequestMapping("/")
    public String test() {
        return "Hello SpringBoot";
    }
}

(6) 测试。运行成功后，在浏览器输入http://localhost:8080，浏览器上显示Hello SpringBoot，表示搭建SpringBoot项目成功。

二、整合MyBatis

MyBatis是一款优秀的持久层框架，它支持定制化 SQL、存储过程以及高级映射。MyBatis 避免了几乎所有的 JDBC 代码和手动设置参数以及获取结果集。MyBatis 可以使用简单的 XML 或注解来配置和映射原生类型、接口和 Java 的 POJO（Plain Old Java Objects，普通老式 Java 对象）为数据库中的记录。简单的说MyBatis就是类似Hibernate的ORM框架，相比之下要轻便、灵活的多，更易保证DB访问的性能。

整合MyBatis分为这么几个步骤：

(1) 在pom.xml文件里集成添加所需要的依赖包。Maven如果不是设置自动导入，右下角会出现Import Changes和Enable Auto-Import, 前者是手动点击导入改变的包，后者是设置为自动导入。

<!-- myBatis -->
<dependency>
    <groupId>org.mybatis.spring.boot</groupId>
    <artifactId>mybatis-spring-boot-starter</artifactId>
    <version>2.0.1</version>
</dependency>

<!-- mySql -->
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <scope>runtime</scope>
</dependency>

<!-- 数据库连接池 -->
<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>druid</artifactId>
    <version>1.1.0</version>
</dependency>

(2) 配置application.yml。在resources文件夹下创建application.yml文件，在里面配置其服务器配置信息、spring配置信息以及mybatis配置信息，配置信息代码如下：

server: 
  port: 8088

spring:
  datasource:
      username: root
      password: root
      url: jdbc:mysql://localhost:3306/soaic?useUnicode=true&characterEncoding=utf-8
      driver-class-name: com.mysql.jdbc.Driver 
      type: com.alibaba.druid.pool.DruidDataSource
  application:
    name: hellospringboot
  http:
      encoding:
        charset: UTF-8
        force: true
  jackson:
      default-property-inclusion: non_null

mybatis:
  mapper-locations: classpath:mapper/*Mapper.xml
  type-aliases-package: com.soaic.hellospringboot.entity

服务器端口号设置为8088，配置spring数据库连接信息和连接池，指定myBatis映射在mapper包下并以Mapper.xml命名结尾和entity包的路径,jackson这里配置的是过滤返回为null的数据。
(3) 开发entity。在com.soaic.hellospringboot包下创建entity包，该包下存放所有数据实体类，接着创建MyUser实体类，定义电影数据属性，并对其做get和set封装，代码如下：

public class MyUser {
    
    private Integer id;
    private String userName;
    private String password;

    public Integer getId() {
        return id;
    }

    public void setId(Integer 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;
    }

}

(4) 开发mapper，在com.soaic.hellospringboot包下创建mapper包，该包存放所有Mapper映射接口，以及在resources包下创建mapper包，该包存放所有定义myBatis与mySQL数据库关联操作的xml文件，通过该文件可以对数据库进行增删改查操作，并以其对应的Mapper接口返回相关数据给调用者，注意的是这文件名需要以Mapper.xml结尾并以前一个mapper包下一一对应，否则会映射不了。

在HellospringbootApplication类上添加@MapperScan("com.soaic.hellospringboot.mapper")扫描指定包下的所有mapper。

@RestController
@SpringBootApplication
@MapperScan("com.soaic.hellospringboot.mapper")
public class HellospringbootApplication {

}

在com.soaic.hellospringboot.mapper包下创建MyUserMapper.java，并编写代码如下：

public interface MyUserMapper {

    Integer insertUser(MyUser user);

    Integer batchInsertUser(List<MyUser> users);

    MyUser deleteUser(Integer id);

    MyUser updateUser(MyUser user);

    MyUser selectUser(Integer id);

    List<MyUser> selectAllUser();

    @Select("select * from user_t where username like CONCAT('%',#{0},'%')")
    @ResultMap("com.soaic.hellospringboot.mapper.MyUserMapper.userMap")
    List<MyUser> selectUserByName(String name);

}

在resources/mapper包下创建MyUserMapper.xml，并编写代码如下：

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="com.soaic.hellospringboot.mapper.MyUserMapper">

    <resultMap id="userMap" type="com.soaic.hellospringboot.entity.MyUser">
        <id column="id" property="id" jdbcType="INTEGER"/>
        <result column="username" property="userName" jdbcType="VARCHAR" />
        <result column="password" property="password" jdbcType="VARCHAR" />
    </resultMap>

    <insert id="insertUser" useGeneratedKeys="true" keyProperty="id" parameterType="com.soaic.hellospringboot.entity.MyUser">
        insert into user_t (username, password)
        values(#{userName,jdbcType=VARCHAR}, #{password,jdbcType=VARCHAR})
    </insert>

    <insert id="batchInsertUser" useGeneratedKeys="true" keyProperty="id">
        insert into user_t (username, password) values
        <foreach item="item" collection="list" separator=",">
            (#{item.username}, #{item.password})
        </foreach>
    </insert>

    <delete id="deleteUser" parameterType="java.lang.Integer">
        delete from user_t
        where id = #id
    </delete>

    <update id="updateUser" parameterType="com.soaic.hellospringboot.entity.MyUser">
        update user_t
        set username = #{userName, jdbcType=VARCHAR}, password = #{password, jdbcType=VARCHAR}
    </update>

    <select id="selectUser" parameterType="java.lang.Integer" resultMap="userMap">
        select * from user_t
        where id = #{id,jdbcType=INTEGER}
    </select>

    <select id="selectAllUser" resultMap="userMap">
        select * from user_t
    </select>

</mapper>

以上代码，主要实现了对user_t表的增删改查、批量添加以及用注解方式根据username模糊查询。要注意的是，id中不能有相同名字，接口中不能有相同方法名，否则会报错。
其它功能可以详细查看myBatis中文官方文档：http://www.mybatis.org/mybatis-3/zh/index.html

(5) 开发services。在com.soaic.hellospringboot包下创建services包，并创建MyUserServices.java文件。该包下存放调用Mapper接口的服务，供后面定义的controller提供使用。

@Service
public class MyUserServices {

    @Resource
    private MyUserMapper userMapper;

    public Integer insertUser(MyUser user) {
        return userMapper.insertUser(user);
    }

    public Integer insertUser(List<MyUser> users) {
        return userMapper.batchInsertUser(users);
    }

    public MyUser deleteUser(Integer id) {
        return userMapper.deleteUser(id);
    }

    public MyUser updateUser(MyUser user) {
        return userMapper.updateUser(user);
    }

    public MyUser selectUser(Integer id) {
        return userMapper.selectUser(id);
    }

    public List<MyUser> selectUser() {
        return userMapper.selectAllUser();
    }

    public List<MyUser> selectUserByName(String name) {
        return userMapper.selectUserByName(name);
    }

}

(6) 开发controller。在com.soaic.hellospringboot包下创建controller包，并创建MyUserController.java。该包下存放所有接口控制器，所有接口都在控制器中定义。

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

    @Autowired
    private MyUserServices myUserServices;

    @RequestMapping(value = "/register", method = RequestMethod.POST)
    public String register(HttpServletRequest request) {
        try {
            String userName = request.getParameter("username");
            String password = request.getParameter("password");

            MyUser user = new MyUser();
            user.setUserName(userName);
            user.setPassword(password);
            return myUserServices.insertUser(user)+"";
        } catch (Exception e) {
            return e.getMessage();
        }
    }

    @RequestMapping("/findAllUser")
    public List<MyUser> findAllUser() {
        return myUserServices.selectUser();
    }
}

以上代码实现了两个接口：
http://localhost:8088/user/register注册接口，请求方式为POST，代码中通过HttpServletRequest来获取请求参数，GET方式也可以通过它来获取。
http://localhost:8088/user/findAllUser获取所有用户接口，请求方式默认为GET。
其它接口实现大家可以自己试着实现以下，实现方法其实都差不多，这里就不做太多实现。

(7) 运行测试。运行直接点击右上角绿色小图标就可以运行项目了。测试/user/findAllUser接口可以在浏览器上直接测试，测试/user/register接口，由于该接口采用的请求方式是POST，所以就不能直接用浏览器测试了。这里推荐大家使用IDEA里自带的测试工具HTTP Client来测试。
打开方式：菜单栏 > tools > HTTP Client > Test RESTfull Web Service


可以看到左边可以添加头Headers,中间添加参数Parameters,右边可以添加文本、文件等，最后点击左上角绿色小图标就可以执行了，是不是特别方便。

三、接口分页实现

在进行接口开发中，分页查询是必不可少的功能，这里我们使用PageHelper分页插件来进行实现，使用它来进行分页特别简单方便。

(1) 在pom.xml中添加依赖库。查看maven中pagehelper的版本：https://mvnrepository.com/artifact/com.github.pagehelper/pagehelper-spring-boot-starter

<!-- 分页 -->
<dependency>
    <groupId>com.github.pagehelper</groupId>
    <artifactId>pagehelper-spring-boot-starter</artifactId>
    <version>1.2.10</version>
</dependency>

(2) 在application.yml中配置分页插件。

# 分页插件配置
pagehelper:
 helperDialect: mysql
 reasonable: true
 supportMethodsArguments: true
 params: count=countSql
 page-size-zero: false

(3) 添加PageModel，这里默认页码数pageNum为第一页，默认一页数量pageSize为10个。

public class PageModel {

    private int pageNum = 1;
    private int pageSize = 10;

    public int getPageNum() {
        return pageNum;
    }

    public void setPageNum(int pageNum) {
        this.pageNum = pageNum;
    }

    public int getPageSize() {
        return pageSize;
    }

    public void setPageSize(int pageSize) {
        this.pageSize = pageSize;
    }
}

(4) 添加PageBean继承PageInfo, 这里主要是为了自定义返回分页数据，注解@JsonIgnore作用是忽略掉该字段，注解JsonProperty作用是更换返回字段key。

public class PageBean<T> extends PageInfo<T> {
    public PageBean(List<T> list){
        super(list);
    }
    @JsonIgnore
    @Override
    public int getSize() {
        return super.getSize();
    }
    @JsonIgnore
    @Override
    public int getStartRow() {
        return super.getStartRow();
    }
    @JsonIgnore
    @Override
    public int getEndRow() {
        return super.getEndRow();
    }
    @JsonIgnore
    @Override
    public int getPrePage() {
        return super.getPrePage();
    }
    @JsonIgnore
    @Override
    public int getNextPage() {
        return super.getNextPage();
    }
    @JsonIgnore
    @Override
    public boolean isIsFirstPage() {
        return super.isIsFirstPage();
    }
    @JsonIgnore
    @Override
    public boolean isIsLastPage() {
        return super.isIsLastPage();
    }
    @JsonIgnore
    @Override
    public boolean isHasNextPage() {
        return super.isHasNextPage();
    }
    @JsonIgnore
    @Override
    public boolean isHasPreviousPage() {
        return super.isHasPreviousPage();
    }
    @JsonIgnore
    @Override
    public int getNavigatePages() {
        return super.getNavigatePages();
    }
    @JsonIgnore
    @Override
    public int[] getNavigatepageNums() {
        return super.getNavigatepageNums();
    }
    @JsonIgnore
    @Override
    public int getNavigateFirstPage() {
        return super.getNavigateFirstPage();
    }
    @JsonIgnore
    @Override
    public int getNavigateLastPage() {
        return super.getNavigateLastPage();
    }
    @JsonIgnore
    @Override
    public int getPages() {
        return super.getPages();
    }
    @JsonProperty("items")
    @Override
    public List<T> getList() {
        return super.getList();
    }
    @JsonProperty("items")
    @Override
    public void setList(List<T> list) {
        super.setList(list);
    }
}

(4) 添加ResponseResult，这里主要是为了返回数据时统一格式，msg是返回消息，code是返回状态码，data是返回的结果数据。

public class ResponseResult<T> {

    private String msg;
    private Integer code;
    private T data;

    public ResponseResult() {}
    
    public ResponseResult(Integer code, String msg, T data) {
        this.data = data;
        this.code = code;
        this.msg = msg;
    }

    public String getMsg() {
        return msg;
    }

    public void setMsg(String msg) {
        this.msg = msg;
    }

    public Integer getCode() {
        return code;
    }

    public void setCode(Integer code) {
        this.code = code;
    }

    public T getData() {
        return data;
    }

    public void setData(T data) {
        this.data = data;
    }

    @Override
    public String toString() {
        return "ResponseResult{" +
                ", msg='" + msg + '\'' +
                ", code=" + code +
                ", data=" + data +
                '}';
    }
}

(5) 修改MyUserController中findAllUser方法。

    @RequestMapping("/findAllUser")
    public ResponseResult<PageBean> findAllUser(PageModel pageModel) {
        ResponseResult<PageBean> responseResult;
        try {
            PageHelper.startPage(pageModel.getPageNum(), pageModel.getPageSize());
            PageHelper.orderBy("id asc");
            List<MyUser> myUsers = myUserServices.selectUser();
            PageBean<MyUser> pageBean = new PageBean<>(myUsers);
            responseResult = new ResponseResult<>(200, "success", pageBean);
        } catch (Exception e) {
            e.printStackTrace();
            responseResult = new ResponseResult<>(501, "failure", null);
        }
        return responseResult;
    }

以上代码修改了几个地方，1）方法中添加了PageModel参数，目的是为了接收页码pageNum和页数量pageSize值。2)调用PageHelper的startPage方法，并把页码和页数量传进去，设置分页。3)再调用PageHelper的orderBy方法设置排序可以设置降序desc和升序asc。4)实例一个PageBean对象并把myUsers对象传到构造方法中，这时实例化的pageBean其实就是分页好的数据。5)这里我们多做一步操作，再实例一个ResponseResult对象，传入code、msg和pageBean对象，最后返回。这时接口拿到的数据就是统一json格式数据了。

调用接口http://localhost:8088/user/findAllUser?pageNum=1&pageSize=10，返回数据如下：

{
    "msg":"success",
    "code":200,
    "data":{
        "total":2,
        "pageNum":1,
        "pageSize":10,
        "items":[
            {
                "id":1,
                "userName":"soaic",
                "password":"123456"
            },
            {
                "id":2,
                "userName":"admin",
                "password":"123456"
            }
        ]
    }
}

四、实现文件上传接口

文件上传也是很api必不可少的功能了，有单个文件上传，也有多个文件和文本一起请求，步骤如下：
(1) 在pom.xml中添加依赖库。

<dependency>
    <groupId>commons-io</groupId>
    <artifactId>commons-io</artifactId>
    <version>2.3</version>
</dependency>

(2) 在contoller包中添加UploadFileController。

@RestController
@RequestMapping("/upload")
public class UploadFileController {

    @RequestMapping(value = "/file", method = RequestMethod.POST)
    public ResponseResult<String> uploadFile(@RequestParam("file") MultipartFile multipartFile) {
        try {
            System.out.println("multipartFile"+multipartFile);
            String filePath = "/Users/soaic/"+multipartFile.getOriginalFilename();
            FileUtils.writeByteArrayToFile(new File(filePath), multipartFile.getBytes());
            return new ResponseResult<>(200, "upload success" , filePath);
        } catch (Exception e) {
            e.printStackTrace();
            return new ResponseResult<>(501, "upload failure", e.getMessage());
        }
    }

    @RequestMapping(value = "/batchFile", method = RequestMethod.POST)
    public ResponseResult<String> uploadFiles(HttpServletRequest request) {
        try {
            String content = request.getParameter("content");
            System.out.println("content="+content);
            //获取上传的文件数组
            List<MultipartFile> files = ((MultipartHttpServletRequest) request).getFiles("file");
            for (MultipartFile file:files) {
                FileUtils.writeByteArrayToFile(new File("/Users/soaic/"+file.getOriginalFilename()), file.getBytes());
            }
            return new ResponseResult<>(200, "upload success",null);
        } catch (Exception e) {
            e.printStackTrace();
            return new ResponseResult<>(501, "upload failure", e.getMessage());
        }
    }
}

以上代码实现了两个接口：一个是单文件上传，另一个是多文件上传并携带参数。单文件上传是通过multipartFile对象来接收文件，并通过FileUtils工具类调用writeByteArrayToFile方法保存文件。多文件上传是通过HttpServletRequest对象调用getFiles方法来获取MultipartFile集合。
(3) 测试。文件上传测试，这里推荐一个新的测试工具Advanced REST Client，用着还是挺不错的，大家可以试试。下载地址：https://install.advancedrestclient.com/install

以上代码都已放在github上，地址：https://github.com/soaic/HelloSpringBoot

这篇文章主要介绍了SpringBoot的项目搭建、整合MyBatis、分页接口实现和文件上传接口。下一篇文章会介绍配置Https、配置拦截器、页面转向、资源指向、事务处理等等，希望大家多多关注。

上一篇下一篇

猜你喜欢

热点阅读