spring boot学习系列之整合Redis集群3

 6,906浏览     wenqyAdmin   

现在学习springboot项目与Redis K-V存储系统的整合。在虚拟机上模拟了Redis集群，如果觉得启动不方便，可以用SecureCRT，XShell等终端仿真程序工具去连虚拟机。如果虚拟机没有安装SSH，使用NAT模式连接虚拟机网络。

安装SSH

sudo apt-get install openssh-server

安装完后自动启动。然后就可以用终端仿真程序工具连了，如果是Ubuntu无法更新，可以参考：http://wenqy.com/2016/03/16/ubuntu%e6%95%b0%e6%8d%ae%e6%ba%90%e5%88%97%e8%a1%a8.html  Ubuntu如何修改数据源列表。

开发

添加依赖，加载Jedis

  1. <!– https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-redis –>
  2. <dependency>
  3.     <groupId>org.springframework.boot</groupId>
  4.     <artifactId>spring-boot-starter-redis</artifactId>
  5.     <version>1.4.7.RELEASE</version>
  6. </dependency>

添加redis配置

springboot配置文件中添加集群的信息

  1. #整合redis，使用redis实现缓存
  2. # Redis数据库索引（默认为0）
  3. #spring.redis.database=0
  4. # Redis服务器地址，单机
  5. #spring.redis.host=192.168.56.101
  6. # Redis服务器连接端口，单机
  7. #spring.redis.port=6379
  8. spring.redis.cluster.nodes=192.168.56.101:30001,192.168.56.101:30002,192.168.56.101:30003,192.168.56.101:30004,192.168.56.101:30005,192.168.56.101:30006
  9. # Redis服务器连接密码（默认为空）
  10. spring.redis.password=
  11. # 连接池最大连接数（使用负值表示没有限制）
  12. spring.redis.pool.max-active=8
  13. # 连接池最大阻塞等待时间（使用负值表示没有限制）
  14. spring.redis.pool.max-wait=-1
  15. # 连接池中的最大空闲连接
  16. spring.redis.pool.max-idle=8
  17. # 连接池中的最小空闲连接
  18. spring.redis.pool.min-idle=0
  19. # 连接超时时间（毫秒）
  20. spring.redis.timeout=0
  21. spring.redis.commandTimeout=5000

项目入口类加入注解@EnableCaching，添加到缓存

  1. @SpringBootApplication
  2. @MapperScan(basePackages = “com.wenqy.mapper”)
  3. @EnableCaching
  4. public class HelloWorldApp {
  6.     public static void main(String[] args) {
  7.         SpringApplication.run(HelloWorldApp.class, args);
  8.     }
  9. }
  11. /**
  12.      * 
  13.     * @Title: findAll 
  14.     * @Description: 加入redis，测试缓存 
  15.     * @param @return    设定文件 
  16.     * @return List<User>    返回类型 
  17.     * @throws
  18.      */
  19.     @RequestMapping(“/findAll”)
  20.     @Cacheable(value=“redis”)
  21.     public List<User> findAll() {
  22.         System.out.println(“进入findAll…”);
  23.         List<User> findAll = userService.findAll();
  24.         return findAll;
  25.     }

自定义redis配置，加入集群

  1. @Configuration
  2. @ConditionalOnClass({JedisCluster.class})
  3. public class RedisConfig {
  5.     @Value(“${spring.redis.cluster.nodes}”)
  6.     private String clusterNodes;
  8.     @Value(“${spring.redis.timeout}”)
  9.     private int timeout;
  11.     @Value(“${spring.redis.pool.max-idle}”)
  12.     private int maxIdle;
  14.     @Value(“${spring.redis.pool.max-wait}”)
  15.     private long maxWaitMillis;
  17.     @Value(“${spring.redis.commandTimeout}”)
  18.     private int commandTimeout;
  20.     @Bean
  21.     public JedisCluster getJedisCluster() {
  23.         String[] cNodes = clusterNodes.split(“,”);
  25.         Set<HostAndPort> nodes = new HashSet<HostAndPort>();
  26.         // 分割出集群节点
  27.         for (String node : cNodes) {
  28.             String[] hp = node.split(“:”);
  29.             nodes.add(new HostAndPort(hp[0],Integer.parseInt(hp[1])));
  30.         }
  31.         JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
  32.         jedisPoolConfig.setMaxIdle(maxIdle);
  33.         jedisPoolConfig.setMaxWaitMillis(maxWaitMillis);
  34.         // 创建集群对象
  35. //      JedisCluster jedisCluster = new JedisCluster(nodes,commandTimeout);
  36.         JedisCluster jedisCluster = new JedisCluster(nodes,commandTimeout,jedisPoolConfig);
  37.         return jedisCluster;
  38.     }
  39. }

