java web如何解决瞬间高并发

1、任何的高并发，请求总是会有一个顺序的

2、java的队列的数据结构是先进先出的取值顺序

3、BlockingQueue类(线程安全)（使用方法可以百度）

一般使用LinkedBlockingQueue

利用以上几点，我们可以把高并发时候的请求放入一个队列，队列的大小可以自己定义，比如队列容量为1000个数据，那么可以利用过滤器或者拦截器把当前的请求放入队列，如果队列的容量满了，其余的请求可以丢掉或者作出相应回复

具体实施：

利用生产者、消费者模型：

将队列的请求一一处理完。

 上代码：

/**
 * @author fuguangli
 * @description 前沿消费者类
 * @Create date:  2017/3/7
 * @using  EXAMPLE
 */
public class Customer implements Runnable{


  /**
   *     抛出异常  特殊值    阻塞     超时
   插入    add(e)  offer(e)  put(e)  offer(e, time, unit)
   移除    remove()  poll()  take()  poll(time, unit)
   检查    element()  peek()  不可用  不可用

   */
  private BlockingQueue blockingQueue;
  private AtomicInteger count = new AtomicInteger();
  public Customer(BlockingQueue blockingQueue) {
    this.blockingQueue = blockingQueue;
  }

  /**
   * When an object implementing interface <code>Runnable</code> is used
   * to create a thread, starting the thread causes the object's
   * <code>run</code> method to be called in that separately executing
   * thread.
   * <p/>
   * The general contract of the method <code>run</code> is that it may
   * take any action whatsoever.
   *
   * @see Thread#run()
   */
  @Override
  public void run() {
    System.out.println("消费者线程启动...");
    LockFlag.setCustomerRunningFlag(true);
    try {
      while (LockFlag.getProducerRunningFlag()){
        System.out.println(Thread.currentThread().getId()+"I'm Customer.Queue current size="+blockingQueue.size());
        String data = (String) blockingQueue.poll(10, TimeUnit.SECONDS);
        if(data!=null){
          System.out.println(Thread.currentThread().getId()+"*************正在消费数据 data="+data);
        }else{
          //表示超过取值时间，视为生产者不再生产数据
          System.out.println(Thread.currentThread().getId()+"队列为空无数据，请检查生产者是否阻塞");
        }
        Thread.sleep(50);
      }
      System.err.println("消费者程序执行完毕");
    } catch (InterruptedException e) {
      e.printStackTrace();
      System.err.println("消费者程序退出");
      LockFlag.setCustomerRunningFlag(false);//异常退出线程
      Thread.currentThread().interrupt();
    }
  }
}

package com.qysxy.framework.queue;

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;

/**
 * @author fuguangli
 * @description 队列生产者类
 * @Create date:  2017/3/7
 * @using    EXAMPLE
 */
public class Producer implements Runnable{


  /**
   *     抛出异常  特殊值    阻塞     超时
   插入  add(e)  offer(e)  put(e)  offer(e, time, unit)
   移除  remove()  poll()  take()  poll(time, unit)
   检查  element()  peek()  不可用  不可用

   */
  private BlockingQueue blockingQueue;
  private AtomicInteger count = new AtomicInteger();
  public Producer(BlockingQueue blockingQueue) {
    this.blockingQueue = blockingQueue;
  }

  /**
   * When an object implementing interface <code>Runnable</code> is used
   * to create a thread, starting the thread causes the object's
   * <code>run</code> method to be called in that separately executing
   * thread.
   * <p/>
   * The general contract of the method <code>run</code> is that it may
   * take any action whatsoever.
   *
   * @see Thread#run()
   */
  @Override
  public void run() {
    System.out.println("生产者线程启动...");
    LockFlag.setProducerRunningFlag(true);
    try {
      while (LockFlag.getProducerRunningFlag()){
        String data = "data:"+count.incrementAndGet();
        if(blockingQueue.offer(data,10, TimeUnit.SECONDS)){
          //返回true表示生产数据正确
          System.out.println("^^^^^^^^^^^^^^正在生产数据 data="+data);
        }else {
          //表示阻塞时间内还没有生产者生产数据
          System.out.println("生产者异常，无法生产数据");
        }
        Thread.sleep(50);

      }
    } catch (InterruptedException e) {
      e.printStackTrace();
      System.err.println("生产者程序退出");
      LockFlag.setProducerRunningFlag(false);//异常退出线程
      Thread.currentThread().interrupt();
    }
  }
}

package com.qysxy.framework.queue;

/**
 * @author fuguangli
 * @description 前沿生产者消费者模型的锁类
 * @Create date:  2017/3/7
 */
public class LockFlag {
  /**
   * 生产者互斥锁
   */
  private static Boolean producerRunningFlag = false;
  /**
   * 消费者互斥锁
   */
  private static Boolean customerRunningFlag = false;

  public static Boolean getProducerRunningFlag() {
    return producerRunningFlag;
  }

  public static void setProducerRunningFlag(Boolean producerRunningFlag) {
    LockFlag.producerRunningFlag = producerRunningFlag;
  }

  public static Boolean getCustomerRunningFlag() {
    return customerRunningFlag;
  }

  public static void setCustomerRunningFlag(Boolean customerRunningFlag) {
    LockFlag.customerRunningFlag = customerRunningFlag;
  }
}

package com.qysxy.framework.queue;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.util.Queue;
import java.util.concurrent.*;

/**
 * @author fuguangli
 * @description 前沿队列实用类，用于大量并发用户
 * @Create date:  2017/3/7
 */
public class BlockingQueueHelper {


