devbox
知新_RL
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

JAVA实现转账接口_java转账接口

作者：知新_RL | 2024-05-15 19:23:55

赞

踩

java转账接口

问题:

尝试用java实现一个转账接口，根据传入的转出账户、转入账户和金额，修改表中账户的金额。
 

分析问题：

1. 尝试使用MySQL数据库存储数据

2. 确保在资金处理时转出账户的余额不会透支

3. 考虑转账的数据不影响其他人的业务

4. 考虑多点部署的并发问题及系统吞吐量问题

     a>并发下保证数据不可以出错（这是转钱哦，搞错了赔不起哦。。。。。。）

     b>不能用java锁，synchronized，ReentrantLock等单点锁（多点部署问题，影响整体吞吐量）

     c> 不能用redis等分布式锁（影响整体吞吐量）

最终代码：

项目目录：

maven配置

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
  4.     <modelVersion>4.0.0</modelVersion>
  5.     <parent>
  6.         <groupId>org.springframework.boot</groupId>
  7.         <artifactId>spring-boot-starter-parent</artifactId>
  8.         <version>2.4.4</version>
  9.         <relativePath/>
  10.     </parent>
  11.     <groupId>com.example</groupId>
  12.     <artifactId>demo</artifactId>
  13.     <version>0.0.1-SNAPSHOT</version>
  14.     <name>demo</name>
  15.     <description>Demo project for Spring Boot</description>
  16.     <properties>
  17.         <java.version>1.8</java.version>
  18.     </properties>
  19.     <dependencies>
  20.         <dependency>
  21.             <groupId>org.springframework.boot</groupId>
  22.             <artifactId>spring-boot-starter-web</artifactId>
  23.         </dependency>
  24.         <dependency>
  25.             <groupId>mysql</groupId>
  26.             <artifactId>mysql-connector-java</artifactId>
  27.             <scope>runtime</scope>
  28.         </dependency>
  29.         <dependency>
  30.             <groupId>org.mybatis.spring.boot</groupId>
  31.             <artifactId>mybatis-spring-boot-starter</artifactId>
  32.             <version>2.1.2</version>
  33.         </dependency>
  34.         <dependency>
  35.             <groupId>com.alibaba</groupId>
  36.             <artifactId>druid</artifactId>
  37.             <version>1.1.10</version>
  38.         </dependency>
  39.         <dependency>
  40.             <groupId>org.projectlombok</groupId>
  41.             <artifactId>lombok</artifactId>
  42.             <version>1.16.10</version>
  43.         </dependency>
  44.     </dependencies>
  45. </project>

yaml

  1. server:
  2.   port: 9088
  3.  
  4. spring:
  5.   application:
  6.     name: demo
  7.   datasource:
  8.     url: jdbc:mysql://127.0.0.1:3306/test?characterEncoding=UTF-8&useSSL=true
  9.     username: root
  10.     password: root
  11.     driver-class-name: com.mysql.cj.jdbc.Driver
  12.  
  13. mybatis:
  14.   type-aliases-package: com.example.demo.model
  15.   mapper-locations: classpath:mybatis/mapper/*.xml

 DataSourceConfig 

  1. package com.example.demo.config;
  2.  
  3. import com.alibaba.druid.pool.DruidDataSource;
  4.  
  5. import javax.sql.DataSource;
  6.  
  7. import org.springframework.beans.factory.annotation.Value;
  8. import org.springframework.context.annotation.Bean;
  9. import org.springframework.context.annotation.Configuration;
  10.  
  11. import lombok.extern.slf4j.Slf4j;
  12.  
  13. @Slf4j
  14. @Configuration
  15. public class DataSourceConfig {
  16.  
  17.     @Value("${spring.datasource.url}")
  18.     private String url;
  19.  
  20.     @Value("${spring.datasource.driver-class-name}")
  21.     private String driverClassName;
  22.  
  23.     @Value("${spring.datasource.username}")
  24.     private String userName;
  25.  
  26.     @Value("${spring.datasource.password}")
  27.     private String password;
  28.  
  29.     @Bean
  30.     public DataSource dataSource() {
  31.         DruidDataSource dataSource = new DruidDataSource();
  32.         dataSource.setUrl(url);
  33.         dataSource.setUsername(userName);
  34.         dataSource.setPassword(password);
  35.         dataSource.setDriverClassName(driverClassName);
  36.         return dataSource;
  37.     }
  38.  
  39. }

MoneyController

  1. package com.example.demo.controller;
  2.  
  3. import com.example.demo.model.vo.TrandingVo;
  4. import com.example.demo.service.MoneyService;
  5. import com.example.demo.utils.RestResponse;
  6.  
  7. import org.springframework.beans.factory.annotation.Autowired;
  8. import org.springframework.web.bind.annotation.PostMapping;
  9. import org.springframework.web.bind.annotation.RequestBody;
  10. import org.springframework.web.bind.annotation.RequestMapping;
  11. import org.springframework.web.bind.annotation.RestController;
  12.  
  13. import lombok.extern.slf4j.Slf4j;
  14.  
  15. /**
  16.  * @Author: yipeng
  17.  * @Date: 2021/6/18 20:58
  18.  */
  19. @Slf4j
  20. @RestController
  21. @RequestMapping("/money")
  22. public class MoneyController {
  23.  
  24.     @Autowired
  25.     private MoneyService moneyService;
  26.  
  27.     @PostMapping("/trading")
  28.     public RestResponse<Boolean> trading(@RequestBody TrandingVo trandingVo) {
  29.         try {
  30.             return RestResponse.buildSuccess(moneyService.trading(trandingVo));
  31.         } catch (Exception e) {
  32.             log.error("trading error: " + e.getMessage());
  33.         }
  34.         return RestResponse.buildSuccess(false);
  35.     }
  36.  
  37. }

