Java操作redis【二十】

1.首先需要将redis的绑定地址为127.0.0.1去掉，同时将redis的保护模式去掉，并且开放6379端口。

　　如果是保护模式需要输入密码才能连接。

(1)去掉绑定地址:

(2)去掉保护模式:

(3)linux中开放6379端口

/sbin/iptables -I INPUT -p tcp --dport 6379 -j ACCEPT

iptables-save

2.Java操作redis

(1)导包:

(2)基本的测试

    // 通过Java程序访问redis

    @Test

    public void test1() {

        //1、获得连接对象

        Jedis jedis = new Jedis("192.168.43.101", 6379);

        //2、获得数据

        String username = jedis.get("str3");

        System.out.println(username);

        //3、存储

        jedis.set("addr", "北京");

        System.out.println(jedis.get("addr"));

        Set<String> keys = jedis.keys("*");

        for (String s:keys){

            System.out.println("key---"+s+"      value---"+jedis.get(s));

        }

    }

(3)使用JedisPoolConfig操作redis

//通过jedis的pool获得jedis连接对象

    @Test

    public void test2(){

        //0、创建池子的配置对象

        JedisPoolConfig poolConfig = new JedisPoolConfig();

        poolConfig.setMaxIdle(30);//最大闲置个数

        poolConfig.setMinIdle(10);//最小闲置个数

        poolConfig.setMaxTotal(50);//最大连接数

        //1、创建一个redis的连接池

        JedisPool pool = new JedisPool(poolConfig, "192.168.43.101", 6379);

        //2、从池子中获取redis的连接资源

        Jedis jedis = pool.getResource();

        //3、操作数据库

        jedis.set("xxx","yyyy");

        System.out.println(jedis.get("xxx"));

        //4、获得数据

        String username = jedis.get("str3");

        System.out.println(username);

        //4、关闭资源

        jedis.close();

        pool.close();

    }

3.封装redis连接操作redis:

(1)src目录下redis.properties

redis.maxIdle=30

redis.minIdle=10

redis.maxTotal=100

redis.url=192.168.43.101

redis.port=6379

(2)封装连接并进行测试:

package RedisTest;

import java.io.IOException;

import java.io.InputStream;

import java.util.Properties;

import redis.clients.jedis.Jedis;

import redis.clients.jedis.JedisPool;

import redis.clients.jedis.JedisPoolConfig;

public class JedisPoolUtils {

    private static JedisPool pool = null;

    static{

        //加载配置文件

        InputStream in = JedisPoolUtils.class.getClassLoader().getResourceAsStream("redis.properties");

        Properties pro = new Properties();

        try {

            pro.load(in);

        } catch (IOException e) {

            e.printStackTrace();

        }

        //获得池子对象

        JedisPoolConfig poolConfig = new JedisPoolConfig();

        poolConfig.setMaxIdle(Integer.parseInt(pro.get("redis.maxIdle").toString()));//最大闲置个数

        poolConfig.setMinIdle(Integer.parseInt(pro.get("redis.minIdle").toString()));//最小闲置个数

        poolConfig.setMaxTotal(Integer.parseInt(pro.get("redis.maxTotal").toString()));//最大连接数

        pool = new JedisPool(poolConfig,pro.getProperty("redis.url") , Integer.parseInt(pro.get("redis.port").toString()));

    }

    //获得jedis资源的方法

    public static Jedis getJedis(){

        return pool.getResource();

    }

    public static void main(String[] args) {

        Jedis jedis = getJedis();

        System.out.println(jedis.get("str3"));

    }

}

总结: jedis封装了很多对redis操作的方法，方法的名字都是以redis中的方法命名的，我们可以直接使用。

例如:

巴特西

Java操作redis【二十】

最新文章

热门文章