コミュニティ 学ぶ ツールライブラリ レジャー
検索
日本語
ホームページ > Java > ＆＃＆チュートリアル > Java Redisの使用シナリオの分析

Java Redisの使用シナリオの分析

王林
リリース： 2023-05-09 13:07:17
転載
968 人が閲覧しました

1. キャッシュとして

1.1 使用する理由

データはメモリに保存され、データ クエリの速度が高速です。データベースのプレッシャーを共有できます。

Java Redisの使用シナリオの分析

1.2 キャッシュに入れるのに適したデータの種類

クエリの頻度は比較的高く、変更の頻度は比較的低いです。

セキュリティ係数の低いデータ

1.3 Redis をキャッシュとして使用する

1.3.1 構成クラスは使用しない

エンティティ クラスはシリアル化する必要があることに注意してください: 

@Data
@AllArgsConstructor
@NoArgsConstructor
@TableName(value = "tb_dept")
public class Dept implements Serializable {
    @TableId(value = "id",type = IdType.AUTO)
    private Integer id;
    private String name;
    private String realname;
}
ログイン後にコピー

対応する依存関係: 

 <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-redis</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!--连接数据源-->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jdbc</artifactId>
        </dependency>
        <!--mp的依赖-->
        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>mybatis-plus-boot-starter</artifactId>
            <version>3.4.2</version>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>
ログイン後にコピー

コントローラー層対応コード: 

@RestController
@RequestMapping("order")
public class DeptController {
    @Resource
    private DeptService deptService;
    @GetMapping("getById/{id}")
    //order/getById/1
    //{}可以放多个，由下面的传参函数对应
    //@PathVariable:获取请求映射中{}的值
    public Dept getById(@PathVariable Integer id){
        return deptService.findById(id);
    }
    @GetMapping("deleteById/{id}")
    public String deleteById(@PathVariable Integer id){
        int i = deptService.deleteById(id);
        return i>0?"删除成功":"删除失败";
    }
    @GetMapping("insert")
    public Dept insert(Dept dept){
        Dept insert = deptService.insert(dept);
        return insert;
    }
    @GetMapping("update")
    public Dept update(Dept dept){
        Dept update = deptService.update(dept);
        return update;
    }
}
ログイン後にコピー

サービス層対応コード: 

@Service
public class DeptService {
    @Resource
    private DeptMapper deptMapper;
    //当存储的value类型为对象类型使用redisTemplate
    //存储的value类型为字符串。StringRedisTemplate
    @Autowired
    private RedisTemplate redisTemplate;
    //业务代码
    public Dept findById(Integer id){
        ValueOperations forValue = redisTemplate.opsForValue();
        //查询缓存
        Object o = forValue.get("dept::" + id);
        //缓存命中
        if(o!=null){
            return (Dept) o;
        }
        Dept dept = deptMapper.selectById(id);
        if(dept!=null){
            //存入缓存中
            forValue.set("dept::"+id,dept,24, TimeUnit.HOURS);
        }
        return dept;
    }
    public int deleteById(Integer id){
        redisTemplate.delete("dept::"+id);
        int i = deptMapper.deleteById(id);
        return i;
    }
    public Dept insert(Dept dept){
        int insert = deptMapper.insert(dept);
        return dept;
    }
    public Dept update(Dept dept){
        redisTemplate.delete("dept::"+dept.getId());
        int i = deptMapper.updateById(dept);
        return dept;
    }
}
ログイン後にコピー

設定ソース:

# データ ソースの構成
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.url=jdbc:mysql://localhost:3306/mydb ?serverTimezone=Asia/Shanghai
spring.datasource.username=root
spring.datasource.password=root
#sql log
mybatis-plus.configuration.log-impl=org.apache.ibatis .logging.stdout.StdOutImpl
#redis に接続
spring.redis.host=192.168.22*.1**
spring.redis.port=6379

キャッシュを表示: コードの最初の部分は同じ @before 通知であり、コードの 2 番目の部分も同じ post 通知です。 AOP を使用して、キャッシュ コードとビジネス コードを分離できます。

