Spring整合Redis数据库（maven项目）

超、凢脫俗 2022-09-23 13:58 153阅读 0赞

**pom.xml**

<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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
      <modelVersion>4.0.0</modelVersion>
    
      <groupId>SpringRedis</groupId>
      <artifactId>SpringRedis</artifactId>
      <version>0.0.1-SNAPSHOT</version>
      <packaging>jar</packaging>
    
      <name>SpringRedis</name>
      <url>http://maven.apache.org</url>
      <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
      </properties>
      <dependencies>
       <dependency>  
            <groupId>org.springframework.data</groupId>  
            <artifactId>spring-data-redis</artifactId>  
            <version>1.0.2.RELEASE</version>  
        </dependency>  
        <dependency>  
            <groupId>org.springframework</groupId>  
            <artifactId>spring-test</artifactId>  
            <version>3.1.2.RELEASE</version>  
        </dependency>  
          
        <dependency>  
            <groupId>redis.clients</groupId>  
            <artifactId>jedis</artifactId>  
            <version>2.1.0</version>  
        </dependency>  
      
        <dependency>
          <groupId>junit</groupId>
          <artifactId>junit</artifactId>
          <version>4.9</version>
          <scope>test</scope>
        </dependency>
      </dependencies>
    </project>

**redis.properties**

# Redis settings  
    redis.host=127.0.0.1
    redis.port=6379
    redis.pass=  
    redis.maxIdle=300  
    redis.maxActive=600  
    redis.maxWait=1000  
    redis.testOnBorrow=true

**applicationContext.xml**

<?xml version="1.0" encoding="UTF-8"?>  
    <beans xmlns="http://www.springframework.org/schema/beans"  
        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p"  
        xmlns:context="http://www.springframework.org/schema/context"  
        xmlns:jee="http://www.springframework.org/schema/jee" xmlns:tx="http://www.springframework.org/schema/tx"  
        xmlns:aop="http://www.springframework.org/schema/aop"  
        xsi:schemaLocation="  
                http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd  
                http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">  
      
        <context:property-placeholder location="classpath:redis.properties" />  
      
        <bean id="poolConfig" class="redis.clients.jedis.JedisPoolConfig">  
            <property name="maxIdle" value="${redis.maxIdle}" />  
            <property name="maxActive" value="${redis.maxActive}" />  
            <property name="maxWait" value="${redis.maxWait}" />  
            <property name="testOnBorrow" value="${redis.testOnBorrow}" />  
        </bean>  
          
        <bean id="connectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory"  
            p:host-name="${redis.host}" p:port="${redis.port}" p:password="${redis.pass}"  p:pool-config-ref="poolConfig"/>  
          
        <bean id="redisTemplate" class="org.springframework.data.redis.core.StringRedisTemplate">  
            <property name="connectionFactory"   ref="connectionFactory" />  
        </bean>         
    </beans>

**User.java**

package com.springredis.entity;
    import java.io.Serializable;
    public class User implements Serializable{
    private static final long serialVersionUID = 7009105230409337695L;
    private int id;
    private String name;
    public User() {
    }
    public User(int id, String name) {
    this.id = id;
    this.name = name;
    }
    public int getId() {
    return id;
    }
    public void setId(int id) {
    this.id = id;
    }
    public String getName() {
    return name;
    }
    public void setName(String name) {
    this.name = name;
    }
    @Override
    public String toString() {
    return "User [id=" + id + ", name=" + name + "]";
    }
    }

**App.java**

package com.springredis;
    
    import java.io.Serializable;
    import org.junit.Test;
    import org.springframework.context.ApplicationContext;
    import org.springframework.context.support.ClassPathXmlApplicationContext;
    import org.springframework.dao.DataAccessException;
    import org.springframework.data.redis.connection.RedisConnection;
    import org.springframework.data.redis.core.RedisCallback;
    import org.springframework.data.redis.core.RedisTemplate;
    import com.springredis.entity.User;
    @SuppressWarnings("unchecked")
    public class App
    {
    private static RedisTemplate<Serializable, Serializable> template;
    static{
    ApplicationContext context=new ClassPathXmlApplicationContext("applicationContext.xml");
    template=(RedisTemplate<Serializable, Serializable>) context.getBean("redisTemplate");
    }
    @Test
    public void setObject(){
    template.execute(new RedisCallback<User>() {
    
    public User doInRedis(RedisConnection connection) throws DataAccessException {
    User user=new User(1, "小宝");
    connection.set(template.getStringSerializer().serialize(""+user.getId()),
    template.getStringSerializer().serialize(user.getName()));
    return null;
    }
    
    });
    } 
    @Test
    public void getObject(){
    User user=template.execute(new RedisCallback<User>() {
    public User doInRedis(RedisConnection connection) throws DataAccessException {
     
    byte[] bname = connection.get(template.getStringSerializer().serialize(""+1));
    String name = template.getStringSerializer().deserialize(bname);
    return new User(1, name);
    }
    
    });
    System.out.println(user.toString());
    } 
    @Test
    public void delete(){
    template.delete("1");
    getObject();
    }
    }