Redis入门第三讲——在Java程序中通过Jedis连接Redis

た入场券 2021-11-23 05:40 223阅读 0赞

# Jedis介绍 #

Redis不仅是使用命令来操作，现在基本上主流的语言都有客户端支持，比如Java、C、C\#、C++、php、Node.js、Go等。在官方网站里罗列了一些Java的客户端，有Jedis、Redisson、Jredis、JDBC-Redis等等，其中官方推荐使用Jedis和Redisson，在企业中用的最多的就是Jedis，所以下面我们就重点学习下Jedis。  
Jedis同样也是托管在github上，地址：[https://github.com/xetorthio/jedis][https_github.com_xetorthio_jedis]。

# Java连接Redis #

首先，你肯定是要创建一个动态的web项目的，然后导入如下两个jar包：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3llcmVueXVhbl9wa3U_size_16_color_FFFFFF_t_70]  
接下来，我就要讲讲在Java程序中如何通过Jedis连接Redis了。

## 通过单实例连接Redis ##

在src源码目录下新建一个包，例如com.meimeixia.jedis，并在该包下新建一个单元测试类——JedisTest.java。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3llcmVueXVhbl9wa3U_size_16_color_FFFFFF_t_70 1]  
这时，你一运行以上程序，就很有可能出现连接超时的现象，也即抛出如下异常：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3llcmVueXVhbl9wa3U_size_16_color_FFFFFF_t_70 2]  
为啥会报异常呢？因为Linux的防火墙默认只对外开放了一个22的端口，其他的端口（自然包括6379）都没打开。那又该怎么解决呢？很简单，把Linux的防火墙设置一下，让它对Redis的6379端口号放行即可。笔者使用的是CentOS 7.6这个版本的Linux系统，而CentOS 7.X默认使用的是firewalld作为防火墙，它与CentOS 6.X是不同的。  
那么怎样设置Linux CentOS 7.6的防火墙呢？首先，使用`cd /etc/firewalld/zones`命令切换到`/etc/firewalld/zones`目录中，然后使用`firewall-cmd --permanent --add-port=6379/tcp`命令来添加一个6379端口，修改成功之后需要使用`service firewalld restart`命令来重启firewalld服务。  
![在这里插入图片描述][20190725225258490.png]  
此时，有可能你运行上面的程序，还是会报错，比如抛出如下异常：

> Could not connect to Redis at 192.168.81.129:6379: Connection refused

我就出现过这种错误，确实令人恼火，那该咋解决呢？我在网上找到了解决方案——打开Redis的配置文件，即redis.conf，找到下面的内容。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3llcmVueXVhbl9wa3U_size_16_color_FFFFFF_t_70 3]  
修改redis.conf配置文件为  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3llcmVueXVhbl9wa3U_size_16_color_FFFFFF_t_70 4]  
此时，你再次运行单元测试类的test1方法，就会输出你想要的内容了。

## 通过连接池连接Redis ##

如果我们要通过Redis连接池获取一个连接Redis的资源，那么得首先创建该Redis连接池的配置对象，然后再使用此配置对象创建出连接池。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3llcmVueXVhbl9wa3U_size_16_color_FFFFFF_t_70 5]  
温馨提示：在实际开发中，Redis连接池是不会关闭掉的。  
像上面这样写代码，也不行啊！在实际开发中是不可能频繁地创建Redis连接池的，池子只须创建一次即可，所以，我们还得抽取一个工具类，专门用于创建Redis连接池（而且只创建一次）和从池子中获取连接Redis的资源。

package com.meimeixia.jedis;
    
    import redis.clients.jedis.Jedis;
    import redis.clients.jedis.JedisPool;
    import redis.clients.jedis.JedisPoolConfig;
    
    public class JedisPoolUtils { 
    	
    	private static JedisPool pool = null;
    	
    	static { 
    		//获得池子对象
    		JedisPoolConfig poolConfig = new JedisPoolConfig();
    		poolConfig.setMaxIdle(30);//设置最大闲置个数，
    		poolConfig.setMinIdle(10);//设置最小闲置个数
    		poolConfig.setMaxTotal(50);//设置最大连接数
    		pool = new JedisPool(poolConfig, "192.168.81.130", 6379);
    	}
    	
    	//获得jedis资源的方法
    	public static Jedis getJedis() { 
    		return pool.getResource();
    	}
    	
    	public static void main(String[] args) { 
    		Jedis jedis = getJedis();
    		System.out.println(jedis.get("xxx"));
    	}
    	
    }

像上面这样写不是不可以，但把Redis所在服务器的IP地址和端口号写死在程序中，着实有点不妥，那么有没有更加优秀一点的做法呢？我们可以在src源码目录下新建一个redis.properties配置文件，内容如下：  
![在这里插入图片描述][20190725232309878.png]  
这样子把Redis所在服务器的IP地址、端口号、…写在一个配置文件，然后在工具类中加载该配置文件，岂不更好！

package com.meimeixia.jedis;
    
    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 prop = new Properties();
    		try { 
    			prop.load(in);
    		} catch (IOException e) { 
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}
    		
    		//获得池子对象
    		JedisPoolConfig poolConfig = new JedisPoolConfig();
    		poolConfig.setMaxIdle(Integer.parseInt(prop.get("redis.maxIdle").toString()));//设置最大闲置个数，
    		poolConfig.setMinIdle(Integer.parseInt(prop.get("redis.minIdle").toString()));//设置最小闲置个数
    		poolConfig.setMaxTotal(Integer.parseInt(prop.get("redis.maxTotal").toString()));//设置最大连接数
    		pool = new JedisPool(poolConfig, prop.getProperty("redis.url"), Integer.parseInt(prop.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("xxx"));
    	}
    	
    }

[https_github.com_xetorthio_jedis]: https://github.com/xetorthio/jedis
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3llcmVueXVhbl9wa3U_size_16_color_FFFFFF_t_70]: /images/20211122/b451cc2bd74a4eefb561d959d2036631.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3llcmVueXVhbl9wa3U_size_16_color_FFFFFF_t_70 1]: /images/20211122/976859400ff745f69f6e035fe3f7a713.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3llcmVueXVhbl9wa3U_size_16_color_FFFFFF_t_70 2]: /images/20211122/8c00207b74f3473785069ab0619bbea0.png
[20190725225258490.png]: /images/20211122/1742049a83c546abb32e876a84802e1b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3llcmVueXVhbl9wa3U_size_16_color_FFFFFF_t_70 3]: /images/20211122/0900778e4efc441492a38a708ebe2073.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3llcmVueXVhbl9wa3U_size_16_color_FFFFFF_t_70 4]: /images/20211122/b9ebc1c7aff6452190b2fe98965c474f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3llcmVueXVhbl9wa3U_size_16_color_FFFFFF_t_70 5]: /images/20211122/54587e4d0ed54ebe9c22b3230784f098.png
[20190725232309878.png]: /images/20211122/8dbf527c33df4abdae5a02b79f57619d.png