SpringBoot+zk+dubbo架构实践（五）：搭建微服务电商架构（内附GitHub地址）

往期回顾

SpringBoot+zk+dubbo架构实践（一）：本地部署zookeeper
SpringBoot+zk+dubbo架构实践（二）：SpringBoot 集成 zookeeper

SpringBoot+zk+dubbo架构实践（三）：部署Dubbo-admin管理平台

SpringBoot+zk+dubbo架构实践（四）：sb+zk+dubbo框架搭建（内附源码Git地址）

先给大家看一个正在开发的一款小程序微商城项目-数据模型：https://100boot.cn/interface/wxshop.html （有小程序源码可以下载哦！）

前言

    

  1. 

    

    我们的sb+zk+dubbo微服务架构实践就要完结了。最后完成2件事情。
    

    2. 

  2. 

    

    1、Spring boot + zk + dubbo 集成 mybatis 和 swagger 
    

    3. 

  3. 

    

    2、实现登录用户的 增删改查业务，附带一个pagehelpe实现的分页查询功能。 
    

    4.

目的是让大家能够快速的使用起来，直接配置一下数据源就可以用喽~~~
我们基于 SpringBoot+zk+dubbo架构实践（四） 来完成今天内容。

user_info 数据库表脚本

    

  1. 

    

    
CREATE TABLE `user_info` (
    

    2. 

  2. 

    

      `id` int(11) NOT NULL AUTO_INCREMENT COMMENT '用户ID',
    

    3. 

  3. 

    

      `user_name` varchar(30) DEFAULT NULL COMMENT '用户名',
    

    4. 

  4. 

    

      `password` varchar(30) DEFAULT NULL COMMENT '密码',
    

    5. 

  5. 

    

      `sex` varchar(2) NOT NULL COMMENT '性别（0 未知，1 男 ，2 女）',
    

    6. 

  6. 

    

      `content` varchar(255) DEFAULT NULL COMMENT '简介',
    

    7. 

  7. 

    

      `create_date` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '创建时间',
    

    8. 

  8. 

    

      `update_date` timestamp NOT NULL DEFAULT '0000-00-00 00:00:00' COMMENT '更新时间',
    

    9. 

  9. 

    

      PRIMARY KEY (`id`)
    

    10. 

  10. 

    

    ) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8 COMMENT='用户信息表'

    

    11.

shop-api 子项目

pom.xml 增加pagehelpe maven配置
    

  1. 

    

    <dependency>
    

    2. 

  2. 

    

          <groupId>com.github.pagehelper</groupId>

    

    3. 

  3. 

    

          <artifactId>pagehelper</artifactId>

    

    4. 

  4. 

    

          <version>4.1.6</version>
    </dependency>

    

    5.
UserInfoService.java 增加用户信息接口
    

  1. 

    

    package com.itunion.shop.service;
    import com.github.pagehelper.PageInfo;
    import com.itunion.shop.dto.UserInfoDto;
    import com.itunion.shop.dto.UserInfoReqListDto;
    import java.util.List;/**

    

    2. 

  2. 

    

     * 用户数据服务
    

    3. 

  3. 

    

     * Created by lin on 2018年06月07日21:12:04
    

    4. 

  4. 

    

    
 */public interface UserInfoService {    /**

    

    5. 

  5. 

    

         * 新增用户信息
    

    6. 

  6. 

    

         */
    

    7. 

  7. 

    

        int addUserInfo(UserInfoDto record);    /**

    

    8. 

  8. 

    

         * 查询所有用户信息
    

    9. 

  9. 

    

         */
    

    10. 

  10. 

    

        List<UserInfoDto> getUserInfoList();    /**

    

    11. 

  11. 

    

         * 根据用户ID删除用户信息
    

    12. 

  12. 

    

         */
    

    13. 

  13. 

    

        int delUserInfoById(Integer id);    /**

    

    14. 

  14. 

    

         * 根据用户ID修改用户信息
    

    15. 

  15. 

    

         */
    

    16. 

  16. 

    

        int modifyUserInfoById(UserInfoDto record);    /**

    

    17. 

  17. 

    

         * 分页查询
    

    18. 

  18. 

    

         */
    

    19. 

  19. 

    

        PageInfo getUserInfoListPage(UserInfoReqListDto userInfoReqListDto);
    

    20. 

  20. 

    

     
    

    21. 

  21. 

    

    }
    

    22.