Service实现类中，自动注入jedisCluster

  1. @Autowired
  2. private JedisCluster jedisCluster;

并写入一个测试方法

  1. public String findRedis() {
  2.     jedisCluster.set(“userName”, “hello wenqy”);
  3.     return jedisCluster.get(“userName”);
  5. }

在控制层加入调用刚才的service方法

  1. @RequestMapping(“/redis”)
  2. public String findRedis() {
  3.     return userService.findRedis();
  5. }

测试

在findRedis方法中打断点，第一次访问时建立缓存，第二次访问发现没有进入该函数。但返回的结果是一样的。

最后访问

redis_hello_wenqy

安装Redis集群

在前面写过Redis单机版集群http://wenqy.com/2017/02/08/redis%e5%8d%95%e6%9c%ba%e7%89%88%e9%9b%86%e7%be%a4.html，是主从模式的方案。现用redis-trib命令，一个Ruby程序来构建单机集群。

发现gem install redis没办法使用，原来ruby 的gem被和谐了，只能将Ruby的镜像转到国内淘宝镜像。

gem sources --remove https://rubygems.org/$ gem sources -a https://ruby.taobao.org/$ gem sources -l

然后更新源列表，安装Rails

gem update --system
Sudo gem install rake
Sudo gem install -v=1.0.1 rack
Sudo gem install rails --no-ri --no-rdoc -v=3.2.7
Sudo gem install rails

修改创建集群 create-cluster脚本

  1. if [ “$1” == “start” ]
  2. then
  3.     while [ $((PORT < ENDPORT)) != “0” ]; do
  4.         PORT=$((PORT+1))
  5.         echo “Starting $PORT“
  6.         ../../src/redis-server /home/wenqy/redis-3.2.6/redis.conf –bind 192.168.56.101 –port $PORT –cluster-enabled yes –cluster-config-file nodes-${PORT}.conf —protected-mode no –cluster-node-timeout $TIMEOUT –appendonly yes –appendfilename appendonly-${PORT}.aof –dbfilename dump-${PORT}.rdb –logfile ${PORT}.log –daemonize yes
  7.     done
  8.     exit 0
  9. fi
  11. if [ “$1” == “create” ]
  12. then
  13.     HOSTS=””
  14.     while [ $((PORT < ENDPORT)) != “0” ]; do
  15.         PORT=$((PORT+1))
  16.         HOSTS=”$HOSTS 192.168.56.101:$PORT“
  17.     done
  18.     ../../src/redis-trib.rb create –replicas $REPLICAS $HOSTS
  19.     exit 0
  20. fi

在连接Redis集群时，会出现Could not get a resource from the pool或

ConnectException: Connection refused: connect等无法建立连接的错误。

就在加载Redis.conf 配置文件中，覆盖参数。启用集群模式，关闭保护模式，设置超时时间，注释掉IP绑定等等

创建集群

~/redis-3.2.6/utils/create-cluster$ ./create-cluster create

启动集群

~/redis-3.2.6/utils/create-cluster$ ./create-cluster start

关闭集群

~/redis-3.2.6/utils/create-cluster$ ./create-cluster stop

客户端访问，并查看集群信息和节点

~/redis-3.2.6/src$ ./redis-cli -c -h 192.168.56.101 -p 30001
cluster info

发现有6个节点，集群状态运行正常。
redis_cluster_info

Cluster nodes

发现Redis集群，3主3从
redis_cluster_nodes

对于开发使用而言，模式都是一样的。但关系型和非关系数据库有适应不同的结构化和非结构化数据。

参考

https://redis.io/topics/cluster-tutorial

小二，再来一碟

赏

发表评论

电子邮件地址不会被公开。 必填项已用*标注

13 + 12 = ?