0
点赞
收藏
分享

微信扫一扫

Java学习(Redis(非关系型数据库))

Android开发指南 2022-03-26 阅读 46
java学习

2022/3/26

一、redis
1.概述:非关系型数据库(NoSQL)
        * 与关系型数据库的区别
        1) 关系型数据库的数据之间有关联关系,并且数据存储在硬盘的文件上(通过表)
        2) 非关系型数据库的数据之间没有关联关系,并且数据存储在内存中(通过键值对)
        * 应用场景:经常查询一些不太经常发生变化的数据,经常操作关系型数据库非常耗时
                 可以通过缓存思想解决这个问题:从缓存中获取数据:有数据:直接返回;
                                        没数据:从数据库中查询,将数据放入缓存,然后返回数据;
        (缓存是内存区域,可以通过redis做缓存,把数据库中的文件备份,来提高查询速度)
        * 总结:关系型数据库与NoSQL数据库并非对立而是互补的关系,即通常情况下使用关系型数据库,在适合使用NoSQL的时候使用NoSQL数据库,一般会将数据存储在关系型数据库中,在nosql数据库备份存储关系型数据库的数据。
        * 什么是redis?redis是c语言开发的一个开源高性能键值对数据库;
        它支持:String,hash,list,set,sortedset(有序集合类型)这些数据类型
        它的应用场景:缓存(数据查询,短连接,新闻内容,商品内容),在线好友,任务列队(秒杀)
                                 应用排行榜,网站访问统计,数据过期处理,分布式集群构架中的session分离

2.下载安装
        1.中文网:http://www.redis.net.cn/
        2.解压直接可以使用:
                * redis.windows.conf:配置文件
                * redis-cli.exe:redis的客户端
                * redis-server.exe:redis服务器端
3.命令操作
      1.redis的数据结构:
          * redis存储的是:key,value格式的数据,其中key都是字符串,value有5种不同的数据结构
                * value的数据结构:
                        1)字符串类型:String
                        2)哈希类型hash:map格式
                        3)列表类型list:linkedlist格式。支持重复元素
                        4)集合类型 set:不允许重复元素
                        5)有序集合类型 sortedset:不允许重复元素,且元素有顺序

4.持久化
        1.redis是一个内存数据库,当redis服务器重启后,获取电脑重启,数据会丢失,我们可以将redis内存中的数据持久化保存到硬盘的文件中。
        2.redis持久化机械:
                1.RDB:默认方式,不需要进行配置,默认就使用这种机制(对性能影响小)
                        * 在一定的间隔时间中,检测key的变化情况,然后持久化数据
                        1.编辑redis.conf文件(数据和时间都可更改)
                                save 900 1(每900秒,15分钟,至少有1条key改变就持久化数据)
                                save 300 10(每300秒,5分钟,至少有10条key改变就持久化数据)
                                save 60 10000(每60秒,1分钟,至少有10000条key改变就持久化数据)
                        2.重新启动redis服务器,并指定配置文件名称
                                D:\redis\redis-5.0.2>redis-server.exe redis.conf
                2.AOF:日志记录的方式,可以记录每一条命令的操作。可以每一次命令操作后,持久化数据。(对性能影响大)
                        1.编辑redis.conf文件
                                appendonly no(关闭aof文件) --> appendonly yes (开启aof)
                                
                                # appendfsync always:每一次操作都进行持久化
                                appendfsync everysec:每隔一秒进行一次持久化
                                # appendfsync no:不进行持久化

5.Java客户端 Jedis
        * Jedis:一款java操作redis数据库的工具
        * 使用步骤:
                * 下载jedis的jar包
                * 使用

package ln.webtest.day01.test;

import org.junit.Test;
import redis.clients.jedis.Jedis;

import java.util.List;
import java.util.Map;
import java.util.Set;

