189 8069 5689
这篇文章给大家介绍Java中redis如何使用，内容非常详细，感兴趣的小伙伴们可以参考借鉴，希望对大家能有所帮助。
滨海新区ssl适用于网站、小程序/APP、API接口等需要进行数据传输应用场景，ssl证书未来市场广阔！成为成都创新互联的ssl证书销售渠道，可以享受市场价格4-6折优惠！如果有意向欢迎电话联系或者加微信：13518219792（备注：SSL证书合作）期待与您的合作！
Redis 支持 32 位和 64 位。这个需要根据你系统平台的实际情况选择，这里我们下载 Redis-x64-3.2.100.zip压缩包，并解压至磁盘指定文件夹
打开文件夹，内容如下：
双击redis-server启动redis，这时Redis默认地址是127.0.0.1，端口号是6379
双击 redisclient-win32.x86.2.0.exe，即可运行，运行如图
在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如何使用就分享到这里了，希望以上内容可以对大家有一定的帮助，可以学到更多知识。如果觉得文章不错，可以把它分享出去让更多的人看到。