java 参数转key=value 代码优化版

以下是一个Java方法，可以将一个参数Map转换为key=value形式的字符串：

public static String mapToQueryString(Map<String, String> params) {
    StringBuilder query = new StringBuilder();
    for (Map.Entry<String, String> entry : params.entrySet()) {
        if (entry.getValue() != null) {
            if (query.length() > 0) {
                query.append('&');
            }
            query.append(entry.getKey()).append('=').append(entry.getValue());
        }
    }
    return query.toString();
}

此方法首先创建一个StringBuilder实例，然后遍历参数Map中的每一个键值对。如果值不为null，则将键和值连接起来，中间用等号连接，并添加到StringBuilder中。如果StringBuilder已经包含了其他键值对，则在新的键值对前加上一个&符号。最终，方法返回StringBuilder中的字符串表示形式。

你可以将此方法放在一个工具类中，并在需要将参数Map转换为字符串时调用它。

相关问题

写一个 redis 集群版 java 客户端

好的，以下是一个简单的 Redis 集群版 Java 客户端的示例代码：

首先，你需要引入 Redis 客户端库 jedis-cluster：

<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>3.5.3</version>
</dependency>

然后，你可以创建一个 RedisClusterClient 类，实现连接池的初始化、数据操作等功能：

import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.JedisCluster;
import redis.clients.jedis.JedisPoolConfig;

import java.util.HashSet;
import java.util.Set;

public class RedisClusterClient {

    private JedisCluster jedisCluster;

    public RedisClusterClient(String nodes) {
        Set<HostAndPort> jedisClusterNodes = new HashSet<>();

        for (String node : nodes.split(",")) {
            String[] parts = node.split(":");
            jedisClusterNodes.add(new HostAndPort(parts[0], Integer.parseInt(parts[1])));
        }

        JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
        jedisPoolConfig.setMaxTotal(128);
        jedisPoolConfig.setMaxIdle(128);
        jedisPoolConfig.setMinIdle(16);
        jedisPoolConfig.setMaxWaitMillis(5000);
        jedisPoolConfig.setTestOnBorrow(true);
        jedisPoolConfig.setTestOnReturn(true);
        jedisPoolConfig.setTestWhileIdle(true);

        this.jedisCluster = new JedisCluster(jedisClusterNodes, jedisPoolConfig);
    }

    public String get(String key) {
        return jedisCluster.get(key);
    }

    public void set(String key, String value) {
        jedisCluster.set(key, value);
    }

    public void del(String key) {
        jedisCluster.del(key);
    }

    // 其他操作...

    public void close() {
        jedisCluster.close();
    }

}

在这个示例中，我们使用 JedisCluster 来连接 Redis 集群，通过构造函数传入节点信息（格式为 "host1:port1,host2:port2,host3:port3"），并初始化连接池配置。然后，我们可以在 RedisClusterClient 中实现 Redis 的各种操作方法，例如 get、set、del 等。

最后，我们可以在应用程序中使用 RedisClusterClient 来连接 Redis 集群，例如：

RedisClusterClient redisClient = new RedisClusterClient("127.0.0.1:6379,127.0.0.1:6380,127.0.0.1:6381");

redisClient.set("key", "value");
String value = redisClient.get("key");
System.out.println(value);

redisClient.del("key");

redisClient.close();

这是一个简单的 Redis 集群版 Java 客户端示例，你可以根据实际需求进行扩展和优化。

写一个 集群版与单机版 redis springboot java 客户端

好的，以下是一个同时支持 Redis 集群版与单机版的 Spring Boot Java 客户端的示例代码：

首先，你需要引入 Redis 客户端库 jedis：

<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>3.5.3</version>
</dependency>

然后，你可以创建一个 RedisClient 类，实现连接池的初始化、数据操作等功能：

import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import redis.clients.jedis.*;

import javax.annotation.PostConstruct;
import java.util.HashSet;
import java.util.Set;

@Component
public class RedisClient {

    private JedisPool jedisPool;
    private JedisCluster jedisCluster;

    @Value("${spring.redis.host}")
    private String host;

    @Value("${spring.redis.port}")
    private int port;

    @Value("${spring.redis.password}")
    private String password;

    @Value("${spring.redis.timeout}")
    private int timeout;

    @Value("${spring.redis.pool.max-active}")
    private int maxActive;

    @Value("${spring.redis.pool.max-idle}")
    private int maxIdle;

    @Value("${spring.redis.pool.max-wait}")
    private long maxWaitMillis;

    @Value("${spring.redis.pool.min-idle}")
    private int minIdle;

    @Value("${spring.redis.cluster.nodes}")
    private String clusterNodes;

    @Value("${spring.redis.cluster.max-redirects}")
    private int maxRedirects;

    @PostConstruct
    public void init() {
        if (clusterNodes == null || clusterNodes.isEmpty()) {
            JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
            jedisPoolConfig.setMaxTotal(maxActive);
            jedisPoolConfig.setMaxIdle(maxIdle);
            jedisPoolConfig.setMaxWaitMillis(maxWaitMillis);
            jedisPoolConfig.setMinIdle(minIdle);
            jedisPool = new JedisPool(jedisPoolConfig, host, port, timeout, password);
        } else {
            Set<HostAndPort> jedisClusterNodes = new HashSet<>();
            for (String node : clusterNodes.split(",")) {
                String[] parts = node.split(":");
                jedisClusterNodes.add(new HostAndPort(parts[0], Integer.parseInt(parts[1])));
            }
            JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
            jedisPoolConfig.setMaxTotal(maxActive);
            jedisPoolConfig.setMaxIdle(maxIdle);
            jedisPoolConfig.setMaxWaitMillis(maxWaitMillis);
            jedisPoolConfig.setMinIdle(minIdle);
            jedisCluster = new JedisCluster(jedisClusterNodes, timeout, timeout, maxRedirects, password, jedisPoolConfig);
        }
    }

    public String get(String key) {
        if (jedisPool != null) {
            try (Jedis jedis = jedisPool.getResource()) {
                return jedis.get(key);
            }
        } else {
            return jedisCluster.get(key);
        }
    }

    public void set(String key, String value) {
        if (jedisPool != null) {
            try (Jedis jedis = jedisPool.getResource()) {
                jedis.set(key, value);
            }
        } else {
            jedisCluster.set(key, value);
        }
    }

    public void del(String key) {
        if (jedisPool != null) {
            try (Jedis jedis = jedisPool.getResource()) {
                jedis.del(key);
            }
        } else {
            jedisCluster.del(key);
        }
    }

    // 其他操作...

    public void close() {
        if (jedisPool != null) {
            jedisPool.close();
        } else {
            jedisCluster.close();
        }
    }

}

在这个示例中，我们增加了一个 init() 方法用来初始化 Redis 连接池，根据配置文件中是否配置了 Redis 集群节点信息来选择使用 JedisPool 还是 JedisCluster。然后，我们可以在 RedisClient 中实现 Redis 的各种操作方法，例如 get、set、del 等。

最后，我们可以在 Spring Boot 应用程序中使用 RedisClient 来连接 Redis，例如：

@Autowired
RedisClient redisClient;

redisClient.set("key", "value");
String value = redisClient.get("key");
System.out.println(value);

redisClient.del("key");

redisClient.close();

这是一个同时支持 Redis 集群版与单机版的 Spring Boot Java 客户端示例，你可以根据实际需求进行扩展和优化。