MeterSphere教程：操作redis集群
【摘要】
今天要分享的内容：用java实现连接redis集群的操作。
为什么要用java脚本而不用python脚本，以及为什么要封装呢？
1、之前有研究过用python去操作redis集群，奈何metersphere平台目前用的是jython去运行的python脚本，在安装了redis-py-cluster插件之后，在使用的时候，导...
今天要分享的内容：用java实现连接redis集群的操作。
为什么要用java脚本而不用python脚本，以及为什么要封装呢？
1、之前有研究过用python去操作redis集群，奈何metersphere平台目前用的是jython去运行的python脚本，在安装了redis-py-cluster插件之后，在使用的时候，导入包会报错
2、网上肯定也有现成的beanshell连接redis的脚本，但是在平台上如果每个人都去写一遍连接的代码的话，显得有点冗余
java操作redis的核心代码参考：
pom文件导入jar包：
-
<dependency>
-
<groupId>org.springframework.boot</groupId>
-
<artifactId>spring-boot-starter-data-redis</artifactId>
-
</dependency>
-
<dependency>
-
<groupId>redis.clients</groupId>
-
<artifactId>jedis</artifactId>
-
</dependency>
简单的工具类如下：
-
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<HostAndPort> jedisClusterNode = new HashSet<HostAndPort>();
-
# 在代码里面去写死对应环境的连接信息
-
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文件可以加入下面内容：
-
<build>
-
<plugins>
-
<plugin>
-
<groupId>org.springframework.boot</groupId>
-
<artifactId>spring-boot-maven-plugin</artifactId>
-
<configuration>
-
<skip>true</skip>
-
</configuration>
-
</plugin>
-
<plugin>
-
<groupId>org.apache.maven.plugins</groupId>
-
<artifactId>maven-assembly-plugin</artifactId>
-
<configuration>
-
<archive>
-
<manifest>
-
<addClasspath>true</addClasspath>
-
<mainClass>com.xxx.xxx.Application</mainClass>
-
</manifest>
-
</archive>
-
<descriptorRefs>
-
<descriptorRef>jar-with-dependencies</descriptorRef>
-
</descriptorRefs>
-
</configuration>
-
<executions>
-
<execution>
-
<id>make-assembly</id>
-
<phase>package</phase>
-
<goals>
-
<goal>single</goal>
-
</goals>
-
</execution>
-
</executions>
-
</plugin>
-
</plugins>
-
</build>
使用mvn package命令就可以打出一个jar包。本次封装的话，只做简单的处理，只提供一个返回测试环境已经连接redis的对象，具体怎么操作redis，由对象本身直接去调用方法操作就行。
在平台的使用：
个人建议优先考虑使用Groovy脚本去调用自己封装好的jar包。调用前，需要先将jar包上传到平台：
如果使用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);
有遇到其他问题的，欢迎加好友互相探讨交流。
文章来源: xiaobotester.blog.csdn.net，作者：小博测试成长之路，版权归原作者所有，如需转载，请联系作者。
原文链接：xiaobotester.blog.csdn.net/article/details/125076271
【版权声明】本文为华为云社区用户转载文章，如果您发现本社区中有涉嫌抄袭的内容，欢迎发送邮件进行举报，并提供相关证据，一经查实，本社区将立刻删除涉嫌侵权内容，举报邮箱：
cloudbbs@huaweicloud.com
- 点赞
- 收藏
- 关注作者
评论（0）