写一个python redis传送数据的客户端和服务端

以下是一个简单的Python Redis传输数据的客户端和服务端示例。

服务端代码：

import redis

r = redis.Redis(host='localhost', port=6379)

# 等待客户端连接
while True:
    message = r.blpop('data_queue')[1]
    print(message.decode())

客户端代码：

import redis

r = redis.Redis(host='localhost', port=6379)

# 发送数据到服务端
data = {'name': 'John', 'age': 30}
r.rpush('data_queue', str(data))

print('Data sent successfully.')

这个示例演示了如何使用Redis的`blpop()`函数从队列中读取数据，并使用`rpush()`函数将数据发送到队列中。请注意，此示例非常简单，并且不包括任何错误处理和许多其他必要的功能。

相关问题

写一个 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 客户端示例，你可以根据实际需求进行扩展和优化。