Java實(shí)現(xiàn)搶紅包功能

更新時(shí)間：2020年09月25日 08:25:52 作者：littleschemer

這篇文章主要為大家詳細(xì)介紹了Java實(shí)現(xiàn)搶紅包功能，采用多線(xiàn)程模擬多人同時(shí)搶紅包，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下

本文實(shí)例為大家分享了Java實(shí)現(xiàn)搶紅包功能的具體代碼，供大家參考，具體內(nèi)容如下

關(guān)鍵思想：

1.搶紅包涉及多人并發(fā)操作，需要做好同步保證多線(xiàn)程運(yùn)行結(jié)果正確。

2.由于同時(shí)在線(xiàn)人數(shù)大，從性能方面考慮，玩家的發(fā)紅包請(qǐng)求不必及時(shí)響應(yīng)，而由服務(wù)端定時(shí)執(zhí)行發(fā)紅包隊(duì)列。

下面是主要的代碼和實(shí)現(xiàn)邏輯說(shuō)明

1.創(chuàng)建一個(gè)類(lèi)，表示紅包這個(gè)實(shí)體概念。直接采用原子變量保證增減同步。Java的原子變量是一種精度更細(xì)的同步機(jī)制，在高度競(jìng)爭(zhēng)的情況下，鎖的性能將超過(guò)原子變量的性能，但在更真實(shí)的競(jìng)爭(zhēng)情況，原子變量享有更好的性能。

public class SpringGift {
 private String role;
 private AtomicInteger gift;
 public String getRole() {
 return role;
 }
 public void setRole(String role) {
 this.role = role;
 }
 public AtomicInteger getGift() {
 return gift;
 }
 public void setGift(AtomicInteger gift) {
 this.gift = gift;
 }
 
 public int getRemainCount(){
 return this.gift.get();
 }
}

2.采用多線(xiàn)程模擬多人同時(shí)搶紅包。服務(wù)端將玩家發(fā)出的紅包保存在一個(gè)隊(duì)列里，然后用Job定時(shí)將紅包信息推送給玩家。每一批玩家的搶紅包請(qǐng)求，其實(shí)操作的都是從隊(duì)列中彈出的第一個(gè)紅包元素，但當(dāng)前的紅包數(shù)量為空的時(shí)候，自動(dòng)彈出下一個(gè)紅包（如果有的話(huà)）。

public class Test {
 public static ConcurrentLinkedQueue<SpringGift> queue;
 public static SpringGift currGift;
 public static AtomicInteger count = new AtomicInteger();
 static class myThread implements Runnable{
 public void run(){
 handleEvent();
 }
 }
 public static void main(String[] args) throws Exception {
 queue = new ConcurrentLinkedQueue<SpringGift>();
 for(int i =0;i<3;i++){
 SpringGift gift = new SpringGift();
 gift.setRole("role"+i);
 gift.setGift(new AtomicInteger(50));
 queue.add(gift);
 }
 myThread mythread = new myThread();
 for(int i=0;i<1000;i++){
 new Thread(mythread).start();
 }
 
 System.err.println("總共收到"+count.get());
 }
 private static SpringGift getGift(){
 //防止多條線(xiàn)程同時(shí)彈出隊(duì)首
 synchronized (queue) {//若沒(méi)有加鎖，打印的count總數(shù)不對(duì)?。。?！
 if(currGift == null || currGift.getRemainCount() <=0){
 currGift = queue.poll();
 }
 }
 return currGift;
 }
 public static void handleEvent(){
 try{
 SpringGift obj = getGift();
 
 if(obj == null || obj.getRemainCount() <= 0){
 System.err.println("沒(méi)有了");
 return ;
 }
 if(obj !=null && obj.getGift().getAndDecrement() >0 ){
 System.err.println("搶到一個(gè)紅包");
 count.getAndIncrement();
 }
  Thread.sleep(500);//模擬處理其他操作
 }catch(Exception e){
 e.printStackTrace();
 }
 }
}

運(yùn)行結(jié)果部分截圖如下