响应式久草编程基础教程:久草Spring Boot 与 Lettuce 在线整合「建议收藏」

响应式久草编程基础教程:久草Spring Boot 与 Lettuce 在线整合「建议收藏」本文主要介绍响应式编程访问Redis,以及SpringBoot与Lettuce的整合使用。Lettuce是可扩展性线程安全的Redis客户端,用于同步、异步和响应式使用。如果多个线程避免阻塞和事务性操作(例如BLPOP和MULTI/EXEC),则它们可以共享一个连接。Lettuce是基于Netty构建的。支持很多高级的Redis特性。根据SpringDataRedis2.0的更新的消息显示,SpringDataRedis不再支持JRedis的驱动,

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE稳定放心使用

本文主要介绍响应式编程访问 Redis,以及 Spring Boot 与 Lettuce 的整合使用。

Lettuce 是可扩展性线程安全的 Redis 客户端,用于同步、异步和响应式使用。如果多个线程避免阻塞和事务性操作(例如 BLPOP 和 MULTI/EXEC),则它们可以共享一个连接。Lettuce 是基于 Netty 构建的。支持很多高级的Redis 特性。

根据 Spring Data Redis 2.0 的更新的消息显示,Spring Data Redis 不再支持 JRedis 的驱动,使用 Lettuce 来支持响应式连接,所以了解 Lettuce 的使用还是很有必要。

响应式久草编程基础教程:久草Spring Boot 与 Lettuce 在线整合「建议收藏」

使用Reactive 驱动连接到Redis

无论使用什么库连接,必须要使用到 ReactiveRedisConnection 和 ReactiveRedisConnectionFactory 来操作 Redis 或者查询存活的连接。

Lettuce 支持 单机,Redis Sentinel、Redis Cluster 集群模式

ReactiveRedisConnection 是与 Redis 通信的核心组件, ReactiveRedisConnectionFactory 用于创建 ReativeRedisConnection 实例。

Spring Boot 整合Lettuce 使用

增加依赖

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.5.3</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.example</groupId>
    <artifactId>spring-reactive-demo</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>spring-reactive-demo</name>
    <description>Demo project for Spring Boot</description>
    <properties>
        <java.version>11</java.version>
    </properties>
    <dependencies>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-redis-reactive</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-webflux</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>io.projectreactor</groupId>
            <artifactId>reactor-test</artifactId>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

配置 ReactiveRedisTemplate

@Configuration
public class LettuceConfig {

    @Bean
    ReactiveRedisTemplate<String, String> reactiveRedisTemplate(ReactiveRedisConnectionFactory reactiveRedisConnectionFactory) {
        return new ReactiveRedisTemplate<>(reactiveRedisConnectionFactory, RedisSerializationContext.string());
    }
}

ReactiveRedisTempalte 操作

@RestController
public class LettuceController {

    @Autowired
    private ReactiveRedisTemplate reactiveRedisTemplate;

    @GetMapping("/put")
    public Mono put(@RequestParam("key") String key, @RequestParam("val") String val) {
        return reactiveRedisTemplate.opsForValue().set(key, val);
    }

    @GetMapping("/get")
    public Mono<String> get(@RequestParam("key") String key) {
        return reactiveRedisTemplate.opsForValue().get(key);
    }

    @GetMapping("/addList")
    public Mono<Long> addList(@RequestParam("key") String key, @RequestParam("val") String val) {
        return reactiveRedisTemplate.opsForList().rightPush(key, val);
    }

    @GetMapping("/getList")
    public Flux<String> getList(@RequestParam("key") String key) {
        return reactiveRedisTemplate.opsForList().range(key, 0L, Long.MAX_VALUE);
    }

    @GetMapping("/setHash")
    public Mono<Boolean> setHash(@RequestParam("key") String key, @RequestParam("hashKey") String hashKey, @RequestParam("val") String val) {
        return reactiveRedisTemplate.opsForHash().put(key, hashKey, val);
    }

    @GetMapping("/getHash")
    public Flux<Map.Entry<String, String>> getHash(@RequestParam("key") String key) {
        return reactiveRedisTemplate.opsForHash().entries(key);
    }
}

    通过 ReactiveRedisTemplate 操作 Redis 的 string, list, hash类型的使用, 大致的了解 Lettuce 的使用,还有很多其他操作的类型,可以通过官方文章自行查阅。

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/180223.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)
blank

相关推荐

  • 如何划分音节并区分重读和非重读单词_重读音节符号怎么标

    如何划分音节并区分重读和非重读单词_重读音节符号怎么标这里涉及到了英语里的双音节和多音节的知识一、双音节单词的音节划分方法可归纳为“两分手.一归前或一归后”.1.“两分手”是指:当两个元音之间有两个辅音字母时,将两个辅音字母划分在前后两个音节里.具体

  • linux .zip文件 解压缩命令的简单使用

    linux .zip文件 解压缩命令的简单使用windows系统下常见的压缩格式有.zip.rarlinux系统下常见的压缩格式有.zip.gz.bz2.tar.gz.tar.bz2下面我来简单的介绍一下linux系统下zip压缩命令的使用方法.zip压缩命令的使用方法.zip的使用方法非常的简单使用zip命令即可压缩文件格式为zip压缩文件名源文件如图mywork

  • docker端口映射无法外部访问_docker用户映射

    docker端口映射无法外部访问_docker用户映射端口映射容器中可以运行一些应用,要让外部也可以访问这些应用,可以通过-P或-p参数来指定端口映射。当使用大写的-P标记时,Docker会随机映射一个物理机的49000~49900之间的端口到内部容器开放的网络端口。-p则可以指定想要映射的物理机端口,并且,在一个指定端口上只可以绑定一个容器。1.映射指定的本地IP和端口到容器端口dockerrun-it-p192.168.10.10:8000:80busybox2.映射本地指定IP的任意端口到

    2022年10月18日
  • 【云栖精选12月刊】2017年,阿里巴巴开源那些事

    【云栖精选12月刊】2017年,阿里巴巴开源那些事

  • jsp+ajax_javascriptjavascript日

    jsp+ajax_javascriptjavascript日明后两天梁言兵老师来讲Ajax及其最近作过的一个真实的Ajax项目,所以,我今天讲解梁老师的课程所需要的一些前置知识。因为大家对Javascript不是很熟悉,所以我首先讲解Javascript的DHTML功能。本来入学考试要求大家很好地掌握Javascript的,但是大家都不能理解我们的苦衷,并没有专心去对待Javascript。想想我前两年强调javascript和css的重要性时,一些培训中

  • 关于python中可迭代对象和迭代器的一些理解

    关于python中可迭代对象和迭代器的一些理解

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号