  private static final Integer maxQueueSize = 1000;
  private static BlockingQueue blockingQueue = new LinkedBlockingQueue(maxQueueSize);
  private static ExecutorService threadPool = Executors.newCachedThreadPool();


  public static BlockingQueue getBlockingQueue() {
    if (blockingQueue == null) {
      blockingQueue = new LinkedBlockingQueue(maxQueueSize);
    }
    return blockingQueue;
  }

  /**
   * @param o 队列处理对象（包含request,response,data）
   */
  public static void requestQueue(Object o) {
    //检测当前的队列大小
    if (blockingQueue != null && blockingQueue.size() < maxQueueSize) {
      //可以正常进入队列
      if (blockingQueue.offer(o)) {
        //添加成功，检测数据处理线程是否正常
        if (LockFlag.getCustomerRunningFlag()) {
          //说明处理线程类正常运行
        } else {
          //说明处理线程类停止，此时，应重新启动线程进行数据处理
          LockFlag.setCustomerRunningFlag(true);

          //example:run
          Customer customer = new Customer(blockingQueue);
          threadPool.execute(customer);

        }

      } else {
        //进入队列失败，做出相应的处理，或者尝试重新进入队列

      }
    } else {
      //队列不正常，或队列大小已达上限，做出相应处理

    }

  }
}

好了，这时候，利用过滤器或者拦截器将每个请求封装成队列元素进行处理就行。

当然了，对于多应用服务器的部署架构来说，数据库也需要加锁，数据库隔离级别下篇再说。

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

# java  # web  # 瞬间高并发  # 深入了解java NIO之Selector（选择器）  # Java NIO Selector用法详解【含多人聊天室实例】  # JAVA代码设置selector不同状态下的背景颜色  # java的多线程高并发详解  # 详解java解决分布式环境中高并发环境下数据插入重复问题  # java web在高并发和分布式下实现订单号生成唯一的解决方案  # java高并发锁的3种实现示例代码  # java高并发写入用户信息到数据库的几种方法  # Java 高并发九：锁的优化和注意事项详解  # Java进阶之高并发核心Selector详解  # 不可用  # 数据处理  # 抛出  # 移除  # 还没有  # 会有  # 好了  # 互斥  # 拦截器  # 我们可以  # 时间内  # 就行  # 数据结构  # 几点  # 满了  # 不正常  # 已达  # 重新启动  # 可以利用  # 正常运行 

相关文章： 如何通过VPS建站实现广告与增值服务盈利？  如何用花生壳三步快速搭建专属网站？  制作旅游网站html,怎样注册旅游网站？  详解ASP.NET 生成二维码实例（采用ThoughtWorks.QRCode和QrCode.Net两种方式）  北京营销型网站制作公司,可以用python做一个营销推广网站吗？  陕西网站制作公司有哪些,陕西凌云电器有限公司官网？  如何快速搭建高效简练网站？  建站主机无法访问？如何排查域名与服务器问题  在线流程图制作网站手机版,谁能推荐几个好的CG原画资源网站么？  如何挑选高效建站主机与优质域名？  c++怎么实现高并发下的无锁队列_c++ std::atomic原子变量与CAS操作【详解】  广平建站公司哪家专业可靠？如何选择？  深圳防火门网站制作公司,深圳中天明防火门怎么编码？  淘宝制作网站有哪些,淘宝网官网主页？  如何选择服务器才能高效搭建专属网站？  网站制作多少钱一个,建一个论坛网站大约需要多少钱？  公众号网站制作网页,微信公众号怎么制作？  弹幕视频网站制作教程下载,弹幕视频网站是什么意思？  成都网站制作报价公司,成都工业用气开户费用？  详解免费开源的.NET多类型文件解压缩组件SharpZipLib（.NET组件介绍之七）  专业公司网站制作公司,用什么语言做企业网站比较好？  网站专业制作公司有哪些,做一个公司网站要多少钱？  XML的“混合内容”是什么 怎么用DTD或XSD定义  如何在Tomcat中配置并部署网站项目？  正规网站制作公司有哪些,目前国内哪家网页网站制作设计公司比较专业靠谱？口碑好？  PHP正则匹配日期和时间(时间戳转换)的实例代码  制作网站的软件下载免费,今日头条开宝箱老是需要下载怎么回事？  西安制作网站公司有哪些,西安货运司机用的最多的app或者网站是什么？  用v-html解决Vue.js渲染中html标签不被解析的问题  车管所网站制作流程,交警当场开简易程序处罚决定书，在交警网站查询不到怎么办？  C#如何使用XPathNavigator高效查询XML  企业在线网站设计制作流程,想建设一个属于自己的企业网站，该如何去做？  javascript中对象的定义、使用以及对象和原型链操作小结  网站制作的软件有哪些,制作微信公众号除了秀米还有哪些比较好用的平台？  定制建站模板如何实现SEO优化与智能系统配置？18字教程  建站之星价格显示格式升级，你的预算足够吗？  宝塔建站后网页无法访问如何解决？  Swift中switch语句区间和元组模式匹配  ,怎么在广州志愿者网站注册？  制作网站的软件免费下载,免费制作app哪个平台好？  高防服务器租用如何选择配置与防御等级？  建站之星安装后如何配置SEO及设计样式？  江苏网站制作公司有哪些,江苏书法考级官方网站？  如何在沈阳梯子盘古建站优化SEO排名与功能模块？  如何快速选择适合个人网站的云服务器配置？  建站之星2.7模板：企业网站建设与h5定制设计专题  寿县云建站：智能SEO优化与多行业模板快速上线指南  ,制作一个手机app网站要多少钱？  定制建站价位费用解析与套餐推荐全攻略  建站主机选购指南与交易推荐：核心配置解析