增加UserInfoDto.java 和 UserInfoReqListDto.java
    

  1. 

    

    UserInfoDto : 用户信息封装 （具体可以GitHub下载源码）
    

    2. 

  2. 

    

    UserInfoReqListDto : 分页数据封装（具体可以GitHub下载源码）
    

    3.

shop-ds 子项目 主要用来接口实现和读写数据库

pom.xml 增加maven配置
    

  1. 

    

    <dependency>
    

    2. 

  2. 

    

                <groupId>com.alibaba</groupId>

    

    3. 

  3. 

    

                <artifactId>druid</artifactId>

    

    4. 

  4. 

    

                <version>1.0.27</version>

    

    5. 

  5. 

    

            </dependency>

    

    6. 

  6. 

    

            <dependency>

    

    7. 

  7. 

    

                <groupId>mysql</groupId>

    

    8. 

  8. 

    

                <artifactId>mysql-connector-java</artifactId>

    

    9. 

  9. 

    

            </dependency>

    

    10. 

  10. 

    

            <dependency>

    

    11. 

  11. 

    

                <groupId>org.mybatis</groupId>

    

    12. 

  12. 

    

                <artifactId>mybatis</artifactId>

    

    13. 

  13. 

    

                <version>3.4.2</version>

    

    14. 

  14. 

    

            </dependency>

    

    15. 

  15. 

    

            <dependency>

    

    16. 

  16. 

    

                <groupId>org.mybatis</groupId>

    

    17. 

  17. 

    

                <artifactId>mybatis-spring</artifactId>

    

    18. 

  18. 

    

                <version>1.3.1</version>

    

    19. 

  19. 

    

            </dependency>

    

    20. 

  20. 

    

            <dependency>

    

    21. 

  21. 

    

                <groupId>com.github.pagehelper</groupId>

    

    22. 

  22. 

    

                <artifactId>pagehelper</artifactId>

    

    23. 

  23. 

    

                <version>4.1.6</version>

    

    24. 

  24. 

    

            </dependency>

    

    25.
mybatis-config.xml
    

  1. 

    

    
<?xml version="1.0" encoding="UTF-8" ?>
    <!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN" "http://mybatis.org/dtd/mybatis-3-config.dtd"><configuration>

    

    2. 

  2. 

    

        <settings>

    

    3. 

  3. 

    

            <setting name="cacheEnabled" value="true"/>

    

    4. 

  4. 

    

            <setting name="lazyLoadingEnabled" value="true"/>

    

    5. 

  5. 

    

            <setting name="aggressiveLazyLoading" value="true"/>

    

    6. 

  6. 

    

            <setting name="useGeneratedKeys" value="true"/>

    

    7. 

  7. 

    

            <setting name="defaultExecutorType" value="SIMPLE"/>

    

    8. 

  8. 

    

            <setting name="defaultStatementTimeout" value="600"/>

    

    9. 

  9. 

    

            <setting name="callSettersOnNulls" value="true"/>

    

    10. 

  10. 

    

        </settings>

    

    11. 

  11. 

    

        <plugins>

    

    12. 

  12. 

    

            <plugin interceptor="com.github.pagehelper.PageHelper">

    

    13. 

  13. 

    

                <property name="dialect" value="mysql"/>

    

    14. 

  14. 

    

            </plugin>

    

    15. 

  15. 

    

        </plugins>

    

    16. 

  16. 

    

        <mappers>

    

    17. 

  17. 

    

            <mapper resource="mappers/UserInfoMapper.xml"/>

    

    18. 

  18. 

    

        </mappers></configuration>

    

    19.
DatasourceConfig.java 链接数据源
    

  1. 

    

    
