Bagaimana untuk mengintegrasikan SpringBoot dan Redis

Integrasi SpringBoot dan pangkalan data bukan hubungan Redis

(1) Tambah pemula pergantungan Spring Data Redis

Perkenalkan pergantungan ini untuk mencipta projek, Kebergantungan berikut akan muncul dalam fail pom.xml projek:

(2) Tulis kelas entiti

Orang:

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 +
                '}';
    }
}

Alamat:

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 + ''' +
                '}';
    }
}

Dalam dua kelas entiti di atas, beberapa anotasi tentang operasi data pangkalan data Redis terlibat:

• @RedisHash("orang"): digunakan untuk nyatakan Manipulasi ruang storan objek kelas entiti dalam pangkalan data Redis Di sini, ini bermakna operasi data untuk kelas entiti Orang disimpan dalam ruang storan bernama orang dalam pangkalan data Redis.

• @Id: digunakan untuk mengenal pasti kunci utama kelas entiti. Dalam pangkalan data Redis, HashKey dalam bentuk rentetan dijana secara lalai untuk mewakili ID objek entiti unik Sudah tentu, ID juga boleh ditentukan secara manual semasa penyimpanan data.

• @Indexed: Digunakan untuk menentukan untuk menjana indeks sekunder untuk atribut yang sepadan dalam pangkalan data Redis. Apabila anotasi ini digunakan, indeks sekunder yang sepadan dengan atribut akan dijana dalam pangkalan data, yang akan menjadikan pertanyaan data mudah Nama indeks adalah sama dengan nama atribut.

(3) Menulis antara muka Repositori

SpringBoot menyediakan konfigurasi automatik untuk beberapa pangkalan data biasa termasuk Redis, dan boleh memudahkan data dalam pangkalan data dengan melaksanakan antara muka Repositori Tambah , padam, semak dan ubah suai operasi:

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);

}

Nota: Kelas antara muka Repositori yang ditulis semasa mengendalikan pangkalan data Redis perlu mewarisi antara muka CrudRepository peringkat terendah dan bukannya mewarisi JpaRepository (JpaRepository adalah SpringBoot bersepadu JPA unik). Sudah tentu, anda juga boleh mengimport kebergantungan JPA dan kebergantungan Redis yang disepadukan oleh SpringBoot ke dalam fail pom.xml projek pada masa yang sama, supaya anda boleh menulis antara muka yang mewarisi antara muka JpaRepository untuk mengendalikan pangkalan data Redis.

(4) Konfigurasi sambungan pangkalan data Redis

Tambah konfigurasi sambungan pangkalan data Redis dalam aplikasi fail konfigurasi global projek. Kod sampel adalah seperti berikut:

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

(. 5) Tulis kaedah ujian unit

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) Ujian integrasi

Buka alat pengurusan visual klien Redis, mula-mula sambung ke pelayan Redis tempatan:

Selepas sambungan berjaya, anda dapat melihat bahawa tiada data dalam pangkalan data Redis setempat:

Jalankan dua kaedah ujian yang ditulis di atas dan lihat keputusan cetakan konsol:

Untuk mengesahkan bahawa kaedah save() memang telah menulis data ke pangkalan data Redis tempatan, buka alat pengurusan visual klien Redis, muat semula data, dan anda boleh melihat bahawa data itu berjaya Ditulis:

Seperti yang dapat dilihat daripada rajah di atas: data yang ditambahkan dengan melaksanakan kaedah save() berjaya disimpan dalam pangkalan data Redis. Selain itu, indeks sekunder yang serupa dengan address.city, firstname, lastname, dsb. dibentuk di sebelah kiri senarai pangkalan data Indeks sekunder ini dijana dengan menambahkan anotasi @Indexed pada atribut yang sepadan semasa membuat kelas Person. Pada masa yang sama, memandangkan indeks sekunder yang sepadan dengan atribut dijana dalam pangkalan data Redis, maklumat data tertentu boleh disoal melalui indeks sekunder Contohnya, repository.findByAddress_City ("Beijing") menanyakan data yang nilai indeksnya ialah Beijing. melalui maklumat alamat.bandar. Jika indeks sekunder atribut yang sepadan tidak ditetapkan, hasil data yang ditanya melalui indeks atribut akan kosong.

Atas ialah kandungan terperinci Bagaimana untuk mengintegrasikan SpringBoot dan Redis. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!