Redis集群与SSM整合使用方法
首先是创建redis-cluster文件夹：
因为redis最少需要6个节点（三主三从），为了更好的理解，我这里创建了两台虚拟机（192.168.0.109 192.168.0.110），分别在两台虚拟机的/opt/redis-4.0.1/redis-cluster下创建三个节点文件夹
192.168.0.109：
192.168.0.110：
以上6个节点全部创建完成，分别再在这六个文件夹下创建redis.conf配置文件，其中配置如图：
port 7000 bind 192.168.0.109 daemonize yes pidfile /var/run/redis_7000.pid cluster-enabled yes cluster-config-file nodes_7000.conf cluster-node-timeout 10000 appendonly yes
其中需要将port pidfile cluster-config-file修改成节点端口号一致，bind改成本机ip，以便远程访问，全部修改完后，即可启动redis服务：
启动命令：
192.168.0.109下的命令：“for((i=0;i<=2;i++)); do /opt/redis-4.0.1/src/redis-server /opt/redis-4.0.1/redis-cluster/700$i/redis.conf; done”
192.168.0.110下的命令：“for((i=3;i<=5;i++)); do /opt/redis-4.0.1/src/redis-server /opt/redis-4.0.1/redis-cluster/700$i/redis.conf; done”
可以看到后台模式启动成功的日志打印，两天机器都需要依次启动所有节点。节点启动完成后，即可创建集群服务：
在其中一台虚拟机上执行如下命令“/opt/redis-4.0.1/src/redis-trib.rb create --replicas 1 192.168.0.109:7000 192.168.0.109:7001 192.168.0.109:7002 192.168.0.110:7003 192.168.0.110:7004 192.168.0.110:7005”
千万记住只需要在一台上执行即可，如果卡在join处不能往下执行，一般情况是出在防火墙端口被禁导致，有两种方式可以解决：
1、不但需要开启7000对外端口，还需要开启17000（因为redis总线端口需要加1000）。
2、直接关闭所有防火墙（因我这里是自己的环境，所以直接关闭了防火墙服务）。
出现上图运行日志，基本就成功搭建好了集群服务，可以清晰的看到各个节点的主从关系，环境搭建好后，这里我们就和我上篇写到的SSM架构进行联合使用。
上次整合的mybaits二级缓存是个单机版本，由于这种方式不支持集群，所以这里从新使用jedis-cluster进行另外一种redis集群与java整合使用的方式。
首先在redis.properties文件中新增集群机器的配置，将6个节点依次加入配置：
#cluster cluster1.host.port=192.168.0.109:7000 cluster2.host.port=192.168.0.109:7001 cluster3.host.port=192.168.0.109:7002 cluster4.host.port=192.168.0.110:7003 cluster5.host.port=192.168.0.110:7004 cluster6.host.port=192.168.0.110:7005
redis配置文件中也与之前改动比较多，我直接列出来，可以直接拷去用了。
spring-redis.xml
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:p="http://www.springframework.org/schema/p"
xmlns:mvc="http://www.springframework.org/schema/mvc"
xmlns:util="http://www.springframework.org/schema/util"
xmlns:aop="http://www.springframework.org/schema/aop"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:task="http://www.springframework.org/schema/task"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-4.3.xsd
http://www.springframework.org/schema/util
http://www.springframework.org/schema/util/spring-util-4.3.xsd
http://www.springframework.org/schema/mvc
http://www.springframework.org/schema/mvc/spring-mvc-4.3.xsd
http://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring-aop-4.3.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-4.3.xsd">
<!-- 连接池基本参数配置，类似数据库连接池 -->
<context:property-placeholder location="classpath*:redis.properties" />
<bean name="genericObjectPoolConfig" class="org.apache.commons.pool2.impl.GenericObjectPoolConfig" >
<property name="maxWaitMillis" value="-1" />
<property name="maxTotal" value="1000" />
<property name="minIdle" value="8" />
<property name="maxIdle" value="100" />
</bean>
<!-- 连接池配置，类似数据库连接池 -->
<!-- <bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory" >
<property name="hostName" value="${redis.host}"></property>
<property name="port" value="${redis.port}"></property>
<property name="password" value="${redis.pass}"></property>
<property name="poolConfig" ref="poolConfig"></property>
</bean> -->
<!-- 调用连接池工厂配置 -->
<!-- <bean id="redisTemplate" class=" org.springframework.data.redis.core.RedisTemplate">
<property name="jedisConnectionFactory" ref="jedisConnectionFactory"></property>
如果不配置Serializer，那么存储的时候智能使用String，如果用User类型存储，那么会提示错误User can't cast to String！！！
<property name="keySerializer">
<bean
class="org.springframework.data.redis.serializer.StringRedisSerializer" />
</property>
<property name="valueSerializer">
<bean
class="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer" />
</property>
</bean> -->
<bean id="jedisCluster" class="com.cjl.util.JedisClusterFactory">
<property name="addressConfig">
<value>classpath:redis.properties</value>
</property>
<property name="addressKeyPrefix" value="cluster" />
<property name="timeout" value="300000" />
<property name="maxRedirections" value="6" />
<property name="genericObjectPoolConfig" ref="genericObjectPoolConfig" />
</bean>
</beans>
将上篇SSM+redis整合中mybatis的开启缓存配置全部禁用，即可启动服务测试了
首先直接注入jedisCluster获取一个集群对象。
这里为了方便，我数据同步直接用了java写了个简单思想，其他方法也可实现，例如Spring AOP方式实现，使用第三方插件，或者数据库层面实现都可行。
启动成功后，反复调用方法。可以看到控制台并未打印sql语句，而是直接在redis集群中直接获取得到数据。以上简单的redis集群实例已经完成，因为时间关系，其中linux中有些坑我没有细细写出。
总结
以上所述是小编给大家介绍的Redis集群与SSM整合使用方法，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对脚本之家网站的支持！
相关文章
这篇文章主要介绍了浅析Mysql中的视图,视图是从一个或者多个表中导出的表，视图的行为与表非常相似，在视图中用户可以使用SELECT语句查询数据，以及使用INSERT、UPDATE和DELETE修改记录,需要的朋友可以参考下2023-05-05
这篇文章主要介绍了新版Eclipse安装、配置,本文通过图文并茂的形式给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2020-08-08
这篇文章主要介绍了SpringBoot 启动流程追踪方法分享的相关资料,需要的朋友可以参考下2023-08-08
这篇文章主要介绍了java实现哈夫曼压缩与解压缩的方法，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2019-10-10
这篇文章主要介绍了详解在Spring中如何使用AspectJ来实现AOP,小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2018-06-06
这篇文章主要介绍了jar包运行时提示jar中没有主清单属性的解决方案，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2023-02-02
springboot 整合EhCache实现单服务缓存的操作方法
这篇文章主要介绍了springboot 整合EhCache实现单服务缓存的操作方法，本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下2022-07-07
这篇文章主要介绍了Java的注解原理详解,注解是JDK1.5引入的新特性,包含在java.lang.annotation包中,它是附加在代码中的一些元信息,将一个类的外部信息与内部成员联系起来,在编 译、运行时进行解析和使用,需要的朋友可以参考下2023-10-10
这篇文章主要介绍了用Java设计模式中的观察者模式开发微信公众号的例子,这里Java的微信SDK等部分便不再详述,只注重关键部分和开发过程中观察者模式优点的体现,需要的朋友可以参考下2016-02-02
这篇文章主要给大家介绍了关于Java中如何自定义一个类加载器加载自己指定的类,自定义类加载器允许我们加载特定路径的类文件,并且可以用于插件系统、热部署和隔离加载等场景,文中通过代码介绍的非常详细,需要的朋友可以参考下2024-12-12
最新评论