java固定大小隊(duì)列的幾種實(shí)現(xiàn)方式詳解
前言
最近團(tuán)隊(duì)有同學(xué)在開發(fā)中,遇到一個(gè)需求,統(tǒng)計(jì)最近10次的異常次數(shù),咨詢有沒有類似的list。針對(duì)這個(gè)問題,記錄一下幾種處理方式。
基于Hutool中的FixedLinkedHashMap
引入maven依賴
<dependency> <groupId>cn.hutool</groupId> <artifactId>hutool-all</artifactId> <version>5.4.0</version> </dependency>
使用示例
// 初始化時(shí)指定大小 private final FixedLinkedHashMap<String, Integer> fixedLinkedHashMap = new FixedLinkedHashMap<>(LIST_SIZE); // 其余寫入和讀取操作同LinkedHashMap類似 // 對(duì)于key,可以按照自己的業(yè)務(wù)需求填寫 fixedLinkedHashMap.put(UUID.randomUUID().toString(), 1); // 讀取操作 // 獲取元素個(gè)數(shù) long size = fixedLinkedHashMap.values().size(); // 統(tǒng)計(jì)其中的總和 int sum = fixedLinkedHashMap.values().stream().mapToInt(value -> value).sum();
基于Guava的EvictingQueue
引入maven依賴
<dependency> <groupId>com.google.guava</groupId> <artifactId>guava</artifactId> <version>30.1.1-jre</version> </dependency>
使用示例
// 初始化時(shí)指定大小 private final EvictingQueue<Integer> evictingQueue = EvictingQueue.create(LIST_SIZE); // 添加元素 evictingQueue.add(MOCK_EXCEPTION_COUNT); // 讀取元素 // 元素個(gè)數(shù) size = evictingQueue.size(); // 統(tǒng)計(jì)其中的和 sum = evictingQueue.stream().mapToInt(value -> value).sum();
注意: 引入了目前(2021-07-12)最新的guava版本30.1.1-jre,EvictingQueue類還是標(biāo)記了@Beta。
基于Redis的list操作
示例在SpringBoot應(yīng)用中,使用RedisTemplate。
主要基于Redis列表的三個(gè)操作。
- LPUSH:將元素插入頭部
- LTRIM: 對(duì)列表進(jìn)行裁剪,可以指定起始位置
- LRANGE: 獲取列表指定范圍內(nèi)的元素
引入maven依賴
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> </dependency>
使用示例
// 初始化RedisTemplate @Resource private RedisTemplate<String, Integer> redisTemplate; ListOperations<String, Integer> stringIntegerListOperations = redisTemplate.opsForList(); // LPUSH操作 stringIntegerListOperations.leftPush(REDIS_LIST_KEY, MOCK_EXCEPTION_COUNT); // LTRIM stringIntegerListOperations.trim(REDIS_LIST_KEY, 0, LIST_SIZE - 1); // LRANGE操作 List<Integer> range = stringIntegerListOperations.range(REDIS_LIST_KEY, 0, LIST_SIZE - 1); // 對(duì)結(jié)果操作 size = range.size(); sum = range.stream().mapToInt(value -> value).sum();
完整示例
@Service
@Slf4j
public class FixedListScheduler {
private static final int LIST_SIZE = 10;
private static final int MOCK_EXCEPTION_COUNT = 1;
private static final String REDIS_LIST_KEY = "redis_fixed_list";
private final FixedLinkedHashMap<String, Integer> fixedLinkedHashMap = new FixedLinkedHashMap<>(LIST_SIZE);
private final EvictingQueue<Integer> evictingQueue = EvictingQueue.create(LIST_SIZE);
@Resource
private RedisTemplate<String, Integer> redisTemplate;
@Scheduled(cron = "*/1 * * * * ?")
public void schedule() {
fixedLinkedHashMap.put(UUID.randomUUID().toString(), MOCK_EXCEPTION_COUNT);
long size = fixedLinkedHashMap.values().size();
int sum = fixedLinkedHashMap.values().stream().mapToInt(value -> value).sum();
log.info("fixedLinkedHashMap size:{}, sum:{}", size, sum);
evictingQueue.add(MOCK_EXCEPTION_COUNT);
size = evictingQueue.size();
sum = evictingQueue.stream().mapToInt(value -> value).sum();
log.info("evictingQueue size:{}, sum:{}", size, sum);
ListOperations<String, Integer> stringIntegerListOperations = redisTemplate.opsForList();
stringIntegerListOperations.leftPush(REDIS_LIST_KEY, MOCK_EXCEPTION_COUNT);
stringIntegerListOperations.trim(REDIS_LIST_KEY, 0, LIST_SIZE - 1);
List<Integer> range = stringIntegerListOperations.range(REDIS_LIST_KEY, 0, LIST_SIZE - 1);
if (!CollectionUtils.isEmpty(range)) {
sum = range.stream().mapToInt(value -> value).sum();
log.info("redis FixedList size:{}, sum:{}", range.size(), sum);
}
}
}
程序啟動(dòng)一段時(shí)間后的日志,可以看到是滿足要求的。
2021-07-12 18:35:29.006 INFO 8622 --- [pool-2-thread-1] com.yichao.myblogs.FixedListScheduler : evictingQueue size:10, sum:10
2021-07-12 18:35:29.009 INFO 8622 --- [pool-2-thread-1] com.yichao.myblogs.FixedListScheduler : redis FixedList size:10, sum:10
2021-07-12 18:35:30.002 INFO 8622 --- [pool-2-thread-1] com.yichao.myblogs.FixedListScheduler : fixedLinkedHashMap size:10, sum:10
2021-07-12 18:35:30.002 INFO 8622 --- [pool-2-thread-1] com.yichao.myblogs.FixedListScheduler : evictingQueue size:10, sum:10
2021-07-12 18:35:30.005 INFO 8622 --- [pool-2-thread-1] com.yichao.myblogs.FixedListScheduler : redis FixedList size:10, sum:10
2021-07-12 18:35:31.005 INFO 8622 --- [pool-2-thread-1] com.yichao.myblogs.FixedListScheduler : fixedLinkedHashMap size:10, sum:10
2021-07-12 18:35:31.005 INFO 8622 --- [pool-2-thread-1] com.yichao.myblogs.FixedListScheduler : evictingQueue size:10, sum:10
2021-07-12 18:35:31.008 INFO 8622 --- [pool-2-thread-1] com.yichao.myblogs.FixedListScheduler : redis FixedList size:10, sum:10
2021-07-12 18:35:32.005 INFO 8622 --- [pool-2-thread-1] com.yichao.myblogs.FixedListScheduler : fixedLinkedHashMap size:10, sum:10
2021-07-12 18:35:32.005 INFO 8622 --- [pool-2-thread-1] com.yichao.myblogs.FixedListScheduler : evictingQueue size:10, sum:10
2021-07-12 18:35:32.009 INFO 8622 --- [pool-2-thread-1] com.yichao.myblogs.FixedListScheduler : redis FixedList size:10, sum:10
2021-07-12 18:35:33.002 INFO 8622 --- [pool-2-thread-1] com.yichao.myblogs.FixedListScheduler : fixedLinkedHashMap size:10, sum:10
2021-07-12 18:35:33.002 INFO 8622 --- [pool-2-thread-1] com.yichao.myblogs.FixedListScheduler : evictingQueue size:10, sum:10
2021-07-12 18:35:33.005 INFO 8622 --- [pool-2-thread-1] com.yichao.myblogs.FixedListScheduler : redis FixedList size:10, sum:10
總結(jié)
以上三種方式均可實(shí)現(xiàn)固定長(zhǎng)度的list。FixedLinkedHashMap和EvictingQueue是基于內(nèi)存的,所以僅支持節(jié)點(diǎn)情況。而基于Redis的list除了單節(jié)點(diǎn)情況,同樣可以在分布式情況使用。
到此這篇關(guān)于java固定大小隊(duì)列的文章就介紹到這了,更多相關(guān)java固定大小隊(duì)列內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
Nacos配置中心搭建及動(dòng)態(tài)刷新配置及踩坑記錄
這篇文章主要介紹了Nacos配置中心搭建及動(dòng)態(tài)刷新配置及踩坑記錄,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2022-11-11
靈活控制任務(wù)執(zhí)行時(shí)間的Cron表達(dá)式范例
這篇文章主要為大家介紹了靈活控制任務(wù)執(zhí)行時(shí)間的Cron表達(dá)式范例,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2023-10-10
如何使用Gradle實(shí)現(xiàn)類似Maven的profiles功能
這篇文章主要介紹了如何使用Gradle實(shí)現(xiàn)類似Maven的profiles功能,本文通過實(shí)例代碼給大家介紹的非常詳細(xì),感興趣的朋友跟隨小編一起看看吧2024-06-06
Java中的字符型文件流FileReader和FileWriter詳細(xì)解讀
這篇文章主要介紹了Java中的字符型文件流FileReader和FileWriter詳細(xì)解讀,與字節(jié)型文件流不同,字節(jié)型文件流讀取和寫入的都是一個(gè)又一個(gè)的字節(jié),而字符型文件流操作的單位是一個(gè)又一個(gè)的字符,字符型流認(rèn)為一個(gè)字母是一個(gè)字符,而一個(gè)漢字也是一個(gè)字符,需要的朋友可以參考下2023-10-10
SpringBoot項(xiàng)目中的視圖解析器問題(兩種)
SpringBoot官網(wǎng)推薦使用HTML視圖解析器,但是根據(jù)個(gè)人的具體業(yè)務(wù)也有可能使用到JSP視圖解析器,所以本文介紹了兩種視圖解析器,感興趣的可以了解下2020-06-06
springboot+camunda實(shí)現(xiàn)工作流的流程分析
Camunda是基于Java語(yǔ)言,支持BPMN標(biāo)準(zhǔn)的工作流和流程自動(dòng)化框架,并且還支持CMMN規(guī)范,DMN規(guī)范,本文給大家介紹springboot+camunda實(shí)現(xiàn)工作流的流程分析,感興趣的朋友一起看看吧2021-12-12
Java代理模式(Proxy)實(shí)現(xiàn)方法詳解
這篇文章主要介紹了Java代理模式(Proxy)實(shí)現(xiàn)的相關(guān)資料,代理模式是一種結(jié)構(gòu)型設(shè)計(jì)模式,通過引入代理對(duì)象來控制對(duì)目標(biāo)對(duì)象的訪問,代理模式的優(yōu)點(diǎn)包括職責(zé)清晰、擴(kuò)展性好、保護(hù)目標(biāo)對(duì)象和增強(qiáng)功能,文中通過代碼介紹的非常詳細(xì),需要的朋友可以參考下2025-04-04

