java中应对高并发的两种策略
Posted wuba
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了java中应对高并发的两种策略相关的知识,希望对你有一定的参考价值。
目的:提高可用性
通过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中应对高并发的两种策略的主要内容,如果未能解决你的问题,请参考以下文章