Merge branch 'master' into 3.0.0
# Conflicts: # pom.xml # redisson-all/pom.xml # redisson-hibernate/pom.xml # redisson-hibernate/redisson-hibernate-4/pom.xml # redisson-hibernate/redisson-hibernate-5/pom.xml # redisson-hibernate/redisson-hibernate-52/pom.xml # redisson-hibernate/redisson-hibernate-53/pom.xml # redisson-spring-boot-starter/pom.xml # redisson-spring-data/pom.xml # redisson-spring-data/redisson-spring-data-16/pom.xml # redisson-spring-data/redisson-spring-data-17/pom.xml # redisson-spring-data/redisson-spring-data-18/pom.xml # redisson-spring-data/redisson-spring-data-20/pom.xml # redisson-tomcat/pom.xml # redisson-tomcat/redisson-tomcat-6/pom.xml # redisson-tomcat/redisson-tomcat-7/pom.xml # redisson-tomcat/redisson-tomcat-8/pom.xml # redisson-tomcat/redisson-tomcat-9/pom.xml # redisson/pom.xmlpull/1933/head
Nikita Koksharov
6 years ago
commit
d940781561
@ -1,224 +0,0 @@
|
||||
/**
|
||||
* Copyright 2018 Nikita Koksharov
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
*
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
*
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package org.redisson.misc;
|
||||
|
||||
import java.lang.reflect.InvocationTargetException;
|
||||
import java.lang.reflect.Method;
|
||||
import java.util.Arrays;
|
||||
import java.util.Collections;
|
||||
import java.util.HashMap;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
||||
import org.redisson.RedissonLiveObjectService;
|
||||
import org.redisson.RedissonReference;
|
||||
import org.redisson.api.RLiveObject;
|
||||
import org.redisson.api.RObject;
|
||||
import org.redisson.api.RObjectReactive;
|
||||
import org.redisson.api.RedissonClient;
|
||||
import org.redisson.api.RedissonReactiveClient;
|
||||
import org.redisson.api.RedissonRxClient;
|
||||
import org.redisson.api.annotation.REntity;
|
||||
import org.redisson.api.annotation.RId;
|
||||
import org.redisson.client.codec.Codec;
|
||||
import org.redisson.codec.ReferenceCodecProvider;
|
||||
import org.redisson.config.Config;
|
||||
import org.redisson.liveobject.misc.ClassUtils;
|
||||
import org.redisson.liveobject.misc.Introspectior;
|
||||
import org.redisson.liveobject.resolver.NamingScheme;
|
||||
|
||||
/**
|
||||
*
|
||||
* @author Rui Gu (https://github.com/jackygurui)
|
||||
*/
|
||||
public class RedissonObjectFactory {
|
||||
|
||||
public static class RedissonObjectBuilder {
|
||||
|
||||
Method defaultCodecMethod;
|
||||
Method customCodecMethod;
|
||||
|
||||
Method get(boolean value) {
|
||||
if (value) {
|
||||
return defaultCodecMethod;
|
||||
}
|
||||
return customCodecMethod;
|
||||
}
|
||||
}
|
||||
|
||||
private static final Map<Class<?>, RedissonObjectBuilder> builders;
|
||||
|
||||
static {
|
||||
HashMap<Class<?>, RedissonObjectBuilder> b = new HashMap<Class<?>, RedissonObjectBuilder>();
|
||||
for (Method method : RedissonClient.class.getDeclaredMethods()) {
|
||||
if (!method.getReturnType().equals(Void.TYPE)
|
||||
&& RObject.class.isAssignableFrom(method.getReturnType())
|
||||
&& method.getName().startsWith("get")) {
|
||||
Class<?> cls = method.getReturnType();
|
||||
if (!b.containsKey(cls)) {
|
||||
b.put(cls, new RedissonObjectBuilder());
|
||||
}
|
||||
RedissonObjectBuilder builder = b.get(cls);
|
||||
if (method.getParameterTypes().length == 2 //first param is name, second param is codec.
|
||||
&& Codec.class.isAssignableFrom(method.getParameterTypes()[1])) {
|
||||
builder.customCodecMethod = method;
|
||||
} else if (method.getParameterTypes().length == 1) {
|
||||
builder.defaultCodecMethod = method;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
for (Method method : RedissonReactiveClient.class.getDeclaredMethods()) {
|
||||
if (!method.getReturnType().equals(Void.TYPE)
|
||||
&& RObjectReactive.class.isAssignableFrom(method.getReturnType())
|
||||
&& method.getName().startsWith("get")) {
|
||||
Class<?> cls = method.getReturnType();
|
||||
if (!b.containsKey(cls)) {
|
||||
b.put(cls, new RedissonObjectBuilder());
|
||||
}
|
||||
RedissonObjectBuilder builder = b.get(cls);
|
||||
if (method.getParameterTypes().length == 2 //first param is name, second param is codec.
|
||||
&& Codec.class.isAssignableFrom(method.getParameterTypes()[1])) {
|
||||
builder.customCodecMethod = method;
|
||||
} else if (method.getParameterTypes().length == 1) {
|
||||
builder.defaultCodecMethod = method;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
builders = Collections.unmodifiableMap(b);
|
||||
|
||||
}
|
||||
|
||||
public static Object fromReference(RedissonClient redisson, RedissonReference rr) throws Exception {
|
||||
Class<? extends Object> type = rr.getType();
|
||||
ReferenceCodecProvider codecProvider = redisson.getConfig().getReferenceCodecProvider();
|
||||
if (type != null) {
|
||||
if (ClassUtils.isAnnotationPresent(type, REntity.class)) {
|
||||
RedissonLiveObjectService liveObjectService = (RedissonLiveObjectService) redisson.getLiveObjectService();
|
||||
REntity anno = ClassUtils.getAnnotation(type, REntity.class);
|
||||
NamingScheme ns = anno.namingScheme()
|
||||
.getDeclaredConstructor(Codec.class)
|
||||
.newInstance(codecProvider.getCodec(anno, type, redisson.getConfig()));
|
||||
Object id = ns.resolveId(rr.getKeyName());
|
||||
return liveObjectService.createLiveObject(type, id);
|
||||
}
|
||||
}
|
||||
|
||||
return getObject(redisson, rr, type, codecProvider);
|
||||
}
|
||||
|
||||
protected static Object getObject(Object redisson, RedissonReference rr, Class<? extends Object> type,
|
||||
ReferenceCodecProvider codecProvider)
|
||||
throws IllegalAccessException, InvocationTargetException, Exception, ClassNotFoundException {
|
||||
if (type != null) {
|
||||
RedissonObjectBuilder b = builders.get(type);
|
||||
if (b == null && type.getInterfaces().length > 0) {
|
||||
type = type.getInterfaces()[0];
|
||||
}
|
||||
b = builders.get(type);
|
||||
if (b != null) {
|
||||
Method builder = b.get(isDefaultCodec(rr));
|
||||
return (isDefaultCodec(rr)
|
||||
? builder.invoke(redisson, rr.getKeyName())
|
||||
: builder.invoke(redisson, rr.getKeyName(), codecProvider.getCodec(rr.getCodecType())));
|
||||
}
|
||||
}
|
||||
throw new ClassNotFoundException("No RObject is found to match class type of " + rr.getTypeName() + " with codec type of " + rr.getCodecName());
|
||||
}
|
||||
|
||||
private static boolean isDefaultCodec(RedissonReference rr) {
|
||||
return rr.getCodec() == null;
|
||||
}
|
||||
|
||||
public static Object fromReference(RedissonRxClient redisson, RedissonReference rr) throws Exception {
|
||||
Class<? extends Object> type = rr.getReactiveType();
|
||||
ReferenceCodecProvider codecProvider = redisson.getConfig().getReferenceCodecProvider();
|
||||
/**
|
||||
* Live Object from reference in reactive client is not supported yet.
|
||||
*/
|
||||
return getObject(redisson, rr, type, codecProvider);
|
||||
}
|
||||
|
||||
public static Object fromReference(RedissonReactiveClient redisson, RedissonReference rr) throws Exception {
|
||||
Class<? extends Object> type = rr.getReactiveType();
|
||||
ReferenceCodecProvider codecProvider = redisson.getConfig().getReferenceCodecProvider();
|
||||
/**
|
||||
* Live Object from reference in reactive client is not supported yet.
|
||||
*/
|
||||
return getObject(redisson, rr, type, codecProvider);
|
||||
}
|
||||
|
||||
public static RedissonReference toReference(Config config, Object object) {
|
||||
if (object != null && ClassUtils.isAnnotationPresent(object.getClass(), REntity.class)) {
|
||||
throw new IllegalArgumentException("REntity should be attached to Redisson before save");
|
||||
}
|
||||
|
||||
if (object instanceof RObject && !(object instanceof RLiveObject)) {
|
||||
Class<?> clazz = object.getClass().getInterfaces()[0];
|
||||
|
||||
RObject rObject = ((RObject) object);
|
||||
if (rObject.getCodec() != null) {
|
||||
config.getReferenceCodecProvider().registerCodec((Class) rObject.getCodec().getClass(), rObject.getCodec());
|
||||
}
|
||||
return new RedissonReference(clazz, rObject.getName(), rObject.getCodec());
|
||||
}
|
||||
if (object instanceof RObjectReactive && !(object instanceof RLiveObject)) {
|
||||
Class<?> clazz = object.getClass().getInterfaces()[0];
|
||||
|
||||
RObjectReactive rObject = ((RObjectReactive) object);
|
||||
if (rObject.getCodec() != null) {
|
||||
config.getReferenceCodecProvider().registerCodec((Class) rObject.getCodec().getClass(), rObject.getCodec());
|
||||
}
|
||||
return new RedissonReference(clazz, rObject.getName(), rObject.getCodec());
|
||||
}
|
||||
|
||||
try {
|
||||
if (object instanceof RLiveObject) {
|
||||
Class<? extends Object> rEntity = object.getClass().getSuperclass();
|
||||
REntity anno = ClassUtils.getAnnotation(rEntity, REntity.class);
|
||||
NamingScheme ns = anno.namingScheme()
|
||||
.getDeclaredConstructor(Codec.class)
|
||||
.newInstance(config.getReferenceCodecProvider().getCodec(anno, (Class) rEntity, config));
|
||||
String name = Introspectior
|
||||
.getFieldsWithAnnotation(rEntity, RId.class)
|
||||
.getOnly().getName();
|
||||
Class<?> type = ClassUtils.getDeclaredField(rEntity, name).getType();
|
||||
|
||||
return new RedissonReference(rEntity,
|
||||
ns.getName(rEntity, type, name, ((RLiveObject) object).getLiveObjectId()));
|
||||
}
|
||||
} catch (Exception e) {
|
||||
throw new IllegalArgumentException(e);
|
||||
}
|
||||
return null;
|
||||
}
|
||||
|
||||
public static <T extends RObject, K extends Codec> T createRObject(RedissonClient redisson, Class<T> expectedType, String name, K codec) throws Exception {
|
||||
List<Class<?>> interfaces = Arrays.asList(expectedType.getInterfaces());
|
||||
for (Class<?> iType : interfaces) {
|
||||
if (builders.containsKey(iType)) {// user cache to speed up things a little.
|
||||
Method builder = builders.get(iType).get(codec != null);
|
||||
return (T) (codec != null
|
||||
? builder.invoke(redisson, name)
|
||||
: builder.invoke(redisson, name, codec));
|
||||
}
|
||||
}
|
||||
throw new ClassNotFoundException("No RObject is found to match class type of " + (expectedType != null ? expectedType.getName() : "null") + " with codec type of " + (codec != null ? codec.getClass().getName() : "null"));
|
||||
}
|
||||
|
||||
public static void warmUp() {}
|
||||
}
|
||||
Loading…
Reference in New Issue