drop table if exists account_wallet;
 
/*==============================================================*/
/* Table: account_wallet          */
/*==============================================================*/
create table account_wallet
(
 id     int not null comment '用戶錢包主鍵',
 user_open_id   varchar(64) comment '用戶中心的用戶唯一編號(hào)',
 user_amount   decimal(10,5),
 create_time   datetime,
 update_time   datetime,
 pay_password   varchar(64),
 is_open    int comment '0:代表未開(kāi)啟支付密碼，1:代表開(kāi)發(fā)支付密碼',
 check_key   varchar(64) comment '平臺(tái)進(jìn)行用戶余額更改時(shí)，首先效驗(yàn)key值，否則無(wú)法進(jìn)行用戶余額更改操作',
 version    int comment '基于mysql樂(lè)觀鎖，解決并發(fā)訪問(wèn)'
 primary key (id)
);

 public AccountWallet selectByOpenId(String openId) {
 // TODO Auto-generated method stub
 return accountWalletMapper.selectByOpenId(openId);
 }
 
 public int updateAccountWallet(AccountWallet record) {
 // TODO Auto-generated method stub
 return accountWalletMapper.updateAccountWallet(record);
 }

 <!--通過(guò)用戶唯一編號(hào)，查詢用戶錢包相關(guān)的信息 -->
 <select id="selectByOpenId" resultMap="BaseResultMap" parameterType="java.lang.String">
 select 
 <include refid="Base_Column_List" />
 from account_wallet
 where user_open_id = #{openId,jdbcType=VARCHAR}
 </select>
 <!--用戶錢包數(shù)據(jù)更改 ，通過(guò)樂(lè)觀鎖(version機(jī)制)實(shí)現(xiàn) -->
 <update id="updateAccountWallet" parameterType="com.settlement.model.AccountWallet">
   <![CDATA[
   update account_wallet set user_amount = #{userAmount,jdbcType=DECIMAL}, version = version + 1 where id =#{id,jdbcType=INTEGER} and version = #{version,jdbcType=INTEGER} 
   ]]> 
 </update>

package com.settlement.controller;
 
import java.math.BigDecimal;
import javax.servlet.http.HttpServletRequest;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.ResponseBody;
import com.settlement.commons.base.BaseController;
import com.settlement.model.AccountWallet;
import com.settlement.service.AccountWalletService;
import com.taobao.api.internal.util.StringUtils;
 
/**
 * 用戶錢包Controller
 * 
 * @author zzg
 * @date 2017-02-10
 */
 
@Controller
@RequestMapping(value = "/wallet")
public class WalletController extends BaseController {
 
	@Autowired
	private AccountWalletService accountWalletService;
 
	/**
	 * 針對(duì)業(yè)務(wù)系統(tǒng)高并發(fā)-----修改用戶錢包數(shù)據(jù)余額，采用樂(lè)觀鎖
	 * 
	 * @return
	 */
	@RequestMapping(value = "/walleroptimisticlock.action", method = RequestMethod.POST)
	@ResponseBody
	public String walleroptimisticlock(HttpServletRequest request) {
 
		String result = "";
 
		try {
			String openId = request.getParameter("openId") == null ? null
					: request.getParameter("openId").trim(); // 用戶唯一編號(hào)
			String openType = request.getParameter("openType") == null ? null
					: request.getParameter("openType").trim(); // 1:代表增加，2：代表減少
			String amount = request.getParameter("amount") == null ? null
					: request.getParameter("amount").trim(); // 金額
 
			if (StringUtils.isEmpty(openId)) {
				return "openId is null";
			}
			if (StringUtils.isEmpty(openType)) {
				return "openType is null";
			}
			if (StringUtils.isEmpty(amount)) {
				return "amount is null";
			}
			AccountWallet wallet = accountWalletService.selectByOpenId(openId);
 
			// 用戶操作金額
			BigDecimal cash = BigDecimal.valueOf(Double.parseDouble(amount));
			cash.doubleValue();
			cash.floatValue();
			if (Integer.parseInt(openType) == 1) {
				wallet.setUserAmount(wallet.getUserAmount().add(cash));
			} else if (Integer.parseInt(openType) == 2) {
				wallet.setUserAmount(wallet.getUserAmount().subtract(cash));
			}
 
			int target = accountWalletService.updateAccountWallet(wallet);
			System.out.println("修改用戶金額是否：" + (target == 1 ? "成功" : "失敗"));
 
		} catch (Exception e) {
			result = e.getMessage();
			return result;
		}
 
		return "success";
	}
 
}

package com.settlement.concurrent; 
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.concurrent.CountDownLatch; 
import com.settlement.commons.utils.HttpRequest; 
 
/**
 * 模擬用戶的并發(fā)請(qǐng)求，檢測(cè)用戶樂(lè)觀鎖的性能問(wèn)題
 * 
 * @author zzg
 * @date 2017-02-10
 */
