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

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

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

整體示意圖

1.nginx緩存

2.進程緩存Caffeine示例

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

4.OpenResty

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

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

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

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

6.Tomcat集群的負載均衡

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

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

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

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

解決方法：

更換負載均衡算法為 hash $request_uri

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

7.redis緩存

兩個問題

緩存預(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