Einführung in die Methode zum Hinzufügen von Redis-Unterstützung zum SSM-Projekt

Sie müssen zuerst die SSM-Entwicklungsumgebung einrichten und Redis installieren. Im Folgenden sind die spezifischen Implementierungsschritte aufgeführt:

1. Führen Sie das Jedis-Rack-Paket in das Projekt ein : jedis-2.8.2.jar, spring-data-redis-1.6.2.RELEASE.jar und commons-pool-1.6.jar Zu hohe oder zu niedrige Werte können zu Ausnahmen führen sind oben erwähnt. Die Kombination ist für persönliche Tests verfügbar.

2. Zum Schreiben von Redis sind zwei Toolklassen erforderlich.

3 org.apache.ibatis .cache.Cache-Schnittstelle

4. Aktivieren Sie in diesem Projekt die mybatis-config.xml-Datei

5 mapper.xml Die Cache-Klasse MybatisRedisCache

RedisUtil-Toolklasse wird zur Kommunikation mit Redis-Daten verwendet. SerializeUtil ist eine Serialisierungstoolklasse und ein Tool unter dem Lang-Paket. Sie wird hauptsächlich für Serialisierungsvorgänge verwendet und stellt auch ein Objekt bereit Klonschnittstelle. Das Folgende ist der spezifische Code:

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

public class RedisUtil {
    private static String ADDR = "127.0.0.1";
    private static int PORT = 6379;
    private static int MAX_ACTIVE = 1024;

    private static int MAX_IDLE = 200;

    private static int MAX_WAIT = 100000;

    private static int TIMEOUT = 10000;

    private static boolean TEST_ON_BORROW = true;

    private static JedisPool jedisPool = null;

    static {
        try{
            JedisPoolConfig config = new JedisPoolConfig();
            config.setMaxIdle(MAX_IDLE);
            config.setMaxWaitMillis(MAX_WAIT);
            config.setTestOnBorrow(TEST_ON_BORROW);
            jedisPool = new JedisPool(config,ADDR,PORT,TIMEOUT);
        }catch (Exception e) {
            e.printStackTrace();
        }
    }

    public synchronized static Jedis getJedis(){
        try{
            if(jedisPool != null){
                Jedis jedis = jedisPool.getResource();
                return jedis;
            }else{
                return null;
            }
        }catch (Exception e) {
            e.printStackTrace();
            return null;
        }
    }

    public static void returnResource(final Jedis jedis){
        if(jedis != null){
            jedisPool.returnResource(jedis);
        }
    }
}

rrree

mybatis-config.xml-Datei, wählen Sie das globale Laden in der spring-mybatis.xml-Datei aus:

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;

public class SerializeUtil {
    public static byte[] serialize(Object object) {
        ObjectOutputStream oos = null;
        ByteArrayOutputStream baos = null;
        try {
            // 序列化
            baos = new ByteArrayOutputStream();
            oos = new ObjectOutputStream(baos);
            oos.writeObject(object);
            byte[] bytes = baos.toByteArray();
            return bytes;
        } catch (Exception e) {
            e.printStackTrace();
        }
        return null;
    }

    public static Object unserialize(byte[] bytes) {
        if (bytes == null)
            return null;
        ByteArrayInputStream bais = null;
        try {
            // 反序列化
            bais = new ByteArrayInputStream(bytes);
            ObjectInputStream ois = new ObjectInputStream(bais);
            return ois.readObject();
        } catch (Exception e) {
            e.printStackTrace();
        }
        return null;
    }

}

import java.util.concurrent.locks.ReadWriteLock;
import java.util.concurrent.locks.ReentrantReadWriteLock;

import org.apache.ibatis.cache.Cache;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class MybatisRedisCache implements Cache {

    private static Logger logger = LoggerFactory.getLogger(MybatisRedisCache.class); 

    /** The ReadWriteLock. */ 

    private final ReadWriteLock readWriteLock = new ReentrantReadWriteLock();

    private String id;

    public MybatisRedisCache(final String id) {  

        if (id == null) {

            throw new IllegalArgumentException("Cache instances require an ID");

        }

        logger.debug(">>>>>>>>>>>>>>>>>>>>>>>>MybatisRedisCache:id="+id);

        this.id = id;

    }  
    public String getId() {

        return this.id;

    }
    public void putObject(Object key, Object value) {

        logger.debug(">>>>>>>>>>>>>>>>>>>>>>>>putObject:"+key+"="+value);

        RedisUtil.getJedis().set(SerializeUtil.serialize(key.toString()), SerializeUtil.serialize(value));

    }
    public Object getObject(Object key) {

        Object value = SerializeUtil.unserialize(RedisUtil.getJedis().get(SerializeUtil.serialize(key.toString())));

        logger.debug(">>>>>>>>>>>>>>>>>>>>>>>>getObject:"+key+"="+value);

        return value;
    }
    public Object removeObject(Object key) {

        return RedisUtil.getJedis().expire(SerializeUtil.serialize(key.toString()),0);

    }

 public void clear() {

        RedisUtil.getJedis().flushDB();

    }

   public int getSize() {

        return Integer.valueOf(RedisUtil.getJedis().dbSize().toString());

    }

   public ReadWriteLock getReadWriteLock() {

        return readWriteLock;

    }
}

Das Folgende ist der detaillierte Code von mybatis-config .xml:

<!-- 配置mybatis -->
    <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
        <property name="dataSource" ref="dataSource" />
        <!-- 加载mybatis的全局配置文件 -->
        <property name="configLocation" value="classpath:resource/mybatis-config.xml"></property>
        <!-- mapper扫描 -->
        <property name="mapperLocations" value="classpath:resource/mapper/*.xml"></property>
       </bean>

Fügen Sie abschließend das referenzierte

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD SQL Map Config 3.0//EN"  
    "http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration>

    <settings>
         <!-- 全局映射器启用缓存 -->
        <setting name="cacheEnabled" value="true"/>

        <!-- 查询时，关闭关联对象即时加载以提高性能 -->
        <setting name="lazyLoadingEnabled" value="false"/>

        <!-- 对于未知的SQL查询，允许返回不同的结果集以达到通用的效果 -->
        <setting name="multipleResultSetsEnabled" value="true"/>

        <!-- 允许使用列标签代替列名 -->
        <setting name="useColumnLabel" value="true"/>

        <!-- 不允许使用自定义的主键值(比如由程序生成的UUID 32位编码作为键值)，数据表的PK生成策略将被覆盖 -->
        <setting name="useGeneratedKeys" value="false"/>

        <!-- 给予被嵌套的resultMap以字段-属性的映射支持 FULL,PARTIAL -->
        <setting name="autoMappingBehavior" value="PARTIAL"/>

        <!-- 对于批量更新操作缓存SQL以提高性能 BATCH,SIMPLE -->
        <!-- <setting name="defaultExecutorType" value="BATCH" /> -->

        <!-- 数据库超过25000秒仍未响应则超时 -->
        <!-- <setting name="defaultStatementTimeout" value="25000" /> -->

        <!-- Allows using RowBounds on nested statements -->
        <setting name="safeRowBoundsEnabled" value="false"/>

        <!-- Enables automatic mapping from classic database column names A_COLUMN to camel case classic Java property names aColumn. -->
        <setting name="mapUnderscoreToCamelCase" value="true"/>

        <!-- MyBatis uses local cache to prevent circular references and speed up repeated nested queries. By default (SESSION) all queries executed during a session are cached. If localCacheScope=STATEMENT 
            local session will be used just for statement execution, no data will be shared between two different calls to the same SqlSession. -->
        <setting name="localCacheScope" value="SESSION"/>

        <!-- Specifies the JDBC type for null values when no specific JDBC type was provided for the parameter. Some drivers require specifying the column JDBC type but others work with generic values 
            like NULL, VARCHAR or OTHER. -->
        <setting name="jdbcTypeForNull" value="OTHER"/>

        <!-- Specifies which Object&#39;s methods trigger a lazy load -->
        <setting name="lazyLoadTriggerMethods" value="equals,clone,hashCode,toString"/>
          <!-- 打印sql语句 -->
        <setting name="logImpl" value="STDOUT_LOGGING" />  
</settings>

</configuration>

zum Namespace des Mapping-Datei-Mappers hinzu. Sie werden feststellen, dass die Konsole die SQL-Anweisung der gerade ausgeführten Abfrage ausgibt Achten Sie zu diesem Zeitpunkt auf die Abfrage, wenn kein SQL ausgegeben wird. Dies zeigt an, dass die Daten von Redis gelesen und an Sie zurückgegeben werden durch Abfrage in der Datenbank. An diesem Punkt ist die Konfiguration erfolgreich.

Natürlich können wir den Redis-Client und -Server öffnen, redis-cli im Redis-Installationsverzeichnis finden, doppelklicken, um es zu öffnen, Schlüssel eingeben * Drücken Sie die Eingabetaste, Sie sehen den generierten Schlüssel, Redis wird ihn sehen Gehen Sie zum Schlüssel entsprechend dem Schlüssel. Holen Sie sich den erforderlichen Wert.

Während des eigentlichen Betriebs sollten Sie auf die RedisUtil-Toolklasse achten. Sie müssen den Port und die ADDR entsprechend Ihrer eigenen Situation festlegen. Wenn das installierte Redis über ein Passwort verfügt, müssen Sie AUTH hinzufügen Es gibt kein Passwort, dies ist nicht erforderlich. Selbst die Zuweisung eines Nullwerts funktioniert nicht.

Einmal versucht: private static String AUTH = " ";

Als Ergebnis wurde diese Ausnahme beim Ausführen gemeldet: jedis.Exceptions.JedisDataException: ERR Client sent AUTH, but no password is set

bedeutet, dass der Redis-Server kein Passwort festgelegt hat, aber der Client eine AUTH-Anfrage an ihn gesendet hat. Darüber hinaus müssen zwischengespeicherte Klassen Serializable implementieren. Wenn Sie vermuten, dass ein Problem mit dem von Ihnen installierten Redis vorliegt, können Sie es mit der folgenden Methode testen:

<?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.krk.sxytj.ytj2001.mapper.YTJ2001Mapper" >
  <cache type="com.krk.sxytj.utils.redis.MybatisRedisCache>

Für weitere Redis-Kenntnisse lesen Sie bitte die Spalte Redis-Datenbank-Tutorial .

Das obige ist der detaillierte Inhalt vonEinführung in die Methode zum Hinzufügen von Redis-Unterstützung zum SSM-Projekt. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!