package com.itunion.shop.config;
    import com.alibaba.druid.pool.DruidDataSource;
    import org.apache.ibatis.session.SqlSessionFactory;
    import org.mybatis.spring.SqlSessionFactoryBean;
    import org.mybatis.spring.annotation.MapperScan;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.core.io.ClassPathResource;
    import org.springframework.jdbc.datasource.DataSourceTransactionManager;import javax.annotation.PostConstruct;
    import java.sql.DataSource;

    @Configuration@MapperScan(basePackages = "com.itunion.shop.mapper")
    public class DatasourceConfig {    
    private static Logger log = LoggerFactory.getLogger(DatasourceConfig.class);    
    @Value("${druid.driver}")    
    private String driverClassName;    
    @Value("${druid.url}")    
    private String url;    
    @Value("${druid.username}")    
    private String username;    
    @Value("${druid.password}")    
    private String password;    
    @Value("${druid.init-size}")    
    private int initSize;    
    @Value("${druid.min-idel}")    
    private int minIdel;    
    @Value("${druid.max-active}")    
    private int maxActive;    
    @Value("${druid.login.timeout.seconds}")    
    private int loginTimeoutSeconds;    
    @Value("${druid.query.timeout.seconds}")    
    private int queryTimeoutSeconds;    
        @Bean

    

    2. 

  2. 

    

        public DataSource dataSource() {
    

    3. 

  3. 

    

            DruidDataSource ds = new DruidDataSource();
    

    4. 

  4. 

    

            ds.setDriverClassName(driverClassName);
    

    5. 

  5. 

    

            ds.setUrl(url);
    

    6. 

  6. 

    

            ds.setUsername(username);
    

    7. 

  7. 

    

            ds.setPassword(password);
    

    8. 

  8. 

    

            ds.setInitialSize(initSize);
    

    9. 

  9. 

    

            ds.setMinIdle(minIdel);
    

    10. 

  10. 

    

            ds.setMaxActive(maxActive);
    

    11. 

  11. 

    

            ds.setLoginTimeout(loginTimeoutSeconds);
    

    12. 

  12. 

    

            ds.setQueryTimeout(queryTimeoutSeconds);        
            return ds;
    

    13. 

  13. 

    

        }    
        @Bean

    

    14. 

  14. 

    

        public SqlSessionFactory sqlSessionFactory() throws Exception {        final SqlSessionFactoryBean sqlSessionFactory = new SqlSessionFactoryBean();
    

    15. 

  15. 

    

            sqlSessionFactory.setDataSource(dataSource());
    

    16. 

  16. 

    

            sqlSessionFactory.setConfigLocation(new ClassPathResource("mybatis-config.xml"));
    

    17. 

  17. 

    

            sqlSessionFactory.setFailFast(true);        
            return sqlSessionFactory.getObject();
    

    18. 

  18. 

    

        }    
        public DataSourceTransactionManager dataSourceTransactionManager() {
    

    19. 

  19. 

    

            log.debug("> transactionManager");        
            return new DataSourceTransactionManager(dataSource());
    

    20. 

  20. 

    

        }    
        @PostConstruct

    

    21. 

  21. 

    

        public void postConstruct() {
    

    22. 

  22. 

    

            log.info("jdbc settings={}", this);
    

    23. 

  23. 

    

        }
    

    24. 

  24. 

    

    }
    

    25.
UserInfo.java 、UserInfoMapper.java 和 UserInfoMapper.xml 自己生成（GitHub 源码里有）
UserInfoMapper.xml 增加 分页查询业务
    

  1. 

    

     <select id="getUserInfoList" parameterType="com.itunion.shop.dto.UserInfoReqListDto" resultType="com.itunion.shop.dto.UserInfoDto">
    

    2. 

  2. 

    

            select

    

    3. 

  3. 

    

            id, user_name as userName, password, sex, content, create_date as createDate, update_date as updateDate
    

    4. 

  4. 

    

            from user_info
    

    5. 

  5. 

    

        </select>
    

    6.
shop-ds-rovider.xml 注册服务配置
    <dubbo:service interface="com.itunion.shop.service.UserInfoService" ref="userInfoService"/>
UserInfoMapper.xml 增加 查询用户信息集合业务
    

  1. 

    

     /**

    

    2. 

  2. 

    

         * 获取用户信息集合
    

    3. 

  3. 

    

         * @return
    

    4. 

  4. 

    

         */
    

    5. 

  5. 

    

        List<UserInfoDto> getUserInfoList(UserInfoReqListDto userInfoReqListDto);
    

    6.
UserInfoServiceImpl.java 增加用户业务实现服务类
    

  1. 

    

    
