Redis单机集群配置和java客户端

骑猪看日落 2022-09-27 04:00 230阅读 0赞

***Redis单机集群配置和java客户端***

**一.redis使用手册 **

**二.redis单机安装**

**三.redis的java单机客户端配置和调试**

**四.redis集群配置手册翻译和配置**

**五.redis的java集群客户端配置和调试**

**一.redis使用手册**

Redis的官网首页[https://redis.io/][https_redis.io]有基本介绍: 它是一个内存型数据结构存储系统，被用作数据库，缓存和中间件。另外有一个redis命令手册的中文网站:[http://doc.redisfans.com/][http_doc.redisfans.com]

**二.redis单机安装**

2.1 官网下载redis-3.2.6-.tar.gz(目前最新版是3.2.8)，解压后在主目录redis-3.2.6下，redis.conf是它的配置文件：

![Center][]

bind指定特定client可访问，注释掉则任意client可访问

port执行server开放的端口，默认6379

repass指密码，注释掉则不需要密码则可以访问

protected-mode值为yes，旨在提供保护模式，当bind和repass均注释时，只允许本地可访问。

2.2 启动redis服务器

需要指定redis.conf；如果不指定则默认在当前目录下寻找，所以如果不指定的话，当前目录需是redis.conf所在目录。

![Center 1][]

由于redis默认配置是bind本地，且配置密码，则本地启动client如下：

![Center 2][]

**三.redis单机客户端配置**(使用之前搭建的项目[http://download.csdn.net/detail/jintao\_ma/9661038][http_download.csdn.net_detail_jintao_ma_9661038])

3.1 添加maven依赖

<dependency>
    	    <groupId>redis.clients</groupId>
    	    <artifactId>jedis</artifactId>
    	    <version>2.9.0</version>
    	</dependency>

3.2 redis.properties(虚拟机中redis服务器地址为192.168.13.172,，另外由于使用java客户端调试，为方便，将redis.conf中bind注释掉)

redis.host = 192.168.13.172
    redis.port = 6379
    redis.password = 123456

springRedis.xml配置

<bean id="jedisPool" class="redis.clients.jedis.JedisPool">
    		<constructor-arg name="host" value="${redis.host}"></constructor-arg>
    		<constructor-arg name="port" value="${redis.port}"></constructor-arg>
    		<constructor-arg name="password" value="${redis.password}"></constructor-arg>
    		<constructor-arg name="timeout" value="3000"></constructor-arg>
    		<constructor-arg name="poolConfig" ref="jedisPoolConfig"></constructor-arg>
    	</bean>

JedisClient.java

package com.mycompany.jedis.dao;
    
    public interface JedisClient {
    	
    	/**获取缓存
    	 * @param key
    	 * @return
    	 */
    	String get(String key);
    
    	/**设置缓存
    	 * @param key
    	 * @param value
    	 * @return
    	 */
    	String set(String key, String value);
    }

JedisClientImpl.java

package com.mycompany.jedis.dao;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Repository;
    
    import redis.clients.jedis.Jedis;
    import redis.clients.jedis.JedisPool;
    
    @Repository("jedisClient")
    public class JedisClientImpl implements JedisClient{
    
    	@Autowired
    	private JedisPool jedisPool;
    	
    	@Override
    	public String get(String key) {
    		String value = null;
    		Jedis jedis = null;
    		try {
    			jedis = jedisPool.getResource();
    			value = jedis.get(key);
    		} catch (Exception e) {
    			e.printStackTrace();
    		} finally {
    			if(jedis!=null){
    				jedis.close();
    			}
    		}
    		return value;
    	}
    
    	@Override
    	public String set(String key, String value) {
    		Jedis jedis = null;
    		try {
    			jedis = jedisPool.getResource();
    			value = jedis.set(key, value);
    		} catch (Exception e) {
    			e.printStackTrace();
    		} finally {
    			if(jedis!=null){
    				jedis.close();
    			}
    		}
    		return value;
    	}
    	
    }

使用定时器跑类JedisTest.java：

package com.mycompany.mvc.quartz;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    
    import com.mycompany.jedis.dao.JedisClient;
    
    @Service("jedisTest")
    public class JedisTest {
    
    	@Autowired
    	private JedisClient jedisClient;
    	
    	public void JedisTestMain(){
    		jedisClient.set("tString","hello");
    		String tString  = jedisClient.get("tString");
    		System.out.println("JedisTest.JedisTestMain():"+tString);
    	}
    	
    }

至此，已完成。

**四.redis集群配置手册翻译和配置**

在配置和使用之前需要阅读文档，官方：[https://redis.io/topics/cluster-tutorial][https_redis.io_topics_cluster-tutorial]，最其中涉及到集群配置的部分进行翻译：[http://blog.csdn.net/jintao\_ma/article/details/60756645][http_blog.csdn.net_jintao_ma_article_details_60756645]

本例的配置如下：

4.1 redis.conf配置中，注释bind，注释repass，protected-mode设置为no

然后设置一下几个选项：

cluster-enabled yes
    cluster-config-file nodes.conf
    cluster-node-timeout 5000
    appendonly yes

4.2 redis主目录下新建目录cluster-test,然后cluster-test中新建子目录7000 7001 7002 7003 7004 7005，复制主目录的redis.conf到每个子目录中，修改端口port分别为7000 7001 7002 7003 7004 7005

在子目录中启动每个redis服务器：

cd 7000
    ../redis-server ./redis.conf

然后在每个子目录中会产生nodes.conf

![Center 3][]  
查看，会发现其中记录了序列号，用来作为该服务器的唯一标识![Center 4][]

4.3 下面需要创建集群

在每个server都启动后，然后创建集群。安装zlib，ruby，rubygem；如：yum -y install zlib，yum -y install ruby，yum -y install rubygem

安装完成后检验下：

![Center 5][]

之后可使用gem命令：

gem install redis

使用gem安装redis之后，接着就可以在redis主目录src目录下使用redis-trib.rb 这个ruby命令来创建集群：

./redis-trib.rb create --replicas 1 192.168.13.172:7000 192.168.13.172:7001 \
    192.168.13.172:7002 192.168.13.172:7003 192.168.13.172:7004 192.168.13.172:7005

如下即可：

![Center 6][]

![Center 7][]

**五.redis的java集群客户端配置和调试**  
5.1 redis.properties

redis01.host = 192.168.13.172
    redis01.port = 7000
    redis02.host = 192.168.13.172
    redis02.port = 7001
    redis03.host = 192.168.13.172
    redis03.port = 7002
    redis04.host = 192.168.13.172
    redis04.port = 7003
    redis05.host = 192.168.13.172
    redis05.port = 7004
    redis06.host = 192.168.13.172
    redis06.port = 7005

spring-Redis.xml

<bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
    		
    		<property name="maxTotal" value="300" />
    		
    		<property name="maxIdle" value="10" />
    		
    		<property name="numTestsPerEvictionRun" value="1024" />
    		
    		<property name="timeBetweenEvictionRunsMillis" value="30000" />
    		
    		<property name="minEvictableIdleTimeMillis" value="1800000" />
    		
    		<property name="softMinEvictableIdleTimeMillis" value="10000" />
    		
    		<property name="maxWaitMillis" value="1500" />
    		
    		<property name="testOnBorrow" value="true" />
    		
    		<property name="testWhileIdle" value="true" />
    		
    		<property name="blockWhenExhausted" value="false" />
    	</bean>
    
    	<bean id="jedisCluster" class="redis.clients.jedis.JedisCluster">
    		<constructor-arg name="jedisClusterNode">
    			<set>
    				<bean class="redis.clients.jedis.HostAndPort">
    					<constructor-arg name="host" value="${redis01.host}"/>
                      	<constructor-arg name="port" value="${redis01.port}"/>
    				</bean>
    				<bean class="redis.clients.jedis.HostAndPort">
    					<constructor-arg name="host" value="${redis02.host}"/>
                      	<constructor-arg name="port" value="${redis02.port}"/>
    				</bean>
    				<bean class="redis.clients.jedis.HostAndPort">
    					<constructor-arg name="host" value="${redis03.host}"/>
                      	<constructor-arg name="port" value="${redis03.port}"/>
                      	
    				</bean>
    				<bean class="redis.clients.jedis.HostAndPort">
    					<constructor-arg name="host" value="${redis04.host}"/>
                      	<constructor-arg name="port" value="${redis04.port}"/>
    				</bean>
    				<bean class="redis.clients.jedis.HostAndPort">
    					<constructor-arg name="host" value="${redis05.host}"/>
                      	<constructor-arg name="port" value="${redis05.port}"/>
    				</bean>
    				<bean class="redis.clients.jedis.HostAndPort">
    					<constructor-arg name="host" value="${redis06.host}"/>
                      	<constructor-arg name="port" value="${redis06.port}"/>
    				</bean>				
    			</set>
    		</constructor-arg>
    		<constructor-arg name="connectionTimeout" value="10000"></constructor-arg>
    		<constructor-arg name="soTimeout" value="10000"></constructor-arg>
    		<constructor-arg name="maxAttempts" value="10000"></constructor-arg>
    
    		<constructor-arg name="poolConfig" ref="jedisPoolConfig"></constructor-arg>
    	</bean>

JedisClusterClientImpl.java

package com.mycompany.jedis.dao;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Repository;
    
    import redis.clients.jedis.JedisCluster;
    
    @Repository("jedisClusterClient")
    public class JedisClusterClientImpl implements JedisClient{
    
    	@Autowired
    	private JedisCluster jedisCluster;
    
    	@Override
    	public String get(String key) {
    		String value = null;
    		try {
    			value = jedisCluster.get(key);
    		} catch (Exception e) {
    			e.printStackTrace();
    		} 
    		return value;
    	}
    
    	@Override
    	public String set(String key, String value) {
    		try {
    			value = jedisCluster.set(key, value);
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    		return value;
    	}
    }

定时器类JedisClusterTest.java

package com.mycompany.mvc.quartz;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    
    import com.mycompany.jedis.dao.JedisClient;
    
    @Service("jedisClusterTest")
    public class JedisClusterTest {
    	
    	@Autowired
    	private JedisClient jedisClusterClient;
    	
    	public void JedisClusterTestMain(){
    		jedisClusterClient.set("tStringCluster","helloCluster");
    		String tString  = jedisClusterClient.get("tStringCluster");
    		System.out.println("JedisTest.JedisTestMain():"+tString);
    	}
    
    }

至此完成

注意前面使用redis-trib.rb创建集群时，需要指定本服务器地址是192.168.13.172，不能为127.0.0.1, 否则Java客户端会出现no reachable node in cluster的错误

[https_redis.io]: https://redis.io/
[http_doc.redisfans.com]: http://doc.redisfans.com/
[Center]: /images/20220708/c4c3f067cdfa400da178db0bf261afeb.png
[Center 1]: /images/20220708/4795c4def6ba42d7bad0db904d17ddf7.png
[Center 2]: /images/20220708/2a9a595fcc7c439bace0f1fdd16ff72b.png
[http_download.csdn.net_detail_jintao_ma_9661038]: http://download.csdn.net/detail/jintao_ma/9661038
[https_redis.io_topics_cluster-tutorial]: https://redis.io/topics/cluster-tutorial
[http_blog.csdn.net_jintao_ma_article_details_60756645]: http://blog.csdn.net/jintao_ma/article/details/60756645
[Center 3]: /images/20220708/b20b0312f05a4758a3b0fc6e524515a3.png
[Center 4]: /images/20220708/9ff8aaa344bb4c95b8fa83515754bb77.png
[Center 5]: /images/20220708/6bc983835a30471d984108f275ec59eb.png
[Center 6]: /images/20220708/85ffa61421864586a4505c03b791f21d.png
[Center 7]: /images/20220708/356adadecdca42ea8c29b0726ad98d71.png