#448

Committed 23 May 2026 01:38PM UTC coverage: 89.341% (+0.4%) from 88.921%

Build # #448

Build Type

push

Committed by

Commit Message

fix: init fail if Kryo not in classpath

Coverage Stats

0 of 4 new or added lines in 1 file covered. (0.0%)

27 existing lines in 9 files now uncovered.

5029 of 5629 relevant lines covered (89.34%)

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 if (SerialPolicy.JACKSON3.equalsIgnoreCase(valueEncoder)) {
            return new Jackson3ValueEncoder(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 Fastjson2ValueDecoder(useIdentityNumber);
        } else if (SerialPolicy.JACKSON3.equalsIgnoreCase(valueDecoder)) {
            return new Jackson3ValueDecoder(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✔
58	return new Kryo5ValueEncoder(useIdentityNumber, Kryo5ValueEncoder.DEFAULT_POOL);	×
59	}/* else if (SerialPolicy.FASTJSON2.equalsIgnoreCase(valueEncoder)) {
60	return new Fastjson2ValueEncoder(useIdentityNumber);
61	} else if (SerialPolicy.JACKSON3.equalsIgnoreCase(valueEncoder)) {
62	return new Jackson3ValueEncoder(useIdentityNumber);
63	}*/ else {
64	throw new CacheConfigException("not supported:" + valueEncoder);	1✔
65	}
66	}
67
68	private boolean isUseIdentityNumber(URI uri) {
69	Map<String, String> params = parseQueryParameters(uri.getQuery());	1✔
70	boolean useIdentityNumber = true;	1✔
71	if ("false".equalsIgnoreCase(params.get("useIdentityNumber"))) {	1✔
72	useIdentityNumber = false;	1✔
73	}
74	return useIdentityNumber;	1✔
75	}
76
77	@Override
78	public Function<byte[], Object> parseDecoder(String valueDecoder) {
79	if (valueDecoder == null) {	1✔
80	throw new CacheConfigException("no serialPolicy");	1✔
81	}
82	valueDecoder = valueDecoder.trim();	1✔
83	URI uri = URI.create(valueDecoder);	1✔
84	valueDecoder = uri.getPath();	1✔
85	boolean useIdentityNumber = isUseIdentityNumber(uri);	1✔
86	if (SerialPolicy.KRYO.equalsIgnoreCase(valueDecoder)) {	1✔
87	return new KryoValueDecoder(useIdentityNumber, KryoValueEncoder.DEFAULT_POOL);	1✔
88	} else if (SerialPolicy.JAVA.equalsIgnoreCase(valueDecoder)) {	1✔
89	return javaValueDecoder(useIdentityNumber);	1✔
90	} else if (SerialPolicy.KRYO5.equalsIgnoreCase(valueDecoder)) {	1✔
UNCOV 91	return new Kryo5ValueDecoder(useIdentityNumber, Kryo5ValueEncoder.DEFAULT_POOL);	×
92	}/* else if (SerialPolicy.FASTJSON2.equalsIgnoreCase(valueDecoder)) {
93	return new Fastjson2ValueDecoder(useIdentityNumber);
94	} else if (SerialPolicy.JACKSON3.equalsIgnoreCase(valueDecoder)) {
95	return new Jackson3ValueDecoder(useIdentityNumber);
96	}*/ else {
97	throw new CacheConfigException("not supported:" + valueDecoder);	1✔
98	}
99	}
100	}

alibaba / jetcache / #448

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