public class ConcurrentTest {
	final static SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); 
	public static void main(String[] args){
		CountDownLatch latch=new CountDownLatch(1);//模擬5人并發(fā)請(qǐng)求，用戶錢包
		
		for(int i=0;i<5;i++){//模擬5個(gè)用戶
			AnalogUser analogUser = new AnalogUser("user"+i,"58899dcd-46b0-4b16-82df-bdfd0d953bfb","1","20.024",latch);
			analogUser.start();
		}
		latch.countDown();//計(jì)數(shù)器減一 所有線程釋放 并發(fā)訪問(wèn)。
		System.out.println("所有模擬請(qǐng)求結(jié)束 at "+sdf.format(new Date())); 		
	}	
	static class AnalogUser extends Thread{
		String workerName;//模擬用戶姓名
		String openId;
		String openType;
		String amount;
		CountDownLatch latch;
		
		public AnalogUser(String workerName, String openId, String openType, String amount,
				CountDownLatch latch) {
			super();
			this.workerName = workerName;
			this.openId = openId;
			this.openType = openType;
			this.amount = amount;
			this.latch = latch;
		}
		@Override
		public void run() {
			// TODO Auto-generated method stub
			try { 
				latch.await(); //一直阻塞當(dāng)前線程，直到計(jì)時(shí)器的值為0 
	  } catch (InterruptedException e) { 
	   e.printStackTrace(); 
	  } 			
			post();//發(fā)送post 請(qǐng)求 			
		} 
		
		public void post(){
			String result = "";
			System.out.println("模擬用戶： "+workerName+" 開(kāi)始發(fā)送模擬請(qǐng)求 at "+sdf.format(new Date())); 
			result = HttpRequest.sendPost("http://localhost:8080/Settlement/wallet/walleroptimisticlock.action", "openId="+openId+"&openType="+openType+"&amount="+amount);
			System.out.println("操作結(jié)果："+result);
			System.out.println("模擬用戶： "+workerName+" 模擬請(qǐng)求結(jié)束 at "+sdf.format(new Date())); 
			
		}			
	}
}

package com.wuyd.mybatispulsdemo;

import com.baomidou.mybatisplus.annotation.DbType;
import com.baomidou.mybatisplus.generator.AutoGenerator;
import com.baomidou.mybatisplus.generator.config.*;
import com.baomidou.mybatisplus.generator.config.rules.NamingStrategy;

/**
 * @author wuyd
 * 創(chuàng)建時(shí)間：2019/10/8 11:17
 */
public class CodeGenerator {
 public static void main(String[] args) {
  AutoGenerator mpg = new AutoGenerator();

  //全局配置
  GlobalConfig gc = new GlobalConfig();
  gc.setOutputDir(System.getProperty("user.dir")+"/src/main/java");
  gc.setFileOverride(true);
  //不需要ActiveRecord特性的請(qǐng)改為false
  gc.setActiveRecord(true);
  gc.setSwagger2(true);
  gc.setAuthor("wuyd");

  //自定義文件命名，注意%s 會(huì)自動(dòng)填充表實(shí)體屬性
  gc.setControllerName("%sController");
  gc.setServiceName("%sService");
  gc.setServiceImplName("%sServiceImpl");
  gc.setEntityName("%sEntity");
  gc.setMapperName("%sMapper");

  mpg.setGlobalConfig(gc);

  //數(shù)據(jù)源配置
  DataSourceConfig dsc = new DataSourceConfig();
  dsc.setDbType(DbType.MYSQL);
  dsc.setDriverName("com.mysql.jdbc.Driver");
  dsc.setUsername("xxx");
  dsc.setPassword("xxx");
  dsc.setUrl("jdbc:mysql://xxx.xxx.xxx.xxx:3306/xxxxx?useUnicode=true&useSSL=false&characterEncoding=utf8");
  mpg.setDataSource(dsc);

  //策略配置
  StrategyConfig strategy = new StrategyConfig();
  //此處可以修改您的表前綴
  strategy.setTablePrefix(new String[]{});
  //表名生成策略
  strategy.setNaming(NamingStrategy.underline_to_camel);
  strategy.setColumnNaming(NamingStrategy.underline_to_camel);
  //需要生成的表
  strategy.setInclude(new String[]{"knapsacks","knapsacks_kind","knapsacks_prop","knapsacks_recharge_card"});

  strategy.setSuperServiceClass(null);
  strategy.setSuperServiceImplClass(null);

  strategy.setSuperMapperClass(null);
  strategy.setControllerMappingHyphenStyle(true);

  strategy.setEntityLombokModel(true);
  strategy.setEntitySerialVersionUID(true);
  strategy.setEntityTableFieldAnnotationEnable(true);

  mpg.setStrategy(strategy);
  // 配置模板
  TemplateConfig templateConfig = new TemplateConfig();
  templateConfig.setXml(null);
  mpg.setTemplate(templateConfig);

  //包配置
  PackageConfig pc = new PackageConfig();
  pc.setParent("com.wuyd.mybatispulsdemo");
  pc.setController("controller");
  pc.setService("service");
  pc.setServiceImpl("service.impl");
  pc.setMapper("mapper");
  pc.setEntity("entity");
  mpg.setPackageInfo(pc);

  //執(zhí)行生成
  mpg.execute();
 }
}

  <dependency>
   <groupId>com.baomidou</groupId>
   <artifactId>mybatis-plus-generator</artifactId>
   <version>3.2.0</version>
  </dependency>
  <!-- ORM 選一款 -->
  <dependency>
   <groupId>com.baomidou</groupId>
   <artifactId>mybatis-plus-boot-starter</artifactId>
   <version>${mybatis-plus-boot-starter.version}</version>
  </dependency>
  <!-- Mysql驅(qū)動(dòng) 注意版本！-->
  <dependency>
   <groupId>mysql</groupId>
   <artifactId>mysql-connector-java</artifactId>
   <version>${mysql-connector.version}</version>
  </dependency>
  <dependency>
   <groupId>org.apache.velocity</groupId>
   <artifactId>velocity-engine-core</artifactId>
   <version>2.1</version>
  </dependency>