redis 客户端集成业务代码

﹏ヽ暗。殇╰゛Y 2023-10-02 18:35 24阅读 0赞

redis 客户端集成业务代码，是我们项目开发中最终面对的，今天我们从头到尾给大家演示一下，起到一个抛砖引玉的作用。

1、中文官网进去：[Redis客户端连接工具资料 -- Redis中文网 -- Redis中国用户组（CRUG）][Redis_ -- Redis_ -- Redis_CRUG]

选择java

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAbmFuZGFvMTU4_size_20_color_FFFFFF_t_70_g_se_x_16][]

进入：

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAbmFuZGFvMTU4_size_20_color_FFFFFF_t_70_g_se_x_16 1][] 发现有这么多客户端类型可以连接到redis：

2、点击Jedis后进入相应Github,[GitHub - redis/jedis: Redis Java client designed for performance and ease of use.][GitHub - redis_jedis_ Redis Java client designed for performance and ease of use.]

jedis连接线程不安全可以引入连接池，每个客户都来了都从池中取一个连接。

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAbmFuZGFvMTU4_size_20_color_FFFFFF_t_70_g_se_x_16 2][]

3、点击lettuce 进入：[GitHub - lettuce-io/lettuce-core: Advanced Java Redis client for thread-safe sync, async, and reactive usage. Supports Cluster, Sentinel, Pipelining, and codecs.][GitHub - lettuce-io_lettuce-core_ Advanced Java Redis client for thread-safe sync_ async_ and reactive usage. Supports Cluster_ Sentinel_ Pipelining_ and codecs.]

这里面有使用详情，可以详细阅读。

4、进入spring官网：

[Spring Data][]

选择redis模块：

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAbmFuZGFvMTU4_size_20_color_FFFFFF_t_70_g_se_x_16 3][]

springboot 里面也有redis相关 点击springboot：

[Spring Data][] 搜索reids

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAbmFuZGFvMTU4_size_20_color_FFFFFF_t_70_g_se_x_16 4][]

点击文档进入：

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAbmFuZGFvMTU4_size_20_color_FFFFFF_t_70_g_se_x_16 5][]

这里面就是使用详情：[Spring Data Redis][]

并且支持tettuce和jedis

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAbmFuZGFvMTU4_size_20_color_FFFFFF_t_70_g_se_x_16 6][]

springboot 里面也有配置：

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAbmFuZGFvMTU4_size_20_color_FFFFFF_t_70_g_se_x_16 7][]

来到：

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAbmFuZGFvMTU4_size_20_color_FFFFFF_t_70_g_se_x_16 8][]

5、实战操作：

pom文件引入：

<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-data-redis</artifactId>
    		</dependency>

1）查询客户端：CONFIG get \*

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAbmFuZGFvMTU4_size_20_color_FFFFFF_t_70_g_se_x_16 9][]

2）修改 成远端可以访问

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAbmFuZGFvMTU4_size_20_color_FFFFFF_t_70_g_se_x_16 10][]

6、默认是二进制字节流：

保存查询：

import org.springframework.data.redis.core.RedisTemplate;//原生的模版
    
        @Autowired
        RedisTemplate  redisTemplate;
    
        @Autowired
        @Qualifier("commonStringRedisTemplate")//方法名注解
        StringRedisTemplate  stringRedisTemplate;
    
        @Autowired
        ObjectMapper  objectMapper;
    
        public void testRedis(){
    
             redisTemplate.opsForValue().set("hello","china");
    
            System.out.println(redisTemplate.opsForValue().get("hello"));
    
    
           // stringRedisTemplate.opsForValue().set("hello01","china");
    
           // System.out.println(stringRedisTemplate.opsForValue().get("hello01"));
    
    }

2）查看：

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAbmFuZGFvMTU4_size_20_color_FFFFFF_t_70_g_se_x_16 11][]

3）更底层的获取连接：

RedisConnection conn = redisTemplate.getConnectionFactory().getConnection();
    
            conn.set("hello02".getBytes(),"mashibing".getBytes());
            System.out.println(new String(conn.get("hello02".getBytes())));

7、json转化：使用这个StringRedisTemplate 模版时要做json序列化配置

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAbmFuZGFvMTU4_size_20_color_FFFFFF_t_70_g_se_x_16 12][]

pom文件引入：

<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-json</artifactId>
    		</dependency>

1)配置：

@Configuration
    public class CommonTemplate {
    
        @Bean
        public StringRedisTemplate commonStringRedisTemplate(RedisConnectionFactory fc){
    
            StringRedisTemplate tp = new StringRedisTemplate(fc);
    
            tp.setHashValueSerializer(new Jackson2JsonRedisSerializer<Object>(Object.class));
            return  tp ;
        }
    }

2）业务引用：

@Autowired
        @Qualifier("commonStringRedisTemplate")//方法名注解
        StringRedisTemplate  stringRedisTemplate;

具体API操作和以前一样。

3）换成Jackson2HashMapper 配置：

先引用：

@Autowired
          ObjectMapper  objectMapper;

然后：

Jackson2HashMapper jm = new Jackson2HashMapper(objectMapper, false);
    
            stringRedisTemplate.opsForHash().putAll("sean01",jm.toHash(p));
    
            Map map = stringRedisTemplate.opsForHash().entries("sean01");
    
            Person per = objectMapper.convertValue(map, Person.class);
            System.out.println(per.getName());

