package ;
import ;
import ;
import ;
import ;
import ;
import ;
import ;
import ;
/**
* @author wzq
* date: 2019/12/23 11:28
* description:
*/
public class OrderService implements Runnable {
private static CyclicBarrier cb = new CyclicBarrier(60);
// Order number generation class
// Add static, getNumber() and synchronous lock to any place of orderNumGenerator or count, which is still thread-safe because the same generator is used, and adding the lock is thread-safe
// The effect is equivalent to a static lock, and many OrderService instances share a lock
private OrderNumGenerator orderNumGenerator = new OrderNumGenerator();
// Implementation method 1
//private DistributeLock lock = new ZookeeperDistributeLock();
// Implementation method 2
//private DistributeLock lock = new ZookeeperDistributeLock2();
/**
* So many OrderService instances share a lock, which can ensure thread safety, but in cluster deployment multi-machine mode,
* Even if each machine has one request to obtain the lock at a time, enough machines will still cause concurrency problems
*/
private static Lock rtLock = new ReentrantLock();
//Implementation method 3, redis distributed lock
//private Jedis jedis = ();
private Jedis jedis = ();
public void run() {
try {
();
} catch (InterruptedException | BrokenBarrierException e) {
();
}
getNumber();
}
public void getNumber() {
String requestId = ().toString();
try {
//();
//();
// Redis server-side deployment requires callback
// Redis lock uses this section to generate order code
/*if ((jedis, "lock", requestId, 2000)) {
String number = ();
(().getName() + "-" + () + ", the order was generated:" + number);
} else {
();
}*/
// Use this section to generate code orders if zookeeper lock or not to add lock
String number = ();
(().getName() + "-" + () + ", Order generated:" + number);
} catch (Exception e) {
();
} finally {
//();
//();
//Redis server-side deployment requires callback
//(jedis, "lock", requestId);
}
}
public static void main(String[] args) {
("#### generated order #####");
for (int i = 0; i < 60; i++) {
new Thread(new OrderService()).start();
}
}
}