Multiple threads share one StatefulRedisConnection may lead to key confusion

[a649339266]

A large number of threads read different keys from different queues, with a very low probability of threads reading the values of keys from other threads；

[a649339266]

But with Jedis, there is no such phenomenon

[a-TODO-rov]

Hey, @a649339266
Jedis and Lettuce are very different drivers in the way they work internally. Could you provide more info, so we can better understand your statement:

• minimal reproducible example (code snippet that reproduces the problem)
• Lettuce version
• Redis version

[a649339266]

lettuce version：
<dependency> <groupId>io.lettuce</groupId> <artifactId>lettuce-core</artifactId> <version>5.2.0.RELEASE</version> </dependency>

redis server version ：4.0.14

This issue only occurs in the production environment （one year about 2-3 times,Restore after restarting the client）and has not been reproduced in my pc。
may be a bug of my server。

`
import io.lettuce.core.RedisClient;
import io.lettuce.core.RedisURI;
import io.lettuce.core.api.StatefulRedisConnection;

import io.lettuce.core.api.sync.RedisCommands;
import org.apache.commons.lang3.StringUtils;

import java.time.Duration;

public class Test {
private static StatefulRedisConnection<String, String> sharedConnection;
static {
RedisURI redisUri = RedisURI.builder()
.withHost("com")
.withPort(6379)
.withDatabase(0)
.withPassword("")
.withTimeout(Duration.ofSeconds(10))
.build();
RedisClient client = RedisClient.create(redisUri);
sharedConnection = client.connect();
}

static class ThreadA extends Thread {
    @Override
    public void run() {
        RedisCommands<String, String> commands = sharedConnection.sync();
        while (true) {
            String balance = commands.lpop("queue1");
            if (StringUtils.isNotBlank(balance) && !"100".equals(balance)) {
                System.out.println("ThreadA：get a value from other key: " + balance);
            }
        }
    }
}

static class ThreadB extends Thread {
    @Override
    public void run() {
        RedisCommands<String, String> commands = sharedConnection.sync();
        while (true) {
            String balance = commands.lpop("queue2");
            if (StringUtils.isNotBlank(balance) && !"200".equals(balance)) {
                System.out.println("ThreadB：get a value from other key:" + balance);
            }
        }
    }
}

static class ThreadC extends Thread {
    @Override
    public void run() {
        RedisCommands<String, String> commands = sharedConnection.sync();
        while (true) {
            commands.rpush("queue2", "200");
            commands.rpush("queue1", "100");
        }
    }
}

public static void main(String[] args) {
    for (int i = 0; i < 10; i++) {
        new ThreadA().start();
        new ThreadB().start();
        new ThreadC().start();
    }
}

}
`