MoneyMapper

  1. package com.example.demo.mapper;
  2.  
  3. import com.example.demo.model.po.MoneyPo;
  4.  
  5. import org.apache.ibatis.annotations.Mapper;
  6.  
  7. /**
  8.  * @Author: yipeng
  9.  * @Date: 2021/6/18 20:49
  10.  */
  11. @Mapper
  12. public interface MoneyMapper {
  13.  
  14.     MoneyPo getOneByUserName(String userName);
  15.  
  16.  
  17.     void update(MoneyPo moneyPo);
  18. }

MoneyPo

  1. package com.example.demo.model.po;
  2.  
  3. import java.io.Serializable;
  4.  
  5. import lombok.Data;
  6.  
  7. /**
  8.  * @Author: yipeng
  9.  * @Date: 2021/6/18 20:49
  10.  */
  11. @Data
  12. public class MoneyPo implements Serializable {
  13.  
  14.  
  15.     private static final long serialVersionUID = -8851981653703733214L;
  16.     
  17.     private Long id;
  18.  
  19.     private String userName;
  20.  
  21.     private Long money;
  22.  
  23. }

TrandingVo

  1. package com.example.demo.model.vo;
  2.  
  3. import lombok.Data;
  4.  
  5. /**
  6.  * @Author: yipeng
  7.  * @Date: 2021/6/18 21:08
  8.  */
  9. @Data
  10. public class TrandingVo {
  11.  
  12.     private String fromUserName;
  13.  
  14.     private String toUserName;
  15.  
  16.     private Long money;
  17.  
  18. }

MoneyService

  1. package com.example.demo.service;
  2.  
  3. import com.example.demo.model.vo.TrandingVo;
  4.  
  5. /**
  6.  * @Author: yipeng
  7.  * @Date: 2021/6/18 21:04
  8.  */
  9. public interface MoneyService {
  10.  
  11.     boolean trading(TrandingVo trandingVo);
  12. }

MoneyServiceImpl

  1. package com.example.demo.service.impl;
  2.  
  3. import com.example.demo.mapper.MoneyMapper;
  4. import com.example.demo.model.po.MoneyPo;
  5. import com.example.demo.model.vo.TrandingVo;
  6. import com.example.demo.service.MoneyService;
  7.  
  8. import org.springframework.beans.factory.annotation.Autowired;
  9. import org.springframework.stereotype.Service;
  10. import org.springframework.transaction.annotation.Transactional;
  11.  
  12. import lombok.extern.slf4j.Slf4j;
  13.  
  14. /**
  15.  * @Author: yipeng
  16.  * @Date: 2021/6/18 21:09
  17.  */
  18. @Service
  19. @Slf4j
  20. public class MoneyServiceImpl implements MoneyService {
  21.  
  22.     @Autowired
  23.     private MoneyMapper moneyMapper;
  24.  
  25.  
  26.     @Override
  27.     @Transactional
  28.     public boolean trading(TrandingVo trandingVo) {
  29.         MoneyPo fromUser = moneyMapper.getOneByUserName(trandingVo.getFromUserName());
  30.         MoneyPo toUser = moneyMapper.getOneByUserName(trandingVo.getToUserName());
  31.         if (fromUser.getMoney() > trandingVo.getMoney()) {
  32.             fromUser.setMoney(fromUser.getMoney() - trandingVo.getMoney());
  33.             toUser.setMoney(toUser.getMoney() + trandingVo.getMoney());
  34.             moneyMapper.update(fromUser);
  35.             moneyMapper.update(toUser);
  36.             return true;
  37.         }
  38.         log.error("trading error" + Thread.currentThread().getName());
  39.         return false;
  40.     }
  41. }

