關(guān)于多級緩存使用(nginx本地緩存、JVM進(jìn)程緩存、redis緩存)

更新時(shí)間：2024年08月02日 09:17:58 作者：棲遲于一丘

這篇文章主要介紹了關(guān)于多級緩存使用(nginx本地緩存、JVM進(jìn)程緩存、redis緩存),具有很好的參考價(jià)值,希望對大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教

整體示意圖

1.nginx緩存

2.進(jìn)程緩存Caffeine示例

3.Lua語法(為了在nginx中做編程)

4.OpenResty

5.封裝向Tomcat發(fā)送的Http請求，獲取數(shù)據(jù)

封裝完函數(shù)之后，我們對nginx.conf進(jìn)行修改（請求進(jìn)來之后會(huì)去尋找item.lua）

item.lua文件內(nèi)容

上面的item.lua文件中需要進(jìn)行拼接數(shù)據(jù)，我們需要JSON結(jié)果處理

6.Tomcat集群的負(fù)載均衡

在實(shí)際生產(chǎn)中tomcat是肯定以集群的方式存在

當(dāng)我們修改nginx.conf發(fā)送請求為集群的時(shí)候，如下圖

這個(gè)時(shí)候存在一個(gè)問題，集群的負(fù)載均衡算法是輪詢，會(huì)導(dǎo)致tomcat進(jìn)程緩存產(chǎn)生浪費(fèi)，舉個(gè)例子

假如現(xiàn)在有兩臺Tomcat服務(wù)器，一臺端口為8080，一臺端口為8081
進(jìn)行訪問，查詢id為1的信息，第一次查詢8080端口的tomcat服務(wù)器，此時(shí)8080端口的tomcat服務(wù)器上有id為1信息的緩存，但是當(dāng)我們再次查詢id為1的信息，因?yàn)檩喸兊臋C(jī)制，會(huì)查詢8081端口的tomcat服務(wù)器，但是id為1的進(jìn)程緩存在8080端口的tomcat服務(wù)器上，并且進(jìn)程緩存在集群之間不會(huì)共享，這就導(dǎo)致會(huì)發(fā)生一種情況，有多少tomcat服務(wù)器，就會(huì)有多少份進(jìn)程緩存，這對資源是一種極大的浪費(fèi)

解決方法：

更換負(fù)載均衡算法為 hash $request_uri

這種負(fù)載均衡算法是通過對id值進(jìn)行hash運(yùn)算然后進(jìn)行對tomcat服務(wù)器數(shù)量取余來判斷訪問哪臺tomcat服務(wù)器，這樣就保證了同一個(gè)id訪問同一個(gè)tomcat服務(wù)器

7.redis緩存

兩個(gè)問題

緩存預(yù)熱代碼(邏輯代碼根據(jù)自己的更換即可)

public class CaffeineConfig implements InitializingBean {

    @Autowired
    private StringRedisTemplate redisTemplate;

    @Autowired
    private IItemService itemService;

    @Autowired
    private IItemStockService itemStockService;

    private static final ObjectMapper MAPPER = new ObjectMapper();

    @Override
    public void afterPropertiesSet() throws Exception {
        // 初始化緩存
        // 1.查詢商品信息
        List<Item> itemList = itemService.list();
        // 2.放入緩存
        for (Item item : itemList) {
            // 2.1 item序列化為JSON
            String json = MAPPER.writeValueAsString(item);
            // 2.2 存入redis
            redisTemplate.opsForValue().set("item:id:" + item.getId(),json);
        }
        
        // 3.查詢商品庫存信息
        List<ItemStock> stockList = itemStockService.list();
        // 2.放入緩存
        for (ItemStock stock : stockList) {
            // 2.1 item序列化為JSON
            String json = MAPPER.writeValueAsString(stock);
            // 2.2 存入redis
            redisTemplate.opsForValue().set("item:stock:id:" + stock.getId(),json);
        }
    }
}

API簡介

InitializingBean