Spring フレームワークでもそれを考えることができるはずです。 --これは注釈を使用して行うことができます。注釈を解析します。

1.3.2 構成クラスを使用する

(1) キャッシュされた構成クラスを追加します

    @Bean
    public CacheManager cacheManager(RedisConnectionFactory factory) {
        RedisSerializer<String> redisSerializer = new StringRedisSerializer();
        Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
        //解决查询缓存转换异常的问题
        ObjectMapper om = new ObjectMapper();
        om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
        jackson2JsonRedisSerializer.setObjectMapper(om);
        // 配置序列化（解决乱码的问题）,过期时间600秒
        RedisCacheConfiguration config = RedisCacheConfiguration.defaultCacheConfig()
                .entryTtl(Duration.ofSeconds(600)) //缓存过期10分钟 ---- 业务需求。
                .serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(redisSerializer))//设置key的序列化方式
                .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(jackson2JsonRedisSerializer)) //设置value的序列化
                .disableCachingNullValues();
        RedisCacheManager cacheManager = RedisCacheManager.builder(factory)
                .cacheDefaults(config)
                .build();
        return cacheManager;
ログイン後にコピー

(2) キャッシュ有効化アノテーションを使用します

Java Redisの使用シナリオの分析

##(3) 使用法の注釈 

//业务代码
    //使用查询注解:cacheNames表示缓存的名称 key:唯一标志---dept::key
    //先从缓存中查看key为（cacheNames::key）是否存在，如果存在则不会执行方法体，如果不存在则执行方法体并把方法的返回值存入缓存中
    @Cacheable(cacheNames = {"dept"},key="#id")
    public Dept findById(Integer id){
        Dept dept = deptMapper.selectById(id);
        return dept;
    }
//先删除缓存在执行方法体。
    @CacheEvict(cacheNames = {"dept"},key = "#id")
    public int deleteById(Integer id){
        int row = deptMapper.deleteById(id);
        return row;
    }
    //这个注释可以确保方法被执行，同时方法的返回值也被记录到缓存中，实现缓存与数据库的同步更新。
    @CachePut(cacheNames = "dept",key="#dept.id")
    public Dept update(Dept dept){
        int insert = deptMapper.updateById(dept);
        return dept;
    }
ログイン後にコピー

2. 分散ロック

ストレス テスト ツールを使用して、同時実行性の高さによって引き起こされるスレッドの安全性の問題をテストします

2.1 ストレステストツールの使用

Java Redisの使用シナリオの分析

Java Redisの使用シナリオの分析

Java Redisの使用シナリオの分析

Java Redisの使用シナリオの分析##内部構成:

Java Redisの使用シナリオの分析

Java Redisの使用シナリオの分析

Java Redisの使用シナリオの分析2.2 インベントリ項目

2.2.1 コントローラー層

@RestController
@RequestMapping("bucket")
public class BucketController {
    @Autowired
    private BucketService bucketService;
    @GetMapping("update/{productId}")
    public String  testUpdate(@PathVariable Integer productId){
        String s = bucketService.updateById(productId);
        return s;
    }
}
ログイン後にコピー
2.2.2 dao 層 
//此处写就不需要在启动类使用注解
@Mapper
public interface BucketMapper extends BaseMapper<Bucket> {
    public Integer updateBucketById(Integer productId);
}
ログイン後にコピー
2.2.3 エンティティ層 
@Data
@AllArgsConstructor
@NoArgsConstructor
public class Bucket {
    @TableId(value = "productId",type = IdType.AUTO)
    private Integer productId;
    private Integer num;
}
ログイン後にコピー
2.2.4 サービス層 
@Service
public class BucketService {
    @Resource
    private BucketMapper bucketMapper;
    public String updateById(Integer productId){
        //查看该商品的库存数量
        Bucket bucket = bucketMapper.selectById(productId);
        if(bucket.getNum()>0){
            //修改库存每次减1
            Integer integer = bucketMapper.updateBucketById(productId);
            System.out.println("扣减成功！剩余库存数："+(bucket.getNum()-1));
            return "success";
        }else {
            System.out.println("扣减失败！库存数不足");
            return "fail";
        }
    }
}
ログイン後にコピー
2.2.5 マッパー
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.qy151wd.dao.BucketMapper">
    <update id="updateBucketById" parameterType="int">
        update bucket set num=num-1 where productId=#{productId}
    </update>
