基础微服务模块base搭建

base 模块下 pom.xml 加入依赖：
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
</dependency>
<dependency>
<groupId>com.xuan</groupId>
<artifactId>tensquare_common</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>

创建启动类：
@SpringBootApplication
public class BaseApplication {

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

@Bean
public IdWorker idWorker() {
    return new IdWorker(1, 1);
}

}

在resources 目录下创建 application.yml
这里需要注意的是 spring-application-name : 横岗必须为中间横岗因为在后期服务之间相互调用的时候只有中间横才能被服务识别。

image.png

我们的第一张表示标签表表结构如下所示：

image.png

我们在base 模块下面创建 pojo包
并创建实体 Label
@Entity
@Table(name = "tb_label")
public class Label implements Serializable {

@Id
private String id;
/**
 * 标签名称
 */
private String labelname;
/**
 * 状态
 */
private String state;
/**
 * 使用数量
 */
private Long count;
/**
 * 关注数
 */
private Long fans;
/**
 * 是否推荐
 */
private String recommend;

public String getId() {
    return id;
}

public void setId(String id) {
    this.id = id;
}

public String getLabelname() {
    return labelname;
}

public void setLabelname(String labelname) {
    this.labelname = labelname;
}

public String getState() {
    return state;
}

public void setState(String state) {
    this.state = state;
}

public Long getCount() {
    return count;
}

public void setCount(Long count) {
    this.count = count;
}

public Long getFans() {
    return fans;
}

public void setFans(Long fans) {
    this.fans = fans;
}

public String getRecommend() {
    return recommend;
}

public void setRecommend(String recommend) {
    this.recommend = recommend;
}

}

接下来创建数据访问接口 dao 层创建dao包
包下创建 LabelDao接口

代码如下：
public interface LabelDao extends JpaRepository<Label, String>, JpaSpecificationExecutor<Label> {
}

image.png