package com.itunion.shop.service.impl;
    import com.alibaba.dubbo.common.logger.Logger;
    import com.alibaba.dubbo.common.logger.LoggerFactory;
    import com.github.pagehelper.PageHelper;
    import com.github.pagehelper.PageInfo;
    import com.itunion.shop.dto.UserInfoDto;
    import com.itunion.shop.dto.UserInfoReqListDto;
    import com.itunion.shop.mapper.UserInfoMapper;
    import com.itunion.shop.model.UserInfo;
    import com.itunion.shop.service.UserInfoService;
    import org.springframework.beans.BeanUtils;
    import org.springframework.beans.factory.annotation.Autowired;
    import java.text.SimpleDateFormat;
    import java.util.Date;
    import java.util.List;
    /**

    

    2. 

  2. 

    

     * 用户信息-服务提供方
    

    3. 

  3. 

    

     * Created by lin on 2018年06月07日21:48:13
    

    4. 

  4. 

    

    
 */

    public class UserInfoServiceImpl implements UserInfoService {    
    private final static Logger LOGGER = LoggerFactory.getLogger(UserInfoServiceImpl.class);    
        @Autowired

    

    5. 

  5. 

    

        private UserInfoMapper userInfoMapper;    
        @Override

    

    6. 

  6. 

    

        public int addUserInfo(UserInfoDto record) {
    

    7. 

  7. 

    

            LOGGER.info("进入用户信息-服务提供方-UserInfoServiceImpl.addUserInfo[" + new SimpleDateFormat("HH:mm:ss").format(new Date()) + "]");
    

    8. 

  8. 

    

            UserInfo userInfo = new UserInfo();
    

    9. 

  9. 

    

            BeanUtils.copyProperties(record, userInfo);
    

    10. 

  10. 

    

            userInfo.setUpdateDate(new Date());        
            return userInfoMapper.insertSelective(userInfo);
    

    11. 

  11. 

    

        }   
        @Override

    

    12. 

  12. 

    

        public List<UserInfoDto> getUserInfoList() {
    

    13. 

  13. 

    

            LOGGER.info("进入用户信息-服务提供方-UserInfoServiceImpl.getUserInfoList[" + new SimpleDateFormat("HH:mm:ss").format(new Date()) + "]");        return userInfoMapper.getUserInfoList(null);
    

    14. 

  14. 

    

        }    
        @Override

    

    15. 

  15. 

    

        public int delUserInfoById(Integer id) {
    

    16. 

  16. 

    

            LOGGER.info("进入用户信息-服务提供方-UserInfoServiceImpl.delUserInfoById[" + new SimpleDateFormat("HH:mm:ss").format(new Date()) + "]");        return userInfoMapper.deleteByPrimaryKey(id);
    

    17. 

  17. 

    

        }    
        @Override

    

    18. 

  18. 

    

        public int modifyUserInfoById(UserInfoDto record) {
    

    19. 

  19. 

    

            LOGGER.info("进入用户信息-服务提供方-UserInfoServiceImpl.modifyUserInfoById[" + new SimpleDateFormat("HH:mm:ss").format(new Date()) + "]");
    

    20. 

  20. 

    

            UserInfo userInfo = new UserInfo();
    

    21. 

  21. 

    

            BeanUtils.copyProperties(record, userInfo);
    

    22. 

  22. 

    

            userInfo.setUpdateDate(new Date());       
         return userInfoMapper.updateByPrimaryKeySelective(userInfo);
    

    23. 

  23. 

    

        }   
         @Override

    

    24. 

  24. 

    

        public PageInfo getUserInfoListPage(UserInfoReqListDto userInfoReqListDto) {
    

    25. 

  25. 

    

            LOGGER.info("进入用户信息-服务提供方-UserInfoServiceImpl.getUserInfoListPage[" + new SimpleDateFormat("HH:mm:ss").format(new Date()) + "]");
    

    26. 

  26. 

    

            PageHelper.startPage(userInfoReqListDto.getPage(), userInfoReqListDto.getSize());
    

    27. 

  27. 

    

            List<UserInfoDto> userInfoDtos = userInfoMapper.getUserInfoList(userInfoReqListDto);
    

    28. 

  28. 

    

            PageInfo<UserInfoDto> userInfoDtoPageInfo = new PageInfo<>(userInfoDtos);        
         return userInfoDtoPageInfo;
    

    29. 

  29. 

    

        }
    

    30. 

  30. 

    

    }
    

    31.
ShopDSApplication.java 项目启动
    

  1. 

    

    
package com.itunion.shop;
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.context.annotation.ImportResource;
    @SpringBootApplication

    // 使用 providers.xml 配置

    @ImportResource(value = {"classpath:shop-ds-rovider.xml"})
    public class ShopDSApplication {    
    public static void main(String[] args) {

    

    2. 

  2. 

    

            SpringApplication.run(ShopDSApplication.class, args);
    

    3. 

  3. 

    

        }
    

    4. 

  4. 

    

    }
    

    5.

