127.0.0.1:6379[2]> get DISCUSS:TOPIC:3d28016e7cb34119aab718da2d4d1fe5::count
"\xac\xed\x00\x05sr\x00\x11java.lang.Integer\x12\xe2\xa0\xa4\xf7\x81\x878\x02\x00\x01I\x00\x05valuexr\x00\x10java.lang.Number\x86\xac\x95\x1d\x0b\x94\xe0\x8b\x02\x00\x00xp\x00\x00\x00\x00"

package com.lkk;

import com.alibaba.fastjson.JSONObject;import com.baomidou.mybatisplus.plugins.Page;import com.lkk.ppm.discuss.domain.entity.ELComment;import io.lettuce.core.RedisClient;import io.lettuce.core.RedisURI;import org.apache.commons.codec.binary.Hex;import org.junit.Assert;import org.junit.Test;import org.springframework.data.redis.connection.RedisConnection;import org.springframework.data.redis.connection.RedisStringCommands;import org.springframework.data.redis.connection.lettuce.LettuceConnection;import org.springframework.data.redis.serializer.JdkSerializationRedisSerializer;import org.springframework.data.redis.serializer.RedisSerializationContext;import org.springframework.data.redis.serializer.RedisSerializer;import org.springframework.data.redis.util.ByteUtils;

import javax.xml.bind.DatatypeConverter;import java.io.ByteArrayInputStream;import java.io.FileInputStream;import java.net.URL;import java.nio.ByteBuffer;

