Java中Redis如何使用

这篇文章给大家介绍Java中redis如何使用，内容非常详细，感兴趣的小伙伴们可以参考借鉴，希望对大家能有所帮助。

滨海新区ssl适用于网站、小程序/APP、API接口等需要进行数据传输应用场景，ssl证书未来市场广阔！成为成都创新互联的ssl证书销售渠道，可以享受市场价格4-6折优惠！如果有意向欢迎电话联系或者加微信：13518219792（备注：SSL证书合作）期待与您的合作！

1、安装

Redis 支持 32 位和 64 位。这个需要根据你系统平台的实际情况选择，这里我们下载 Redis-x64-3.2.100.zip压缩包，并解压至磁盘指定文件夹

2、启动

打开文件夹，内容如下：

双击redis-server启动redis，这时Redis默认地址是127.0.0.1，端口号是6379

双击 redisclient-win32.x86.2.0.exe，即可运行，运行如图

3、Java使用Redis

在maven下添加以下内容，引入jedis

	redis.clients
	jedis
	2.9.0

编写对象序列化与反序列化工具类

package com.jedis.util;

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;


public class SerializeUtil {
    /*
     * 序列化
     * */
    public static byte[] serizlize(Object object){
        ObjectOutputStream oos = null;
        ByteArrayOutputStream baos = null;
        try {
            baos = new ByteArrayOutputStream();
            oos = new ObjectOutputStream(baos);
            oos.writeObject(object);
            byte[] bytes = baos.toByteArray();
            return bytes;
        } catch (Exception e) {
            e.printStackTrace();
        }finally {
            try {
                if(baos != null){
                    baos.close();
                }
                if (oos != null) {
                    oos.close();
                }
            } catch (Exception e2) {
                e2.printStackTrace();
            }
        }
        return null;
    }
    /*
     * 反序列化
     * */
    public static Object deserialize(byte[] bytes){
        ByteArrayInputStream bais = null;
        ObjectInputStream ois = null;
        try{
            bais = new ByteArrayInputStream(bytes);
            ois = new ObjectInputStream(bais);
            return ois.readObject();
        }catch(Exception e){
            e.printStackTrace();
        }finally {
            try {
                if (ois != null) {
                    ois.close();
                }
                if(bais != null){
                    bais.close();
                }
            } catch (Exception e2) {
                e2.printStackTrace();
            }
        }
        return null;
    }

}

编写Jedis工具类

package com.jedis.util;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.stereotype.Component;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import java.util.Map;

public class JedisComponent {

    private JedisPool jedisPool;

    public JedisComponent(JedisPool jedisPool){
        this.jedisPool = jedisPool;
    }

    public  void setObject(String key,Object object){
        Jedis jedis = null;
        try {
            jedis = jedisPool.getResource();
            jedis.set(key.getBytes(), SerializeUtil.serizlize(object));
        } finally {
            if (jedis != null) {
                jedis.close();
            }
        }
    }
    public  Boolean exists(String key){
        Jedis jedis = null;
        try {
            jedis = jedisPool.getResource();
            return  jedis.exists(key);
        } finally {
            if (jedis != null) {
                jedis.close();
            }
        }
    }
    public  Object getObject(String key){
        Jedis jedis = null;
        try {
            jedis = jedisPool.getResource();
            byte[] bytes = jedis.get(key.getBytes());
            return SerializeUtil.deserialize(bytes);
        } finally {
            if (jedis != null) {
                jedis.close();
            }
        }
    }
    public void setMap(String key, Map map) {
        Jedis jedis = null;
        try {
            jedis = jedisPool.getResource();
            jedis.hmset(key,map);
        } finally {
            if (jedis != null) {
                jedis.close();
            }
        }
    }
    public Map getMap(String key) {
        Jedis jedis = null;
        try {
            jedis = jedisPool.getResource();
           return  jedis.hgetAll(key);
        } finally {
            if (jedis != null) {
                jedis.close();
            }
        }
    }


    public void set(String key, String val) {
        Jedis jedis = null;
        try {
            jedis = jedisPool.getResource();
            jedis.set(key, val);
        } finally {
            if (jedis != null) {
                jedis.close();
            }
        }
    }

    public String get(String key) {
        Jedis jedis = null;
        try {
            jedis = jedisPool.getResource();
            return jedis.get(key);
        } finally {
            if (jedis != null) {
                jedis.close();
            }
        }
    }
    public void setKeyTime(String key,int time) {
        Jedis jedis = null;
        try {
            jedis = jedisPool.getResource();
            jedis.expire(key,time);
        } finally {
            if (jedis != null) {
                jedis.close();
            }
        }
    }
    public void delKey(String key) {
        Jedis jedis = null;
        try {
            jedis = jedisPool.getResource();
            jedis.del(key);
        } finally {
            if (jedis != null) {
                jedis.close();
            }
        }
    }
    public Long getKeyTime(String key) {
        Jedis jedis = null;
        try {
            jedis = jedisPool.getResource();
           return jedis.ttl(key);
        } finally {
            if (jedis != null) {
                jedis.close();
            }
        }
    }