好了， shop-ds 项目配置好了，接下来开始配是 移动端子项目和PC端子项目（我们文章只配置一下移动端的 PC端自己copy）

shop-web 子项目

pom.xml 增加 swagger 和 pagehelper maven配置
    

  1. 

    

    <dependency>
    

    2. 

  2. 

    

                <groupId>io.springfox</groupId>

    

    3. 

  3. 

    

                <artifactId>springfox-swagger2</artifactId>

    

    4. 

  4. 

    

                <version>2.7.0</version>

    

    5. 

  5. 

    

            </dependency>

    

    6. 

  6. 

    

            <dependency>

    

    7. 

  7. 

    

                <groupId>io.springfox</groupId>

    

    8. 

  8. 

    

                <artifactId>springfox-swagger-ui</artifactId>

    

    9. 

  9. 

    

                <version>2.7.0</version>

    

    10. 

  10. 

    

            </dependency>

    

    11. 

  11. 

    

     
    

    12. 

  12. 

    

            <dependency>

    

    13. 

  13. 

    

                <groupId>com.github.pagehelper</groupId>

    

    14. 

  14. 

    

                <artifactId>pagehelper</artifactId>

    

    15. 

  15. 

    

                <version>4.1.6</version>

    

    16. 

  16. 

    

            </dependency>

    

    17.
shop-web-consumer.xml 注册服务配置
        <dubbo:reference id="userInfoService" check="false" interface="com.itunion.shop.service.UserInfoService"/>

UserInfoController.java 移动端业务入口

    

  1. 

    

    
