Netty处理HTTP请求(Netty Handle HTTP requests)

 基本上BlockingQueues使用锁来确保数据的一致性并避免数据丢失，因此在太高的并发环境中它会拒绝许多任务（您的情况）。 
 
 您可以使用RejectedExecutionHandler实现在trunk上播放以重试提供任务。 一种实现可以是： 
 
new RejectedExecutionHandler() {
        @Override
        public void rejectedExecution(final Runnable r, final ThreadPoolExecutor executor) {
            for (int i = 0; i < 10; i++) {
                if (executor.getQueue().offer(r)) {
                    return;
                }

                try {
                    Thread.sleep(50);
                } catch (final InterruptedException e) {
                    // no-op
                }
            }
            throw new RejectedExecutionException();
        }
    }
 
 随机睡眠（在最小和最大之间）它甚至可以更好地工作。 
 
 这个想法基本上是：如果队列已满，请等待一段时间以减少并发性。 

Basically BlockingQueues use locks to ensure the consistency of data and avoid data loss, so in too highly concurrent environment it will reject a lot of tasks (your case).
 
You can play on trunk with the RejectedExecutionHandler implementation to retry to offer the task. One implementation can be:
 
new RejectedExecutionHandler() {
        @Override
        public void rejectedExecution(final Runnable r, final ThreadPoolExecutor executor) {
            for (int i = 0; i < 10; i++) {
                if (executor.getQueue().offer(r)) {
                    return;
                }

                try {
                    Thread.sleep(50);
                } catch (final InterruptedException e) {
                    // no-op
                }
            }
            throw new RejectedExecutionException();
        }
    }
 
It even works better with random sleep (between min and max).
 
The idea is basically: if the queue is full, wait some short time to reduce the concurrency.