我们知道,在前台为了提高用户体验度,在很多情况下都会去用ajax发异步处理一些请求,比如用户登录,注册等等.最近在做的项目中,在后台也老用到异步处理一些数据,比如当注册用户过多,一般我们的数据连接池里面就的数据连接是固定,当用户需要的连接数大于我们数据连接池所支持的数据连接数时,就会出现阻塞这种情况,用户就会感觉很慢,我们可以先返回一个消息给用户说他注册成功,然后我们异步处理,将用户的注册信息插入到数据库中.这样给用户的体验效果会好一点(这只是举个例子,当然在实际操作中我们这样做的情况很少,因为的话当返回给用户提示信息的时候,用户去登录却登录不上.)，注册信息过多。。。

1.我们异步处理后台信息有两个方法 当并发量不是很高的时候 我们可以在后台起一个定时任务（ScheduledTaskExecutorFactory.getScheduledTaskExecutor().scheduleWithFixedDelay）

2.当我们并发量高的时候 我们就要用到队列了

首先 我们先创建一个队列

private static final Logger log = LoggerFactory.getLogger(PushMessageBean.class);

    private static final int PUSH_MESSAGE_QUEUE_SIZE = 10;

    private BlockingQueue<PushMessage> messagequeue = new ArrayBlockingQueue<PushMessage>(PUSH_MESSAGE_QUEUE_SIZE);

然后 我们把数据加入队列

    /**

     * 外部放入

     * 

     * @param syncDetail

     */

    public void putQueue(PushMessage pushMessage) {

        while (!messagequeue.offer(pushMessage)) {

            log.debug("PushMessage的queue满了，请求插入");

            ScheduledTaskExecutorFactory.getScheduledTaskExecutor().execute(new QueueInsertTask(messagequeue));

        }

    }

最后我们对队列中的数据进行操作

当然 为了能够达到最好的同步效果 我们最好也起一个定时任务

   public void initialize() {

        // 定时的去清理queue中的数据，入库

        ScheduledTaskExecutorFactory.getScheduledTaskExecutor().scheduleWithFixedDelay(

                new QueueInsertTask(messagequeue), 10, 10, TimeUnit.SECONDS);

    }