[大数据] Spring 中使用 Jedis 来操作 Redis 数据库

开发: C++知识库 Java知识库 JavaScript Python PHP知识库人工智能区块链大数据移动开发嵌入式开发工具数据结构与算法开发测试游戏开发网络协议系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑笔记本显卡显示器固态硬盘硬盘耳机手机 iphone vivo oppo 小米华为单反装机图拉丁

-> 大数据 -> Spring 中使用 Jedis 来操作 Redis 数据库 -> 正文阅读

[大数据]Spring 中使用 Jedis 来操作 Redis 数据库

		   <dependency>
                <groupId>redis.clients</groupId>
                <artifactId>jedis</artifactId>
                <version>2.9.0</version>
            </dependency>

在这里插入图片描述

applicationcontext-jedis.xml 文件中的内容

<!--    配置连接单机版redis的Bean-->
    <bean id="jedis" class="redis.clients.jedis.JedisPool">
     // Redis的 主机 IP
        <constructor-arg name="host" value="192.168.159.129"></constructor-arg>
      // Redis 在主机上运行的 端口
        <constructor-arg name="port" value="6379"></constructor-arg>
    </bean>

但是，同样注意到，可以配置对于 Redis连接池的一些配置。那么你就可以在 applicationcontext-jedis.xml 多写一个类型为GenericObjectPoolConfig 或它的子类的 bean，再进行参数指定即可设定。
在这里插入图片描述

在这里插入图片描述

下面 JedisPoolConfig 既是 GenericObjectPoolConfig 的继承子类

    <bean id="jedisconfig" class="redis.clients.jedis.JedisPoolConfig">
        <property name="maxIdle" value="27"></property>
        <property name="maxTotal" value="27"></property>
        <property name="minIdle" value="0"></property>
    </bean>
<!--    配置连接单机版redis的Bean-->
    <bean id="jedis" class="redis.clients.jedis.JedisPool">
        <constructor-arg name="host" value="192.168.159.129"></constructor-arg>
        <constructor-arg name="port" value="6379"></constructor-arg>
        <constructor-arg name="poolConfig" ref="jedisconfig"></constructor-arg>
    </bean>

由于一些加载顺序的问题，我直接在springmvc.xml 中直接 import 了这个容器。

 <import resource="applicationcontext-jedis.xml"/>

//注入 类型为 JedisPool 的 Bean
    @Autowired
    private JedisPool jedisPool;

            // 1. 从连接池获取jedis对象
		    Jedis jedis=jedisPool.getResource();
		    // 2. 执行操作
            jedis.sadd(RedisContant.SETMEALPICALL,uploadFileName);
            // 如果使用JedisPool，close操作不是关闭连接，代表归还连接池
            jedis.close();

       Jedis jedis=jedisPool.getResource();
        //利用电话，来查询 一个用户的相关信息
        Member telephone = memberService.getMemByphone(map.get("telephone"));
        //使用com.alibaba.fastjson 的JSON，来对 用户对象 序列化
        String s = JSON.toJSON(telephone).toString();

        //存入 登录或注册 者的 信息（30分钟）
        jedis.del(map.get("telephone"));
        //将序列化后的 字符串信息，存入 Redis，并 定时 30分钟，30分钟后  自动删除
        jedis.set(map.get("telephone"),s,"NX", "EX", 60 * 30);
        jedis.close();