//jedis的测试类
public class JedisTest {
    //快速入门
    @Test
    public void test1(){
        //获取连接
        Jedis jedis = new Jedis("localhost", 6379);
        //2.操作
        jedis.set("username", "zhangsan");
        //3.关闭连接
        jedis.close();
    }
    //字符串 string格式 数据结构操作
    @Test
    public void test2(){
        //1.获取连接
        Jedis jedis = new Jedis(); //如果使用空参构造,默认值"localhost",6379端口
        //2.操作
        //存储
        jedis.set("username", "zhangsan");
        //获取
        String username = jedis.get("username");
        System.out.println(username);

        //可以使用setex()方法存储可以指定过期时间的key value
        jedis.setex("activecode", 20, "hehe");
        //将activecode:hehe键值对存入redis,并且20秒后自动删除该键值对

        //3.关闭连接
        jedis.close();
    }
    //哈希 数据结构操作
    @Test
    public void test3(){
        //1.获取连接
        Jedis jedis = new Jedis(); //如果使用空参构造,默认值"localhost",6379端口
        //2.操作
        //存储
        jedis.hset("user", "name", "lisi");
        jedis.hset("user", "age", "23");
        jedis.hset("user", "gender", "female");
        //获取
        String name = jedis.hget("user", "name");
        System.out.println(name);
        //获取hash的所有map数据
        Map<String, String> user = jedis.hgetAll("user");
        //keySet
        for (String key:user.keySet()){
            //获取value
            String value = user.get(key);
            System.out.println(key+":"+value);
        }

        //3.关闭连接
        jedis.close();
    }
    //List 数据结构操作
    @Test
    public void test4(){
        //获取连接
        Jedis jedis = new Jedis();
        //2.操作
        //list存储
        jedis.lpush("mylist", "a","c","d");//从左边存
        jedis.rpush("mylist", "a","c","d");//从右边存

        //list 范围获取
        List<String> mylist = jedis.lrange("mylist", 0, -1);
        System.out.println(mylist);

        //list弹出
        String element1 = jedis.lpop("mylist"); //d
        String element2 = jedis.rpop("mylist"); //d
        System.out.println(element1);
        System.out.println(element2);
        //list 范围获取
        List<String> mylist1 = jedis.lrange("mylist", 0, -1);
        System.out.println(mylist1);
        //3.关闭连接
        jedis.close();
    }
    //set 数据结构操作
    @Test
    public void test5(){
        //获取连接
        Jedis jedis = new Jedis();
        //2.操作
        //set存储
        jedis.sadd("myset", "java","php");
        //set获取
        Set<String> myset = jedis.smembers("myset");
        System.out.println(myset);
        //3.关闭连接
        jedis.close();
    }
    //sortedset 数据结构操作
    @Test
    public void test6(){
        //获取连接
        Jedis jedis = new Jedis();
        //2.操作
        //sortedset 存储
        jedis.zadd("mysortedset", 1, "你");
        jedis.zadd("mysortedset", 3, "吗");
        jedis.zadd("mysortedset", 2, "懂");
        //sortedset获取
        Set<String> mysortedset = jedis.zrange("mysortedset", 0, -1);
        System.out.println(mysortedset);
        //3.关闭连接
        jedis.close();
    }
}

6.Jedis连接池

//jedis连接池使用
    @Test
    public void test7(){
        //0 创建一个配置对象
        JedisPoolConfig config = new JedisPoolConfig();
        config.setMaxTotal(50); //最大活动对象数
        config.setMaxIdle(10);  //最大能够保持idel状态的对象数

        //创建Jedis连接池对象
        JedisPool jedisPool = new JedisPool(config,"localhost",6379);//给config定义主机名和端口号
        //2.获取连接
        Jedis jedis = jedisPool.getResource();
        //3.使用
        jedis.set("hehe", "heihei");
        //4.关闭,归还到连接池中
        jedis.close();
    }

7.Jedis连接池工具类

host=127.0.0.1
port=6379
maxTotal=50
maxIdle=10
package ln.webtest.day01.test;

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

import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;

public class JedisPoolUtils {
    private static JedisPool jedisPool;

    static {
        //读取配置文件
        InputStream is = JedisPoolUtils.class.getClassLoader().getResourceAsStream("jedis.properties");
        //创建Properties对象
        Properties pro = new Properties();
        //关联文件
        try {
            pro.load(is);
        } catch (IOException e) {
            e.printStackTrace();
        }
        //获取数据,设置到JedisPoolConfig中
        JedisPoolConfig config = new JedisPoolConfig();
        config.setMaxTotal(Integer.parseInt(pro.getProperty("maxTotal")));
        config.setMaxIdle(Integer.parseInt(pro.getProperty("maxIdle")));

        //初始化JedisPool
        JedisPool jedisPool = new JedisPool(config, pro.getProperty("host"), Integer.parseInt(pro.getProperty("port")));
    }
    //获取连接方法
    public static Jedis getJedis(){
        return jedisPool.getResource();
    }
}
//jedis连接池工具类使用
    @Test
    public void test8(){
        //通过连接池工具类获取
        Jedis jedis = JedisPoolUtils.getJedis();
        //使用
        jedis.set("hello", "world");
        //关闭 归还到连接池中
        jedis.close();
    }
举报

相关推荐

0 条评论