首页 > 代码库 > java使用redis数据库

java使用redis数据库

使用maven管理jar,添加依赖:   

<dependency>

     <groupId>redis.clients</groupId>

     <artifactId>jedis</artifactId>

     <version>2.7.0</version>

 </dependency>//需要的jar

使用redis数据库的配置(设置属性的值,可以根据具体需要),存数据

  JedisPool jedisPool = null;

        JedisPoolConfig poolConfig = new JedisPoolConfig();

        poolConfig.setMaxIdle(10);

        poolConfig.setMaxTotal(100);

        poolConfig.setMaxWaitMillis(10000);

        poolConfig.setTestOnBorrow(true);

        jedisPool = new JedisPool(poolConfig, "192.168.0.109", 6379);    //配置Jedis的配置,端口,服务器地址

存储过程

  List<String> lines = Files.readAllLines(Paths.get("E:/oooooooo/task.txt"));//要存储的数据源,数据格式多为json形式的字符串

        Jedis jedis = jedisPool.getResource();

        jedis.select(3);// 3是指在把数据库上的分区,可以自由设置

        Pipeline pipelined = jedis.pipelined();

        lines.forEach(l -> {

            pipelined.lpush(数据库名, l);

        });

        pipelined.sync(); //这段代码的作用是通过管道(Pipeline)批量存储到redis数据库

通过java获取redis上的数据

  JedisPoolConfig poolConfig = new JedisPoolConfig();

        poolConfig.setMaxIdle(10);

        poolConfig.setMaxTotal(500);

        poolConfig.setMaxWaitMillis(100000);

        poolConfig.setTestOnBorrow(true);

        jedisPool = new JedisPool(poolConfig, 服务器地址, 端口, timeout, 数据库密码);

  Jedis jedis = jedisPool.getResource();

   jedis.select(3);// 3是指在把数据库上的分区,可以自由设置

       String targetString = jedis.lpop(数据库名);;//targetString就是取出来的目标数据

  jedisPool.returnResourceObject(jedis); //一顿操作之后,记得释放jedis的资源

java使用redis数据库