今天要分享的内容：用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);

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