spring boot连接NoSQL数据库Redis写入和读取数据

淩亂°似流年 2023-10-01 15:39 11阅读 0赞

既然是连接Redis数据库，首先需要把Redis数据库启动起来。配置启动Redis详情：

[Windows环境搭建最新版NoSQL数据库Redis数据存储服务\_Zhang Phil-CSDN博客（1）下载安装最新Windows版的Redis。Redis官方目前没有直接给出Windows版本的发行版本，网上一搜，给出的多数是老旧的微软在2016年制作的Windows版本Redis发行版本。现在github上有一个，专注于Windows版本的Redis发行，跟进比较及时，最新版的Redis之Windows版本，链接地址：Releases · tporadowski/redis · GitHubhttps://github.com/tporadowski/redis/releases下载解压![favicon32.ico][]https://blog.csdn.net/zhangphil/article/details/122535147][Windows_NoSQL_Redis_Zhang Phil-CSDN_1_Windows_Redis_Redis_Windows_2016_Windows_Redis_github_Windows_Redis_Redis_Windows_Releases _ tporadowski_redis _ GitHubhttps_github.com_tporadowski_redis_releases_favicon32.ico_https_blog.csdn.net_zhangphil_article_details_122535147]

然后，

（1）创建一个maven的spring项目，在pom.xml添加相关依赖：

<dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-data-redis</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-data-rest</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web-services</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
    
            <dependency>
                <groupId>redis.clients</groupId>
                <artifactId>jedis</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
                <scope>provided</scope>
            </dependency>

（2）在resources下的application.properties里面配置连接Redis数据库的参数信息：

spring.redis.host=127.0.0.1
    spring.redis.port=6379
    spring.redis.database=0
    # Redis默认密码为空
    spring.redis.password=
    spring.redis.jedis.pool.max-active=8
    spring.redis.jedis.pool.max-wait=-1
    spring.redis.timeout=60000

（3）编写项目所需的各个模块、类。

spring boot连接Redis所需的数据库配置类：

import org.springframework.beans.factory.annotation.Value;
    import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.data.redis.connection.RedisConnectionFactory;
    import org.springframework.data.redis.connection.RedisStandaloneConfiguration;
    import org.springframework.data.redis.connection.jedis.JedisClientConfiguration;
    import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
    import org.springframework.data.redis.core.RedisTemplate;
    import org.springframework.data.redis.serializer.*;
    import redis.clients.jedis.JedisPoolConfig;
    
    import java.time.Duration;
    
    @Configuration
    @EnableAutoConfiguration
    public class MyRedisAutoConfiguration {
        @Value("${spring.redis.host}")
        private String host;
    
        @Value("${spring.redis.database}")
        private Integer database;
    
        @Value("${spring.redis.port}")
        private Integer port;
    
        @Value("${spring.redis.jedis.pool.max-active}")
        private int maxActive;
    
        @Value("${spring.redis.jedis.pool.max-wait}")
        private int maxWait;
    
        //@Value("${spring.redis.timeout}")
        //private int timeOut;
    
    
        @Bean
        public RedisTemplate<String, Object> MY_REDIS_TEMPLATE(RedisConnectionFactory connectionFactory) {
            RedisTemplate<String, Object> template = new RedisTemplate<>();
            template.setConnectionFactory(connectionFactory);
    
            RedisSerializer<String> redisSerializer = new StringRedisSerializer();
    
            //key序列化方式
            template.setKeySerializer(redisSerializer);
    
            //value序列化
            template.setValueSerializer(new GenericJackson2JsonRedisSerializer());
    
            return template;
        }
    
        @Bean
        public RedisConnectionFactory redisConnectionFactory() {
            RedisStandaloneConfiguration redisStandaloneConfiguration = new RedisStandaloneConfiguration();
            redisStandaloneConfiguration.setHostName(host);
            redisStandaloneConfiguration.setPort(port);
            redisStandaloneConfiguration.setDatabase(database);
    
            JedisPoolConfig poolConfig = new JedisPoolConfig();
            poolConfig.setMaxWait(Duration.ofMillis(maxWait));
            poolConfig.setMaxTotal(maxActive);
    
            JedisClientConfiguration.JedisPoolingClientConfigurationBuilder jpcb = (JedisClientConfiguration.JedisPoolingClientConfigurationBuilder) JedisClientConfiguration.builder().usePooling().poolConfig(poolConfig);
            JedisClientConfiguration jedisClientConfiguration = jpcb.build();
            return new JedisConnectionFactory(redisStandaloneConfiguration, jedisClientConfiguration);
        }
    }

数据库存取的数据实体类，即打算往Redis数据库存入的结构化数据对象，本例是一个person类：

import lombok.AllArgsConstructor;
    import lombok.Data;
    import lombok.NoArgsConstructor;
    
    @Data
    @NoArgsConstructor
    @AllArgsConstructor
    public class Person {
        private String name;
        private String city;
    }

写一个通过RedisTemplat读写操作Redis数据库的服务类：

import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.data.redis.core.RedisTemplate;
    import org.springframework.stereotype.Service;
    
    import java.util.HashMap;
    import java.util.Iterator;
    import java.util.Set;
    
    @Service
    public class MyRedisService {
        @Autowired
        RedisTemplate MY_REDIS_TEMPLATE; //注意，这里的变量名需要和MyRedisAutoConfiguration里面的RedisTemplate实现函数名相同。
    
        public boolean setPerson(String key, Person value) {
            boolean result = false;
            try {
                MY_REDIS_TEMPLATE.opsForValue().set(key, value);
                result = true;
            } catch (Exception e) {
                e.printStackTrace();
            }
    
            return result;
        }
    
        public Person getPerson(String key) {
            return (Person) MY_REDIS_TEMPLATE.opsForValue().get(key);
        }
    
        public HashMap<String, Person> getAllPerson() {
            Set<Object> set = MY_REDIS_TEMPLATE.keys("*");
            Iterator iterator = set.iterator();
    
            HashMap<String, Person> map = new HashMap<>();
            while (iterator.hasNext()) {
                String k = (String) iterator.next();
                Person p = (Person) MY_REDIS_TEMPLATE.opsForValue().get(k);
                map.put(k, p);
            }
    
            return map;
        }
    }

对外暴露的接口控制器controller：

import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.PathVariable;
    import org.springframework.web.bind.annotation.RestController;
    
    import java.util.HashMap;
    import java.util.UUID;
    
    @RestController
    public class PersonController {
        @Autowired
        private MyRedisService redisService;
    
        @GetMapping("/add/{name}")
        public String add(@PathVariable("name") String name) {
            Person person = new Person(name, "Chengdu");
    
            try {
                redisService.setPerson(UUID.randomUUID() + "", person);
                System.out.println("写入Redis:" + person);
            } catch (Exception e) {
                e.printStackTrace();
            }
    
            return person.toString();
        }
    
        @GetMapping("/person/{id}")
        public Person getById(@PathVariable("id") String id) {
            Person p = redisService.getPerson(id);
            System.out.println("读取" + p);
            return p;
        }
    
        @GetMapping("/all")
        public HashMap<String, Person> getAll() {
            return redisService.getAllPerson();
        }
    }

剩下的就是一个简单的application：

import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    
    @SpringBootApplication
    public class SpringRedisApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(SpringRedisApplication.class, args);
        }
    
    }

