The async-redis-client from yishh

async-redis-client's People

Contributors

Stargazers

Watchers

async-redis-client's Issues

多线程调用导致的并发冲突

测试代码

final AsyncRedisClient client = new NettyRedisClient("192.168.1.246:6379", 1, null);
for (int i = 0; i < 20; i++) {
            new Thread(new Runnable() {
                @Override
                public void run() {
                    for (int count = 0; count < 100; count++) {
                        String key = randomString(5);
                        String value = randomString(10);
                        try {
                            String status = client.set(key, value).get();
                            if("OK".equals(status)) {

                                String redisValue = (String) client.get(key).get();

                                if (!value.equals(redisValue)) {
                                    System.out.println("expected value " + value + ",but return " + redisValue);

                                }
                            } else {
                                System.out.println("expected set directive return OK,but return " + status);
                            }
                        } catch (Exception e) {
                            e.printStackTrace();
                            //Thread.currentThread().interrupt();
                        }
                    }
                }
            }).start();
        }

private static Random randGen = new SecureRandom();
        private static char[] numbersAndLetters = ("0123456789abcdefghijklmnopqrstuvwxyz" +
                "0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZ").toCharArray();
    public static final String randomString(int length) {
        if (length < 1) {
            return null;
        }
        // Create a char buffer to put random letters and numbers in.
        char [] randBuffer = new char[length];
        for (int i=0; i<randBuffer.length; i++) {
            randBuffer[i] = numbersAndLetters[randGen.nextInt(71)];
        }
        return new String(randBuffer);
    }