8、消息订阅：

1）发送角色：

stringRedisTemplate.convertAndSend("ooxx","hello");

2）接收角色：

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAbmFuZGFvMTU4_size_20_color_FFFFFF_t_70_g_se_x_16 13][]

3）发送角色：

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAbmFuZGFvMTU4_size_20_color_FFFFFF_t_70_g_se_x_16 14][]

接收角色：

RedisConnection cc = stringRedisTemplate.getConnectionFactory().getConnection();
            cc.subscribe(new MessageListener() {
                @Override
                public void onMessage(Message message, byte[] pattern) {
                    byte[] body = message.getBody();
                    System.out.println(new String(body));
                }
            }, "ooxx".getBytes());
    
            while(true){
                stringRedisTemplate.convertAndSend("ooxx","hello  from nandao ");
                try {
                    Thread.sleep(3000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }

到此，redis的实战操作整个流程演示了一遍，大家在项目中一定多测试、多查看资料，定会很快掌握。

[Redis_ -- Redis_ -- Redis_CRUG]: http://redis.cn/clients.html
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAbmFuZGFvMTU4_size_20_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/b4468f38e5a44efab841a65cf3028ba9.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAbmFuZGFvMTU4,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAbmFuZGFvMTU4_size_20_color_FFFFFF_t_70_g_se_x_16 1]: https://img-blog.csdnimg.cn/3d9349f0fa054c1a9e02e94491b0de6a.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAbmFuZGFvMTU4,size_20,color_FFFFFF,t_70,g_se,x_16
[GitHub - redis_jedis_ Redis Java client designed for performance and ease of use.]: https://github.com/redis/jedis
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAbmFuZGFvMTU4_size_20_color_FFFFFF_t_70_g_se_x_16 2]: https://img-blog.csdnimg.cn/4722173b414c4c9ba792ff27ebb576a3.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAbmFuZGFvMTU4,size_20,color_FFFFFF,t_70,g_se,x_16
[GitHub - lettuce-io_lettuce-core_ Advanced Java Redis client for thread-safe sync_ async_ and reactive usage. Supports Cluster_ Sentinel_ Pipelining_ and codecs.]: https://github.com/lettuce-io/lettuce-core
[Spring Data]: https://spring.io/projects/spring-data
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAbmFuZGFvMTU4_size_20_color_FFFFFF_t_70_g_se_x_16 3]: https://img-blog.csdnimg.cn/b23489ff73d5432ebdd206068099d125.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAbmFuZGFvMTU4,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAbmFuZGFvMTU4_size_20_color_FFFFFF_t_70_g_se_x_16 4]: https://img-blog.csdnimg.cn/d2257618587e40e3a7c23308a98de407.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAbmFuZGFvMTU4,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAbmFuZGFvMTU4_size_20_color_FFFFFF_t_70_g_se_x_16 5]: https://img-blog.csdnimg.cn/6f97ef7717894ac594ffc19d9ed06372.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAbmFuZGFvMTU4,size_20,color_FFFFFF,t_70,g_se,x_16
[Spring Data Redis]: https://docs.spring.io/spring-data/redis/docs/current/reference/html/
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAbmFuZGFvMTU4_size_20_color_FFFFFF_t_70_g_se_x_16 6]: https://img-blog.csdnimg.cn/5498f87d8c0848b5b85404cb8d00f0e1.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAbmFuZGFvMTU4,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAbmFuZGFvMTU4_size_20_color_FFFFFF_t_70_g_se_x_16 7]: https://img-blog.csdnimg.cn/e033a980d122431f91c112476d7ed8ff.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAbmFuZGFvMTU4,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAbmFuZGFvMTU4_size_20_color_FFFFFF_t_70_g_se_x_16 8]: https://img-blog.csdnimg.cn/2cc24360315b4c81b79a37a2684b9558.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAbmFuZGFvMTU4,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAbmFuZGFvMTU4_size_20_color_FFFFFF_t_70_g_se_x_16 9]: https://img-blog.csdnimg.cn/38e95eeae89b457caa207a3ea46f42b7.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAbmFuZGFvMTU4,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAbmFuZGFvMTU4_size_20_color_FFFFFF_t_70_g_se_x_16 10]: https://img-blog.csdnimg.cn/98b398e0640a44b2b25e9745ac5f8024.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAbmFuZGFvMTU4,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAbmFuZGFvMTU4_size_20_color_FFFFFF_t_70_g_se_x_16 11]: https://img-blog.csdnimg.cn/a3de4dde03094f02bef3139653204e9a.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAbmFuZGFvMTU4,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAbmFuZGFvMTU4_size_20_color_FFFFFF_t_70_g_se_x_16 12]: https://img-blog.csdnimg.cn/d1d55b6c85b740a8b1070d2565d6368a.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAbmFuZGFvMTU4,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAbmFuZGFvMTU4_size_20_color_FFFFFF_t_70_g_se_x_16 13]: https://img-blog.csdnimg.cn/d7914e504df441f49272baca247d4cad.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAbmFuZGFvMTU4,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAbmFuZGFvMTU4_size_20_color_FFFFFF_t_70_g_se_x_16 14]: https://img-blog.csdnimg.cn/d55860216a16456d843faeff3370af92.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAbmFuZGFvMTU4,size_20,color_FFFFFF,t_70,g_se,x_16