（4）以上代码完成后，开始运行spring boot程序。在浏览器输入

[http://localhost:8080/add/fly][http_localhost_8080_add_fly]

如果一切正常，浏览器会返回输出显示：

Person(name=fly, city=Chengdu)

在浏览器输入[http://localhost:8080/all][http_localhost_8080_all]

浏览器返回：

{"85505b27-f798-42c8-9713-c523e2a63aaa":{"name":"fly","city":"Chengdu"}}

![3cf51f8aa3b543e6b8a574f5fe603119.png][]

可知此时的Redis数据库里面，key是85505b27-f798-42c8-9713-c523e2a63aaa的数据条目对应的值为：

{"name":"fly","city":"Chengdu"}

此时，如果在浏览器里面输入[http://localhost:8080/person/85505b27-f798-42c8-9713-c523e2a63aaa][http_localhost_8080_person_85505b27-f798-42c8-9713-c523e2a63aaa]

浏览器返回输出：

![8044cba80693479d94a5303f66a1fde5.png][]

用Another Redis Desktop Manager查看此时的数据数据存储：

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAemhhbmdwaGls_size_20_color_FFFFFF_t_70_g_se_x_16][]

再用另外一个Redis GUI工具redis-gui查看：

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAemhhbmdwaGls_size_20_color_FFFFFF_t_70_g_se_x_16 1][]

[favicon32.ico]: https://g.csdnimg.cn/static/logo/favicon32.ico
[Windows_NoSQL_Redis_Zhang Phil-CSDN_1_Windows_Redis_Redis_Windows_2016_Windows_Redis_github_Windows_Redis_Redis_Windows_Releases _ tporadowski_redis _ GitHubhttps_github.com_tporadowski_redis_releases_favicon32.ico_https_blog.csdn.net_zhangphil_article_details_122535147]: https://blog.csdn.net/zhangphil/article/details/122535147
[http_localhost_8080_add_fly]: http://localhost:8080/add/fly
[http_localhost_8080_all]: http://localhost:8080/all
[3cf51f8aa3b543e6b8a574f5fe603119.png]: https://img-blog.csdnimg.cn/3cf51f8aa3b543e6b8a574f5fe603119.png
[http_localhost_8080_person_85505b27-f798-42c8-9713-c523e2a63aaa]: http://localhost:8080/person/85505b27-f798-42c8-9713-c523e2a63aaa
[8044cba80693479d94a5303f66a1fde5.png]: https://img-blog.csdnimg.cn/8044cba80693479d94a5303f66a1fde5.png
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAemhhbmdwaGls_size_20_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/015621e492224c72a409dddbb8b1b5c4.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAemhhbmdwaGls,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAemhhbmdwaGls_size_20_color_FFFFFF_t_70_g_se_x_16 1]: https://img-blog.csdnimg.cn/9bd0564272364adf920a1f29e09622f4.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAemhhbmdwaGls,size_20,color_FFFFFF,t_70,g_se,x_16