Java实现抢红包功能

本文实例为大家分享了java实现抢红包功能的具体代码，供大家参考，具体内容如下

关键思想：

1.抢红包涉及多人并发操作，需要做好同步保证多线程运行结果正确。

2.由于同时在线人数大，从性能方面考虑，玩家的发红包请求不必及时响应，而由服务端定时执行发红包队列。

下面是主要的代码和实现逻辑说明

1.创建一个类，表示红包这个实体概念。直接采用原子变量保证增减同步。java的原子变量是一种精度更细的同步机制，在高度竞争的情况下，锁的性能将超过原子变量的性能，但在更真实的竞争情况，原子变量享有更好的性能。

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.采用多线程模拟多人同时抢红包。服务端将玩家发出的红包保存在一个队列里，然后用job定时将红包信息推送给玩家。每一批玩家的抢红包请求，其实操作的都是从队列中弹出的第一个红包元素，但当前的红包数量为空的时候，自动弹出下一个红包（如果有的话）。

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(){
 //防止多条线程同时弹出队首
 synchronized (queue) {//若没有加锁，打印的count总数不对！！！！
  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("没有了");
  return ;
  }
  if(obj !=null && obj.getgift().getanddecrement() >0 ){
  system.err.println("抢到一个红包");
  count.getandincrement();
  }
    thread.sleep(500);//模拟处理其他操作
 }catch(exception e){
  e.printstacktrace();
 }
 }
}

运行结果部分截图如下

需要注意的是，getgift()这个方法，由于是自动弹出队首元素，必须做好同步机制，否则，当多个请求同时操作某一个红包的最后一次剩余时，会造成总的红包数量不正确。

（将加锁的代码注释后，会发现打印的总数量有可能不正确了！）

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。