Comment intégrer SpringBoot et Redis

Intégration de SpringBoot et de la base de données non relationnelle Redis

(1) Ajouter un démarreur de dépendance Spring Data Redis

#🎜🎜 # Introduisez cette dépendance pour créer un projet, et les dépendances suivantes apparaîtront dans le pom du projet 🎜🎜#Person:

package com.hardy.springbootdataredis.domain;import org.springframework.data.annotation.Id;import org.springframework.data.redis.core.RedisHash;import org.springframework.data.redis.core.index.Indexed;/**
 * @Author: HardyYao
 * @Date: 2021/6/15 */@RedisHash("persons")   // 指定操作实体类对象在Redis数据库中的存储空间public class Person {

    @Id // 标识实体类主键private String id;

    @Indexed // 标识对应属性在Redis数据库中生成二级索引private String firstname;

    @Indexedprivate String lastname;private Address address;public String getId() {return id;
    }public void setId(String id) {this.id = id;
    }public String getFirstname() {return firstname;
    }public void setFirstname(String firstname) {this.firstname = firstname;
    }public String getLastname() {return lastname;
    }public void setLastname(String lastname) {this.lastname = lastname;
    }public Address getAddress() {return address;
    }public void setAddress(Address address) {this.address = address;
    }

    @Overridepublic String toString() {return "Person{" +
                "id='" + id + ''' +
                ", firstname='" + firstname + ''' +
                ", lastname='" + lastname + ''' +
                ", address=" + address +
                '}';
    }
}

Address:

package com.hardy.springbootdataredis.domain;import org.springframework.data.redis.core.index.Indexed;/**
 * @Author: HardyYao
 * @Date: 2021/6/15 */public class Address {

    @Indexedprivate String city;

    @Indexedprivate String country;public String getCity() {return city;
    }public void setCity(String city) {this.city = city;
    }public String getCountry() {return country;
    }public void setCountry(String country) {this.country = country;
    }

    @Overridepublic String toString() {return "Address{" +
                "city='" + city + ''' +
                ", country='" + country + ''' +
                '}';
    }
}

Dans les deux classes d'entité ci-dessus. , plusieurs annotations sur les opérations de données de la base de données Redis sont impliquées :

@RedisHash("persons") : utilisé pour spécifier l'espace de stockage de l'objet de classe d'entité opérationnelle dans la base de données Redis. Ici, cela signifie que les opérations de données pour la classe d'entité Person sont toutes stockées dans la base de données Redis sous l'espace de stockage nommé personnes.

@Id : utilisé pour identifier la clé primaire de la classe d'entité. Dans la base de données Redis, une HashKey sous la forme d'une chaîne est générée par défaut pour représenter l'ID unique de l'objet d'entité. Bien entendu, l'ID peut également être spécifié manuellement lors du stockage des données.

• @Indexed : utilisé pour spécifier de générer un index secondaire pour l'attribut correspondant dans la base de données Redis. Lorsque cette annotation est utilisée, l'index secondaire correspondant à l'attribut sera généré dans la base de données, ce qui simplifiera la requête de données. Le nom de l'index est le même que le nom de l'attribut.

• (3) Écrire l'interface du référentiel

SpringBoot fournit une configuration automatisée pour certaines bases de données courantes, notamment Redis, qui peut être implémentée en implémentant le référentiel interface Simplifiez l'opération d'ajout, de suppression, de vérification et de modification des données dans la base de données :

• package com.hardy.springbootdataredis.repository;import com.hardy.springbootdataredis.domain.Person;import org.springframework.data.repository.CrudRepository;import java.util.List;/**
   * @Author: HardyYao
   * @Date: 2021/6/15 */public interface PersonRepository extends CrudRepository<Person, String> {
  
      List<Person> findByAddress_City(String City);
  
  }

  Note
 : La classe d'interface Repository écrite lors de l'exploitation de la base de données Redis doit hériter de la Interface CrudRepository de niveau le plus bas. Au lieu d'hériter de JpaRepository (JpaRepository est unique à l'intégration de JPA par SpringBoot). Bien entendu, vous pouvez également importer simultanément les dépendances JPA et Redis intégrées par SpringBoot dans le fichier pom.xml du projet, afin de pouvoir écrire une interface qui hérite de l'interface JpaRepository pour faire fonctionner la base de données Redis.

(4) Configuration de la connexion à la base de données Redis

Ajoutez la configuration de la connexion à la base de données Redis dans le fichier de configuration globale application.properties du projet. L'exemple de code est le suivant :

.

# Redis服务器地址
spring.redis.host=127.0.0.1
# Redis服务器连接端口
spring.redis.port=6379
# Redis服务器连接密码（默认为空）
spring.redis.password=

# 🎜🎜#(5) Méthode de test unitaire d'écriture

package com.hardy.springbootdataredis;import com.hardy.springbootdataredis.domain.Address;import com.hardy.springbootdataredis.domain.Person;import com.hardy.springbootdataredis.repository.PersonRepository;import org.junit.jupiter.api.Test;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.boot.test.context.SpringBootTest;import java.util.List;

@SpringBootTestclass SpringbootdataRedisApplicationTests {

    @Autowiredprivate PersonRepository repository;

    @Testpublic void savePerson() {
        Person person = new Person();
        person.setFirstname("张");
        person.setLastname("三");
        Address address = new Address();
        address.setCity("北京");
        address.setCountry("中国");
        person.setAddress(address);// 向Redis数据库添加数据Person save = repository.save(person);
    }

    @Testpublic void selectPerson() {
        List<Person> list = repository.findByAddress_City("北京");for (Person person : list) {
            System.out.println(person);
        }
    }

}

(6) Test d'intégration

Ouvrez l'outil de gestion visuelle du client Redis, connectez-vous d'abord au serveur Redis local :

Une fois la connexion réussie, vous pouvez voir qu'il n'y a aucune donnée dans la base de données Redis locale :

#🎜 🎜#

# 🎜🎜#Exécutez les deux méthodes de test écrites ci-dessus et visualisez les résultats d'impression de la console :

Afin de vérifier que le La méthode save() écrit réellement les données. Après avoir entré la base de données Redis locale, ouvrez l'outil de gestion visuelle du client Redis et actualisez les données. Vous pouvez voir que les données ont été écrites avec succès :

.

Passed Comme le montre la figure ci-dessus : les données ajoutées en exécutant la méthode save() sont stockées avec succès dans la base de données Redis. De plus, un index secondaire similaire à adresse.ville, prénom, nom, etc. est formé sur le côté gauche de la liste de bases de données. Ces index secondaires sont générés en ajoutant l'annotation @Indexed aux attributs correspondants lors de la création de la classe Personne. Dans le même temps, puisque l'index secondaire correspondant à l'attribut est généré dans la base de données Redis, des informations de données spécifiques peuvent être interrogées via l'index secondaire. Par exemple, depositaire.findByAddress_City ("Beijing") interroge les données dont la valeur d'index est Pékin. via l’index adresse.ville. Si l'index secondaire de l'attribut correspondant n'est pas défini, le résultat des données interrogé via l'index d'attribut sera vide.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!