package com.itunion.shop.web.controller;
    import com.github.pagehelper.PageInfo;
    import com.itunion.shop.common.UniformResultTemplate;
    import com.itunion.shop.dto.UserInfoDto;
    import com.itunion.shop.dto.UserInfoReqListDto;
    import com.itunion.shop.service.UserInfoService;
    import io.swagger.annotations.Api;
    import io.swagger.annotations.ApiImplicitParam;
    import io.swagger.annotations.ApiOperation;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.http.MediaType;
    import org.springframework.stereotype.Controller;
    import org.springframework.web.bind.annotation.*;
    import javax.servlet.http.HttpServletRequest;
    import java.text.SimpleDateFormat;
    import java.util.Date;
    import java.util.List;
    /**

    

    2. 

  2. 

    

     * 用户信息-移动端消费方
    

    3. 

  3. 

    

     * Created by lin on 2018年06月07日22:02:07
    

    4. 

  4. 

    

    
 */

    @Controller@RequestMapping("userInfo")
    @Api(description = "测试移动")
    public class UserInfoController {    
    private Logger LOGGER = LoggerFactory.getLogger(UserInfoController.class);    
        @Autowired

    

    5. 

  5. 

    

        UserInfoService userInfoService;    
        @ApiOperation(value = "getUserInfoList", notes = "查询所有用户信息")        @RequestMapping(value = "getUserInfoList", method = RequestMethod.GET)    
        @ResponseBody

    

    6. 

  6. 

    

        public UniformResultTemplate<List<UserInfoDto>> getUserInfoList() {
    

    7. 

  7. 

    

            LOGGER.info("进入用户信息-移动端消费方-UserInfoController.getUserInfoList[" + new SimpleDateFormat("HH:mm:ss").format(new Date()) + "]");
    

    8. 

  8. 

    

            UniformResultTemplate<List<UserInfoDto>> uniformResultTemplate = new UniformResultTemplate<>();
    

    9. 

  9. 

    

            uniformResultTemplate.setCode(100);
    

    10. 

  10. 

    

            uniformResultTemplate.setMessage("查询所有用户信息成功！");
    

    11. 

  11. 

    

            uniformResultTemplate.setResult(userInfoService.getUserInfoList());        
            return uniformResultTemplate;
    

    12. 

  12. 

    

        }    
        @ApiOperation(value = "getUserInfoListPage", notes = "查询所有用户信息-分页")    
        @ApiImplicitParam(name = "userInfoReqListDto", value = "{\"page\":\"1\",\"size\":\"2\"}")    
        @RequestMapping(value = "getUserInfoListPage", method = RequestMethod.POST)    
        @ResponseBody

    

    13. 

  13. 

    

        public UniformResultTemplate<PageInfo> getUserInfoList(@RequestBody UserInfoReqListDto userInfoReqListDto) {
    

    14. 

  14. 

    

            LOGGER.info("进入用户信息-移动端消费方-UserInfoController.getUserInfoListPage[" + new SimpleDateFormat("HH:mm:ss").format(new Date()) + "]");
    

    15. 

  15. 

    

            UniformResultTemplate<PageInfo> uniformResultTemplate = new UniformResultTemplate<>();
    

    16. 

  16. 

    

            uniformResultTemplate.setCode(100);
    

    17. 

  17. 

    

            uniformResultTemplate.setMessage("查询所有用户信息成功分页！");
    

    18. 

  18. 

    

            uniformResultTemplate.setResult(userInfoService.getUserInfoListPage(userInfoReqListDto));        
            return uniformResultTemplate;
    

    19. 

  19. 

    

        }    
    @ApiOperation(value = "addUserInfo", notes = "新增用户信息")   
     @ApiImplicitParam(name = "userInfoDto", value = "{\"userName\":\"测试用户名\",\"password\":\"000000\",\"sex\":1,\"content\":\"这里是IT实战联哦~~~\"}")    
     @RequestMapping(value="addUserInfo", method = RequestMethod.POST)    
     @ResponseBody

    

    20. 

  20. 

    

        public UniformResultTemplate<String> addUserInfo(@RequestBody UserInfoDto userInfoDto) {
    

    21. 

  21. 

    

     
    

    22. 

  22. 

    

        LOGGER.info("进入用户信息-移动端消费方-UserInfoController.addUserInfo[" + new SimpleDateFormat("HH:mm:ss").format(new Date()) + "]");
    

    23. 

  23. 

    

            UniformResultTemplate<String> uniformResultTemplate = new UniformResultTemplate<>();
    

    24. 

  24. 

    

            Integer num = userInfoService.addUserInfo(userInfoDto);        if(num > 0){
    

    25. 

  25. 

    

                uniformResultTemplate.setCode(100);
    

    26. 

  26. 

    

                uniformResultTemplate.setMessage("新增用户信息成功！");
    

    27. 

  27. 

    

                uniformResultTemplate.setResult(num+"");
    

    28. 

  28. 

    

            }else{
    

    29. 

  29. 

    

                uniformResultTemplate.setCode(400);
    

    30. 

  30. 

    

                uniformResultTemplate.setMessage("新增用户信息失败！");
    

    31. 

  31. 

    

                uniformResultTemplate.setResult(num+"");
    

    32. 

  32. 

    

            }        
             return uniformResultTemplate;
    

    33. 

  33. 

    

        }    
        @ApiOperation(value="delUserInfoById", notes="根据用户ID删除用户信息")      @ApiImplicitParam(name = "id", value = "4" , paramType="path" , dataType="Integer")    
        @RequestMapping(value="delUserInfoById/{id}", method = RequestMethod.POST)    
        @ResponseBody

    

    34. 

  34. 

    

        public UniformResultTemplate<String> deleteKdgVipItem(@PathVariable Integer id) {
    

    35. 

  35. 

    

            LOGGER.info("进入用户信息-移动端消费方-UserInfoController.delUserInfoById[" + new SimpleDateFormat("HH:mm:ss").format(new Date()) + "]");
    

    36. 

  36. 

    

            UniformResultTemplate<String> uniformResultTemplate = new UniformResultTemplate<>();
    

    37. 

  37. 

    

            Integer num = userInfoService.delUserInfoById(id);        if(num > 0){
    

    38. 

  38. 

    

                uniformResultTemplate.setCode(100);
    

    39. 

  39. 

    

                uniformResultTemplate.setMessage("根据用户ID删除用户信息成功！");
    

    40. 

  40. 

    

                uniformResultTemplate.setResult(num+"");
    

    41. 

  41. 

    

            }else{
    

    42. 

  42. 

    

                uniformResultTemplate.setCode(400);
    

    43. 

  43. 

    

                uniformResultTemplate.setMessage("根据用户ID删除用户信息失败！");
    

    44. 

  44. 

    

                uniformResultTemplate.setResult(num+"");
    

    45. 

  45. 

    

            }        
            return uniformResultTemplate;
    

    46. 

  46. 

    

        }    
        @ApiOperation(value = "modifyUserInfo", notes = "修改用户信息")   
         @ApiImplicitParam(name = "userInfoDto", value = "{\"id\":10,\"userName\":\"测试修改用户名\",\"password\":55555,\"sex\":1,\"content\":\"这里是最新的IT实战联哦~~~\"}")    
         @RequestMapping(value="modifyUserInfo", method = RequestMethod.POST, produces= MediaType.APPLICATION_JSON_UTF8_VALUE)    
         @ResponseBody

    

    47. 

  47. 

    

        public UniformResultTemplate<String> modifyUserInfo(@RequestBody UserInfoDto userInfoDto) {
    

    48. 

  48. 

    

            LOGGER.info("进入用户信息-移动端消费方-UserInfoController.modifyUserInfo[" + new SimpleDateFormat("HH:mm:ss").format(new Date()) + "]");
    

    49. 

  49. 

    

            UniformResultTemplate<String> uniformResultTemplate = new UniformResultTemplate<>();
    

    50. 

  50. 

    

            Integer num = userInfoService.modifyUserInfoById(userInfoDto);        if(num > 0){
    

    51. 

  51. 

    

                uniformResultTemplate.setCode(100);
    

    52. 

  52. 

    

                uniformResultTemplate.setMessage("修改用户信息成功！");
    

    53. 

  53. 

    

                uniformResultTemplate.setResult(num+"");
    

    54. 

  54. 

    

            }else{
    

    55. 

  55. 

    

                uniformResultTemplate.setCode(400);
    

    56. 

  56. 

    

                uniformResultTemplate.setMessage("修改用户信息失败！");
    

    57. 

  57. 

    

                uniformResultTemplate.setResult(num+"");
    

    58. 

  58. 

    

            }        return uniformResultTemplate;
    

    59. 

  59. 

    

        }
    

    60. 

  60. 

    

    }
    

    61.

