码迷,mamicode.com
首页 > 编程语言 > 详细

java中应对高并发的两种策略

时间:2019-09-13 17:50:51      阅读:120      评论:0      收藏:0      [点我收藏+]

标签:入口   java   private   实现   简单的   object   处理   mit   rup   

目的:提高可用性

通过ExecutorService实现队列泄洪

//含有20个线程的线程池
private ExecutorService executorService = Executors.newFixedThreadPool(20);

将有并发压力的下游代码放入到线程池的submit方法中,如下:

//同步调用线程池的submit方法 简单实现 拥塞窗口为20的队列泄洪(一个服务器同一时间只能处理20个请求,其他请求队列等待)
Future<Object> future = executorService.submit(new Callable<Object>() {
@Override
public Object call() throws Exception {
//此处调用下游有并发压力的接口
return null;
}
});
try {
future.get();
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}

 

通过Guava RateLimit 负载均衡的情况下,在单机内部实现限流

需要加入Guava依赖

<dependency>
    <groupId>com.google.guava</groupId>
    <artifactId>guava</artifactId>
    <version>18.0</version>
  </dependency>

 

private RateLimiter rateLimiter = RateLimiter.create(300);//限制300tps

在方法入口内加上以下代码:

    //入口处限流
        if(!rateLimiter.tryAcquire()){
            //抛出异常;
        }

 

最后:

这里只简单描述了如何最简单的使用,降低高并发对系统的压力,没有剖析内部源码实现,望谅解

java中应对高并发的两种策略

标签:入口   java   private   实现   简单的   object   处理   mit   rup   

原文地址:https://www.cnblogs.com/wuba/p/11516985.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!