tio-boot?jfinal-plugins框架整合redis示例詳解

更新時間：2023年12月27日 08:54:16 作者：李通

這篇文章主要為大家介紹了tio-boot?jfinal-plugins框架整合redis示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪

jfinal-plugins

tio-boot 是一個基于Java的網(wǎng)絡(luò)編程框架，用于快速開發(fā)高性能的網(wǎng)絡(luò)應(yīng)用程序。

redis 是一個廣泛使用的開源緩存服務(wù)，它可以提高應(yīng)用程序的性能和擴展性。

整合ecache需要用到j(luò)final-plugins

https://central.sonatype.com/artifact/com.litongjava/jfinal-p...

添加依賴

<properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <java.version>1.8</java.version>
    <maven.compiler.source>${java.version}</maven.compiler.source>
    <maven.compiler.target>${java.version}</maven.compiler.target>
    <graalvm.version>23.1.1</graalvm.version>
    <tio.boot.version>1.2.9</tio.boot.version>
    <lombok-version>1.18.30</lombok-version>
    <hotswap-classloader.version>1.2.1</hotswap-classloader.version>
    <final.name>web-hello</final.name>
    <main.class>com.litongjava.tio.web.hello.HelloApp</main.class>
  </properties>
  <dependencies>
    <dependency>
      <groupId>com.litongjava</groupId>
      <artifactId>tio-boot</artifactId>
      <version>${tio.boot.version}</version>
    </dependency>
    <dependency>
      <groupId>org.projectlombok</groupId>
      <artifactId>lombok</artifactId>
      <version>${lombok-version}</version>
      <optional>true</optional>
      <scope>provided</scope>
    </dependency>
    <dependency>
      <groupId>com.litongjava</groupId>
      <artifactId>hotswap-classloader</artifactId>
      <version>${hotswap-classloader.version}</version>
    </dependency>
    <dependency>
      <groupId>com.litongjava</groupId>
      <artifactId>jfinal-plugins</artifactId>
      <version>1.0.0</version>
    </dependency>
    <dependency>
      <groupId>com.jfinal</groupId>
      <artifactId>activerecord</artifactId>
      <version>5.1.2</version>
    </dependency>
  </dependencies>

依賴解釋

tio-boot是框架核心，
jfinal-plugins提供與Ehcache的集成
activerecord jfinal-plugins依賴jfinal-plugins

jfinal-plugins依賴如下

cron4j:2.2.5
ehcache-core:2.6.11
jedis:3.6.3
fst:2.57

RedisPluginConfig 配置類

這個類是一個配置類，用于初始化和配置 Redis 插件。它通過 @Configuration 注解標記為配置類。類中的方法 redisPlugin 通過 @Initialization 注解標記為初始化方法。在這個方法中，創(chuàng)建了一個 RedisPlugin 實例并啟動它。啟動插件意味著 RedisPlugin 將連接redis服務(wù)

package com.litongjava.tio.web.hello.config;
import com.litongjava.jfinal.aop.annotation.Configuration;
import com.litongjava.jfinal.aop.annotation.Initialization;
import com.litongjava.jfinal.plugin.redis.Redis;
import com.litongjava.jfinal.plugin.redis.RedisPlugin;
@Configuration
public class RedisPluginConfig {
  @Initialization
  public void redisPlugin() {
    // 用于緩存bbs模塊的redis服務(wù)
    RedisPlugin bbsRedis = new RedisPlugin("bbs", "localhost");
    bbsRedis.start();
    // 測試連接
    Redis.use("bbs").getJedis().connect();
  }
}

控制器

RedisTestController 包含三個方法，每個方法都演示了如何使用Redis進行不同類型的操作。以下是對每個方法的詳細解釋：

1. test01() 方法 - 基本的 Redis 緩存操作

目的: 演示了如何使用Redis進行基本的緩存操作。
過程:
- 使用 Redis.use("bbs") 獲取名為 "bbs" 的 Redis 緩存實例。
- 試圖使用鍵 "litong" 從緩存中獲取值。
- 如果值不存在（即 null），記錄一條日志（表示需要計算新的值），并將一個新值 "value___001" 設(shè)置到這個鍵中。
- 返回緩存中的值（如果是首次調(diào)用，將返回 null，因為設(shè)置值是在檢查之后）。

2. test02() 方法 - 使用 Redis.call 方法

目的: 演示了如何使用 Redis.call 方法執(zhí)行更復雜的Redis操作。
過程:
- 使用 Redis.call 方法執(zhí)行一個 lambda 表達式，它使用 jedis 客戶端從 Redis 中獲取鍵為 "user" 的值。
- 將獲取的JSON字符串解析為 User 類的實例。
- 如果未找到用戶（即 user 為 null），記錄一條日志，并創(chuàng)建一個新的 User 實例。
- 使用 Redis.call 再次將新的 User 實例以JSON格式保存到 Redis 中。
- 返回 User 對象。

3. test03() 方法 - 調(diào)用 Jedis API

目的: 演示如何直接調(diào)用 Jedis API 進行Redis操作。
過程:
- 使用 Redis.call 方法執(zhí)行一個 lambda 表達式，該表達式調(diào)用 j.incrBy 方法增加 "increase" 鍵的值。
- j.incrBy("increase", 1) 表示將 "increase" 鍵的值增加1。
- 返回增加后的值。

package com.litongjava.tio.web.hello.controller;
import com.alibaba.fastjson2.JSON;
import com.litongjava.jfinal.plugin.redis.Cache;
import com.litongjava.jfinal.plugin.redis.Redis;
import com.litongjava.tio.http.server.annotation.RequestPath;
import com.litongjava.tio.web.hello.model.User;
import lombok.extern.slf4j.Slf4j;
@Slf4j
@RequestPath("/redis/test")
public class RedisTestController {
  /**
   * 測試redis
   * @return
   */
  public Object test01() {
    String cacheKey = "litong";
    Cache bbsCache = Redis.use("bbs");
    Object value = bbsCache.get(cacheKey);
    if (value == null) {
      log.info("計算新的值");
      bbsCache.set(cacheKey, "value___001");
    }
    return value;
  }
  /**
   * 使用Redis.call方法
   * @return
   */
  public User test02() {
    User user = Redis.call(jedis -> {
      String userJsonString = jedis.get("user");
      return JSON.parseObject(userJsonString, User.class);
    });
    if (user == null) {
      log.info("重新計算user");
      User user1 = new User("ping", "00000000");
      user = user1;
      // 或者簡化為下面代碼
      Redis.call(j -> {
        return j.set("user", JSON.toJSONString(user1));
      });
    }
    return user;
  }
  /**
   * 調(diào)用Jedis API
   * @return
   */
  public Long test03() {
    Long ret = Redis.call(j -> j.incrBy("increase", 1));
    return ret;
  }
}

訪問測試