> 文档中心 > MeterSphere教程:操作redis集群

MeterSphere教程:操作redis集群

今天要分享的内容:用java实现连接redis集群的操作

为什么要用java脚本而不用python脚本,以及为什么要封装呢?

1、之前有研究过用python去操作redis集群,奈何metersphere平台目前用的是jython去运行的python脚本,在安装了redis-py-cluster插件之后,在使用的时候,导入包会报错

2、网上肯定也有现成的beanshell连接redis的脚本,但是在平台上如果每个人都去写一遍连接的代码的话,显得有点冗余

java操作redis的核心代码参考:

pom文件导入jar包:

    org.springframework.boot    spring-boot-starter-data-redis    redis.clients    jedis

简单的工具类如下:

package com.xxx.xxx;import redis.clients.jedis.HostAndPort;import redis.clients.jedis.Jedis;import redis.clients.jedis.JedisCluster;import redis.clients.jedis.JedisPoolConfig;import java.util.HashSet;import java.util.Set;public class RedisTools {    public static JedisCluster getRedisClient(String env) { JedisCluster jedisCluster = null;        String redis_host = "xxxxxxxxx"; # 替换成redis的集群地址 Jedis jedis = new Jedis(""); JedisPoolConfig config = new JedisPoolConfig(); config.setMaxTotal(20); config.setMaxIdle(10); config.setMinIdle(5); Set jedisClusterNode = new HashSet();        # 在代码里面去写死对应环境的连接信息 if (env.toLowerCase() != "test") {            redis_host = ""; } jedisClusterNode.add(new HostAndPort(redis_host, 6379)); jedisCluster = new JedisCluster(jedisClusterNode, 6000, 5000, 10, null, config); return jedisCluster;    }}

测试一下效果:

JedisCluster redis_client = RedisTools.getRedisClient("test");System.out.println(redis_client.get("xxxx"));System.out.println(redis_client.hgetAll("xxxx"));Set query_result = redis_client.zrange("xxxxx", 0, -1);

接下来就是将代码打成jar包,然后上传到metersphere平台上去进行调用:

打包的时候,要记得把相关的依赖包一起打包进去,pom文件可以加入下面内容:

          org.springframework.boot     spring-boot-maven-plugin       true            org.apache.maven.plugins     maven-assembly-plugin                true   com.xxx.xxx.Application                jar-with-dependencies                    make-assembly      package         single                  

使用mvn  package命令就可以打出一个jar包。本次封装的话,只做简单的处理,只提供一个返回测试环境已经连接redis的对象,具体怎么操作redis,由对象本身直接去调用方法操作就行。

在平台的使用:

个人建议优先考虑使用Groovy脚本去调用自己封装好的jar包。调用前,需要先将jar包上传到平台:

8f25689339e8aa835a8907b522030454.png

如果使用beanshell脚本调用的话,容易错误。

Groovy脚本调用jar包中的方法的案例:

import com.xxx.xxx.RedisTools;import redis.clients.jedis.JedisCluster;JedisCluster redis_client =  RedisTools.getRedisClient("test");String result = redis_client.hgetAll("xxxxx").toString();log.info(result);

f1a2a4fca2c5a83ca9f8c61d8b28de43.png

有遇到其他问题的,欢迎加好友互相探讨交流。

风车动漫