springcloud微服务（三）-支付模块

痛定思痛。 2023-10-06 20:44 14阅读 0赞

在没有微服务的情况下，生产者和消费者的模型如下：

![574cc2d69dc04e56917d428f09fea54d.png][]

## 一、创建子模块-支付模块payment8001 ##

## 二、修改pom文件 ##

<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.14</version>
            </dependency>
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
            </dependency>
            <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>
            </dependency>
        </dependencies>

## 三、配置application.yml文件 ##

![14cb4d5f4b29476d89646a21303d0a3d.png][]

server:
      port: 8001
    
    spring:
      application:
        name: cloud-payment-service
    
      datasource:
        type: com.alibaba.druid.pool.DruidDataSource
        driver-class-name: com.mysql.cj.jdbc.Driver
        url: jdbc:mysql://localhost:3306/ssm_crud?serverTimezone=UTC&useUnicode=true&characterEncoding=UTF-8
        username: root
        password: 123456
    
    mybatis:
      type-aliases-package: com.atorientsec.springcloud.entities
      mapper-locations: classpath:mapper/*.xml

3.1 每个module都需要一个端口号，端口代表一个module（应用程序）

3.2 spring.application.name 应用的名字

3.3 spring.datasource 代表spring整合的数据库

3.4 mybatis: type-aliases-package给每个实体类起别名，类名的小写

mapper-locations:mapper接口与xml文件关联的路径

## 四、创建主程序类 ##

![97eadbd836d247298f43ef0a8ce9b725.png][]

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

总结：创建微服务的步骤：创建module->改pom->创建yml文件->创建主类

下面开始业务类

## 一、创建实体 ##

由于与web端交互，应答的是json消息体，而且web端不会解析每一个不同的消息体。所以我们需要创建一个公共的子模块，来保存我们的所有的实体类。先打成jar包，其他的子模块pom引入此jar包。这样其他的子模块就不需要创建实体类了。

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA6Iqx5p6c5rC06I6y_size_13_color_FFFFFF_t_70_g_se_x_16][]

1.1 CommonResult类就是我们与web端交互的类，此类的字段有状态码，消息，以及数据

@Data
    @NoArgsConstructor
    public class CommonResult<T> {
        private Integer code;
        private String message;
        private T data;
    
        public CommonResult(Integer code,String message)
        {
            this.code=code;
            this.message=message;
        }
        public CommonResult(Integer code,String message,T data)
        {
            this(code, message);
            this.data = data;
        }
    }

1.2 Payment实体类

@Data
    @NoArgsConstructor
    @AllArgsConstructor
    public class Payment implements Serializable {
        private Long id;
        private String serial;
    }

注：实体类的序列化 implements Serializable

序列化就是对实例对象的状态(State 对象属性而不包括对象方法)进行通用编码（如格式化的字节码）并保存，以保证对象的完整性和可传递性。

简而言之：序列化，就是为了在不同时间或不同平台的JVM之间共享实例对象

## 二、修改payment8001的pom文件引入cloud-api-commons依赖 ##

<dependency>
        <groupId>otc.orientsec</groupId>
        <artifactId>cloud-api-commons</artifactId>
        <version>1.0-SNAPSHOT</version>
    </dependency>

## 三、dao层 ##

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA6Iqx5p6c5rC06I6y_size_13_color_FFFFFF_t_70_g_se_x_16 1][]

@Mapper
    public interface PaymentMapper {
        Payment getPaymentById(@Param("id") Long id);
        int addPayment(Payment payment);
    }

3.1 @Mapper注解

@Mapper 一般我们用在接口上，使用 @Mapper，最终 Mybatis 会有一个拦截器，会自动的把 @Mapper 注解的接口生成动态代理类。

3.2 @Param注解

采用\#\{\}的方式把@Param注解括号内的参数进行引用

3.3 Mapper接口对应的XML文件

<mapper namespace="com.atorientsec.springcloud.mapper.PaymentMapper">
        
        <resultMap id="paymentMap" type="payment">
            <id property="id" column="id" jdbcType="BIGINT"></id>
            <id property="serial" column="serial" jdbcType="VARCHAR"></id>
        </resultMap>
        <select id="getPaymentById" parameterType="Long" resultMap="paymentMap">
            select id,serial from ssm_crud.payment where id=#{id};
        </select>
    
        <insert id="addPayment" parameterType="payment">
            insert into ssm_crud.payment(serial) values(#{serial});
        </insert>
    </mapper>

## 四、services层 ##

@Service
    public class PaymentServices {
    
        @Autowired
        private PaymentMapper paymentMapper;
    
        public Payment getPaymentById(Long id)
        {
            return paymentMapper.getPaymentById(id);
        }
        public int addPayment( Payment payment)
        {
            return paymentMapper.addPayment(payment);
        }
    
    }

## 五、controller层 ##

@RestController
    @Slf4j
    public class PaymentController {
    
        @Autowired
        private PaymentServices paymentServices;
    
        @Value("${server.port}")
        private String serverPort;
    
        @GetMapping("/payment/get/{id}")
        public CommonResult<Payment> getPaymentById(@PathVariable("id") Long id)
        {
             Payment payment=paymentServices.getPaymentById(id);
             log.info("********查询结果*********："+payment);
             if(payment != null)
             {
                 return new CommonResult<>(200,"查询数据成功,serverport:"+serverPort,payment);
             }else
             {
                 return new CommonResult<>(444,"查询到对应的记录，查询ID："+id);
             }
    
        }
        @PostMapping("/payment/create")
        public CommonResult addPayment(@RequestBody Payment payment)
        {
    
           int result = paymentServices.addPayment(payment);
           log.info("******插入结果："+result);
           if(result>0)
           {
               return new CommonResult(200,"插入成功");
           }else
           {
               return new CommonResult(445,"插入失败");
           }
        }
    }

5.1 可以看到返回类型都是公共的CommonResult类型的，web端容易解析

5.2 @RequestBody注解

作用：@RequestBody注解用于读取http请求的内容(**字符串**)，通过springmvc提供的HttpMessageConverter接口将读到的内容（json数据）转换为java对象并绑定到Controller方法的参数上。

5.3 @Value()注解：

@Value("$\{XXX\}"):注解从配置文件读取值的用法

## 六、Jemeter测试接口 ##

1. 添加 配置元件 ->HTTP信息头管理器

![b34b371fadd44dd9a0b9ff0b1a1ba9dc.png][]

解决方案：就是在 HTTP信息头管理器

配置Content-Type:application/json

![22df51ff3c1e42e284ce9f26674d631a.png][]

2. 添加->后置处理器->BeanShell监听器

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA6Iqx5p6c5rC06I6y_size_18_color_FFFFFF_t_70_g_se_x_16][]

解决查询时应答体中文乱码的问题。

3. 结果

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA6Iqx5p6c5rC06I6y_size_20_color_FFFFFF_t_70_g_se_x_16][]

![7826dba3506b44acafe686c6769f0c1c.png][]

[574cc2d69dc04e56917d428f09fea54d.png]: https://img-blog.csdnimg.cn/574cc2d69dc04e56917d428f09fea54d.png
[14cb4d5f4b29476d89646a21303d0a3d.png]: https://img-blog.csdnimg.cn/14cb4d5f4b29476d89646a21303d0a3d.png
[97eadbd836d247298f43ef0a8ce9b725.png]: https://img-blog.csdnimg.cn/97eadbd836d247298f43ef0a8ce9b725.png
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA6Iqx5p6c5rC06I6y_size_13_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/bfcc40e8658b442587c7de1747029ff7.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA6Iqx5p6c5rC06I6y,size_13,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA6Iqx5p6c5rC06I6y_size_13_color_FFFFFF_t_70_g_se_x_16 1]: https://img-blog.csdnimg.cn/ca0654e7f7de451e932d089119de20dc.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA6Iqx5p6c5rC06I6y,size_13,color_FFFFFF,t_70,g_se,x_16
[b34b371fadd44dd9a0b9ff0b1a1ba9dc.png]: https://img-blog.csdnimg.cn/b34b371fadd44dd9a0b9ff0b1a1ba9dc.png
[22df51ff3c1e42e284ce9f26674d631a.png]: https://img-blog.csdnimg.cn/22df51ff3c1e42e284ce9f26674d631a.png
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA6Iqx5p6c5rC06I6y_size_18_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/32062d7f76074acaa2e71b49a1af0e97.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA6Iqx5p6c5rC06I6y,size_18,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA6Iqx5p6c5rC06I6y_size_20_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/7dce667f374b4477a4ad318aff16ddd2.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA6Iqx5p6c5rC06I6y,size_20,color_FFFFFF,t_70,g_se,x_16
[7826dba3506b44acafe686c6769f0c1c.png]: https://img-blog.csdnimg.cn/7826dba3506b44acafe686c6769f0c1c.png