/** * @author Administrator * @date 2019/9/5 0005 12:40 * @Description */public class TestRedisSerializer {

    private static final int CURRENT = 111;    private static final int SIZE = 222;

    static RedisSerializer serial;    static RedisSerializationContext.SerializationPair serializationPair;    static RedisStringCommands redisStringCommands;

    static {        RedisURI redisURI = RedisURI.create("192.168.11.200", 6380);        redisURI.setPassword("Redis!123");        long jedis = 100000L;        RedisConnection connection = new LettuceConnection(jedis, RedisClient.create(redisURI));        connection.select(2);

        redisStringCommands = connection.stringCommands();        // 切换 序列化组件        serial = new JdkSerializationRedisSerializer();// 默认就是 JdkSerializationRedisSerializer

//          StringRedisSerializer 只能够序列化字符串， 不能序列化 对象。 好像没啥用！//       serial = new StringRedisSerializer();

        // GenericFastJsonRedisSerializer 可以将对象序列化为 json格式字符串//        serial = new GenericFastJsonRedisSerializer();

        serializationPair = RedisSerializationContext.SerializationPair.fromSerializer(serial);    }

    @Test    public void testHex() throws Exception {//        ByteUtils.getBytes(this.cacheConfig.getValueSerializationPair().write(value)//         ByteUtils.getBytes(this.cacheConfig.getValueSerializationPair().write(value)//        org.apache.commons.compress.utils.ByteUtils.

        String foo = "hello";        byte[] bytes = foo.getBytes("unicode");        bytes = foo.getBytes();//        bytes = foo.getBytes("gb2312");

        /**         * 虽然foo 是纯英文字母，但 下面的方法都 无法将bytes 还原到上面的hello 了。。 TODO         */        System.out.println( Hex.encodeHexString( bytes ) );// 结果是 纯16进制的内容 68656c6c6f，不带 \ x 无法查看        String s = DatatypeConverter.printHexBinary(bytes);;// 结果是 纯16进制的内容 68656c6c6f， 无法查看        System.out.println("s = " + s);//        byte[] decoded = Hex.decodeHex("00A0BF");//        System.out.println("decoded = " + new String(decoded));

        /**         *  还原到上面的hello         */        dumpBytesToHex(bytes);

        // 尝试读取class文件        // 当前文件        String fileFullName = "E:\\dev\\erdp2\\erdp_discuss\\erdp_discuss_service\\target\\test-classes\\com\\lkk\\TestRedisSerializer.class";        FileInputStream fis = new FileInputStream(fileFullName);//        fis.getChannel()//        ByteArrayInputStream//        fis.read()        int available = fis.available();        byte[] classBytes = new byte[available];        int read = fis.read(classBytes);

        String s1 = dumpBytesToHex(classBytes);// 除了换行符，基本上 得到了 和 notepad++ 一样的效果。        Assert.assertTrue(s1.contains("TestRedisSerializer"));

        ClassLoader classLoader = TestRedisSerializer.class.getClassLoader();

    }

    @Test    public void testWrite() throws Exception {        String key = "RESOURCE:ITEM:FILE::9fd04b83e33844b1a21ffa1c05978fc1_content.js";//        key = "RESOURCE:ITEM:FILE::3fa4bbdff660490092ba9af971980838_template.html";//        key = "DISCUSS:TOPIC:3d28016e7cb34119aab718da2d4d1fe5::count";        key = "DISCUSS:TOPIC:xxx::count";        write(key);    }

    private void write(Object key) throws Exception {        /**         * CURRENT SIZE 测试read 要用到         */        Page<ELComment> page = new Page<>(CURRENT, SIZE);        String s2 = JSONObject.toJSONString(page);//        byte[] bytes = ByteUtils.getBytes(serializationPair.write(key));

        //如果是 JdkSerializationRedisSerializer : write 1 结果是  "\xac\xed\x00\x05sr\x00\x11java.lang.Integer\x12\xe2\xa0\xa4\xf7\x81\x878\x02\x00\x01I\x00\x05valuexr\x00\x10java.lang.Number\x86\xac\x95\x1d\x0b\x94\xe0\x8b\x02\x00\x00xp\x00\x00\x00\x01"//        byte[] bytes = ByteUtils.getBytes(serializationPair.write(1));

        byte[] bytes = ByteUtils.getBytes(serializationPair.write(page));        Boolean set = redisStringCommands.set(key.toString().getBytes(), bytes);//        System.out.println("set = " + set);//        byte[] bytes = ByteUtils.getBytes(RedisSerializationContext.SerializationPair.fromSerializer(serial).write(new String("abc阿斯蒂芬")));//        System.out.println("bytes = " + bytes.length);        String s = dumpBytesToHex(bytes);        Assert.assertTrue(s.contains("com.baomidou.mybatisplus.plugins.Page"));    }

    @Test    public void testRead() throws Exception {        String key = "DISCUSS:TOPIC:xxx::count";        read(key);    }

    private void read(String key) {        byte[] bytes1 = redisStringCommands.get(key.getBytes());        System.out.println("TestRedis.aaa");        System.out.println("bytes1 === " + new String(bytes1));// 直接打印 二进制内容        System.out.println("TestRedis.bbb");        dumpBytesToHex(bytes1);// 打印 16 进制内容

        Page<ELComment> read = (Page<ELComment>) serializationPair.read(ByteBuffer.wrap(bytes1));        System.out.println("read = " + read);        int pages = read.getPages();        int size = read.getSize();        System.out.println("size = " + size);        Assert.assertEquals(read.getSize(), SIZE);        Assert.assertEquals(read.getCurrent(), CURRENT);    }

    /**     * 转换为16进制 再打印     * @param bytes     * @return     */    public static String dumpBytesToHex(byte[] bytes) {        String s = bytesToHex(bytes);        System.out.println("Hex String:\n" + s);        return s;    }

    private static final char[] HEX_ARRAY = "0123456789ABCDEF".toCharArray();

    public static String bytesToHex66(byte[] bytes) {        StringBuffer sb = new StringBuffer();        char[] hexChars = new char[bytes.length * 2];        for (int j = 0; j < bytes.length; j++) {            byte aByte = bytes[j];            if (aByte > 33 && aByte < 128) {                sb.append((char) aByte);                continue;            }            int v = bytes[j] & 0xFF;            hexChars[j * 2] = HEX_ARRAY[v >>> 4];            hexChars[j * 2 + 1] = HEX_ARRAY[v & 0x0F];

            String hex = Integer.toHexString(aByte & 0xFF);            sb.append("\\x");            sb.append(hex);            if (hex.length() < 2) {                if (aByte == 0) {//                    continue; // Fixme ,                } else {                }                sb.append(0); // Fixme ,            }        }//        return new String(hexChars);        return sb.toString();    }

    /**     * @param bytes     * @return     */    public static String bytesToHex(byte[] bytes) {        StringBuffer sb = new StringBuffer();        for (int i = 0; i < bytes.length; i++) {            byte aByte = bytes[i];

            /**             * 这一段是做 ascii码字符 转换             */            if (aByte > 33 && aByte < 128) {                sb.append((char) aByte);                continue;            }            String hex = Integer.toHexString(aByte & 0xFF);            sb.append("\\x");            sb.append(hex);            if (hex.length() < 2) {                if (aByte == 0) {//                    continue;                } else {                }                sb.append(0);            }        }        return sb.toString();    }

}