</mapper>
ログイン後にコピー
2.2 .6 依存関係
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-redis</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!--连接数据源-->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jdbc</artifactId>
        </dependency>
        <!--mp的依赖-->
        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>mybatis-plus-boot-starter</artifactId>
            <version>3.4.2</version>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>
ログイン後にコピー
2.2.7 テスト結果

Java Redisの使用シナリオの分析同じインベントリが n 回使用されていることがわかります。そしてデータベース内の在庫はマイナスです。スレッドの安全性の問題が原因です。

2.3 解決策

2.3.1 同期ロックまたはロック ロックを使用する

対応するサービス レイヤーは 
@Service
public class BucketService {
    @Resource
    private BucketMapper bucketMapper;
    public String updateById(Integer productId){
        //加自动锁
        synchronized (this){
            //查看该商品的库存数量
            Bucket bucket = bucketMapper.selectById(productId);
            if(bucket.getNum()>0){
                //修改库存每次减1
                Integer integer = bucketMapper.updateBucketById(productId);
                System.out.println("扣减成功！剩余库存数："+(bucket.getNum()-1));
                return "success";
            }else {
                System.out.println("扣减失败！库存数不足");
                return "fail";
            }
        }
    }
}
ログイン後にコピー

に変更されますプロジェクト クラスターが構築されると、ロックが無効です。

#2.3.2 redisTemplate の使用Java Redisの使用シナリオの分析##(1) idea を使用してクラスター プロジェクトを開きます

（ 2) nginx

Java Redisの使用シナリオの分析

(3) テスト結果

Java Redisの使用シナリオの分析

# を使用し、数値と負の値が重複していることを確認します。在庫。

Java Redisの使用シナリオの分析(4) 解決策

サービス対応コード修正

@Service
public class BucketService {
    @Resource
    private BucketMapper bucketMapper;
    @Autowired
    private RedisTemplate redisTemplate;
    public String updateById(Integer productId){
        ValueOperations<String,String> forValue = redisTemplate.opsForValue();
        Boolean flag = forValue.setIfAbsent("aaa::" + productId, "-----------------");
        if(flag){
            try{
                //查看该商品的库存数量
                Bucket bucket = bucketMapper.selectById(productId);
                if(bucket.getNum()>0){
                    //修改库存每次减1
                    Integer integer = bucketMapper.updateBucketById(productId);
                    System.out.println("扣减成功！剩余库存数："+(bucket.getNum()-1));
                    return "success";
                }else {
                    System.out.println("扣减失败！库存数不足");
                    return "fail";
                }
            }finally {
                redisTemplate.delete("aaa::"+productId);
            }
        }
    return "服务器正忙，请稍后再试.......";
    }
}
ログイン後にコピー
Java Redisの使用シナリオの分析ここでの圧力測定速度は速すぎて困るので注意(5 秒間で 100 スレッドを推奨)

圧力テスト後の結果は次のとおりです:

以上がJava Redisの使用シナリオの分析の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。

関連ラベル：
java redis
ソース：yisu.com
前の記事：Java 並行プログラミング スレッドの作成方法: 次の記事：Java ASM は logback ログレベルの動的切り替え方式を使用します
このウェブサイトの声明
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。
著者別の最新記事
最新の問題
自動四捨五入を行わずにJavaScriptで文字列を19桁の数値に変換するにはどうすればよいですか? 数値に変換したい場合は、文字列入力 number input="6145390195186705543" があります。Java スクリプトはこの入力を自動的に丸...
から 2024-03-30 14:42:35
0
1
367
関連トピック
詳細>
人気のおすすめ
人気のチュートリアル
詳細>
関連するチュートリアル
人気のおすすめ
最新のコース
最新のダウンロード
詳細>
ウェブエフェクト
公式サイト
サイト素材
フロントエンドテンプレート