备注：工具类 可以GitHub下载源码

Application.java 项目启动
    

  1. 

    

    
package com.itunion.shop;
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.boot.web.support.SpringBootServletInitializer;
    import org.springframework.context.annotation.ImportResource;
    @SpringBootApplication@ImportResource(value = { "classpath:shop-web-consumer.xml" })
    public class Application extends SpringBootServletInitializer {   
     public static void main(String[] args) throws Exception {
    

    2. 

  2. 

    

            SpringApplication.run(Application.class, args);
    

    3. 

  3. 

    

        }
    

    4. 

  4. 

    

    }
    

    5.
application.properties
    

  1. 

    

    
server.port=8081  #端口
    server.context-path=/wxShop #项目名称
    swagger.enable=true
    swagger.protocol=http
    

    2. 

  2. 

    

    swagger.host=127.0.0.1:8081

    

    3.

备注：shop-pc 子项目和 shop-web 配置都是一样的，不多做介绍

项目启动

访问地址
http://127.0.0.1:8081/wxShop/swagger-ui.html
效果

SpringBoot+zk+dubbo架构实践（五）：搭建微服务电商架构（内附GitHub地址）


可以看到我们一共写了5个业务 用户的 增、删、改、查和分页查询。

总结

SpringBoot+zk+dubbo架构实践 分解为5篇文章写完，为了让大家能够最快入门微服务架构 并实现编码，没有做深入的剖析， 小编将源码上传GitHub：https://github.com/yundianzixun/weixin-shop。在具体工作中还会遇到更多复杂的问题，架构师之路就是不断解决问题的，一边解决问题一边进阶。小编能做的还很少，希望该实践系列能够对大家有用，谢谢支持！

关注我们

更多精彩内容请关注“IT实战联盟”公*众*号，平台会提供更多技术实践内容，也可以加入交流群和作者互撩哦~~~

相关文章：

  • 2021-05-12
  • 2021-11-22
  • 2021-08-17
  • 2021-11-25
  • 2021-04-27
  • 2022-12-23
  • 2021-08-20
  • 2021-12-12
猜你喜欢
  • 2022-12-23
  • 2021-09-20
  • 2022-03-05
  • 2021-11-30
  • 2021-12-08
  • 2021-12-28
相关资源
相似解决方案
热门标签
Java Python linux javascript Mysql C# Docker 算法 前端 SpringBoot Redis Vue spring 设计模式 .net core .net kubernetes c++ 数据库 数据结构 大数据 js 机器学习 微服务 Android Go 程序员 面试 JVM ASP.net core 云原生 人工智能 后端 PHP git CSS golang k8s Nginx Django mybatis 深度学习 多线程 React 架构 devops 爬虫 云计算 Spring Boot LeetCode