接下来在模块下面创建 service包包下创建LabelService 类
@Service("labelService")
@Transactional
public class LabelService {
@Autowired
private LabelDao labelDao;
@Autowired
private IdWorker idWorker;

/**
 * <p>Description: 查询全部标签 </p>
 *
 * @author Yat-Xuan
 * @params: []
 * @return: java.util.List<com.tensquare.base.pojo.Label>
 * @Date: 2018/11/13 0013 14:49
 * @Modified By:
 */
public List<Label> findAll() {
    return labelDao.findAll();
}

/**
 * <p>Description: 根据ID查询标签 </p>
 *
 * @author Yat-Xuan
 * @params: [id]
 * @return: com.tensquare.base.pojo.Label
 * @Date: 2018/11/13 0013 14:49
 * @Modified By:
 */
public Label findById(String id) {
    return labelDao.findById(id).get();
}

/**
 * <p>Description:增加标签 </p>
 *
 * @author Yat-Xuan
 * @params: [label]
 * @return: void
 * @Date: 2018/11/13 0013 14:50
 * @Modified By:
 */
public void save(Label label) {
    /**
     * 设置ID
     */
    label.setId(idWorker.nextId() + "");
    labelDao.save(label);
}

/**
 * 修改标签
 *
 * @param label
 */
public void update(Label label) {
    labelDao.save(label);
}

/**
 * 删除标签
 *
 * @param id
 */
public void deleteById(String id) {
    labelDao.deleteById(id);
}

public List<Label> findSearch(Label label) {
    return labelDao.findAll(getPredicate(label));
}

public Page<Label> pageQuery(Label label, int page, int size) {

    PageUtil pageUtil = new PageUtil();
    pageUtil.setCurrNo(page);
    pageUtil.setSize(size);

    Pageable pageable = PageRequest.of(pageUtil.getCurrNo() - 1, pageUtil.getSize());
    return labelDao.findAll(getPredicate(label), pageable);
}

public Specification<Label> getPredicate(Label label) {
    return new Specification<Label>() {
        /**
         *
         * @param root 根对象，也就是要把条件封装到那个对象中去。类似：where 类名=label.getId
         * @param criteriaQuery 封装的都是查询的关键字 比如：order by, group by等
         * @param criteriaBuilder 用来封装条件对象，如果直接返回null 表示不需要任何查询条件
         * @return
         */
        @Override
        public Predicate toPredicate(Root<Label> root, CriteriaQuery<?> criteriaQuery, CriteriaBuilder criteriaBuilder) {

            //new 一个集合存放所有的条件
            List<Predicate> list = new ArrayList<>();

            if (label.getLabelname() != null && !"".equals(label.getLabelname())) {
                //下面相当于 where like "%小明%"
                Predicate predicate =
                        criteriaBuilder.like(root.get("labelname").as(String.class), "%" + label.getLabelname() + "%");
                list.add(predicate);
            }

            if (label.getState() != null && !"".equals(label.getState())) {
                Predicate predicate =
                        criteriaBuilder.equal(root.get("state").as(String.class), label.getState());
                list.add(predicate);
            }

            if (label.getRecommend() != null && !"".equals(label.getRecommend())) {
                Predicate predicate =
                        criteriaBuilder.equal(root.get("recommend").as(String.class), label.getRecommend());
                list.add(predicate);
            }

            if (label.getCount() != null && !"".equals(label.getCount())) {
                Predicate predicate =
                        criteriaBuilder.equal(root.get("count").as(String.class), label.getCount());
                list.add(predicate);
            }

            if (label.getFans() != null && !"".equals(label.getFans())) {
                Predicate predicate =
                        criteriaBuilder.equal(root.get("fans").as(String.class), label.getFans());
                list.add(predicate);
            }

            //new 一个数组作为最终返回值的条件
            Predicate[] predicates = new Predicate[list.size()];

            //把list转成数组
            predicates = list.toArray(predicates);

            return criteriaBuilder.and(predicates);
        }
    };
}

}
这个service 里面有需要注意的点是有用到分页以及条件查询需要注意一下
分页工具如下：pageutil
public class PageUtil {
/**
* 当前页码
*/
private int currNo = 1;

/**
 * 每页显示条数
 */
private int size = 15;

/**
 * 总页码
 */
private int totalCurrNo;

/**
 * 总数据
 */
private int totalSize;

public PageUtil() {
}

public PageUtil(int currNo, int size) {
    this.currNo = currNo == 0 ? 1 : currNo > this.totalCurrNo ? this.totalCurrNo : currNo;
    this.size = size == 0 ? 15 : size;
}

public int getCurrNo() {
    return currNo;
}

public void setCurrNo(int currNo) {
    this.currNo = currNo == 0 ? 1 : currNo > this.totalCurrNo ? this.totalCurrNo : currNo;
}

public int getSize() {
    return size;
}

public void setSize(int size) {
    this.size = size == 0 ? 15 : size;
}

public int getTotalCurrNo() {
    return totalCurrNo;
}

public void setTotalCurrNo(int totalCurrNo) {
    this.totalCurrNo = totalCurrNo;
}

public int getTotalSize() {
    return totalSize;
}

public void setTotalSize(int totalSize) {
    this.totalSize = totalSize;
    if (this.totalSize > 0) {
        this.totalCurrNo = this.totalSize % this.size == 0 ? this.totalSize / this.size : this.totalSize / this.size + 1;
    } else {
        this.totalCurrNo = 1;
    }
}

}
最后需要完成的是 controller 部分：
@RestController
@CrossOrigin
@RequestMapping("/label")
@RefreshScope
public class LabelController {

@Resource
private LabelService labelService;

@GetMapping
public Result findAll() {
    return new Result(true, StatusCode.OK, "查询成功", labelService.findAll());
}

@GetMapping("/{labelId}")
public Result findById(@PathVariable("labelId") String labelId) {
    return new Result(true, StatusCode.OK, "查询成功", labelService.findById(labelId));
}

@PostMapping
public Result save(@RequestBody Label label) {
    labelService.save(label);
    return new Result(true, StatusCode.OK, "新增成功");
}

@PutMapping("/{labelId}")
public Result update(@PathVariable String labelId, @RequestBody Label label) {
    label.setId(labelId);
    labelService.update(label);
    return new Result(true, StatusCode.OK, "更新成功");
}

@DeleteMapping("/{labelId}")
public Result delete(@PathVariable String labelId) {
    labelService.deleteById(labelId);
    return new Result(true, StatusCode.OK, "删除成功");
}

@PostMapping("/search")
public Result findSearch(@RequestBody Label label) {
    List<Label> list = labelService.findSearch(label);
    return new Result(true, StatusCode.OK, "查询成功", list);
}

@PostMapping("/search/{page}/{size}")
public Result pageQuery(@RequestBody Label label, @PathVariable int page, @PathVariable int size) {
    Page<Label> pageData = labelService.pageQuery(label, page, size);
    return new Result(true, StatusCode.OK, "查询成功",
                    new PageResult<Label>(pageData.getTotalElements(), pageData.getContent()));
}

}

此 controller 需要注意的是：@RefreshScope
这个注解
最后为了使我们的代码更容易做维护我们做一个类集中处理异常
controller 包下创建 BaseExceptionHandler

@RestControllerAdvice
public class BaseExceptionHandler {

@ExceptionHandler(value = Exception.class)
public Result exception(Exception e) {
    e.printStackTrace();
    return new Result(false, StatusCode.ERROR, e.getMessage());
}

}
这里还需要注意一个点：跨域：

image.png

基础微服务模块base搭建

推荐阅读更多精彩内容