    public Long removeKeyTime(String key){
        Jedis jedis = null;
        try {
            jedis = jedisPool.getResource();
            return jedis.persist(key);
        } finally {
            if (jedis != null) {
                jedis.close();
            }
        }
    }

}

编写测试对象Student

package com.jedisTest;

import java.io.Serializable;

/**
 * Created by Administrator on 2019/7/16 0016.
 */
public class Student implements Serializable{

    private static final long serialVersionUID = 8562001374896568949L;

    private String fid;

    private String name;

    private Integer age;

    public String getFid() {
        return fid;
    }

    public void setFid(String fid) {
        this.fid = fid;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public Integer getAge() {
        return age;
    }

    public void setAge(Integer age) {
        this.age = age;
    }

    @Override
    public String toString() {
        return "Student{" +
                "fid='" + fid + '\'' +
                ", name='" + name + '\'' +
                ", age='" + age + '\'' +
                '}';
    }
}

最后编写main方法测试

package com.jedisTest;

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

import java.util.HashMap;
import java.util.Map;
import java.util.UUID;

/**
 * Created by Administrator on 2019/7/16 0016.
 */
public class JedisTest {
    //路由
    private static String host="127.0.0.1";

    //端口号
    private static int port=6379;
    //超时
    private static int timeout=10000;

    //    private String password="supermap";
    //连接池最大连接数（使用负值表示没有限制）
    private static int maxActive=1024;

    //连接池中的最大空闲连接
    private static int maxIdle=200;

    //连接池中最小空闲连接
    private static int minIdle=0;
    //最大等待
    private static long maxWaitMillis=10000;

    public static void main(String[] args){

        JedisPool jedisPool = null;
        try{
            JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
            jedisPoolConfig.setMaxIdle(maxIdle);
            jedisPoolConfig.setMaxWaitMillis(maxWaitMillis);
            jedisPoolConfig.setMaxTotal(maxActive);
            jedisPoolConfig.setMinIdle(minIdle);
            jedisPool = new JedisPool(jedisPoolConfig,host,port,timeout,null);
            System.out.println("JedisPool资源池注入成功！");
            System.out.println("redis地址：" + host + ":" + port);

            JedisComponent jedisComponent = new JedisComponent(jedisPool);//实例化JedisComponent工具类

            //字符串的操作
            String today = "2019-07-16";

            jedisComponent.set("date", today);//将字符串today存入Redis
            String value = jedisComponent.get("date");//将key为date的value取出
            System.out.println("今天的日期是：" + value);//打印value到控制台

            jedisComponent.setKeyTime("date",10);//给date设置过期时间,单位是秒

            Boolean date = jedisComponent.exists("date");//判断key为date的数据是否存在

            jedisComponent.removeKeyTime("date");//删除date的过期时间

            jedisComponent.delKey("date");//删除key为date的数据



            //对象的操作
            Student stuSave1 = new Student();
            stuSave1.setFid(UUID.randomUUID().toString());
            stuSave1.setName("小明");
            stuSave1.setAge(10);

            jedisComponent.setObject("stu1",stuSave1);//将stu1序列化存入Redis


            Student stuGet1 = (Student) jedisComponent.getObject("stu1");//将stu1反序列化取出
            System.out.println(stuGet1.toString());//打印stuGet1到控制台

            jedisComponent.setKeyTime("stu1",10);//给stu1设置过期时间,单位是秒

            //Map集合操作
            Map map = new HashMap<>();//Redis只支持Map集合键值都为String类型的存取
            map.put("水果","香蕉");
            map.put("家具","沙发");
            jedisComponent.setMap("map", map);//将map存入Redis
            Map map1 = jedisComponent.getMap("map");//将key为map从Redis取出
            if(map1 != null){

                for (Map.Entry entry : map1.entrySet()) {
                    System.out.println("key = " + entry.getKey() + ", value = " + entry.getValue());
                }

            }

            jedisComponent.delKey("map");//删除key为map的数据


        }catch (Exception e){
            e.printStackTrace();
        }finally {
            jedisPool.close();//最后关闭JedisPool资源池
        }
    }
}

控制台输出

关于Java中Redis如何使用就分享到这里了，希望以上内容可以对大家有一定的帮助，可以学到更多知识。如果觉得文章不错，可以把它分享出去让更多的人看到。