package com.javartisan.concurrent;import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.List;
import java.util.UUID;import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.Transaction;/*** redis并发抢购测试** @author javartisan*/
public class RedisTest {public static void main(String[] args) {final String watchkeys = "watchkeys";ExecutorService executor = Executors.newFixedThreadPool(20);GenericObjectPoolConfig poolConfig = new GenericObjectPoolConfig();JedisPool jedisPool = new JedisPool(poolConfig, "127.0.0.1", 6379, 10000, "root");final Jedis jedis = jedisPool.getResource();jedis.auth("root");jedis.set(watchkeys, "0");// 重置watchkeys为0jedis.del("setsucc", "setfail");// 清空抢成功的，与没有成功的jedis.close();for (int i = 0; i < 10000; i++) {// 测试一万人同时访问executor.execute(new MyRunnable(jedisPool));}executor.shutdown();}
}class MyRunnable implements Runnable {String watchkeys = "watchkeys";// 监视keysJedisPool jedisPool = null;public MyRunnable(JedisPool jedisPool) {this.jedisPool = jedisPool;}@Overridepublic void run() {Jedis jedis = jedisPool.getResource();try {jedis.watch(watchkeys);//代码块1 watchkeysString val = jedis.get(watchkeys);int valint = Integer.valueOf(val);String userifo = UUID.randomUUID().toString();if (valint < 10) {Transaction tx = jedis.multi();//代码块2 开启事务tx.incr("watchkeys");List<Object> list = tx.exec();//代码块3 提交事务，如果此时watchkeys被改动了，则返回emptyListif (list.size() > 0) {System.out.println("用户：" + userifo + "抢购成功，当前抢购成功人数:" + (valint + 1));/* 抢购成功业务逻辑 */jedis.sadd("setsucc", userifo);return;}}System.out.println("用户：" + userifo + "抢购失败");jedis.sadd("setfail", userifo);return;} catch (Exception e) {e.printStackTrace();} finally {jedis.close();}}}

 public List<Object> exec() {client.exec();client.getAll(1); // Discard all but the last replyinTransaction = false;List<Object> unformatted = client.getObjectMultiBulkReply();  if (unformatted == null) { //事务失败return Collections.emptyList();}List<Object> formatted = new ArrayList<Object>();for (Object o : unformatted) {try {formatted.add(generateResponse(o).get());} catch (JedisDataException e) {formatted.add(e);}}return formatted;}

  public Response<String> get(String key) {getClient(key).get(key);return getResponse(BuilderFactory.STRING);}