#447

Committed 23 May 2026 01:52AM UTC coverage: 88.921% (-0.4%) from 89.31%

Build # #447

Build Type

push

Committed by

Commit Message

feat: allow customize DecodeFilter for kryo decoder

Coverage Stats

54 of 59 new or added lines in 8 files covered. (91.53%)

24 existing lines in 8 files now uncovered.

4976 of 5596 relevant lines covered (88.92%)

0.89 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

95.35

/jetcache-anno/src/main/java/com/alicp/jetcache/anno/support/DefaultEncoderParser.java

/**
 * Created on 2019/6/7.
 */
package com.alicp.jetcache.anno.support;

import com.alicp.jetcache.CacheConfigException;
import com.alicp.jetcache.anno.SerialPolicy;
import com.alicp.jetcache.support.JavaValueDecoder;
import com.alicp.jetcache.support.JavaValueEncoder;
import com.alicp.jetcache.support.Kryo5ValueDecoder;
import com.alicp.jetcache.support.Kryo5ValueEncoder;
import com.alicp.jetcache.support.KryoValueDecoder;
import com.alicp.jetcache.support.KryoValueEncoder;

import java.net.URI;
import java.util.HashMap;
import java.util.Map;
import java.util.function.Function;

/**
 * @author huangli
 */
public class DefaultEncoderParser implements EncoderParser {
    protected static Map<String, String> parseQueryParameters(String query) {
        Map<String, String> m = new HashMap<>();
        if (query != null) {
            String[] pairs = query.split("&");
            for (String pair : pairs) {
                int idx = pair.indexOf("=");
                String key = idx > 0 ? pair.substring(0, idx) : pair;
                String value = idx > 0 && pair.length() > idx + 1 ? pair.substring(idx + 1) : null;
                if (key != null && value != null) {
                    m.put(key, value);
                }
            }
        }
        return m;
    }

    JavaValueDecoder javaValueDecoder(boolean useIdentityNumber) {
        return new JavaValueDecoder(useIdentityNumber);
    }

    @Override
    public Function<Object, byte[]> parseEncoder(String valueEncoder) {
        if (valueEncoder == null) {
            throw new CacheConfigException("no serialPolicy");
        }
        valueEncoder = valueEncoder.trim();
        URI uri = URI.create(valueEncoder);
        valueEncoder = uri.getPath();
        boolean useIdentityNumber = isUseIdentityNumber(uri);
        if (SerialPolicy.KRYO.equalsIgnoreCase(valueEncoder)) {
            return new KryoValueEncoder(useIdentityNumber, KryoValueEncoder.DEFAULT_POOL);
        } else if (SerialPolicy.JAVA.equalsIgnoreCase(valueEncoder)) {
            return new JavaValueEncoder(useIdentityNumber);
        } else if (SerialPolicy.KRYO5.equalsIgnoreCase(valueEncoder)) {
            return new Kryo5ValueEncoder(useIdentityNumber, Kryo5ValueEncoder.DEFAULT_POOL);
        }/* else if (SerialPolicy.FASTJSON2.equalsIgnoreCase(valueEncoder)) {
            return new Fastjson2ValueEncoder(useIdentityNumber);
        }*/ else {
            throw new CacheConfigException("not supported:" + valueEncoder);
        }
    }

    private boolean isUseIdentityNumber(URI uri) {
        Map<String, String> params = parseQueryParameters(uri.getQuery());
        boolean useIdentityNumber = true;
        if ("false".equalsIgnoreCase(params.get("useIdentityNumber"))) {
            useIdentityNumber = false;
        }
        return useIdentityNumber;
    }

    @Override
    public Function<byte[], Object> parseDecoder(String valueDecoder) {
        if (valueDecoder == null) {
            throw new CacheConfigException("no serialPolicy");
        }
        valueDecoder = valueDecoder.trim();
        URI uri = URI.create(valueDecoder);
        valueDecoder = uri.getPath();
        boolean useIdentityNumber = isUseIdentityNumber(uri);
        if (SerialPolicy.KRYO.equalsIgnoreCase(valueDecoder)) {
            return new KryoValueDecoder(useIdentityNumber, KryoValueEncoder.DEFAULT_POOL);
        } else if (SerialPolicy.JAVA.equalsIgnoreCase(valueDecoder)) {
            return javaValueDecoder(useIdentityNumber);
        } else if (SerialPolicy.KRYO5.equalsIgnoreCase(valueDecoder)) {
            return new Kryo5ValueDecoder(useIdentityNumber, Kryo5ValueEncoder.DEFAULT_POOL);
        }/* else if (SerialPolicy.FASTJSON2.equalsIgnoreCase(valueDecoder)) {
            return new Kryo5ValueDecoder(useIdentityNumber);
        }*/ else {
            throw new CacheConfigException("not supported:" + valueDecoder);
        }
    }
}

