SSM中操作Redis—Jedis

SSM中操作Redis——Jedis

1、Jedis

• jedis是基于java的redis客户端，集成了redis的命令操作，提供了连接池管理
  
• jedis的方法就是redis的命令
  

2、导入依赖

1. <dependency>
2.     <groupId>redis.clients</groupId>
3.     <artifactId>jedis</artifactId>
4.     <version>2.9.0</version>
5. </dependency>
6. <dependency>
7.     <groupId>junit</groupId>
8.     <artifactId>junit</artifactId>
9.     <version>4.12</version>
10. </dependency>
11. <dependency>
12.     <groupId>org.projectlombok</groupId>
13.     <artifactId>lombok</artifactId>
14.     <version>1.18.12</version>
15.     <scope>provided</scope>
16. </dependency>

复制代码

3、简单使用

1. @Test
2. public void quickTest() throws Exception {
3.     // 参数一：redis服务器ip
4.     // 参数二：redis服务器的端口号
5.     Jedis jedis = new Jedis("192.168.27.132", 6379);
6.     String name = jedis.set("name", "zhangsan");
7.     System.out.println("name = " + name);
8.     String value = jedis.get("name");
9.     System.out.println("value = " + value);
10. }

复制代码

4、连接池使用

1. @Test
2. public void JedisPoolTestDemo() {
3.     GenericObjectPoolConfig poolConfig = new GenericObjectPoolConfig();
4.     String host = "192.168.27.132";
5.     int port = 6379;
6.     int timeout = 5000;
7.     //产生连接池对象
8.     JedisPool jedisPool = new JedisPool(poolConfig, host, port, timeout);
9.     Jedis jedis = jedisPool.getResource();
10.     jedis.set("name","张三");
11.     jedis.set("name1","张三1");
12.     jedis.set("name2","张三2");
13.     jedis.hset("person","name","李四");
14.     jedis.hset("person","name1","李四1");
15.     jedis.hset("person","name2","李四2");
17.     System.out.println(jedis.get("name"));
18.     System.out.println(jedis.get("name1"));
19.     System.out.println(jedis.get("name2"));
20.     Map<String, String> person = jedis.hgetAll("person");
21.     System.out.println("person = " + person);
22.     //关闭后归还到连接池
23.     jedis.close();
24. }

复制代码

5、工具类封装连接池

1. public class JedisPoolUtils {
2.     private  static JedisPool jedisPool = null;
4.     private static final String HOST = "192.168.27.132";
5.     private static final int PORT = 6379;
6.     private static final int TIMEOUT = 3000;
7.     static {
8.         GenericObjectPoolConfig poolConfig = new GenericObjectPoolConfig();
9.         jedisPool = new JedisPool(poolConfig,HOST,PORT,TIMEOUT);
10.     }
12.     public static Jedis getResource() {
13.         return jedisPool.getResource();
14.     }
15. }

复制代码

6、连接池工具类使用

1. Jedis jedis = JedisPoolUtils.getResource(); //在连接池中获取jedis连接对象
2. String name = jedis.get("name");
3. System.out.println("name = " + name);
4. jedis.close();//关闭并归还连接

复制代码

7、Jedis保存一个对象

• 可以通过json保存
  
• 也可以通过字节存储
  

7.1 通过json存储

思路：将创建好的对象转成json格式字符串，存储到redis中

1. //创建对象
2. Device device = new Device();
3. device.setId(1);
4. device.setDeviceName("挖掘机");
5. device.setPrice(30000D);
7. //json转换
8. ObjectMapper objectMapper = new ObjectMapper();
9. String json = objectMapper.writeValueAsString(device);
11. //获取jedis对象
12. Jedis jedis = JedisPoolUtils.getResource();
13. //存储对象
14. jedis.set("device:" + device.getId(), json);
16. String deviceString = jedis.get("device:" + device.getId());
17. System.out.println("deviceString = " + deviceString);
18. //归还连接到连接池
19. jedis.close();

复制代码

7.2 字节存储

思路：

• 将创建好的对象序列化为字节数组，存储到redis中
  
• 从redis中获取字节数组，并将字节数组反序列化为对象
  

1. //创建对象
2. Device device = new Device();
3. device.setId(1);
4. device.setDeviceName("挖掘机");
5. device.setPrice(30000D);
6. //获取jedis对象
7. Jedis jedis = JedisPoolUtils.getResource();
8. //对象转换为字节数组，使用SerializationUtils的serialize()方法
9. byte[] key = ("device:" + device.getId()).getBytes();
10. byte[] value = SerializationUtils.serialize(device);
12. //存储字节
13. jedis.set(key, value);
15. //获取key对应的value
16. byte[] bytes = jedis.get(key);
18. //SerializationUtils的deserialize()方法 将字节转为对象
19. Device device1 = (Device) SerializationUtils.deserialize(bytes);
20. System.out.println(device1);
22. //归还连接到连接池
23. jedis.close();

复制代码

8、Jedis管道操作

当我们有10000条数据要存储到redis中，使用原始方式存：

1. @Test
2. public void tenThousandTest(){
3.     Jedis jedis = JedisPoolUtils.getResource();
4.     long start = System.currentTimeMillis();
5.     for (int i = 0; i < 10000; i++) {
6.         jedis.set("i:"+i,"v:"+i);
7.     }
8.     System.out.println(System.currentTimeMillis()-start);//大概4秒
9.     jedis.close();
10. }

复制代码

当执行完之后得到时间差，发现用时大概4秒。
为什么redis读写性能优异，却花费了4秒钟？

使用过查看redis性能命令的小伙伴会发现读写的性能能达到100000次/s
据官方的bench-mark数据：读的速度是110000次/s,写的速度是81000次/s

1. #redis写的性能
2. redis-benchmark set
4. #redis读的性能
5. redis-benchmark get

复制代码

那为什么在这里执行10000次写却用了4秒钟，是不是redis性能不靠谱啊

其实不然，我们仔细想一下，我们的jedis程序和redis服务器是在不同服务器上，
那Jedis的数据要保存到redis中就要通过网络传输
对于上面代码而言，每写一个就要传一个到redis中，一共要发送10000次，这之间消耗的时间是比较久的，也就对代码执行完之后计算得出的时间产生了影响。

• 其实redis的读写性能是ok的，其瓶颈在于传输性能上。
  

那有什么提升jedis传输性能的方法呢

有，Jedis提供了一个pipelined()，也就是管道操作，我们来看升级后的代码

1. @Test
2. public void test(){
3.     Jedis jedis = JedisPoolUtils.getResource();
4.     Long start = System.currentTimeMillis();
5.     Pipeline pipelined = jedis.pipelined();
6.     for (int i = 0; i < 10000; i++) {
7.         pipelined.set("k:"+i,"v:"+i);
8.     }
9.     System.out.println(System.currentTimeMillis()-start);//55毫秒
10.     jedis.close();
11. }

复制代码

最后测试发现执行几乎瞬间完成，用时55毫秒，比4秒提升了70多倍。
为什么管道操作那么快

它将所有操作都打包，一次性发给redis服务器，由原先一万次的传输变为一次传输，大大提高了传输性能，节省了时间。
而redis接收到之后做一万次写入，一万次写入对于redis来说小菜一碟。

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！