logo
搜索
我的图书馆

发文章

发文工具

其他工具

留言交流
搜索
分享

java连接redis存取数据(详细)

 三十的狼 2020-12-17

声明:本文章仅供参考,学无止境,若有不足之处请指出,非常感谢!

源代码+相关工具下载:https://download.csdn.net/download/corleone_4ever/10811258

目录

一.相关工具

二.准备工作

三.新建jedis项目

四.编写代码

五.连接测试

六.注意事项

一.相关工具

 

如果没有服务器的同学,可以在自己的电脑安装虚拟机,我这里使用的是:VMware10+centos7+redis5.0

贴出 VMware10+centos7 下载地址:https://download.csdn.net/download/corleone_4ever/10812834

 

开发工具用的myeclipse2014

jdk版本为1.7

 

 

java连接redis所需依赖jar包:

jedis-2.9.0.jar (redis连接工具)

commons-pool2-2.6.0.jar (jedis连接池)

fastjson-1.2.2.jar (阿里的json序列化工具)

junit-4.12.jar (单元测试)

贴出demo下载地址(包含vm10+centos7+redis5.0+jedis连接依赖jar包及其相关工具文档):

https://download.csdn.net/download/corleone_4ever/10811258

二.准备工作

在通过java连接redis之前,首先得配置好java环境

安装好redis,并且能通过外部访问(需要关闭对应防火墙)

1.启动redis 

2.输入ifconfig获取本机ip,通过外部连接测试,我这里使用的是RedisDesktopManager

 3.新建连接,输入你自己的ip,redis端口和密码,没有密码就不输入

 4.连接成功


 

 

三.新建jedis项目

1.新建项目:右键→new→other→选择web下的Dynamic Web Project

2.这里项目名称为jedis

 

3.引入相关jar包,直接把依赖jar包复制到WEB-INF下的lib目录下

4.引入 junit:右键项目→properties-→ava build parh→Libraries→ADD Library→Junit→Finish

这里也可以直接引用junit包,我是用的myeclipse自带的

 5.新建包com.redis.test   项目结构如下

 四.编写代码

这里直接贴出代码

1.redis.properties : redis连接配置文件

连接池配置参考:https://blog.csdn.net/wx5040257/article/details/78474157

  1. #redis服务器ip
  2. redis.ip=192.168.10.21
  3. #redis服务器端口号
  4. redis.port=6379
  5. #redis密码
  6. redis.passWord=
  7. #与服务器建立连接的超时时间
  8. redis.timeout=3000
  9. #jedis的最大活跃连接数
  10. pool.maxTotal=10
  11. #jedis最大空闲连接数
  12. pool.maxIdle=3
  13. #jedis池没有连接对象返回时，等待可用连接的最大时间，单位毫秒，默认值为-1，表示永不超时。
  14. #如果超过等待时间，则直接抛出JedisConnectionException
  15. pool.maxWaitMillis=3000

2.RedisPoolUtil : 连接池配置工具

这里使用单例模式+双重锁定写的一个redis连接池配置工具(如需xml配置连接池,自行百度,原理相同)

  1. package com.redis.test;
  3. import java.util.Properties;
  5. import redis.clients.jedis.Jedis;
  6. import redis.clients.jedis.JedisPool;
  7. import redis.clients.jedis.JedisPoolConfig;
  8. import redis.clients.jedis.exceptions.JedisConnectionException;
  10. /**
  11.  * jedis连接池工具
  12.  * @author corleone
  13.  * @date 2018年11月27日
  14.  */
  15. public class RedisPoolUtil {
  16. private volatile  static JedisPool jedisPool = null;
  17. private static String redisConfigFile = "redis.properties";
  18. //把redis连接对象放到本地线程中
  19. private static ThreadLocal<Jedis> local=new ThreadLocal<Jedis>();
  20. private RedisPoolUtil() {
  21. }
  23. /**
  24.  * 初始化连接池
  25.  * @author corleone
  26.  * @date 2018年11月27日
  27.  */
  28. public static void initialPool() {
  29. try {
  30. Properties props = new Properties();
  31. //加载连接池配置文件
  32. props.load(RedisPoolUtil.class.getClassLoader().getResourceAsStream(redisConfigFile));
  33. // 创建jedis池配置实例
  34. JedisPoolConfig config = new JedisPoolConfig();
  35. // 设置池配置项值
  36. config.setMaxTotal(Integer.valueOf(props.getProperty("pool.maxTotal")));
  37. config.setMaxIdle(Integer.valueOf(props.getProperty("pool.maxIdle")));
  38. config.setMaxWaitMillis(Long.valueOf(props.getProperty("pool.maxWaitMillis")));
  39. // 根据配置实例化jedis池
  40. jedisPool = new JedisPool(config, props.getProperty("redis.ip"),
  41. Integer.valueOf(props.getProperty("redis.port")),
  42. Integer.valueOf(props.getProperty("redis.timeout")),
  43. "".equals(props.getProperty("redis.passWord"))?null:props.getProperty("redis.passWord"));
  44. System.out.println("连接池初始化成功");
  45. } catch (Exception e) {
  46. e.printStackTrace();
  47. System.err.println("连接池初始化失败");
  48. }
  49. }
  51. /**
  52.  * 获取连接
  53.  * @return 
  54.  * @author corleone
  55.  * @date 2018年11月27日
  56.  */
  57. public static Jedis getInstance() { 
  58. //Redis对象
  59.         Jedis jedis =local.get();
  60.         if(jedis==null){
  61.         if (jedisPool == null) {    
  62.             synchronized (RedisPoolUtil.class) {
  63.     if (jedisPool == null) {
  64.     initialPool(); 
  65.     }
  66.     }
  67.             }
  68.         try{
  69.         jedis = jedisPool.getResource();
  70.         }catch(JedisConnectionException e){
  71.         e.printStackTrace();
  72.         }
  74.         local.set(jedis);
  75.         }
  76.         return jedis;  
  77.     }
  79. /**
  80.  * 关闭连接
  81.  * @author corleone
  82.  * @date 2018年11月27日
  83.  */
  84. public static void closeConn(){
  85. Jedis jedis =local.get();
  86. if(jedis!=null){
  87. jedis.close();
  88. }
  89. local.set(null);
  90. }
  92. }

3.SerializeUtil : java序列化/反序列化封装工具

  1. package com.redis.test;
  3. import java.io.ByteArrayInputStream;
  4. import java.io.ByteArrayOutputStream;
  5. import java.io.ObjectInputStream;
  6. import java.io.ObjectOutputStream;
  8. /**
  9.  * java序列化/反序列化工具
  10.  * @author corleone
  11.  * @date 2018年11月27日
  12.  */
  13. public class SerializeUtil {
  16.     /**
  17.      * 序列化
  18.      * @param object
  19.      * @author corleone
  20.      * @date 2018年11月27日
  21.      */
  22.     public static byte[] serizlize(Object object){
  23.         ObjectOutputStream oos = null;
  24.         ByteArrayOutputStream baos = null;
  25.         try {
  26.             baos = new ByteArrayOutputStream();
  27.             oos = new ObjectOutputStream(baos);
  28.             oos.writeObject(object);
  29.             byte[] bytes = baos.toByteArray();
  30.             return bytes;
  31.         } catch (Exception e) {
  32.             e.printStackTrace();
  33.         }finally {
  34.             try {
  35.                 if(baos != null){
  36.                     baos.close();
  37.                 }
  38.                 if (oos != null) {
  39.                     oos.close();
  40.                 }
  41.             } catch (Exception e2) {
  42.                 e2.printStackTrace();
  43.             }
  44.         }
  45.         return null;
  46.     }
  49.     /**
  50.      * 反序列化
  51.      * @param bytes
  52.      * @author corleone
  53.      * @date 2018年11月27日
  54.      */
  55.     public static Object deserialize(byte[] bytes){
  56.         ByteArrayInputStream bais = null;
  57.         ObjectInputStream ois = null; 
  58.         try{
  59.             bais = new ByteArrayInputStream(bytes);
  60.             ois = new ObjectInputStream(bais);
  61.             return ois.readObject();
  62.         }catch(Exception e){
  63.             e.printStackTrace();
  64.         }finally {
  65.             try {
  67.             } catch (Exception e2) {
  68.                 e2.printStackTrace();
  69.             }
  70.         }
  71.         return null;
  72.     }
  73. }

4.MapUtil : 对象与map相互转换封装工具

能够转换的对象需要该对象的属性必须是String或int类型,我这里只做演示,其他类型需要自己扩展

  1. package com.redis.test;
  3. import java.lang.reflect.Field;
  4. import java.lang.reflect.Method;
  5. import java.lang.reflect.Modifier;
  6. import java.util.HashMap;
  7. import java.util.Map;
  9. /**
  10.  * java反射机制
  11.  * 对象与map相互转换
  12.  * @author corleone
  13.  * @date 2018年11月14日
  14.  */
  15. public class MapUtil {
  17. /**
  18.  * map转对象(目前只支持对象中含有String和int类型的属性,其他类型需要自己扩展)
  19.  * @param map
  20.  * @param beanClass
  21.  * @throws Exception 
  22.  * @author corleone
  23.  * @date 2018年11月27日
  24.  */
  25. public static <T> Object mapToObject(Map<String, String> map, Class<?> beanClass)
  26. throws Exception {
  27. if (map == null)
  28. return null;
  30. Object obj = beanClass.newInstance();
  32. Field[] fields = obj.getClass().getDeclaredFields();
  33. for (Field field : fields) {
  34. int mod = field.getModifiers();
  35. if (Modifier.isStatic(mod) || Modifier.isFinal(mod)) {
  36. continue;
  37. }
  39. field.setAccessible(true);
  40. if(field.getType().equals(int.class)){
  41. field.set(obj, Integer.parseInt(map.get(field.getName())));
  42. }else{
  43. field.set(obj, (Object)map.get(field.getName()));
  44. }
  46. }
  48. return obj;
  49. }
  51. /**
  52.  * 对象转map(目前只支持对象属性为基本类型)
  53.  * @param obj
  54.  * @throws Exception 
  55.  * @author corleone
  56.  * @date 2018年11月27日
  57.  */
  58. public static Map<String, String> objectToMap(Object obj) throws Exception {
  59. if (obj == null) {
  60. return null;
  61. }
  63. Map<String, String> map = new HashMap<String, String>();
  65. Field[] declaredFields = obj.getClass().getDeclaredFields();
  66. for (Field field : declaredFields) {
  67. field.setAccessible(true);
  68. map.put(field.getName(), field.get(obj).toString());
  69. }
  71. return map;
  72. }
  78. }

 

5.ReflectUtil : 通过反射根据对象属性名称获取对应属性的值(在实际项目中用aop实现连接redis的时候有用到,本次演示没有用到该工具类,所以不贴出代码,有兴趣可以下载demo自己研究下:一.相关工具)

6.RedisOps : jedis存取常用数据封装工具类

这里写了String类型和hash类型两种数据存取,如需要存取其他数据类型可以自己扩展

  1. package com.redis.test;
  5. import com.alibaba.fastjson.JSON;
  7. import redis.clients.jedis.Jedis;
  9. /**
  10.  * redis存取工具类
  11.  * @author corleone
  12.  * @date 2018年11月15日
  13.  */
  14. public class RedisOps {
  17. /**
  18.  * kv字符串存
  19.  * @param key
  20.  * @param value 
  21.  * @author corleone
  22.  * @date 2018年11月15日
  23.  */
  24.     public static void set(String key,String value){
  25.         Jedis jedis = RedisPoolUtil.getInstance();
  26.         jedis.set(key, value);
  27.          RedisPoolUtil.closeConn();
  28.     }
  30.     /**
  31.      * kv字符串取
  32.      * @param key
  33.      * @return 字符串
  34.      * @author corleone
  35.      * @date 2018年11月15日
  36.      */
  37.     public static String get(String key){
  38.         Jedis jedis = RedisPoolUtil.getInstance();
  39.         String value = jedis.get(key);
  40.          RedisPoolUtil.closeConn();
  41.         return value;
  42.     }
  43.     /**
  44.      * kv对象存(java序列化方式)
  45.      * @param key
  46.      * @param object 对象类必须实现序列化
  47.      * @author corleone
  48.      * @date 2018年11月15日
  49.      */
  50.     public static void setObjectSerialize(String key,Object object){
  51.         Jedis jedis = RedisPoolUtil.getInstance();
  52.         if(jedis==null){
  53.         return;
  54.         }
  55.         jedis.set(key.getBytes(), SerializeUtil.serizlize(object));
  56.          RedisPoolUtil.closeConn();
  57.     }
  59.     /**
  60.      * kv对象取(java反序列化)
  61.      * @param key
  62.      * @return 对象
  63.      * @author corleone
  64.      * @date 2018年11月15日
  65.      */
  66.     public static Object getObjectSerialize(String key){
  67.         Jedis jedis = RedisPoolUtil.getInstance();
  68.         if(jedis==null){
  69.         return null;
  70.         }
  71.         byte[] bytes = jedis.get(key.getBytes());
  72.          RedisPoolUtil.closeConn();
  73.          if(bytes==null){
  74.          return null;
  75.          }
  76.         return SerializeUtil.deserialize(bytes);
  77.     }
  79.     /**
  80.      * 删除key
  81.      * @param key 
  82.      * @author corleone
  83.      * @date 2018年11月15日
  84.      */
  85.     public static void del(String key){
  86.     Jedis jedis = RedisPoolUtil.getInstance();
  87.     if(jedis==null){
  88.     return;
  89.     }
  90.     jedis.del(key.getBytes());
  91.      RedisPoolUtil.closeConn();
  92.     }
  95.     /**
  96.      * kv对象存(json方式)
  97.      * @param key
  98.      * @param object 
  99.      * @author corleone
  100.      * @date 2018年11月15日
  101.      */
  102.     public static void setObjectJson(String key,Object object){
  103.         Jedis jedis = RedisPoolUtil.getInstance();
  104.         if(jedis==null){
  105.         return;
  106.         }
  107.         jedis.set(key, JSON.toJSONString(object));
  108.          RedisPoolUtil.closeConn();
  109.     }
  110.     /**
  111.      * kv对象取(json方式)
  112.      * @param key
  113.      * @param clazz反序列化对象类型
  114.      * @return 对象
  115.      * @author corleone
  116.      * @date 2018年11月15日
  117.      */
  118. @SuppressWarnings({ "unchecked" })
  119. public static <T> Object getObjectJson(String key,Class<?> clazz){
  120.         Jedis jedis = RedisPoolUtil.getInstance();
  121.         if(jedis==null){
  122.         return null;
  123.         }
  124.         String result= jedis.get(key);
  125.          RedisPoolUtil.closeConn();
  126.          if(result==null){
  127.          return null;
  128.          }
  129.          T obj=(T)JSON.parseObject(result,clazz);
  130.         return obj;
  131.     }
  133. /**
  134.  * kv对象存(map形势)
  135.  * @param key
  136.  * @param u
  137.  * @throws Exception 
  138.  * @author corleone
  139.  * @date 2018年11月27日
  140.  */
  141. public static void setObjectHash(String key, Object u) throws Exception {
  142. Jedis jedis = RedisPoolUtil.getInstance();
  143.         if(jedis==null){
  144.         return ;
  145.         }
  146.         jedis.hmset(key, MapUtil.objectToMap(u));
  147.         RedisPoolUtil.closeConn();
  149. }
  151. /**
  152.  * kv对象取(map形势)
  153.  * @param key
  154.  * @param clazz
  155.  * @throws Exception 
  156.  * @author corleone
  157.  * @date 2018年11月27日
  158.  */
  159. public static Object getObjectHash(String key,Class<?> clazz) throws Exception {
  160.  Jedis jedis = RedisPoolUtil.getInstance();
  161.         if(jedis==null){
  162.         return null;
  163.         }
  164.         Object obj = MapUtil.mapToObject(jedis.hgetAll(key), clazz);
  165.          RedisPoolUtil.closeConn();
  166.          if(obj==null){
  167.          return null;
  168.          }
  169.         return obj;
  170. }
  171. }

7.User  Vehicle两个实体类  后者没有实现Serializable,不能用于java序列化存取

User

  1. package com.redis.test;
  3. import java.io.Serializable;
  5. /**
  6.  * 用户实体类
  7.  * @author corleone
  8.  * @date 2018年11月27日
  9.  */
  10. public class User implements Serializable {
  11.     private static final long serialVersionUID = -3210884885630038713L;
  12.     private int id;
  13.     private String name;
  14.     private int age;
  15.     public User(){
  17.     }
  18.     public User(int id,String name,int age){
  19.         this.id = id;
  20.         this.name = name;
  21.         this.age=age;
  22.     }
  23. public int getId() {
  24. return id;
  25. }
  26. public void setId(int id) {
  27. this.id = id;
  28. }
  29. public String getName() {
  30. return name;
  31. }
  32. public void setName(String name) {
  33. this.name = name;
  34. }
  35. public int getAge() {
  36. return age;
  37. }
  38. public void setAge(int age) {
  39. this.age = age;
  40. }
  41. @Override
  42. public String toString() {
  43. return "User [id=" + id + ", name=" + name + ", age=" + age + "]";
  44. }
  47. }

Vehicle

  1. package com.redis.test;
  3. /**
  4.  * 车辆实体类
  5.  * @author corleone
  6.  * @date 2018年11月27日
  7.  */
  8. public class Vehicle {
  9. private int id;
  11. private String platenumber;
  13. private String color;
  16.  public Vehicle(){
  18.     }
  19. public int getId() {
  20. return id;
  21. }
  23. public Vehicle(int id, String platenumber, String color) {
  24. this.id = id;
  25. this.platenumber = platenumber;
  26. this.color = color;
  27. }
  29. public void setId(int id) {
  30. this.id = id;
  31. }
  33. public String getPlatenumber() {
  34. return platenumber;
  35. }
  37. public void setPlatenumber(String platenumber) {
  38. this.platenumber = platenumber;
  39. }
  41. public String getColor() {
  42. return color;
  43. }
  45. public void setColor(String color) {
  46. this.color = color;
  47. }
  49. @Override
  50. public String toString() {
  51. return "Vehicle [id=" + id + ", platenumber=" + platenumber
  52. + ", color=" + color + "]";
  53. }
  56. }

8.JTest : jedis存取数据测试类

  1. package com.redis.test;
  3. import org.junit.Test;
  5. import redis.clients.jedis.Jedis;
  7. /**
  8.  * jedis存取测试
  9.  * @author corleone
  10.  * @date 2018年11月27日
  11.  */
  12. public class JTest {
  14. /**
  15.  * 测试连接
  16.  * @author corleone
  17.  * @date 2018年11月27日
  18.  */
  19. @Test
  20. public void TestPing(){
  21. Jedis jedis = RedisPoolUtil.getInstance();
  22. System.out.println(jedis.ping());
  23. }
  25. /**
  26.  * 测试java序列化存取
  27.  * @author corleone
  28.  * @date 2018年11月27日
  29.  */
  30. @Test
  31. public void TestSerialize(){
  32. User u = new User(1,"小明",6);
  33. RedisOps.setObjectSerialize(User.class.getName().toString()+":"+1, u);
  34. User u2 = (User)RedisOps.getObjectSerialize(User.class.getName().toString()+":"+1);
  35. System.out.println(u2.toString());
  36. }
  38. /**
  39.  *  测试json序列化存取
  40.  * @author corleone
  41.  * @date 2018年11月27日
  42.  */
  43. @Test
  44. public void TestJson(){
  45. User u = new User(1,"小明",6);
  46. Vehicle v = new Vehicle(1,"渝A00000","蓝色");
  47. RedisOps.setObjectJson(User.class.getName().toString()+":"+1, u);
  48. RedisOps.setObjectJson(Vehicle.class.getName().toString()+":"+1, v);
  49. User u2 = (User)RedisOps.<User>getObjectJson(User.class.getName().toString()+":"+1,User.class);
  50. Vehicle v2 = (Vehicle)RedisOps.<Vehicle>getObjectJson(Vehicle.class.getName().toString()+":"+1,Vehicle.class);
  51. System.out.println(u2.toString());
  52. System.out.println(v2.toString());
  53. }
  55. /**
  56.  * 测试hash存取
  57.  * @throws Exception 
  58.  * @author corleone
  59.  * @date 2018年11月27日
  60.  */
  61. @Test
  62. public void TestHash() throws Exception{
  63. Vehicle v = new Vehicle(1,"渝A00000","蓝色");
  64. RedisOps.setObjectHash(Vehicle.class.getName().toString()+":"+1, v);
  65. Vehicle v2=(Vehicle) RedisOps.getObjectHash(Vehicle.class.getName().toString()+":"+1,Vehicle.class);
  66. System.out.println(v2.toString());
  67. }
  69. }

五.连接测试

这里以json序列化存取对象为例

1.执行TestJson方法成功

2.查看redis中的数据

 六.注意事项

这里都是踩坑过来的,把我遇到过的问题也贴出来

1.外部无法连接:一般是linux防火墙未关闭的原因,这里特别注意centos7关闭防火墙与之前版本不一样,如果你用的centos7,那么请整对centos7进行百度

2.如果你的redis没有密码,请不要输入空字符串

3.java序列化存取对象,记得实现Serializable

4.如果你的实体类添加了有参构造方法,请重写无参构造方法,否则报如下错误

 

后续贴出springAOP实现redis连接,以及本人在实际业务中的存取方式,如有不足感谢指出!

   

    本站是提供个人知识管理的网络存储空间，所有内容均由用户发布，不代表本站观点。请注意甄别内容中的联系方式、诱导购买等信息，谨防诈骗。如发现有害或侵权内容，请点击一键举报。
    转藏 分享 献花（0）

    来自： 三十的狼 > 《jedis》

    举报/认领

    0条评论

    发表

    请遵守用户 评论公约

    类似文章 更多