1	/**
2	* Created on 2019/6/7.
3	*/
4	package com.alicp.jetcache.anno.support;
5
6	import com.alicp.jetcache.CacheConfigException;
7	import com.alicp.jetcache.anno.SerialPolicy;
8	import com.alicp.jetcache.support.JavaValueDecoder;
9	import com.alicp.jetcache.support.JavaValueEncoder;
10	import com.alicp.jetcache.support.Kryo5ValueDecoder;
11	import com.alicp.jetcache.support.Kryo5ValueEncoder;
12	import com.alicp.jetcache.support.KryoValueDecoder;
13	import com.alicp.jetcache.support.KryoValueEncoder;
14
15	import java.net.URI;
16	import java.util.HashMap;
17	import java.util.Map;
18	import java.util.function.Function;
19
20	/**
21	* @author huangli
22	*/
23	public class DefaultEncoderParser implements EncoderParser {	1✔
24	protected static Map<String, String> parseQueryParameters(String query) {
25	Map<String, String> m = new HashMap<>();	1✔
26	if (query != null) {	1✔
27	String[] pairs = query.split("&");	1✔
28	for (String pair : pairs) {	1✔
29	int idx = pair.indexOf("=");	1✔
30	String key = idx > 0 ? pair.substring(0, idx) : pair;	1✔
31	String value = idx > 0 && pair.length() > idx + 1 ? pair.substring(idx + 1) : null;	1✔
32	if (key != null && value != null) {	1✔
33	m.put(key, value);	1✔
34	}
35	}
36	}
37	return m;	1✔
38	}
39
40	JavaValueDecoder javaValueDecoder(boolean useIdentityNumber) {
41	return new JavaValueDecoder(useIdentityNumber);	1✔
42	}
43
44	@Override
45	public Function<Object, byte[]> parseEncoder(String valueEncoder) {
46	if (valueEncoder == null) {	1✔
47	throw new CacheConfigException("no serialPolicy");	1✔
48	}
49	valueEncoder = valueEncoder.trim();	1✔
50	URI uri = URI.create(valueEncoder);	1✔
51	valueEncoder = uri.getPath();	1✔
52	boolean useIdentityNumber = isUseIdentityNumber(uri);	1✔
53	if (SerialPolicy.KRYO.equalsIgnoreCase(valueEncoder)) {	1✔
54	return new KryoValueEncoder(useIdentityNumber, KryoValueEncoder.DEFAULT_POOL);	1✔
55	} else if (SerialPolicy.JAVA.equalsIgnoreCase(valueEncoder)) {	1✔
56	return new JavaValueEncoder(useIdentityNumber);	1✔
57	} else if (SerialPolicy.KRYO5.equalsIgnoreCase(valueEncoder)) {	1✔
NEW 58	return new Kryo5ValueEncoder(useIdentityNumber, Kryo5ValueEncoder.DEFAULT_POOL);	×
59	}/* else if (SerialPolicy.FASTJSON2.equalsIgnoreCase(valueEncoder)) {
60	return new Fastjson2ValueEncoder(useIdentityNumber);
61	}*/ else {
62	throw new CacheConfigException("not supported:" + valueEncoder);	1✔
63	}
64	}
65
66	private boolean isUseIdentityNumber(URI uri) {
67	Map<String, String> params = parseQueryParameters(uri.getQuery());	1✔
68	boolean useIdentityNumber = true;	1✔
69	if ("false".equalsIgnoreCase(params.get("useIdentityNumber"))) {	1✔
70	useIdentityNumber = false;	1✔
71	}
72	return useIdentityNumber;	1✔
73	}
74
75	@Override
76	public Function<byte[], Object> parseDecoder(String valueDecoder) {
77	if (valueDecoder == null) {	1✔
78	throw new CacheConfigException("no serialPolicy");	1✔
79	}
80	valueDecoder = valueDecoder.trim();	1✔
81	URI uri = URI.create(valueDecoder);	1✔
82	valueDecoder = uri.getPath();	1✔
83	boolean useIdentityNumber = isUseIdentityNumber(uri);	1✔
84	if (SerialPolicy.KRYO.equalsIgnoreCase(valueDecoder)) {	1✔
85	return new KryoValueDecoder(useIdentityNumber, KryoValueEncoder.DEFAULT_POOL);	1✔
86	} else if (SerialPolicy.JAVA.equalsIgnoreCase(valueDecoder)) {	1✔
87	return javaValueDecoder(useIdentityNumber);	1✔
88	} else if (SerialPolicy.KRYO5.equalsIgnoreCase(valueDecoder)) {	1✔
NEW 89	return new Kryo5ValueDecoder(useIdentityNumber, Kryo5ValueEncoder.DEFAULT_POOL);	×
90	}/* else if (SerialPolicy.FASTJSON2.equalsIgnoreCase(valueDecoder)) {
91	return new Kryo5ValueDecoder(useIdentityNumber);
92	}*/ else {
93	throw new CacheConfigException("not supported:" + valueDecoder);	1✔
94	}
95	}
96	}

alibaba / jetcache / #447

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous