【springcloud合集】04:新建Moudle——微服务提供者支付模块

本文涉及的产品
服务治理 MSE Sentinel/OpenSergo,Agent数量 不受限
简介: 【springcloud合集】04:新建Moudle——微服务提供者支付模块

上一节父工程已经建完,本文开始新建第一个Moule——支付模块。 意在模拟用户下单跳转到支付模块(如支付宝)这样一个过程。


新建Moudle(五大步)

1.建moudle

注意:命名要规范,后面moudle变多,随意命名会分不清。我用的名字是:cloud-provider-payment8001

20201107153122981.png

20201107153231871.png

新建完成之后观察父工程pom文件的变化。

20201107152956285.png

2.改pom

修改Moudle的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>cloud2020</artifactId>
        <groupId>com.li.springcloud</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>
    <artifactId>cloud-provider-payment8001</artifactId>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid-spring-boot-starter</artifactId>
            <version>1.1.10</version>
        </dependency>
        <!--mysql-connector-java-->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
        </dependency>
        <!--jdbc-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jdbc</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>
</project>

补充知识:spring-boot-starter-actuator——监控系统健康情况的工具


在生产环境中,需要实时或定期监控服务的可用性。Spring Boot的actuator(健康监控)功能提供了很多监控所需的接口,可以对应用系统进行配置查看、相关功能统计等。在启动时会有显示。


3.写yml

在子Moudle的resources目录下新建application.yml

20201107154026467.png

server:
  port: 8001
spring:
  application:
    name: cloud-payment-service
  datasource:
    type: com.alibaba.druid.pool.DruidDataSource
    driver-class-name: org.gjt.mm.mysql.Driver
    url: jdbc:mysql://localhost:3306/db2019?useUnicode=true&characterEncoding=utf-8&useSSL=false
    username: root
    password: root
mybatis:
  mapperLocations: classpath:mapper/*.xml
  type-aliases-package: com.li.springcloud.entities

修改成自己数据库配置。

新建数据库db2019,建表payment

CREATE TABLE payment (
 id BIGINT(20) NOT NULL AUTO_INCREMENT COMMENT 'ID',
 SERIAL VARCHAR(200) DEFAULT '00000',
 PRIMARY KEY(id)
) ENGINE=INNODB AUTO_INCREMENT=1 DEFAULT CHARSET='utf8'
INSERT INTO payment VALUES(01,'202011061045');
INSERT INTO payment(SERIAL) VALUES('202011061046');

4.主启动

新建主启动类,和springboot一样。注意目录关系,主启动类要建在最外面,不然访问时报:Required request body is missing

20201107154505130.png

package com.li.springcloud;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class PaymentMain8001 {
    public static void main(String[] args) {
        SpringApplication.run(PaymentMain8001.class,args);
    }
}

5.业务类

mysql->dao->service->controller->VUE

5.1实体类entities

package com.li.springcloud.entities;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable;
@Data
@AllArgsConstructor
@NoArgsConstructor
public class Payment implements Serializable {
    private Long id;
    private String serial;
}
package com.li.springcloud.entities;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
 *@Author: 一条IT
 *@Date: 2020/11/5 11:17
 **/
@Data
@AllArgsConstructor
@NoArgsConstructor
public class CommonResult<T> {
//    404 not found
    private Integer code;
    private String message;
    private T data;
    public CommonResult(Integer code, String message){
        this(code,message,null);
    }
}

补充知识1:CommenResult


作为返回结果集,无论什么业务,传给前端一个结果,类似“404 not found”。


补充知识2:Lombok:可用来帮助开发人员消除 Java 的冗长代码,尤其是对于简单的 Java 对象(POJO)。它通过注解实现这一目的。


@NoArgsConstructor:生成无参构造器;


@AllArgsConstructor:生成全参构造器


@Data:作用于类上,是以下注解的集合:@ToString @EqualsAndHashCode @Getter @Setter @RequiredArgsConstructor


lombok的使用除了要引入依赖,还要安装插件,依赖已经在pom文件写好。


idea安装

20201107160500863.png

eclipse安装:https://blog.csdn.net/qq_35868412/article/details/93137304

了解更多Lombok:https://www.jianshu.com/p/2543c71a8e45

5.2dao

package com.li.springcloud.dao;
import org.apache.ibatis.annotations.Mapper;
import com.li.springcloud.entities.Payment;
import org.apache.ibatis.annotations.Param;
/**
 * @Author: 一条IT
 * @Date: 2020/11/5 14:00
 */
@Mapper
public interface PaymentDao {
//    新增订单
    public int create(Payment Payment);
//按照id查找订单
    public Payment getPaymentById(@Param("id") Long id);
}

写Mapper,mabits操作

20201107160736324.png

<?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.li.springcloud.dao.PaymentDao">
   <insert id="create" parameterType="Payment" useGeneratedKeys="true" keyProperty="id">
       insert into payment(serial) values(#{serial});
   </insert>
    <resultMap id="BaseResultMap" type="com.li.springcloud.entities.Payment">
        <id column="id" property="id" jdbcType="BIGINT"></id>
        <id column="serial" property="serial" jdbcType="VARCHAR"></id>
    </resultMap>
    <select id="getPaymentById" parameterType="Long" resultMap="BaseResultMap">
        select * from payment where id=#{id};
    </select>
</mapper>

注意:parameterType不要写成parameterMap;id对应方法名,不要手敲,容易错,统统复制粘贴。

5.3service

先写接口,再写实现类。方法同样复制dao的,不要手敲。

package com.li.springcloud.service;
import com.li.springcloud.entities.Payment;
import org.apache.ibatis.annotations.Param;
/**
 * @Author: 一条IT
 * @Date: 2020/11/5 14:20
 */
public interface PaymentService {
    public int create(Payment Payment);
    public Payment getPaymentById(@Param("id") Long id);
}

实现类

package com.li.springcloud.service;
import com.li.springcloud.dao.PaymentDao;
import com.li.springcloud.entities.Payment;
import org.apache.ibatis.annotations.Param;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
/**
 * @Author: 一条IT
 * @Date: 2020/11/5 14:21
 */
@Service
public class PaymentServiceImpl implements PaymentService {
    @Resource
    private PaymentDao paymentDao;
    public int create(Payment Payment) {
        return paymentDao.create(Payment);
    }
    public Payment getPaymentById(@Param("id") Long id) {
        return paymentDao.getPaymentById(id);
    }
}


5.4controller

package com.li.springcloud.controller;
import com.li.springcloud.entities.CommonResult;
import com.li.springcloud.entities.Payment;
import com.li.springcloud.service.PaymentService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
/**
 * @Author: 一条IT
 * @Date: 2020/11/5 14:33
 */
@RestController
//日志
@Slf4j
public class PaymentController {
//    Java自带的依赖注入:import javax.annotation.Resource;
    @Resource
    private PaymentService paymentService;
    //尽量用新的注解
    @PostMapping(value = "/payment/create")
    public CommonResult create(@RequestBody Payment payment)
    {
        int result = paymentService.create(payment);
        log.info("*****插入结果:"+result);
        if(result > 0)
        {
            return new CommonResult(200,"插入数据库成功: ",result);
        }else{
            return new CommonResult(444,"插入数据库失败",null);
        }
    }
    @GetMapping(value = "/payment/get/{id}")
    public CommonResult getPaymentById(@PathVariable("id") Long id){
        Payment payment=paymentService.getPaymentById(id);
        log.info("********查询结果:"+payment);
        if (payment!=null){
            return new CommonResult(200,"查询成功",payment);
        }else {
            return new CommonResult(444,"查询失败,id="+id,null);
        }
    }
}

测试模块功能

启动模块

20201107163723396.png

查询订单方法,因为是get请求,浏览器可测。地址栏输入:http://localhost:8001/payment/get/1

20201107163916233.png

新增订单方法,因为是post请求,大部分浏览器不支持,使用postman测试。


postman需要准备的:


1. 选post请求


2. Headers中添加 key: Content-Type value:application/json


3. Body中选raw, JSON


4. 文本框中写入json参数


//

20201107164139493.png

总结

构建微服务模块五大步

1.建moudle

2.改pom

3.写yml

4.主启动

5.业务类

下一节将会新建另一个模块Order模块,模拟用户下单。

 

相关实践学习
基于CentOS快速搭建LAMP环境
本教程介绍如何搭建LAMP环境,其中LAMP分别代表Linux、Apache、MySQL和PHP。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
相关文章
|
2天前
|
Prometheus 监控 负载均衡
【SpringCloud】微服务重点解析
【SpringCloud】微服务重点解析
13 0
|
2天前
|
缓存 负载均衡 算法
【微服务 SpringCloud】实用篇 · Ribbon负载均衡
【微服务 SpringCloud】实用篇 · Ribbon负载均衡
9 0
|
2天前
|
负载均衡 监控 算法
【微服务 SpringCloud】实用篇 · Eureka注册中心
【微服务 SpringCloud】实用篇 · Eureka注册中心
11 1
|
2天前
|
存储 SpringCloudAlibaba Java
【微服务 SpringCloud】实用篇 · 服务拆分和远程调用
【微服务 SpringCloud】实用篇 · 服务拆分和远程调用
16 2
|
2天前
|
消息中间件 Java RocketMQ
Spring Cloud RocketMQ:构建可靠消息驱动的微服务架构
【4月更文挑战第28天】消息队列在微服务架构中扮演着至关重要的角色,能够实现服务之间的解耦、异步通信以及数据分发。Spring Cloud RocketMQ作为Apache RocketMQ的Spring Cloud集成,为微服务架构提供了可靠的消息传输机制。
30 1
|
2天前
|
Dubbo Java 应用服务中间件
Spring Cloud Dubbo: 微服务通信的高效解决方案
【4月更文挑战第28天】在微服务架构的发展中,服务间的高效通信至关重要。Spring Cloud Dubbo 提供了一种基于 RPC 的通信方式,使得服务间的调用就像本地方法调用一样简单。本篇博客将探讨 Spring Cloud Dubbo 的核心概念,并通过具体实例展示其在项目中的实战应用。
20 2
|
2天前
|
负载均衡 Java 网络架构
【SpringCloud】如何理解分布式、微服务、集群
【SpringCloud】如何理解分布式、微服务、集群
24 1
|
2天前
|
Java 数据安全/隐私保护 Sentinel
微服务学习 | Spring Cloud 中使用 Sentinel 实现服务限流
微服务学习 | Spring Cloud 中使用 Sentinel 实现服务限流
|
2天前
|
运维 监控 Java
SpringCloud&认识微服务
SpringCloud&认识微服务
18 0
|
2天前
|
人工智能 监控 安全
Java+Spring Cloud +Vue+UniApp微服务智慧工地云平台源码
视频监控系统、人员实名制与分账制管理系统、车辆管理系统、环境监测系统、大型设备监测(龙门吊、塔吊、升降机、卸料平台等)、用电监测系统、基坑监测系统、AI算法分析(安全帽佩戴、火焰识别、周界报警、人员聚众报警、升降机超载报警)、安全培训、设备监测。
31 4