zxl
2026-03-25 74e332504d98caaf8fab951d7d24be762b169f49
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
package com.tievd.jyz.cache;
 
import com.google.common.cache.Cache;
import com.google.common.cache.CacheBuilder;
import com.tievd.jyz.mqtt.dto.MqttParamDTO;
 
import java.util.Map;
import java.util.concurrent.TimeUnit;
 
public class EventCodeResourceCache {
 
    /** 图片临时缓存,用于事件还未生成时,接收到图片
     * eventCode:oilRecordId */
    private final static Cache<String, MqttParamDTO>
            EVENT_CODE_RESOURCE_CACHE_MAP = CacheBuilder.newBuilder().expireAfterWrite(10, TimeUnit.MINUTES).build();
    
    
    
    /**
     * 压入
     */
    public static void put(String eventCode, MqttParamDTO data){
        EVENT_CODE_RESOURCE_CACHE_MAP.put(eventCode, data);
    }
 
    /**
     * 获取
     * @param eventCode
     * @return
     */
    public static MqttParamDTO get(String eventCode){
        return EVENT_CODE_RESOURCE_CACHE_MAP.getIfPresent(eventCode);
    }
 
    /**
     * 移除
     * @param eventCode
     * @return
     */
    public static void remove(String eventCode){
        EVENT_CODE_RESOURCE_CACHE_MAP.invalidate(eventCode);
    }
    
    public static Map<String, MqttParamDTO> asMap() {
        return EVENT_CODE_RESOURCE_CACHE_MAP.asMap();
    }
    
}