RestResponse<T>

  1. package com.example.demo.utils;
  2.  
  3. import org.springframework.http.HttpStatus;
  4.  
  5. import lombok.Data;
  6. import lombok.extern.slf4j.Slf4j;
  7.  
  8. @Data
  9. @Slf4j
  10. public class RestResponse<T> {
  11.  
  12.     private int code;
  13.     private String message;
  14.     private T data;
  15.  
  16.     private RestResponse() {
  17.  
  18.     }
  19.  
  20.     public static RestResponse build(HttpStatus status) {
  21.         RestResponse result = new RestResponse();
  22.         result.code = status.value();
  23.         result.message = status.getReasonPhrase();
  24.         return result;
  25.     }
  26.     
  27.     public static <T> RestResponse<T> buildSuccess(T t) {
  28.         RestResponse resp = build(HttpStatus.OK);
  29.         resp.setData(t);
  30.         return resp;
  31.     }
  32. }
  33.  
  34.

DemoApplication

  1. package com.example.demo;
  2.  
  3. import org.mybatis.spring.annotation.MapperScan;
  4. import org.springframework.boot.SpringApplication;
  5. import org.springframework.boot.autoconfigure.SpringBootApplication;
  6.  
  7. @MapperScan("com.example.demo.mapper")
  8. @SpringBootApplication
  9. public class DemoApplication {
  10.  
  11.     public static void main(String[] args) {
  12.  
  13.         SpringApplication.run(DemoApplication.class, args);
  14.     }
  15.  
  16. }

MoneyMapper.xml

  1. <?xml version="1.0" encoding="UTF-8" ?>
  2. <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
  3. <mapper namespace="com.example.demo.mapper.MoneyMapper" >
  4.     <resultMap id="BaseResultMap" type="com.example.demo.model.po.MoneyPo" >
  5.         <id column="id" property="id" jdbcType="BIGINT" />
  6.         <result column="userName" property="userName" jdbcType="VARCHAR" />
  7.         <result column="money" property="money" jdbcType="BIGINT" />
  8.     </resultMap>
  9.  
  10.     <sql id="Base_Column_List" >
  11.         id, userName, money
  12.     </sql>
  13.  
  14.     <select id="getOneByUserName" parameterType="java.lang.String" resultMap="BaseResultMap" >
  15.         SELECT
  16.         <include refid="Base_Column_List" />
  17.         FROM money
  18.         WHERE userName = #{userName} FOR UPDATE
  19.     </select>
  20.  
  21.     <update id="update" parameterType="com.example.demo.model.po.MoneyPo" >
  22.         UPDATE
  23.         money
  24.         SET
  25.         userName = #{userName}, money = #{money}
  26.         WHERE
  27.         id = #{id}
  28.     </update>
  29.  
  30.  
  31. </mapper>

money.sql

  1. CREATE DATABASE IF NOT EXISTS test;
  2. use test;
  3. DROP TABLE IF EXISTS `money`;
  4. CREATE TABLE `money` (
  5.   `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '主键id',
  6.   `userName` varchar(32) DEFAULT NULL COMMENT '用户名',
  7.   `money` bigint(20) DEFAULT 0 COMMENT '账户金额',
  8.   PRIMARY KEY (`id`),
  9.   UNIQUE KEY `userName` (`userName`)
  10. ) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;
  11.  
  12. insert into money set userName = 'Tom', money = 10000;
  13. insert into money set userName = 'John', money = 10000;

具体分析

实现过程：

1. @Transactional注解

2. 行级排他锁（FOR UPDATE）

JMeter压测一下（100QPS * 10S）

压测数据：

curl -X POST http://127.0.0.1:9088/money/trading -H 'Content-Type: application/json' -d '{"fromUserName":"Tom","toUserName":"John","money":10}'

压测前数据表：

压测后数据表：

压测数据：

结论：

单用户点对点转账吞吐量50QPS左右，能够满足正常业务需求。

声明：本文内容由网友自发贡献，转载请注明出处：【wpsshop】
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。