> getFilterEntrys() {
+ return entrys;
+ }
+
+ /**
+ * 自动扫描地过滤指定的class
+ *
+ * @param property
+ * @param clazzname
+ */
+ @SuppressWarnings("unchecked")
+ public final void filter(AnyValue property, String clazzname) {
+ filter(property, clazzname, true);
+ }
+
+ /**
+ * 过滤指定的class
+ *
+ * @param property application.xml中对应class节点下的property属性项
+ * @param clazzname class名称
+ * @param autoscan 为true表示自动扫描的， false表示显著调用filter， AutoLoad的注解将被忽略
+ */
+ public final void filter(AnyValue property, String clazzname, boolean autoscan) {
+ if (!accept(property, clazzname)) return;
+ try {
+ Class clazz = Class.forName(clazzname);
+ if (accept(property, clazz, autoscan)) {
+ FilterEntry en = new FilterEntry(clazz, property);
+ if (!entrys.contains(en)) entrys.add(en);
+ }
+ } catch (Throwable cfe) {
+ }
+ }
+
+ private static Pattern[] toPattern(String[] regs) {
+ if (regs == null) return null;
+ int i = 0;
+ Pattern[] rs = new Pattern[regs.length];
+ for (String reg : regs) {
+ if (reg == null || reg.trim().isEmpty()) continue;
+ rs[i++] = Pattern.compile(reg.trim());
+ }
+ if (i == 0) return null;
+ if (i == rs.length) return rs;
+ Pattern[] ps = new Pattern[i];
+ System.arraycopy(rs, 0, ps, 0, i);
+ return ps;
+ }
+
+ /**
+ * 判断class是否有效
+ *
+ * @param property
+ * @param classname
+ * @return
+ */
+ public boolean accept(AnyValue property, String classname) {
+ if (this.refused) return false;
+ if (classname.startsWith("java.") || classname.startsWith("javax.")) return false;
+ if (excludePatterns != null) {
+ for (Pattern reg : excludePatterns) {
+ if (reg.matcher(classname).matches()) return false;
+ }
+ }
+ if (includePatterns != null) {
+ for (Pattern reg : includePatterns) {
+ if (reg.matcher(classname).matches()) return true;
+ }
+ }
+ return includePatterns == null;
+ }
+
+ /**
+ * 判断class是否有效
+ *
+ * @param property
+ * @param clazz
+ * @param autoscan
+ * @return
+ */
+ @SuppressWarnings("unchecked")
+ public boolean accept(AnyValue property, Class clazz, boolean autoscan) {
+ if (this.refused || !Modifier.isPublic(clazz.getModifiers())) return false;
+ if (clazz.getAnnotation(Ignore.class) != null) return false;
+ if (autoscan) {
+ AutoLoad auto = (AutoLoad) clazz.getAnnotation(AutoLoad.class);
+ if (auto != null && !auto.value()) return false;
+ }
+ if (annotationClass != null && clazz.getAnnotation(annotationClass) == null) return false;
+ return superClass == null || (clazz != superClass && superClass.isAssignableFrom(clazz));
+ }
+
+ public void setSuperClass(Class superClass) {
+ this.superClass = superClass;
+ }
+
+ public void setAnnotationClass(Class annotationClass) {
+ this.annotationClass = annotationClass;
+ }
+
+ public Pattern[] getIncludePatterns() {
+ return includePatterns;
+ }
+
+ public void setIncludePatterns(String[] includePatterns) {
+ this.includePatterns = toPattern(includePatterns);
+ }
+
+ public Pattern[] getExcludePatterns() {
+ return excludePatterns;
+ }
+
+ public void setExcludePatterns(String[] excludePatterns) {
+ this.excludePatterns = toPattern(excludePatterns);
+ }
+
+ public Class getAnnotationClass() {
+ return annotationClass;
+ }
+
+ public Class getSuperClass() {
+ return superClass;
+ }
+
+ public boolean isRefused() {
+ return refused;
+ }
+
+ public void setRefused(boolean refused) {
+ this.refused = refused;
+ }
+
+ /**
+ * 存放符合条件的class与class指定的属性项
+ *
+ * @param
+ */
+ public static final class FilterEntry {
+
+ private final String name;
+
+ private final Class type;
+
+ private final AnyValue property;
+
+ protected Object attachment;
+
+ public FilterEntry(Class type, AnyValue property) {
+ this.type = type;
+ this.property = property;
+ this.name = property == null ? "" : property.getValue("name", "");
+ }
+
+ @Override
+ public String toString() {
+ return this.getClass().getSimpleName() + "[thread=" + Thread.currentThread().getName()
+ + ", type=" + this.type.getSimpleName() + ", name=" + name
+ + ", remote=" + (property == null ? "null" : property.getValue("remote")) + "]";
+ }
+
+ @Override
+ public int hashCode() {
+ return this.type.hashCode();
+ }
+
+ @Override
+ public boolean equals(Object obj) {
+ if (obj == null) return false;
+ if (getClass() != obj.getClass()) return false;
+ return (this.type == ((FilterEntry) obj).type && this.name.equals(((FilterEntry) obj).name));
+ }
+
+ public Class getType() {
+ return type;
+ }
+
+ public String getName() {
+ return name;
+ }
+
+ public AnyValue getProperty() {
+ return property;
+ }
+
+ public Object getAttachment() {
+ return attachment;
+ }
+
+ public void setAttachment(Object attachment) {
+ this.attachment = attachment;
+ }
+
+ }
+
+ /**
+ * class加载类
+ */
+ public static class Loader {
+
+ protected static final Logger logger = Logger.getLogger(Loader.class.getName());
+
+ /**
+ * 加载当前线程的classpath扫描所有class进行过滤
+ *
+ * @param exclude 不需要扫描的文件夹， 可以为null
+ * @param filters
+ * @throws IOException
+ */
+ public static void load(final File exclude, final ClassFilter... filters) throws IOException {
+ URLClassLoader loader = (URLClassLoader) Thread.currentThread().getContextClassLoader();
+ List urlfiles = new ArrayList<>(2);
+ List urljares = new ArrayList<>(2);
+ final URL exurl = exclude != null ? exclude.toURI().toURL() : null;
+ for (URL url : loader.getURLs()) {
+ if (exurl != null && exurl.sameFile(url)) continue;
+ if (url.getPath().endsWith(".jar")) {
+ urljares.add(url);
+ } else {
+ urlfiles.add(url);
+ }
+ }
+
+ List files = new ArrayList<>();
+ boolean debug = logger.isLoggable(Level.FINEST);
+ StringBuilder debugstr = new StringBuilder();
+ for (URL url : urljares) {
+ try (JarFile jar = new JarFile(URLDecoder.decode(url.getFile(), "UTF-8"))) {
+ Enumeration it = jar.entries();
+ while (it.hasMoreElements()) {
+ String entryname = it.nextElement().getName().replace('/', '.');
+ if (entryname.endsWith(".class") && entryname.indexOf('$') < 0) {
+ String classname = entryname.substring(0, entryname.length() - 6);
+ if (classname.startsWith("javax.") || classname.startsWith("org.") || classname.startsWith("com.mysql.")) continue;
+ if (debug) debugstr.append(classname).append("\r\n");
+ for (final ClassFilter filter : filters) {
+ if (filter != null) filter.filter(null, classname);
+ }
+ }
+ }
+ }
+ }
+ for (URL url : urlfiles) {
+ files.clear();
+ File root = new File(url.getFile());
+ String rootpath = root.getPath();
+ loadClassFiles(exclude, root, files);
+ for (File f : files) {
+ String classname = f.getPath().substring(rootpath.length() + 1, f.getPath().length() - 6).replace(File.separatorChar, '.');
+ if (classname.startsWith("javax.") || classname.startsWith("org.") || classname.startsWith("com.mysql.")) continue;
+ if (debug) debugstr.append(classname).append("\r\n");
+ for (final ClassFilter filter : filters) {
+ if (filter != null) filter.filter(null, classname);
+ }
+ }
+ }
+ //if (debug) logger.log(Level.INFO, "scan classes: \r\n{0}", debugstr);
+ }
+
+ private static void loadClassFiles(File exclude, File root, List files) {
+ if (root.isFile() && root.getName().endsWith(".class")) {
+ files.add(root);
+ } else if (root.isDirectory()) {
+ if (exclude != null && exclude.equals(root)) return;
+ for (File f : root.listFiles()) {
+ loadClassFiles(exclude, f, files);
+ }
+ }
+ }
+ }
+}
diff --git a/src/com/wentch/redkale/boot/LogFileHandler.java b/src/com/wentch/redkale/boot/LogFileHandler.java
new file mode 100644
index 000000000..e21921c1f
--- /dev/null
+++ b/src/com/wentch/redkale/boot/LogFileHandler.java
@@ -0,0 +1,230 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.boot;
+
+import java.io.*;
+import java.nio.file.*;
+import static java.nio.file.StandardCopyOption.*;
+import java.time.*;
+import java.util.*;
+import java.util.concurrent.*;
+import java.util.concurrent.atomic.*;
+import java.util.logging.*;
+import java.util.logging.Formatter;
+
+/**
+ * 自定义的日志存储类
+ *
+ * @author zhangjx
+ */
+public class LogFileHandler extends Handler {
+
+ public static class LoggingFormater extends Formatter {
+
+ private static final String format = "%1$tY-%1$tm-%1$td %1$tH:%1$tM:%1$tS.%tL %4$s %2$s\r\n%5$s%6$s\r\n";
+
+ @Override
+ public String format(LogRecord record) {
+ String source;
+ if (record.getSourceClassName() != null) {
+ source = record.getSourceClassName();
+ if (record.getSourceMethodName() != null) {
+ source += " " + record.getSourceMethodName();
+ }
+ } else {
+ source = record.getLoggerName();
+ }
+ String message = formatMessage(record);
+ String throwable = "";
+ if (record.getThrown() != null) {
+ StringWriter sw = new StringWriter();
+ PrintWriter pw = new PrintWriter(sw) {
+ @Override
+ public void println() {
+ super.print("\r\n");
+ }
+ };
+ pw.println();
+ record.getThrown().printStackTrace(pw);
+ pw.close();
+ throwable = sw.toString();
+ }
+ return String.format(format,
+ System.currentTimeMillis(),
+ source,
+ record.getLoggerName(),
+ record.getLevel().getName(),
+ message,
+ throwable);
+ }
+
+ }
+
+ protected final LinkedBlockingQueue records = new LinkedBlockingQueue();
+
+ private String pattern;
+
+ private int limit; //文件大小限制
+
+ private final AtomicInteger index = new AtomicInteger();
+
+ private int count = 1; //文件限制
+
+ private long tomorrow;
+
+ private boolean append;
+
+ private final AtomicLong length = new AtomicLong();
+
+ private File logfile;
+
+ private OutputStream stream;
+
+ public LogFileHandler() {
+ updateTomorrow();
+ configure();
+ open();
+ }
+
+ private void updateTomorrow() {
+ Calendar cal = Calendar.getInstance();
+ cal.set(Calendar.HOUR_OF_DAY, 0);
+ cal.set(Calendar.MINUTE, 0);
+ cal.set(Calendar.SECOND, 0);
+ cal.set(Calendar.MILLISECOND, 0);
+ cal.add(Calendar.DAY_OF_YEAR, 1);
+ long t = cal.getTimeInMillis();
+ if (this.tomorrow != t) index.set(0);
+ this.tomorrow = t;
+ }
+
+ private void open() {
+ new Thread() {
+ {
+ setName("Logging-FileHandler-Thread");
+ setDaemon(true);
+ }
+
+ @Override
+ public void run() {
+ while (true) {
+ try {
+ LogRecord record = records.take();
+ if ((limit > 0 && limit <= length.get()) || tomorrow <= record.getMillis()) {
+ updateTomorrow();
+ if (stream != null) {
+ stream.close();
+ for (int i = Math.min(count - 2, index.get() - 1); i > 0; i--) {
+ File greater = new File(logfile.getPath() + "." + i);
+ if (greater.exists()) Files.move(greater.toPath(), new File(logfile.getPath() + "." + (i + 1)).toPath(), REPLACE_EXISTING, ATOMIC_MOVE);
+ }
+ Files.move(logfile.toPath(), new File(logfile.getPath() + ".1").toPath(), REPLACE_EXISTING, ATOMIC_MOVE);
+ stream = null;
+ }
+ }
+ if (stream == null) {
+ index.incrementAndGet();
+ java.time.LocalDate date = LocalDate.now();
+ logfile = new File(pattern.replace("%d", String.valueOf((date.getYear() * 10000 + date.getMonthValue() * 100 + date.getDayOfMonth()))));
+ logfile.getParentFile().mkdirs();
+ length.set(logfile.length());
+ stream = new FileOutputStream(logfile, append);
+ }
+ //----------------------写日志-------------------------
+ String message = getFormatter().format(record);
+ String encoding = getEncoding();
+ byte[] bytes = encoding == null ? message.getBytes() : message.getBytes(encoding);
+ stream.write(bytes);
+ length.addAndGet(bytes.length);
+ } catch (Exception e) {
+ ErrorManager err = getErrorManager();
+ if (err != null) err.error(null, e, ErrorManager.WRITE_FAILURE);
+ }
+ }
+
+ }
+ }.start();
+ }
+
+ private void configure() {
+ LogManager manager = LogManager.getLogManager();
+ String cname = getClass().getName();
+ pattern = manager.getProperty(cname + ".pattern");
+ if (pattern == null) pattern = "logs/log-%d.log";
+ String limitstr = manager.getProperty(cname + ".limit");
+ try {
+ if (limitstr != null) limit = Math.abs(Integer.decode(limitstr));
+ } catch (Exception e) {
+ }
+ String countstr = manager.getProperty(cname + ".count");
+ try {
+ if (countstr != null) count = Math.max(1, Math.abs(Integer.decode(countstr)));
+ } catch (Exception e) {
+ }
+ String appendstr = manager.getProperty(cname + ".append");
+ try {
+ if (appendstr != null) append = "true".equalsIgnoreCase(appendstr) || "1".equals(appendstr);
+ } catch (Exception e) {
+ }
+ String levelstr = manager.getProperty(cname + ".level");
+ try {
+ if (levelstr != null) {
+ Level l = Level.parse(levelstr);
+ setLevel(l != null ? l : Level.ALL);
+ }
+ } catch (Exception e) {
+ }
+ String filterstr = manager.getProperty(cname + ".filter");
+ try {
+ if (filterstr != null) {
+ Class clz = ClassLoader.getSystemClassLoader().loadClass(filterstr);
+ setFilter((Filter) clz.newInstance());
+ }
+ } catch (Exception e) {
+ }
+ String formatterstr = manager.getProperty(cname + ".formatter");
+ try {
+ if (formatterstr != null) {
+ Class clz = ClassLoader.getSystemClassLoader().loadClass(formatterstr);
+ setFormatter((Formatter) clz.newInstance());
+ }
+ } catch (Exception e) {
+ }
+ if (getFormatter() == null) setFormatter(new SimpleFormatter());
+
+ String encodingstr = manager.getProperty(cname + ".encoding");
+ try {
+ if (encodingstr != null) setEncoding(encodingstr);
+ } catch (Exception e) {
+ }
+ }
+
+ @Override
+ public void publish(LogRecord record) {
+ records.offer(record);
+ }
+
+ @Override
+ public void flush() {
+ try {
+ if (stream != null) stream.flush();
+ } catch (Exception e) {
+ ErrorManager err = getErrorManager();
+ if (err != null) err.error(null, e, ErrorManager.FLUSH_FAILURE);
+ }
+ }
+
+ @Override
+ public void close() throws SecurityException {
+ try {
+ if (stream != null) stream.close();
+ } catch (Exception e) {
+ ErrorManager err = getErrorManager();
+ if (err != null) err.error(null, e, ErrorManager.CLOSE_FAILURE);
+ }
+ }
+
+}
diff --git a/src/com/wentch/redkale/boot/NodeHttpServer.java b/src/com/wentch/redkale/boot/NodeHttpServer.java
new file mode 100644
index 000000000..6fc78c3bc
--- /dev/null
+++ b/src/com/wentch/redkale/boot/NodeHttpServer.java
@@ -0,0 +1,83 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.boot;
+
+import com.wentch.redkale.net.http.WebServlet;
+import com.wentch.redkale.net.http.HttpServer;
+import com.wentch.redkale.net.http.HttpServlet;
+import com.wentch.redkale.util.AnyValue;
+import com.wentch.redkale.boot.ClassFilter.FilterEntry;
+import com.wentch.redkale.service.Service;
+import java.lang.reflect.Modifier;
+import java.net.InetSocketAddress;
+import java.util.*;
+import java.util.concurrent.CountDownLatch;
+import java.util.logging.*;
+
+/**
+ *
+ * @author zhangjx
+ */
+public final class NodeHttpServer extends NodeServer {
+
+ private final HttpServer server;
+
+ public NodeHttpServer(Application application, CountDownLatch servicecdl, HttpServer server) {
+ super(application, servicecdl, server);
+ this.server = server;
+ }
+
+ @Override
+ public void init(AnyValue config) throws Exception {
+ server.init(config);
+ super.init(config);
+ }
+
+ @Override
+ public InetSocketAddress getSocketAddress() {
+ return server == null ? null : server.getSocketAddress();
+ }
+
+ @Override
+ public void load(AnyValue config) throws Exception {
+ super.load(config);
+ ClassFilter httpFilter = createHttpServletClassFilter(application.nodeName, config);
+ ClassFilter serviceFilter = createServiceClassFilter(application.nodeName, config);
+ long s = System.currentTimeMillis();
+ ClassFilter.Loader.load(application.getHome(), serviceFilter, httpFilter);
+ long e = System.currentTimeMillis() - s;
+ logger.info(this.getClass().getSimpleName() + " load filter class in " + e + " ms");
+ loadService(config.getAnyValue("services"), serviceFilter); //必须在servlet之前
+ if (server != null) initHttpServlet(config.getAnyValue("servlets"), httpFilter);
+ }
+
+ protected static ClassFilter createHttpServletClassFilter(final String node, final AnyValue config) {
+ return createClassFilter(node, config, WebServlet.class, HttpServlet.class, null, "servlets", "servlet");
+ }
+
+ protected void initHttpServlet(final AnyValue conf, final ClassFilter filter) throws Exception {
+ final StringBuilder sb = logger.isLoggable(Level.FINE) ? new StringBuilder() : null;
+ final String prefix = conf == null ? "" : conf.getValue("prefix", "");
+ final String threadName = "[" + Thread.currentThread().getName() + "] ";
+ for (FilterEntry en : filter.getFilterEntrys()) {
+ Class clazz = en.getType();
+ if (Modifier.isAbstract(clazz.getModifiers())) continue;
+ WebServlet ws = clazz.getAnnotation(WebServlet.class);
+ if (ws == null || ws.value().length == 0) continue;
+ final HttpServlet servlet = clazz.newInstance();
+ application.factory.inject(servlet);
+ String[] mappings = ws.value();
+ if (ws.fillurl() && !prefix.isEmpty()) {
+ for (int i = 0; i < mappings.length; i++) {
+ mappings[i] = prefix + mappings[i];
+ }
+ }
+ this.server.addHttpServlet(servlet, en.getProperty(), mappings);
+ if (sb != null) sb.append(threadName).append(" Loaded ").append(clazz.getName()).append(" --> ").append(Arrays.toString(mappings)).append(LINE_SEPARATOR);
+ }
+ if (sb != null && sb.length() > 0) logger.log(Level.FINE, sb.toString());
+ }
+}
diff --git a/src/com/wentch/redkale/boot/NodeServer.java b/src/com/wentch/redkale/boot/NodeServer.java
new file mode 100644
index 000000000..b5325e5b3
--- /dev/null
+++ b/src/com/wentch/redkale/boot/NodeServer.java
@@ -0,0 +1,250 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.boot;
+
+import com.wentch.redkale.net.sncp.ServiceEntry;
+import com.wentch.redkale.net.Server;
+import com.wentch.redkale.net.sncp.Sncp;
+import com.wentch.redkale.service.Service;
+import com.wentch.redkale.service.MultiService;
+import com.wentch.redkale.util.AnyValue;
+import com.wentch.redkale.util.Ignore;
+import com.wentch.redkale.boot.ClassFilter.FilterEntry;
+import com.wentch.redkale.util.AnyValue.DefaultAnyValue;
+import java.io.*;
+import java.lang.annotation.Annotation;
+import java.lang.reflect.*;
+import java.net.InetSocketAddress;
+import java.util.*;
+import java.util.concurrent.*;
+import java.util.function.Consumer;
+import java.util.logging.*;
+
+/**
+ *
+ * @author zhangjx
+ */
+public abstract class NodeServer {
+
+ public static final String LINE_SEPARATOR = "\r\n";
+
+ protected final Logger logger;
+
+ protected final Application application;
+
+ private final CountDownLatch servicecdl;
+
+ private final Server server;
+
+ protected Consumer consumer;
+
+ public NodeServer(Application application, CountDownLatch servicecdl, Server server) {
+ this.application = application;
+ this.servicecdl = servicecdl;
+ this.server = server;
+ this.logger = Logger.getLogger(this.getClass().getSimpleName());
+ }
+
+ public void load(final AnyValue config) throws Exception {
+ }
+
+ public void init(AnyValue config) throws Exception {
+ //设置root文件夹
+ String webroot = config.getValue("root", "root");
+ File myroot = new File(webroot);
+ if (!webroot.contains(":") && !webroot.startsWith("/")) {
+ myroot = new File(System.getProperty(Application.RESNAME_HOME), webroot);
+ }
+ final String homepath = myroot.getCanonicalPath();
+ Server.loadLib(logger, config.getValue("lib", "") + ";" + homepath + "/lib/*;" + homepath + "/classes");
+ }
+
+ public abstract InetSocketAddress getSocketAddress();
+
+ public void start() throws IOException {
+ server.start();
+ }
+
+ public void shutdown() throws IOException {
+ server.shutdown();
+ }
+
+ protected void loadLocalService(final Set> entrys) throws Exception {
+ final HashMap localServices = application.localServices;
+ for (final FilterEntry entry : entrys) {
+ Class serviceClass = entry.getType();
+ if (serviceClass.getAnnotation(Ignore.class) != null) continue;
+ final boolean multi = MultiService.class.isAssignableFrom(serviceClass);
+ if (!multi) { //单例模式
+ synchronized (application.localServices) {
+ ServiceEntry old = localServices.get(serviceClass);
+ if (old == null) {
+ old = new ServiceEntry(serviceClass, (Service) serviceClass.newInstance(), entry.getProperty(), "");
+ localServices.put(serviceClass, old);
+ }
+ if (consumer != null) consumer.accept(old);
+ continue;
+ }
+ }
+ String name = multi ? entry.getName() : "";
+ synchronized (application.localServices) {
+ ServiceEntry old = localServices.get(serviceClass);
+ if (old != null && old.containsName(name)) {
+ if (consumer != null) consumer.accept(old);
+ continue;
+ }
+ final Service service = (Service) serviceClass.newInstance();
+ if (old == null) {
+ old = new ServiceEntry(serviceClass, service, entry.getProperty(), name);
+ localServices.put(serviceClass, old);
+ } else {
+ old.addName(name);
+ }
+ if (consumer != null) consumer.accept(old);
+ }
+ }
+ }
+
+ protected void loadRemoteService(final Set> entrys) throws Exception {
+ for (FilterEntry entry : entrys) {
+ Class serviceClass = entry.getType();
+ if (serviceClass.getAnnotation(Ignore.class) != null) continue;
+ String remote = entry.getAttachment().toString();
+ Service service = Sncp.createRemoteService(entry.getName(), serviceClass, remote);
+ synchronized (application.remoteServices) {
+ application.remoteServices.add(new ServiceEntry(serviceClass, service, entry.getProperty(), entry.getName()));
+ }
+ }
+ }
+
+ @SuppressWarnings("unchecked")
+ protected void loadService(final AnyValue servicesConf, ClassFilter serviceFilter) throws Exception {
+ if (serviceFilter == null) return;
+ final String threadName = "[" + Thread.currentThread().getName() + "] ";
+ final Set> entrys = serviceFilter.getFilterEntrys();
+ final Set> localentrys = new HashSet<>(entrys.size());
+ final Set> remotentrys = new HashSet<>(entrys.size());
+ final String defremote = getRemoteName(servicesConf, "LOCAL");
+ for (FilterEntry entry : entrys) { //service实现类
+ final Class type = entry.getType();
+ if (type.isInterface()) continue;
+ if (Modifier.isFinal(type.getModifiers())) continue;
+ if (!Modifier.isPublic(type.getModifiers())) continue;
+ if (Modifier.isAbstract(type.getModifiers())) continue;
+ if (type.getAnnotation(Ignore.class) != null) continue;
+ final String remote = getRemoteName(entry.getProperty(), defremote);
+ if ("LOCAL".equals(remote)) { //本地模式
+ localentrys.add(entry);
+ } else { //远程模式
+ entry.setAttachment(remote);
+ remotentrys.add(entry);
+ }
+ }
+ loadLocalService(localentrys);
+ loadRemoteService(remotentrys);
+ servicecdl.countDown();
+ servicecdl.await();
+
+ final StringBuilder sb = logger.isLoggable(Level.INFO) ? new StringBuilder() : null;
+ synchronized (application) {
+ if (!application.serviceInited) {
+ application.serviceInited = true;
+ //--------------- register ---------------
+ application.localServices.forEach((x, y) -> {
+ y.getNames().forEach(n -> application.factory.register(n, y.getServiceClass(), y.getService()));
+ });
+ application.remoteServices.forEach(y -> {
+ y.getNames().forEach(n -> application.factory.register(n, y.getServiceClass(), y.getService()));
+ });
+ //---------------- inject ----------------
+ application.localServices.forEach((x, y) -> {
+ application.factory.inject(y.getService());
+ });
+ application.remoteServices.forEach(y -> {
+ application.factory.inject(y.getService());
+ });
+ //----------------- init -----------------
+ application.localServices.entrySet().parallelStream().forEach(k -> {
+ Class x = k.getKey();
+ ServiceEntry y = k.getValue();
+ long s = System.currentTimeMillis();
+ y.getService().init(y.getServiceConf());
+ long e = System.currentTimeMillis() - s;
+ if (e > 2 && sb != null) {
+ sb.append(threadName).append("LocalService(").append(y.getNames()).append("|").append(y.getServiceClass()).append(") init ").append(e).append("ms").append(LINE_SEPARATOR);
+ }
+ });
+ if (sb != null && sb.length() > 0) logger.log(Level.INFO, sb.toString());
+ }
+ }
+ }
+
+ private String getRemoteName(AnyValue av, String remote) {
+ remote = (remote == null || remote.trim().isEmpty()) ? "LOCAL" : remote.trim();
+ if (av == null) return remote;
+ String r = av.getValue("remote");
+ if ("LOCAL".equalsIgnoreCase(r)) return "LOCAL";
+ if (r != null && !r.trim().isEmpty()) return r.trim();
+ return remote;
+ }
+
+ protected static ClassFilter createServiceClassFilter(final String localNode, final AnyValue config) {
+ return createClassFilter(localNode, config, null, Service.class, Annotation.class, "services", "service");
+ }
+
+ protected static ClassFilter createClassFilter(final String localNode, final AnyValue config, Class ref,
+ Class inter, Class ref2, String properties, String property) {
+ ClassFilter filter = new ClassFilter(ref, inter);
+ if (properties == null && properties == null) return filter;
+ AnyValue list = config == null ? null : config.getAnyValue(properties);
+ if (list == null) return filter;
+ if ("services".equals(properties)) {
+ for (AnyValue group : list.getAnyValues("group")) {
+ String remotenames = group.getValue("remotenames");
+ for (AnyValue propnode : group.getAnyValues(property)) {
+ boolean hasremote = false;
+ if (remotenames != null) {
+ for (String rn : remotenames.split(";")) {
+ rn = rn.trim();
+ if (rn.isEmpty() || localNode.equals(rn)) continue;
+ DefaultAnyValue s = new DefaultAnyValue();
+ s.addValue("value", propnode.getValue("value"));
+ s.addValue("name", rn);
+ s.addValue("remote", rn);
+ ((DefaultAnyValue) list).addValue(property, s);
+ hasremote = true;
+ }
+ }
+ if (hasremote) {
+ ((DefaultAnyValue) propnode).setValue("name", localNode);
+ ((DefaultAnyValue) propnode).setValue("remote", "");
+ ((DefaultAnyValue) list).addValue(property, propnode);
+ }
+ }
+ }
+ }
+ for (AnyValue av : list.getAnyValues(property)) {
+ for (AnyValue prop : av.getAnyValues("property")) {
+ ((DefaultAnyValue) av).addValue(prop.getValue("name"), prop.getValue("value"));
+ }
+ filter.filter(av, av.getValue("value"), false);
+ }
+ if (list.getBoolValue("autoload", true)) {
+ String includes = list.getValue("includes", "");
+ String excludes = list.getValue("excludes", "");
+ filter.setIncludePatterns(includes.split(";"));
+ filter.setExcludePatterns(excludes.split(";"));
+ } else {
+ if (ref2 == null || ref2 == Annotation.class) {
+ filter.setRefused(true);
+ } else if (ref2 != Annotation.class) {
+ filter.setAnnotationClass(ref2);
+ }
+ }
+ return filter;
+ }
+
+}
diff --git a/src/com/wentch/redkale/boot/NodeSncpServer.java b/src/com/wentch/redkale/boot/NodeSncpServer.java
new file mode 100644
index 000000000..8f6e74899
--- /dev/null
+++ b/src/com/wentch/redkale/boot/NodeSncpServer.java
@@ -0,0 +1,50 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.boot;
+
+import com.wentch.redkale.net.sncp.SncpServer;
+import com.wentch.redkale.util.AnyValue;
+import com.wentch.redkale.service.Service;
+import java.net.InetSocketAddress;
+import java.util.concurrent.CountDownLatch;
+
+/**
+ *
+ * @author zhangjx
+ */
+public final class NodeSncpServer extends NodeServer {
+
+ private final SncpServer server;
+
+ public NodeSncpServer(Application application, CountDownLatch regcdl, SncpServer server) {
+ super(application, regcdl, server);
+ this.server = server;
+ this.consumer = x -> server.addService(x);
+ }
+
+ @Override
+ public void init(AnyValue config) throws Exception {
+ server.init(config);
+ super.init(config);
+ }
+
+ @Override
+ public InetSocketAddress getSocketAddress() {
+ return server == null ? null : server.getSocketAddress();
+ }
+
+ @Override
+ public void load(AnyValue config) throws Exception {
+ super.load(config);
+ ClassFilter serviceFilter = createServiceClassFilter(application.nodeName, config);
+ long s = System.currentTimeMillis();
+ ClassFilter.Loader.load(application.getHome(), serviceFilter);
+ long e = System.currentTimeMillis() - s;
+ logger.info(this.getClass().getSimpleName() + " load filter class in " + e + " ms");
+ loadService(config.getAnyValue("services"), serviceFilter); //必须在servlet之前
+ }
+
+}
diff --git a/src/com/wentch/redkale/convert/AnyEncoder.java b/src/com/wentch/redkale/convert/AnyEncoder.java
new file mode 100644
index 000000000..6522a3b31
--- /dev/null
+++ b/src/com/wentch/redkale/convert/AnyEncoder.java
@@ -0,0 +1,40 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.convert;
+
+import java.lang.reflect.Type;
+
+/**
+ * 对不明类型的对象进行序列化； BSON序列化时将对象的类名写入Writer，JSON则不写入。
+ *
+ * @author zhangjx
+ * @param
+ */
+public final class AnyEncoder implements Encodeable {
+
+ final Factory factory;
+
+ AnyEncoder(Factory factory) {
+ this.factory = factory;
+ }
+
+ @Override
+ @SuppressWarnings("unchecked")
+ public void convertTo(final Writer out, final T value) {
+ if (value == null) {
+ out.writeNull();
+ } else {
+ out.wirteClassName(value.getClass());
+ factory.loadEncoder(value.getClass()).convertTo(out, value);
+ }
+ }
+
+ @Override
+ public Type getType() {
+ return Object.class;
+ }
+
+}
diff --git a/src/com/wentch/redkale/convert/ArrayDecoder.java b/src/com/wentch/redkale/convert/ArrayDecoder.java
new file mode 100644
index 000000000..fa41b8b3a
--- /dev/null
+++ b/src/com/wentch/redkale/convert/ArrayDecoder.java
@@ -0,0 +1,79 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.convert;
+
+import java.lang.reflect.*;
+import java.util.*;
+
+/**
+ * 对象数组的序列化，不包含int[]、long[]这样的primitive class数组.
+ * 数组长度不能超过 32767。 在BSON中数组长度设定的是short，对于大于32767长度的数组传输会影响性能，所以没有采用int存储。
+ * 支持一定程度的泛型。
+ *
+ * @author zhangjx
+ * @param
+ */
+@SuppressWarnings("unchecked")
+public final class ArrayDecoder implements Decodeable {
+
+ private final Type type;
+
+ private final Type componentType;
+
+ private final Class componentClass;
+
+ private final Decodeable decoder;
+
+ public ArrayDecoder(final Factory factory, final Type type) {
+ this.type = type;
+ if (type instanceof GenericArrayType) {
+ Type t = ((GenericArrayType) type).getGenericComponentType();
+ this.componentType = t instanceof TypeVariable ? Object.class : t;
+ } else if ((type instanceof Class) && ((Class) type).isArray()) {
+ this.componentType = ((Class) type).getComponentType();
+ } else {
+ throw new ConvertException("(" + type + ") is not a array type");
+ }
+ if (this.componentType instanceof ParameterizedType) {
+ this.componentClass = (Class) ((ParameterizedType) this.componentType).getRawType();
+ } else {
+ this.componentClass = (Class) this.componentType;
+ }
+ factory.register(type, this);
+ this.decoder = factory.loadDecoder(this.componentType);
+ }
+
+ @Override
+ public T[] convertFrom(Reader in) {
+ final int len = in.readArrayB();
+ if (len == Reader.SIGN_NULL) return null;
+ final Decodeable localdecoder = this.decoder;
+ final List result = new ArrayList();
+ if (len == Reader.SIGN_NOLENGTH) {
+ while (in.hasNext()) {
+ result.add(localdecoder.convertFrom(in));
+ }
+ } else {
+ for (int i = 0; i < len; i++) {
+ result.add(localdecoder.convertFrom(in));
+ }
+ }
+ in.readArrayE();
+ T[] rs = (T[]) Array.newInstance((Class) this.componentClass, result.size());
+ return result.toArray(rs);
+ }
+
+ @Override
+ public String toString() {
+ return this.getClass().getSimpleName() + "{componentType:" + this.componentType + ", decoder:" + this.decoder + "}";
+ }
+
+ @Override
+ public Type getType() {
+ return type;
+ }
+
+}
diff --git a/src/com/wentch/redkale/convert/ArrayEncoder.java b/src/com/wentch/redkale/convert/ArrayEncoder.java
new file mode 100644
index 000000000..f85744375
--- /dev/null
+++ b/src/com/wentch/redkale/convert/ArrayEncoder.java
@@ -0,0 +1,75 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.convert;
+
+import java.lang.reflect.*;
+
+/**
+ * 对象数组的反序列化，不包含int[]、long[]这样的primitive class数组.
+ * 数组长度不能超过 32767。 在BSON中数组长度设定的是short，对于大于32767长度的数组传输会影响性能，所以没有采用int存储。
+ * 支持一定程度的泛型。
+ *
+ * @author zhangjx
+ * @param
+ */
+@SuppressWarnings("unchecked")
+public final class ArrayEncoder implements Encodeable {
+
+ private final Type type;
+
+ private final Type componentType;
+
+ private final Encodeable anyEncoder;
+
+ private final Encodeable encoder;
+
+ public ArrayEncoder(final Factory factory, final Type type) {
+ this.type = type;
+ if (type instanceof GenericArrayType) {
+ Type t = ((GenericArrayType) type).getGenericComponentType();
+ this.componentType = t instanceof TypeVariable ? Object.class : t;
+ } else if ((type instanceof Class) && ((Class) type).isArray()) {
+ this.componentType = ((Class) type).getComponentType();
+ } else {
+ throw new ConvertException("(" + type + ") is not a array type");
+ }
+ factory.register(type, this);
+ this.encoder = factory.loadEncoder(this.componentType);
+ this.anyEncoder = factory.getAnyEncoder();
+ }
+
+ @Override
+ public void convertTo(Writer out, T[] value) {
+ if (value == null) {
+ out.writeNull();
+ return;
+ }
+ if (value.length == 0) {
+ out.writeArrayB(0);
+ out.writeArrayE();
+ return;
+ }
+ out.writeArrayB(value.length);
+ final Type comp = this.componentType;
+ boolean first = true;
+ for (Object v : value) {
+ if (!first) out.writeArrayMark();
+ ((v.getClass() == comp) ? encoder : anyEncoder).convertTo(out, v);
+ if (first) first = false;
+ }
+ out.writeArrayE();
+ }
+
+ @Override
+ public String toString() {
+ return this.getClass().getSimpleName() + "{componentType:" + this.componentType + ", encoder:" + this.encoder + "}";
+ }
+
+ @Override
+ public Type getType() {
+ return type;
+ }
+}
diff --git a/src/com/wentch/redkale/convert/CollectionDecoder.java b/src/com/wentch/redkale/convert/CollectionDecoder.java
new file mode 100644
index 000000000..df87cfd99
--- /dev/null
+++ b/src/com/wentch/redkale/convert/CollectionDecoder.java
@@ -0,0 +1,69 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.convert;
+
+import com.wentch.redkale.util.Creator;
+import java.lang.reflect.ParameterizedType;
+import java.lang.reflect.Type;
+import java.util.Collection;
+
+/**
+ * 对象集合的反序列化.
+ * 集合大小不能超过 32767。 在BSON中集合大小设定的是short，对于大于32767长度的集合传输会影响性能，所以没有采用int存储。
+ * 支持一定程度的泛型。
+ *
+ * @author zhangjx
+ * @param
+ */
+@SuppressWarnings("unchecked")
+public final class CollectionDecoder implements Decodeable> {
+
+ private final Type type;
+
+ private final Type componentType;
+
+ protected Creator> creator;
+
+ private final Decodeable decoder;
+
+ public CollectionDecoder(final Factory factory, final Type type) {
+ this.type = type;
+ if (type instanceof ParameterizedType) {
+ final ParameterizedType pt = (ParameterizedType) type;
+ this.componentType = pt.getActualTypeArguments()[0];
+ this.creator = factory.loadCreator((Class) pt.getRawType());
+ factory.register(type, this);
+ this.decoder = factory.loadDecoder(this.componentType);
+ } else {
+ throw new ConvertException("collectiondecoder not support the type (" + type + ")");
+ }
+ }
+
+ @Override
+ public Collection convertFrom(Reader in) {
+ final int len = in.readArrayB();
+ if (len == Reader.SIGN_NULL) return null;
+ final Decodeable localdecoder = this.decoder;
+ final Collection result = this.creator.create();
+ if (len == Reader.SIGN_NOLENGTH) {
+ while (in.hasNext()) {
+ result.add(localdecoder.convertFrom(in));
+ }
+ } else {
+ for (int i = 0; i < len; i++) {
+ result.add(localdecoder.convertFrom(in));
+ }
+ }
+ in.readArrayE();
+ return result;
+ }
+
+ @Override
+ public Type getType() {
+ return type;
+ }
+
+}
diff --git a/src/com/wentch/redkale/convert/CollectionEncoder.java b/src/com/wentch/redkale/convert/CollectionEncoder.java
new file mode 100644
index 000000000..e823a5775
--- /dev/null
+++ b/src/com/wentch/redkale/convert/CollectionEncoder.java
@@ -0,0 +1,65 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.convert;
+
+import java.lang.reflect.*;
+import java.util.Collection;
+
+/**
+ * 对象集合的序列化.
+ * 集合大小不能超过 32767。 在BSON中集合大小设定的是short，对于大于32767长度的集合传输会影响性能，所以没有采用int存储。
+ * 支持一定程度的泛型。
+ *
+ * @author zhangjx
+ * @param
+ */
+@SuppressWarnings("unchecked")
+public final class CollectionEncoder implements Encodeable> {
+
+ private final Type type;
+
+ private final Encodeable encoder;
+
+ public CollectionEncoder(final Factory factory, final Type type) {
+ this.type = type;
+ if (type instanceof ParameterizedType) {
+ Type t = ((ParameterizedType) type).getActualTypeArguments()[0];
+ if (t instanceof TypeVariable) {
+ this.encoder = factory.getAnyEncoder();
+ } else {
+ this.encoder = factory.loadEncoder(t);
+ }
+ } else {
+ this.encoder = factory.getAnyEncoder();
+ }
+ }
+
+ @Override
+ public void convertTo(Writer out, Collection value) {
+ if (value == null) {
+ out.writeNull();
+ return;
+ }
+ if (value.isEmpty()) {
+ out.writeArrayB(0);
+ out.writeArrayE();
+ return;
+ }
+ out.writeArrayB(value.size());
+ boolean first = true;
+ for (Object v : value) {
+ if (!first) out.writeArrayMark();
+ encoder.convertTo(out, v);
+ if (first) first = false;
+ }
+ out.writeArrayE();
+ }
+
+ @Override
+ public Type getType() {
+ return type;
+ }
+}
diff --git a/src/com/wentch/redkale/convert/Convert.java b/src/com/wentch/redkale/convert/Convert.java
new file mode 100644
index 000000000..61b42ff63
--- /dev/null
+++ b/src/com/wentch/redkale/convert/Convert.java
@@ -0,0 +1,26 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.convert;
+
+/**
+ * 序列化操作类
+ *
+ * @author zhangjx
+ * @param
+ * @param
+ */
+public abstract class Convert {
+
+ protected final Factory factory;
+
+ protected Convert(Factory factory) {
+ this.factory = factory;
+ }
+
+ public Factory getFactory() {
+ return this.factory;
+ }
+}
diff --git a/src/com/wentch/redkale/convert/ConvertColumn.java b/src/com/wentch/redkale/convert/ConvertColumn.java
new file mode 100644
index 000000000..1a868f0c4
--- /dev/null
+++ b/src/com/wentch/redkale/convert/ConvertColumn.java
@@ -0,0 +1,44 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.convert;
+
+import java.lang.annotation.*;
+import static java.lang.annotation.ElementType.*;
+import static java.lang.annotation.RetentionPolicy.*;
+
+/**
+ * 依附在setter、getter方法、字段进行简单的配置
+ *
+ * @author zhangjx
+ */
+@Inherited
+@Documented
+@Target({METHOD, FIELD})
+@Retention(RUNTIME)
+@Repeatable(ConvertColumns.class)
+public @interface ConvertColumn {
+
+ /**
+ * 给字段取个别名， 只对JSON有效
+ *
+ * @return
+ */
+ String name() default "";
+
+ /**
+ * 解析/序列化时是否屏蔽该字段
+ *
+ * @return
+ */
+ boolean ignore() default false;
+
+ /**
+ * 解析/序列化定制化的TYPE
+ *
+ * @return
+ */
+ ConvertType type() default ConvertType.ALL;
+}
diff --git a/src/com/wentch/redkale/convert/ConvertColumnEntry.java b/src/com/wentch/redkale/convert/ConvertColumnEntry.java
new file mode 100644
index 000000000..c5339b17a
--- /dev/null
+++ b/src/com/wentch/redkale/convert/ConvertColumnEntry.java
@@ -0,0 +1,67 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.convert;
+
+/**
+ * ConvertColumn 对应的实体类
+ *
+ * @author zhangjx
+ */
+public final class ConvertColumnEntry {
+
+ private String name = "";
+
+ private boolean ignore;
+
+ private ConvertType convertType;
+
+ public ConvertColumnEntry() {
+ }
+
+ public ConvertColumnEntry(ConvertColumn column) {
+ if (column == null) return;
+ this.name = column.name();
+ this.ignore = column.ignore();
+ this.convertType = column.type();
+ }
+
+ public ConvertColumnEntry(String name, boolean ignore) {
+ this.name = name;
+ this.ignore = ignore;
+ this.convertType = ConvertType.ALL;
+ }
+
+ public ConvertColumnEntry(String name, boolean ignore, ConvertType convertType) {
+ this.name = name;
+ this.ignore = ignore;
+ this.convertType = convertType;
+ }
+
+ public String name() {
+ return name == null ? "" : name;
+ }
+
+ public void setName(String name) {
+ this.name = name;
+ }
+
+ public boolean ignore() {
+ return ignore;
+ }
+
+ public void setIgnore(boolean ignore) {
+ this.ignore = ignore;
+ }
+
+ public ConvertType type() {
+ return convertType == null ? ConvertType.ALL : convertType;
+ }
+
+ public void setConvertType(ConvertType convertType) {
+ this.convertType = convertType;
+ }
+
+}
diff --git a/src/com/wentch/redkale/convert/ConvertColumns.java b/src/com/wentch/redkale/convert/ConvertColumns.java
new file mode 100644
index 000000000..a5e613ad0
--- /dev/null
+++ b/src/com/wentch/redkale/convert/ConvertColumns.java
@@ -0,0 +1,24 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.convert;
+
+import java.lang.annotation.*;
+import static java.lang.annotation.ElementType.*;
+import static java.lang.annotation.RetentionPolicy.*;
+
+/**
+ * ConvertColumn 的多用类
+ *
+ * @author zhangjx
+ */
+@Inherited
+@Documented
+@Target({METHOD, FIELD})
+@Retention(RUNTIME)
+public @interface ConvertColumns {
+
+ ConvertColumn[] value();
+}
diff --git a/src/com/wentch/redkale/convert/ConvertException.java b/src/com/wentch/redkale/convert/ConvertException.java
new file mode 100644
index 000000000..002c6946e
--- /dev/null
+++ b/src/com/wentch/redkale/convert/ConvertException.java
@@ -0,0 +1,28 @@
+/*
+ * To change this template, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.convert;
+
+/**
+ *
+ * @author zhangjx
+ */
+public class ConvertException extends RuntimeException {
+
+ public ConvertException() {
+ super();
+ }
+
+ public ConvertException(String s) {
+ super(s);
+ }
+
+ public ConvertException(String message, Throwable cause) {
+ super(message, cause);
+ }
+
+ public ConvertException(Throwable cause) {
+ super(cause);
+ }
+}
diff --git a/src/com/wentch/redkale/convert/ConvertType.java b/src/com/wentch/redkale/convert/ConvertType.java
new file mode 100644
index 000000000..7871a01d8
--- /dev/null
+++ b/src/com/wentch/redkale/convert/ConvertType.java
@@ -0,0 +1,28 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.convert;
+
+/**
+ *
+ * @author zhangjx
+ */
+public enum ConvertType {
+
+ JSON(1),
+ BSON(2),
+ ALL(127);
+
+ private final int value;
+
+ private ConvertType(int v) {
+ this.value = v;
+ }
+
+ public boolean contains(ConvertType type) {
+ if (type == null) return false;
+ return this.value >= type.value && (this.value & type.value) > 0;
+ }
+}
diff --git a/src/com/wentch/redkale/convert/DeMember.java b/src/com/wentch/redkale/convert/DeMember.java
new file mode 100644
index 000000000..2897e7d23
--- /dev/null
+++ b/src/com/wentch/redkale/convert/DeMember.java
@@ -0,0 +1,64 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.convert;
+
+import com.wentch.redkale.util.Attribute;
+
+/**
+ *
+ * @author zhangjx
+ * @param
+ * @param
+ * @param
+ */
+@SuppressWarnings("unchecked")
+public final class DeMember implements Comparable> {
+
+ protected final Attribute attribute;
+
+ protected Decodeable decoder;
+
+ public DeMember(final Attribute attribute) {
+ this.attribute = attribute;
+ }
+
+ public DeMember(Attribute attribute, Decodeable decoder) {
+ this(attribute);
+ this.decoder = decoder;
+ }
+
+ public final void read(R in, T obj) {
+ this.attribute.set(obj, decoder.convertFrom(in));
+ }
+
+ public Attribute getAttribute() {
+ return this.attribute;
+ }
+
+ @Override
+ public final int compareTo(DeMember o) {
+ if (o == null) return 1;
+ return this.attribute.field().compareTo(o.attribute.field());
+ }
+
+ @Override
+ public boolean equals(Object obj) {
+ if (this == obj) return true;
+ if (!(obj instanceof DeMember)) return false;
+ DeMember other = (DeMember) obj;
+ return compareTo(other) == 0;
+ }
+
+ @Override
+ public int hashCode() {
+ return this.attribute.field().hashCode();
+ }
+
+ @Override
+ public String toString() {
+ return "DeMember{" + "attribute=" + attribute.field() + ", decoder=" + decoder + '}';
+ }
+}
diff --git a/src/com/wentch/redkale/convert/Decodeable.java b/src/com/wentch/redkale/convert/Decodeable.java
new file mode 100644
index 000000000..c6b58899a
--- /dev/null
+++ b/src/com/wentch/redkale/convert/Decodeable.java
@@ -0,0 +1,27 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.convert;
+
+import java.lang.reflect.Type;
+
+/**
+ *
+ * @author zhangjx
+ * @param
+ * @param
+ */
+public interface Decodeable {
+
+ public T convertFrom(final R in);
+
+ /**
+ * 泛型映射接口
+ *
+ * @return
+ */
+ public Type getType();
+
+}
diff --git a/src/com/wentch/redkale/convert/EnMember.java b/src/com/wentch/redkale/convert/EnMember.java
new file mode 100644
index 000000000..85fb0fe4f
--- /dev/null
+++ b/src/com/wentch/redkale/convert/EnMember.java
@@ -0,0 +1,60 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.convert;
+
+import com.wentch.redkale.util.Attribute;
+
+/**
+ *
+ * @author zhangjx
+ * @param
+ * @param
+ * @param
+ */
+@SuppressWarnings("unchecked")
+public final class EnMember implements Comparable> {
+
+ private final Attribute attribute;
+
+ final Encodeable encoder;
+
+ public EnMember(Attribute attribute, Encodeable encoder) {
+ this.attribute = attribute;
+ this.encoder = encoder;
+ }
+
+ public boolean write(final W out, final boolean comma, final T obj) {
+ F value = attribute.get(obj);
+ if (value == null) return comma;
+ out.writeField(comma, attribute);
+ encoder.convertTo(out, value);
+ return true;
+ }
+
+ @Override
+ public final int compareTo(EnMember o) {
+ if (o == null) return 1;
+ return this.attribute.field().compareTo(o.attribute.field());
+ }
+
+ @Override
+ public boolean equals(Object obj) {
+ if (this == obj) return true;
+ if (!(obj instanceof EnMember)) return false;
+ EnMember other = (EnMember) obj;
+ return compareTo(other) == 0;
+ }
+
+ @Override
+ public int hashCode() {
+ return this.attribute.field().hashCode();
+ }
+
+ @Override
+ public String toString() {
+ return "EnMember{" + "attribute=" + attribute.field() + ", encoder=" + encoder + '}';
+ }
+}
diff --git a/src/com/wentch/redkale/convert/Encodeable.java b/src/com/wentch/redkale/convert/Encodeable.java
new file mode 100644
index 000000000..595383445
--- /dev/null
+++ b/src/com/wentch/redkale/convert/Encodeable.java
@@ -0,0 +1,27 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.convert;
+
+import java.lang.reflect.Type;
+
+/**
+ *
+ * @author zhangjx
+ * @param
+ * @param
+ */
+public interface Encodeable {
+
+ public void convertTo(final W out, T value);
+
+ /**
+ * 泛型映射接口
+ *
+ * @return
+ */
+ public Type getType();
+
+}
diff --git a/src/com/wentch/redkale/convert/Factory.java b/src/com/wentch/redkale/convert/Factory.java
new file mode 100644
index 000000000..41da5a10b
--- /dev/null
+++ b/src/com/wentch/redkale/convert/Factory.java
@@ -0,0 +1,342 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.convert;
+
+import com.wentch.redkale.convert.ext.StringArraySimpledCoder;
+import com.wentch.redkale.convert.ext.DoubleArraySimpledCoder;
+import com.wentch.redkale.convert.ext.LongSimpledCoder;
+import com.wentch.redkale.convert.ext.ByteArraySimpledCoder;
+import com.wentch.redkale.convert.ext.IntArraySimpledCoder;
+import com.wentch.redkale.convert.ext.DoubleSimpledCoder;
+import com.wentch.redkale.convert.ext.TwoLongSimpledCoder;
+import com.wentch.redkale.convert.ext.CharSimpledCoder;
+import com.wentch.redkale.convert.ext.IntSimpledCoder;
+import com.wentch.redkale.convert.ext.InetAddressSimpledCoder;
+import com.wentch.redkale.convert.ext.LongArraySimpledCoder;
+import com.wentch.redkale.convert.ext.DateSimpledCoder;
+import com.wentch.redkale.convert.ext.BoolSimpledCoder;
+import com.wentch.redkale.convert.ext.CharArraySimpledCoder;
+import com.wentch.redkale.convert.ext.EnumSimpledCoder;
+import com.wentch.redkale.convert.ext.BigIntegerSimpledCoder;
+import com.wentch.redkale.convert.ext.ByteSimpledCoder;
+import com.wentch.redkale.convert.ext.StringSimpledCoder;
+import com.wentch.redkale.convert.ext.NumberSimpledCoder;
+import com.wentch.redkale.convert.ext.TypeSimpledCoder;
+import com.wentch.redkale.convert.ext.ShortArraySimpledCoder;
+import com.wentch.redkale.convert.ext.BoolArraySimpledCoder;
+import com.wentch.redkale.convert.ext.ShortSimpledCoder;
+import com.wentch.redkale.convert.ext.FloatArraySimpledCoder;
+import com.wentch.redkale.convert.ext.FloatSimpledCoder;
+import com.wentch.redkale.util.TwoLong;
+import com.wentch.redkale.util.Creator;
+import java.lang.reflect.GenericArrayType;
+import java.lang.reflect.ParameterizedType;
+import java.lang.reflect.Type;
+import java.util.Collection;
+import java.util.Map;
+import java.lang.reflect.*;
+import java.math.BigInteger;
+import java.net.*;
+import static com.wentch.redkale.convert.ext.InetAddressSimpledCoder.*;
+import java.util.*;
+
+/**
+ *
+ * @author zhangjx
+ * @param
+ * @param
+ */
+@SuppressWarnings("unchecked")
+public abstract class Factory {
+
+ private final Factory parent;
+
+ protected Convert convert;
+
+ private final Encodeable anyEncoder = new AnyEncoder(this);
+
+ //-----------------------------------------------------------------------------------
+ private final HashedMap creators = new HashedMap();
+
+ private final HashedMap> decoders = new HashedMap();
+
+ private final HashedMap> encoders = new HashedMap();
+
+ private final HashMap columnEntrys = new HashMap();
+
+ protected Factory(Factory parent) {
+ this.parent = parent;
+ if (parent == null) {
+ //---------------------------------------------------------
+ this.register(boolean.class, BoolSimpledCoder.instance);
+ this.register(Boolean.class, BoolSimpledCoder.instance);
+
+ this.register(byte.class, ByteSimpledCoder.instance);
+ this.register(Byte.class, ByteSimpledCoder.instance);
+
+ this.register(short.class, ShortSimpledCoder.instance);
+ this.register(Short.class, ShortSimpledCoder.instance);
+
+ this.register(char.class, CharSimpledCoder.instance);
+ this.register(Character.class, CharSimpledCoder.instance);
+
+ this.register(int.class, IntSimpledCoder.instance);
+ this.register(Integer.class, IntSimpledCoder.instance);
+
+ this.register(long.class, LongSimpledCoder.instance);
+ this.register(Long.class, LongSimpledCoder.instance);
+
+ this.register(float.class, FloatSimpledCoder.instance);
+ this.register(Float.class, FloatSimpledCoder.instance);
+
+ this.register(double.class, DoubleSimpledCoder.instance);
+ this.register(Double.class, DoubleSimpledCoder.instance);
+
+ this.register(Number.class, NumberSimpledCoder.instance);
+ this.register(String.class, StringSimpledCoder.instance);
+ this.register(java.util.Date.class, DateSimpledCoder.instance);
+ this.register(BigInteger.class, BigIntegerSimpledCoder.instance);
+ this.register(InetAddress.class, InetAddressSimpledCoder.instance);
+ this.register(TwoLong.class, TwoLongSimpledCoder.instance);
+ this.register(Class.class, TypeSimpledCoder.instance);
+ this.register(InetSocketAddress.class, InetSocketAddressSimpledCoder.instance);
+ this.register(InetSocketAddress.class, InetSocketAddressSimpledCoder.instance);
+ //---------------------------------------------------------
+ this.register(boolean[].class, BoolArraySimpledCoder.instance);
+ this.register(byte[].class, ByteArraySimpledCoder.instance);
+ this.register(short[].class, ShortArraySimpledCoder.instance);
+ this.register(char[].class, CharArraySimpledCoder.instance);
+ this.register(int[].class, IntArraySimpledCoder.instance);
+ this.register(long[].class, LongArraySimpledCoder.instance);
+ this.register(float[].class, FloatArraySimpledCoder.instance);
+ this.register(double[].class, DoubleArraySimpledCoder.instance);
+ this.register(String[].class, StringArraySimpledCoder.instance);
+ //---------------------------------------------------------
+ }
+ }
+
+ public Factory parent() {
+ return this.parent;
+ }
+
+ public abstract ConvertType getConvertType();
+
+ public abstract boolean isReversible();
+
+ public abstract Factory createChild();
+
+ public Convert getConvert() {
+ return convert;
+ }
+
+ public ConvertColumnEntry findRef(AccessibleObject field) {
+ if (field == null) return null;
+ ConvertColumnEntry en = this.columnEntrys.get(field);
+ if (en != null) return en;
+ final ConvertType ct = this.getConvertType();
+ for (ConvertColumn ref : field.getAnnotationsByType(ConvertColumn.class)) {
+ if (ref.type().contains(ct)) return new ConvertColumnEntry(ref);
+ }
+ return null;
+ }
+
+ public final boolean register(final Class type, String column, ConvertColumnEntry entry) {
+ if (type == null || column == null || entry == null) return false;
+ try {
+ final Field field = type.getDeclaredField(column);
+ String get = "get";
+ if (field.getType() == boolean.class || field.getType() == Boolean.class) get = "is";
+ char[] cols = column.toCharArray();
+ cols[0] = Character.toUpperCase(cols[0]);
+ String col2 = new String(cols);
+ try {
+ register(type.getMethod(get + col2), entry);
+ } catch (Exception ex) {
+ }
+ try {
+ register(type.getMethod("set" + col2, field.getType()), entry);
+ } catch (Exception ex) {
+ }
+ return register(field, entry);
+ } catch (Exception e) {
+ return false;
+ }
+ }
+
+ public final boolean register(final AccessibleObject field, final ConvertColumnEntry entry) {
+ if (field == null || entry == null) return false;
+ this.columnEntrys.put(field, entry);
+ return true;
+ }
+
+ public final void register(final Class clazz, final Creator creator) {
+ creators.put(clazz, creator);
+ }
+
+ public final Creator findCreator(Class type) {
+ Creator creator = creators.get(type);
+ if (creator != null) return creator;
+ return this.parent == null ? null : this.parent.findCreator(type);
+ }
+
+ public final Creator loadCreator(Class type) {
+ Creator result = findCreator(type);
+ if (result == null) {
+ result = Creator.create(type);
+ creators.put(type, result);
+ }
+ return result;
+ }
+
+ //----------------------------------------------------------------------
+ public final Encodeable getAnyEncoder() {
+ return (Encodeable) anyEncoder;
+ }
+
+ public final void register(final Type clazz, final SimpledCoder coder) {
+ decoders.put(clazz, coder);
+ encoders.put(clazz, coder);
+ }
+
+ public final void register(final Type clazz, final Decodeable decoder) {
+ decoders.put(clazz, decoder);
+ }
+
+ public final void register(final Type clazz, final Encodeable printer) {
+ encoders.put(clazz, printer);
+ }
+
+ public final Decodeable findDecoder(final Type type) {
+ Decodeable rs = (Decodeable) decoders.get(type);
+ if (rs != null) return rs;
+ return this.parent == null ? null : this.parent.findDecoder(type);
+ }
+
+ public final Encodeable findEncoder(final Type type) {
+ Encodeable rs = (Encodeable) encoders.get(type);
+ if (rs != null) return rs;
+ return this.parent == null ? null : this.parent.findEncoder(type);
+ }
+
+ public final Decodeable loadDecoder(final Type type) {
+ Decodeable decoder = findDecoder(type);
+ if (decoder != null) return decoder;
+ if (type instanceof GenericArrayType) return new ArrayDecoder(this, type);
+ Class clazz;
+ if (type instanceof ParameterizedType) {
+ final ParameterizedType pts = (ParameterizedType) type;
+ clazz = (Class) (pts).getRawType();
+ } else if (type instanceof Class) {
+ clazz = (Class) type;
+ } else {
+ throw new ConvertException("not support the type (" + type + ")");
+ }
+ decoder = findDecoder(clazz);
+ if (decoder != null) return decoder;
+ return createDecoder(type, clazz);
+ }
+
+ public final Decodeable createDecoder(final Type type) {
+ Class clazz;
+ if (type instanceof ParameterizedType) {
+ final ParameterizedType pts = (ParameterizedType) type;
+ clazz = (Class) (pts).getRawType();
+ } else if (type instanceof Class) {
+ clazz = (Class) type;
+ } else {
+ throw new ConvertException("not support the type (" + type + ")");
+ }
+ return createDecoder(type, clazz);
+ }
+
+ private Decodeable createDecoder(final Type type, final Class clazz) {
+ Decodeable decoder = null;
+ ObjectDecoder od = null;
+ if (clazz.isEnum()) {
+ decoder = new EnumSimpledCoder(clazz);
+ } else if (clazz.isArray()) {
+ decoder = new ArrayDecoder(this, type);
+ } else if (Collection.class.isAssignableFrom(clazz)) {
+ decoder = new CollectionDecoder(this, type);
+ } else if (Map.class.isAssignableFrom(clazz)) {
+ decoder = new MapDecoder(this, type);
+ } else if (clazz == Object.class) {
+ od = new ObjectDecoder(type);
+ decoder = od;
+ } else if (!clazz.getName().startsWith("java.")) {
+ od = new ObjectDecoder(type);
+ decoder = od;
+ }
+ if (decoder == null) throw new ConvertException("not support the type (" + type + ")");
+ register(type, decoder);
+ if (od != null) od.init(this);
+ return decoder;
+ }
+
+ public final Encodeable loadEncoder(final Type type) {
+ Encodeable encoder = findEncoder(type);
+ if (encoder != null) return encoder;
+ if (type instanceof GenericArrayType) return new ArrayEncoder(this, type);
+ Class clazz;
+ if (type instanceof ParameterizedType) {
+ final ParameterizedType pts = (ParameterizedType) type;
+ clazz = (Class) (pts).getRawType();
+ } else if (type instanceof TypeVariable) {
+ TypeVariable tv = (TypeVariable) type;
+ Type t = Object.class;
+ if (tv.getBounds().length == 1) {
+ t = tv.getBounds()[0];
+ }
+ if (!(t instanceof Class)) t = Object.class;
+ clazz = (Class) t;
+ } else if (type instanceof Class) {
+ clazz = (Class) type;
+ } else {
+ throw new ConvertException("not support the type (" + type + ")");
+ }
+ encoder = findEncoder(clazz);
+ if (encoder != null) return encoder;
+ return createEncoder(type, clazz);
+ }
+
+ public final Encodeable createEncoder(final Type type) {
+ Class clazz;
+ if (type instanceof ParameterizedType) {
+ final ParameterizedType pts = (ParameterizedType) type;
+ clazz = (Class) (pts).getRawType();
+ } else if (type instanceof Class) {
+ clazz = (Class) type;
+ } else {
+ throw new ConvertException("not support the type (" + type + ")");
+ }
+ return createEncoder(type, clazz);
+ }
+
+ private Encodeable createEncoder(final Type type, final Class clazz) {
+ Encodeable encoder = null;
+ ObjectEncoder oe = null;
+ if (clazz.isEnum()) {
+ encoder = new EnumSimpledCoder(clazz);
+ } else if (clazz.isArray()) {
+ encoder = new ArrayEncoder(this, type);
+ } else if (Collection.class.isAssignableFrom(clazz)) {
+ encoder = new CollectionEncoder(this, type);
+ } else if (Map.class.isAssignableFrom(clazz)) {
+ encoder = new MapEncoder(this, type);
+ } else if (clazz == Object.class) {
+ return (Encodeable) this.anyEncoder;
+ } else if (!clazz.getName().startsWith("java.")) {
+ oe = new ObjectEncoder(type);
+ encoder = oe;
+ }
+ if (encoder == null) throw new ConvertException("not support the type (" + type + ")");
+ register(type, encoder);
+ if (oe != null) oe.init(this);
+ return encoder;
+
+ }
+
+}
diff --git a/src/com/wentch/redkale/convert/HashedMap.java b/src/com/wentch/redkale/convert/HashedMap.java
new file mode 100644
index 000000000..acd7fbbec
--- /dev/null
+++ b/src/com/wentch/redkale/convert/HashedMap.java
@@ -0,0 +1,68 @@
+/*
+ * To change this template, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.convert;
+
+/**
+ * 只增不减的伪Map类
+ *
+ * @author zhangjx
+ * @param
+ * @param
+ */
+@SuppressWarnings("unchecked")
+public final class HashedMap {
+
+ protected final transient Entry[] table;
+
+ public HashedMap() {
+ this(128);
+ }
+
+ public HashedMap(int initCapacity) {
+ this.table = new Entry[Math.max(initCapacity, 16)];
+ }
+
+ public final V get(final K key) {
+ final K k = key;
+ final Entry[] data = this.table;
+ Entry entry = data[k.hashCode() & (data.length - 1)];
+ while (entry != null) {
+ if (k == entry.key) return entry.value;
+ entry = entry.next;
+ }
+ return null;
+ }
+
+ public final V put(K key, V value) {
+ final K k = key;
+ final Entry[] data = this.table;
+ final int index = k.hashCode() & (data.length - 1);
+ Entry entry = data[index];
+ while (entry != null) {
+ if (k == entry.key) {
+ entry.value = value;
+ return entry.value;
+ }
+ entry = entry.next;
+ }
+ data[index] = new Entry<>(key, value, data[index]);
+ return null;
+ }
+
+ protected static final class Entry {
+
+ protected V value;
+
+ protected final K key;
+
+ protected final Entry next;
+
+ protected Entry(K key, V value, Entry next) {
+ this.key = key;
+ this.value = value;
+ this.next = next;
+ }
+ }
+}
diff --git a/src/com/wentch/redkale/convert/MapDecoder.java b/src/com/wentch/redkale/convert/MapDecoder.java
new file mode 100644
index 000000000..dfd7c2c1e
--- /dev/null
+++ b/src/com/wentch/redkale/convert/MapDecoder.java
@@ -0,0 +1,78 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.convert;
+
+import com.wentch.redkale.util.Creator;
+import java.lang.reflect.ParameterizedType;
+import java.lang.reflect.Type;
+import java.util.Map;
+
+/**
+ *
+ * @author zhangjx
+ * @param
+ * @param
+ */
+@SuppressWarnings("unchecked")
+public final class MapDecoder implements Decodeable> {
+
+ private final Type type;
+
+ private final Type keyType;
+
+ private final Type valueType;
+
+ protected Creator> creator;
+
+ private final Decodeable keyDecoder;
+
+ private final Decodeable valueDecoder;
+
+ public MapDecoder(final Factory factory, final Type type) {
+ this.type = type;
+ if (type instanceof ParameterizedType) {
+ final ParameterizedType pt = (ParameterizedType) type;
+ this.keyType = pt.getActualTypeArguments()[0];
+ this.valueType = pt.getActualTypeArguments()[1];
+ this.creator = factory.loadCreator((Class) pt.getRawType());
+ factory.register(type, this);
+ this.keyDecoder = factory.loadDecoder(this.keyType);
+ this.valueDecoder = factory.loadDecoder(this.valueType);
+ } else {
+ throw new ConvertException("mapdecoder not support the type (" + type + ")");
+ }
+ }
+
+ @Override
+ public Map convertFrom(Reader in) {
+ final int len = in.readMapB();
+ if (len == Reader.SIGN_NULL) return null;
+ final Map result = this.creator.create();
+ if (len == Reader.SIGN_NOLENGTH) {
+ while (in.hasNext()) {
+ K key = keyDecoder.convertFrom(in);
+ in.skipBlank();
+ V value = valueDecoder.convertFrom(in);
+ result.put(key, value);
+ }
+ } else {
+ for (int i = 0; i < len; i++) {
+ K key = keyDecoder.convertFrom(in);
+ in.skipBlank();
+ V value = valueDecoder.convertFrom(in);
+ result.put(key, value);
+ }
+ }
+ in.readMapE();
+ return result;
+ }
+
+ @Override
+ public Type getType() {
+ return this.type;
+ }
+
+}
diff --git a/src/com/wentch/redkale/convert/MapEncoder.java b/src/com/wentch/redkale/convert/MapEncoder.java
new file mode 100644
index 000000000..b4c12ff39
--- /dev/null
+++ b/src/com/wentch/redkale/convert/MapEncoder.java
@@ -0,0 +1,62 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.convert;
+
+import java.lang.reflect.ParameterizedType;
+import java.lang.reflect.Type;
+import java.util.Map;
+
+/**
+ *
+ * @author zhangjx
+ * @param
+ * @param
+ */
+@SuppressWarnings("unchecked")
+public final class MapEncoder implements Encodeable> {
+
+ private final Type type;
+
+ private final Encodeable keyencoder;
+
+ private final Encodeable valencoder;
+
+ public MapEncoder(final Factory factory, final Type type) {
+ this.type = type;
+ if (type instanceof ParameterizedType) {
+ final Type[] pt = ((ParameterizedType) type).getActualTypeArguments();
+ this.keyencoder = factory.loadEncoder(pt[0]);
+ this.valencoder = factory.loadEncoder(pt[1]);
+ } else {
+ this.keyencoder = factory.getAnyEncoder();
+ this.valencoder = factory.getAnyEncoder();
+ }
+ }
+
+ @Override
+ public void convertTo(Writer out, Map value) {
+ final Map values = value;
+ if (values == null) {
+ out.writeNull();
+ return;
+ }
+ out.writeMapB(values.size());
+ boolean first = true;
+ for (Map.Entry en : values.entrySet()) {
+ if (!first) out.writeArrayMark();
+ this.keyencoder.convertTo(out, en.getKey());
+ out.writeMapMark();
+ this.valencoder.convertTo(out, en.getValue());
+ if (first) first = false;
+ }
+ out.writeMapE();
+ }
+
+ @Override
+ public Type getType() {
+ return type;
+ }
+}
diff --git a/src/com/wentch/redkale/convert/ObjectDecoder.java b/src/com/wentch/redkale/convert/ObjectDecoder.java
new file mode 100644
index 000000000..072ee8c46
--- /dev/null
+++ b/src/com/wentch/redkale/convert/ObjectDecoder.java
@@ -0,0 +1,144 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.convert;
+
+
+import static com.wentch.redkale.convert.ObjectEncoder.TYPEZERO;
+import com.wentch.redkale.util.Creator;
+import java.lang.reflect.*;
+import java.util.Arrays;
+import java.util.HashSet;
+import java.util.Set;
+import java.util.concurrent.atomic.AtomicInteger;
+
+/**
+ *
+ * @author zhangjx
+ * @param
+ * @param
+ */
+@SuppressWarnings("unchecked")
+public final class ObjectDecoder implements Decodeable {
+
+ protected final Type type;
+
+ protected final Class typeClass;
+
+ protected Creator creator;
+
+ protected DeMember[] members;
+
+ protected Factory factory;
+
+ protected ObjectDecoder(Type type) {
+ this.type = type;
+ if (type instanceof ParameterizedType) {
+ final ParameterizedType pt = (ParameterizedType) type;
+ this.typeClass = (Class) pt.getRawType();
+ } else {
+ this.typeClass = (Class) type;
+ }
+ this.members = new DeMember[0];
+ }
+
+ public void init(final Factory factory) {
+ this.factory = factory;
+ if (type == Object.class) return;
+
+ Class clazz = null;
+ if (type instanceof ParameterizedType) {
+ final ParameterizedType pts = (ParameterizedType) type;
+ clazz = (Class) (pts).getRawType();
+ } else if (!(type instanceof Class)) {
+ throw new ConvertException("[" + type + "] is no a class");
+ } else {
+ clazz = (Class) type;
+ }
+ final Type[] virGenericTypes = this.typeClass.getTypeParameters();
+ final Type[] realGenericTypes = (type instanceof ParameterizedType) ? ((ParameterizedType) type).getActualTypeArguments() : TYPEZERO;
+ this.creator = factory.loadCreator(clazz);
+ final Set list = new HashSet<>();
+ try {
+ ConvertColumnEntry ref;
+ for (final Field field : clazz.getFields()) {
+ if (Modifier.isStatic(field.getModifiers())) continue;
+ ref = factory.findRef(field);
+ if (ref != null && ref.ignore()) continue;
+ Type t = ObjectEncoder.makeGenericType(field.getGenericType(), virGenericTypes, realGenericTypes);
+ list.add(new DeMember(ObjectEncoder.createAttribute(factory, clazz, field, null, null), factory.loadDecoder(t)));
+ }
+ final boolean reversible = factory.isReversible();
+ for (final Method method : clazz.getMethods()) {
+ if (Modifier.isStatic(method.getModifiers())) continue;
+ if (Modifier.isAbstract(method.getModifiers())) continue;
+ if (method.isSynthetic()) continue;
+ if (method.getName().length() < 4) continue;
+ if (!method.getName().startsWith("set")) continue;
+ if (method.getParameterTypes().length != 1) continue;
+ if (method.getReturnType() != void.class) continue;
+ if (reversible) {
+ boolean is = method.getParameterTypes()[0] == boolean.class || method.getParameterTypes()[0] == Boolean.class;
+ try {
+ clazz.getMethod(method.getName().replaceFirst("set", is ? "is" : "get"));
+ } catch (Exception e) {
+ continue;
+ }
+ }
+ ref = factory.findRef(method);
+ if (ref != null && ref.ignore()) continue;
+ Type t = ObjectEncoder.makeGenericType(method.getGenericParameterTypes()[0], virGenericTypes, realGenericTypes);
+ list.add(new DeMember(ObjectEncoder.createAttribute(factory, clazz, null, null, method), factory.loadDecoder(t)));
+ }
+ this.members = list.toArray(new DeMember[list.size()]);
+ Arrays.sort(this.members);
+ } catch (Exception ex) {
+ throw new ConvertException(ex);
+ }
+ }
+
+ /**
+ * 对象格式: [0x1][short字段个数][字段名][字段值]...[0x2]
+ *
+ * @param in
+ * @return
+ */
+ @Override
+ public final T convertFrom(final R in) {
+ final String clazz = in.readClassName();
+ if (clazz != null && !clazz.isEmpty()) {
+ try {
+ return (T) factory.loadDecoder(Class.forName(clazz)).convertFrom(in);
+ } catch (Exception ex) {
+ throw new ConvertException(ex);
+ }
+ }
+ if (in.readObjectB() == Reader.SIGN_NULL) return null;
+ final T result = this.creator.create();
+ final AtomicInteger index = new AtomicInteger();
+ while (in.hasNext()) {
+ DeMember member = in.readField(index, members);
+ in.skipBlank();
+ if (member == null) {
+ in.skipValue(); //跳过该属性的值
+ } else {
+ member.read(in, result);
+ }
+ index.incrementAndGet();
+ }
+ in.readObjectE();
+ return result;
+ }
+
+ @Override
+ public final Type getType() {
+ return this.type;
+ }
+
+ @Override
+ public String toString() {
+ return "ObjectDecoder{" + "type=" + type + ", members=" + Arrays.toString(members) + '}';
+ }
+}
diff --git a/src/com/wentch/redkale/convert/ObjectEncoder.java b/src/com/wentch/redkale/convert/ObjectEncoder.java
new file mode 100644
index 000000000..9fdcc24b1
--- /dev/null
+++ b/src/com/wentch/redkale/convert/ObjectEncoder.java
@@ -0,0 +1,213 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.convert;
+
+import com.wentch.redkale.util.Attribute;
+import java.lang.reflect.*;
+import java.util.*;
+
+/**
+ *
+ * @author zhangjx
+ * @param
+ * @param
+ */
+@SuppressWarnings("unchecked")
+public final class ObjectEncoder implements Encodeable {
+
+ static final Type[] TYPEZERO = new Type[0];
+
+ protected final Type type;
+
+ protected final Class typeClass;
+
+ protected EnMember[] members;
+
+ protected Factory factory;
+
+ protected ObjectEncoder(Type type) {
+ this.type = type;
+ if (type instanceof ParameterizedType) {
+ final ParameterizedType pt = (ParameterizedType) type;
+ this.typeClass = (Class) pt.getRawType();
+ } else {
+ this.typeClass = (Class) type;
+ }
+ this.members = new EnMember[0];
+ }
+
+ static Type makeGenericType(final Type type, final Type[] virGenericTypes, final Type[] realGenericTypes) {
+ if (type instanceof Class) {
+ return type;
+ } else if (type instanceof ParameterizedType) {
+ final ParameterizedType pt = (ParameterizedType) type;
+ Type[] paramTypes = pt.getActualTypeArguments();
+ final Type[] newTypes = new Type[paramTypes.length];
+ int count = 0;
+ for (int i = 0; i < newTypes.length; i++) {
+ newTypes[i] = makeGenericType(paramTypes[i], virGenericTypes, realGenericTypes);
+ if (paramTypes[i] == newTypes[i]) count++;
+ }
+ if (count == paramTypes.length) return pt;
+ return new ParameterizedType() {
+
+ @Override
+ public Type[] getActualTypeArguments() {
+ return newTypes;
+ }
+
+ @Override
+ public Type getRawType() {
+ return pt.getRawType();
+ }
+
+ @Override
+ public Type getOwnerType() {
+ return pt.getOwnerType();
+ }
+
+ };
+ }
+ if (realGenericTypes == null) return type;
+ if (type instanceof WildcardType) {
+ final WildcardType wt = (WildcardType) type;
+ for (Type f : wt.getUpperBounds()) {
+ for (int i = 0; i < virGenericTypes.length; i++) {
+ if (virGenericTypes[i] == f) return realGenericTypes.length == 0 ? Object.class : realGenericTypes[i];
+ }
+ }
+ } else if (type instanceof TypeVariable) {
+ for (int i = 0; i < virGenericTypes.length; i++) {
+ if (virGenericTypes[i] == type) return i >= realGenericTypes.length ? Object.class : realGenericTypes[i];
+ }
+ }
+ return type;
+ }
+
+ private static String readGetSetFieldName(Method method) {
+ if (method == null) return null;
+ String fname = method.getName();
+ if (!fname.startsWith("is") && !fname.startsWith("get") && !fname.startsWith("set")) return fname;
+ fname = fname.substring(fname.startsWith("is") ? 2 : 3);
+ if (fname.length() > 1 && !(fname.charAt(1) >= 'A' && fname.charAt(1) <= 'Z')) {
+ fname = Character.toLowerCase(fname.charAt(0)) + fname.substring(1);
+ } else if (fname.length() == 1) {
+ fname = "" + Character.toLowerCase(fname.charAt(0));
+ }
+ return fname;
+ }
+
+ static Attribute createAttribute(final Factory factory, Class clazz, final Field field, final Method getter, final Method setter) {
+ String fieldalias = null;
+ if (field != null) { // public field
+ ConvertColumnEntry ref = factory.findRef(field);
+ fieldalias = ref == null || ref.name().isEmpty() ? field.getName() : ref.name();
+ } else if (getter != null) {
+ ConvertColumnEntry ref = factory.findRef(getter);
+ String mfieldname = readGetSetFieldName(getter);
+ if (ref == null) {
+ try {
+ ref = factory.findRef(clazz.getDeclaredField(mfieldname));
+ } catch (Exception e) {
+ }
+ }
+ fieldalias = ref == null || ref.name().isEmpty() ? mfieldname : ref.name();
+ } else { // setter != null
+ ConvertColumnEntry ref = factory.findRef(setter);
+ String mfieldname = readGetSetFieldName(setter);
+ if (ref == null) {
+ try {
+ ref = factory.findRef(clazz.getDeclaredField(mfieldname));
+ } catch (Exception e) {
+ }
+ }
+ fieldalias = ref == null || ref.name().isEmpty() ? mfieldname : ref.name();
+ }
+ return Attribute.create(clazz, fieldalias, field, getter, setter);
+ }
+
+ public void init(final Factory factory) {
+ this.factory = factory;
+ if (type == Object.class) return;
+ //if (!(type instanceof Class)) throw new ConvertException("[" + type + "] is no a class");
+ final Class clazz = this.typeClass;
+ final Set list = new HashSet<>();
+ final Type[] virGenericTypes = this.typeClass.getTypeParameters();
+ final Type[] realGenericTypes = (type instanceof ParameterizedType) ? ((ParameterizedType) type).getActualTypeArguments() : null;
+ if (realGenericTypes != null) {
+ // println(type + "," + Arrays.toString(virGenericTypes) + ", " + Arrays.toString(realGenericTypes));
+ }
+ try {
+ ConvertColumnEntry ref;
+ for (final Field field : clazz.getFields()) {
+ if (Modifier.isStatic(field.getModifiers())) continue;
+ ref = factory.findRef(field);
+ if (ref != null && ref.ignore()) continue;
+ Type t = makeGenericType(field.getGenericType(), virGenericTypes, realGenericTypes);
+ list.add(new EnMember(createAttribute(factory, clazz, field, null, null), factory.loadEncoder(t)));
+ }
+ final boolean reversible = factory.isReversible();
+ for (final Method method : clazz.getMethods()) {
+ if (Modifier.isStatic(method.getModifiers())) continue;
+ if (Modifier.isAbstract(method.getModifiers())) continue;
+ if (method.isSynthetic()) continue;
+ if (method.getName().length() < 3) continue;
+ if (method.getName().equals("getClass")) continue;
+ if (!method.getName().startsWith("is") && !method.getName().startsWith("get")) continue;
+ if (method.getParameterTypes().length != 0) continue;
+ if (method.getReturnType() == void.class) continue;
+ if (reversible) {
+ boolean is = method.getName().startsWith("is");
+ try {
+ clazz.getMethod(method.getName().replaceFirst(is ? "is" : "get", "set"), method.getReturnType());
+ } catch (Exception e) {
+ continue;
+ }
+ }
+ ref = factory.findRef(method);
+ if (ref != null && ref.ignore()) continue;
+ Type t = makeGenericType(method.getGenericReturnType(), virGenericTypes, realGenericTypes);
+ list.add(new EnMember(createAttribute(factory, clazz, null, method, null), factory.loadEncoder(t)));
+ }
+ this.members = list.toArray(new EnMember[list.size()]);
+ Arrays.sort(this.members);
+
+ } catch (Exception ex) {
+ throw new ConvertException(ex);
+ }
+ }
+
+ @Override
+ public final void convertTo(W out, T value) {
+ if (value == null) {
+ out.wirteClassName(null);
+ out.writeNull();
+ return;
+ }
+ if (value != null && value.getClass() != this.typeClass) {
+ final Class clz = value.getClass();
+ out.wirteClassName(clz);
+ factory.loadEncoder(clz).convertTo(out, value);
+ return;
+ }
+ out.writeObjectB(members.length, value);
+ boolean comma = false;
+ for (EnMember member : members) {
+ comma = member.write(out, comma, value);
+ }
+ out.writeObjectE(value);
+ }
+
+ @Override
+ public final Type getType() {
+ return this.type;
+ }
+
+ @Override
+ public String toString() {
+ return "ObjectEncoder{" + "type=" + type + ", members=" + Arrays.toString(members) + '}';
+ }
+}
diff --git a/src/com/wentch/redkale/convert/Reader.java b/src/com/wentch/redkale/convert/Reader.java
new file mode 100644
index 000000000..ba40ed756
--- /dev/null
+++ b/src/com/wentch/redkale/convert/Reader.java
@@ -0,0 +1,112 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.convert;
+
+import java.util.concurrent.atomic.AtomicInteger;
+
+/**
+ *
+ * @author zhangjx
+ */
+public interface Reader {
+
+ public static final short SIGN_NULL = -1;
+
+ public static final short SIGN_NOLENGTH = -2;
+
+ /**
+ * 是否还存在下个元素或字段
+ *
+ * @return
+ */
+ public boolean hasNext();
+
+ /**
+ * 跳过值(不包含值前面的字段)
+ */
+ public void skipValue();
+
+ /**
+ * /跳过字段与值之间的多余内容， json就是跳过:符, map跳过:
+ */
+ public void skipBlank();
+
+ /**
+ * 读取对象的开头 返回字段数
+ *
+ * @return
+ */
+ public int readObjectB();
+
+ /**
+ * 读取对象的尾端
+ *
+ */
+ public void readObjectE();
+
+ /**
+ * 读取数组的开头并返回数组的长度
+ *
+ * @return
+ */
+ public int readArrayB();
+
+ /**
+ * 读取数组的尾端
+ *
+ */
+ public void readArrayE();
+
+ /**
+ * 读取map的开头并返回map的size
+ *
+ * @return
+ */
+ public int readMapB();
+
+ /**
+ * 读取数组的尾端
+ *
+ */
+ public void readMapE();
+
+ /**
+ * 根据字段读取字段对应的DeMember
+ *
+ * @param index
+ * @param members
+ * @return
+ */
+ public DeMember readField(final AtomicInteger index, final DeMember[] members);
+
+ public boolean readBoolean();
+
+ public byte readByte();
+
+ public char readChar();
+
+ public short readShort();
+
+ public int readInt();
+
+ public long readLong();
+
+ public float readFloat();
+
+ public double readDouble();
+
+ /**
+ * 读取无转义字符长度不超过255的字符串， 例如枚举值、字段名、类名字符串等
+ *
+ * @return
+ */
+ public String readSmallString();
+
+ public String readClassName();
+
+ public String readString();
+
+}
diff --git a/src/com/wentch/redkale/convert/SimpledCoder.java b/src/com/wentch/redkale/convert/SimpledCoder.java
new file mode 100644
index 000000000..db0e42657
--- /dev/null
+++ b/src/com/wentch/redkale/convert/SimpledCoder.java
@@ -0,0 +1,42 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.convert;
+
+import java.lang.reflect.ParameterizedType;
+import java.lang.reflect.Type;
+
+/**
+ *
+ * @author zhangjx
+ * @param
+ * @param
+ * @param
+ */
+public abstract class SimpledCoder implements Decodeable, Encodeable {
+
+ private Type type;
+
+ @Override
+ public abstract void convertTo(final W out, final T value);
+
+ @Override
+ public abstract T convertFrom(final R in);
+
+ @Override
+ @SuppressWarnings("unchecked")
+ public Class getType() {
+ if (type == null) {
+ Type[] ts = ((ParameterizedType) getClass().getGenericSuperclass()).getActualTypeArguments();
+ type = ts[ts.length - 1];
+ }
+ return (Class) type;
+ }
+
+ @Override
+ public String toString() {
+ return this.getClass().getSimpleName();
+ }
+}
diff --git a/src/com/wentch/redkale/convert/Writer.java b/src/com/wentch/redkale/convert/Writer.java
new file mode 100644
index 000000000..bf86892bb
--- /dev/null
+++ b/src/com/wentch/redkale/convert/Writer.java
@@ -0,0 +1,113 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.convert;
+
+import com.wentch.redkale.util.Attribute;
+
+/**
+ *
+ * @author zhangjx
+ */
+public interface Writer {
+
+ /**
+ * 输出null值
+ */
+ public void writeNull();
+
+ /**
+ *
+ * @param clazz
+ */
+ public void wirteClassName(Class clazz);
+
+ /**
+ * 输出一个对象前的操作
+ *
+ * @param fieldCount 字段个数
+ *
+ * @param obj
+ */
+ public void writeObjectB(int fieldCount, Object obj);
+
+ /**
+ * 输出一个对象后的操作
+ *
+ * @param obj
+ */
+ public void writeObjectE(Object obj);
+
+ /**
+ * 输出一个数组前的操作
+ *
+ * @param size 数组长度
+ */
+ public void writeArrayB(int size);
+
+ /**
+ * 输出数组元素间的间隔符
+ *
+ */
+ public void writeArrayMark();
+
+ /**
+ * 输出一个数组后的操作
+ *
+ */
+ public void writeArrayE();
+
+ /**
+ * 输出一个Map前的操作
+ *
+ * @param size map大小
+ */
+ public void writeMapB(int size);
+
+ /**
+ * 输出一个Map中key与value间的间隔符
+ *
+ */
+ public void writeMapMark();
+
+ /**
+ * 输出一个Map后的操作
+ *
+ */
+ public void writeMapE();
+
+ /**
+ * 输出一个字段
+ *
+ * @param comma 是否非第一个字段
+ * @param attribute
+ */
+ public void writeField(boolean comma, Attribute attribute);
+
+ public void writeBoolean(boolean value);
+
+ public void writeByte(byte value);
+
+ public void writeChar(char value);
+
+ public void writeShort(short value);
+
+ public void writeInt(int value);
+
+ public void writeLong(long value);
+
+ public void writeFloat(float value);
+
+ public void writeDouble(double value);
+
+ /**
+ * 写入无转义字符长度不超过255的字符串， 例如枚举值、字段名、类名字符串等 *
+ *
+ * @param value
+ */
+ public void writeSmallString(String value);
+
+ public void writeString(String value);
+}
diff --git a/src/com/wentch/redkale/convert/bson/BsonConvert.java b/src/com/wentch/redkale/convert/bson/BsonConvert.java
new file mode 100644
index 000000000..dd3b27539
--- /dev/null
+++ b/src/com/wentch/redkale/convert/bson/BsonConvert.java
@@ -0,0 +1,61 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.convert.bson;
+
+import com.wentch.redkale.convert.Convert;
+import com.wentch.redkale.convert.Factory;
+import com.wentch.redkale.util.ObjectPool;
+import java.lang.reflect.Type;
+
+/**
+ *
+ * @author zhangjx
+ */
+public final class BsonConvert extends Convert {
+
+ private static final ObjectPool readerPool = new ObjectPool<>(Integer.getInteger("convert.bson.pool.size", 16), BsonReader.class);
+
+ private static final ObjectPool writerPool = new ObjectPool<>(Integer.getInteger("convert.bson.pool.size", 16), BsonWriter.class);
+
+ protected BsonConvert(Factory factory) {
+ super(factory);
+ }
+
+ public T convertFrom(final Type type, final byte[] bytes) {
+ if (bytes == null) return null;
+ return convertFrom(type, bytes, 0, bytes.length);
+ }
+
+ public T convertFrom(final Type type, final byte[] bytes, int start, int len) {
+ if (type == null) return null;
+ final BsonReader in = readerPool.poll();
+ in.setBytes(bytes, start, len);
+ @SuppressWarnings("unchecked")
+ T rs = (T) factory.loadDecoder(type).convertFrom(in);
+ readerPool.offer(in);
+ return rs;
+ }
+
+ public byte[] convertTo(final Type type, Object value) {
+ if (type == null) return null;
+ final BsonWriter out = writerPool.poll();
+ factory.loadEncoder(type).convertTo(out, value);
+ byte[] result = out.toArray();
+ writerPool.offer(out);
+ return result;
+ }
+
+ public byte[] convertTo(Object value) {
+ if (value == null) {
+ final BsonWriter out = writerPool.poll();
+ out.writeNull();
+ byte[] result = out.toArray();
+ writerPool.offer(out);
+ return result;
+ }
+ return convertTo(value.getClass(), value);
+ }
+}
diff --git a/src/com/wentch/redkale/convert/bson/BsonFactory.java b/src/com/wentch/redkale/convert/bson/BsonFactory.java
new file mode 100644
index 000000000..7930b24fb
--- /dev/null
+++ b/src/com/wentch/redkale/convert/bson/BsonFactory.java
@@ -0,0 +1,54 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.convert.bson;
+
+import com.wentch.redkale.convert.ConvertType;
+import com.wentch.redkale.convert.Factory;
+import java.io.Serializable;
+
+/**
+ *
+ * @author zhangjx
+ */
+public final class BsonFactory extends Factory {
+
+ private static final BsonFactory instance = new BsonFactory(null);
+
+ static {
+ instance.register(Serializable.class, instance.loadDecoder(Object.class));
+ instance.register(Serializable.class, instance.loadEncoder(Object.class));
+ }
+
+ private BsonFactory(BsonFactory parent) {
+ super(parent);
+ this.convert = new BsonConvert(this);
+ }
+
+ public static BsonFactory root() {
+ return instance;
+ }
+
+ @Override
+ public final BsonConvert getConvert() {
+ return (BsonConvert) convert;
+ }
+
+ @Override
+ public BsonFactory createChild() {
+ return new BsonFactory(this);
+ }
+
+ @Override
+ public ConvertType getConvertType() {
+ return ConvertType.BSON;
+ }
+
+ @Override
+ public boolean isReversible() {
+ return true;
+ }
+
+}
diff --git a/src/com/wentch/redkale/convert/bson/BsonReader.java b/src/com/wentch/redkale/convert/bson/BsonReader.java
new file mode 100644
index 000000000..8095f6035
--- /dev/null
+++ b/src/com/wentch/redkale/convert/bson/BsonReader.java
@@ -0,0 +1,245 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.convert.bson;
+
+import com.wentch.redkale.convert.ConvertException;
+import com.wentch.redkale.convert.DeMember;
+import com.wentch.redkale.convert.Reader;
+import com.wentch.redkale.util.ObjectPool.Poolable;
+import com.wentch.redkale.util.Utility;
+import java.util.concurrent.atomic.AtomicInteger;
+
+/**
+ *
+ * @author zhangjx
+ */
+public final class BsonReader implements Reader, Poolable {
+
+ public static final short SIGN_OBJECTB = (short) 0xBB;
+
+ public static final short SIGN_OBJECTE = (short) 0xEE;
+
+ public static final byte SIGN_HASNEXT = 1;
+
+ public static final byte SIGN_NONEXT = 0;
+
+ public static final byte VERBOSE_NO = 1;
+
+ public static final byte VERBOSE_YES = 2;
+
+ private int position = -1;
+
+ private byte[] content;
+
+ public BsonReader() {
+ }
+
+ public BsonReader(byte[] bytes) {
+ setBytes(bytes, 0, bytes.length);
+ }
+
+ public BsonReader(byte[] bytes, int start, int len) {
+ setBytes(bytes, start, len);
+ }
+
+ public final void setBytes(byte[] bytes) {
+ setBytes(bytes, 0, bytes.length);
+ }
+
+ public final void setBytes(byte[] bytes, int start, int len) {
+ this.content = bytes;
+ this.position = start - 1;
+ //this.limit = start + len - 1;
+ }
+
+ @Override
+ public void prepare() {
+ }
+
+ @Override
+ public void release() {
+ this.position = -1;
+ //this.limit = -1;
+ this.content = null;
+ }
+
+ public void close() {
+ this.release();
+ }
+
+ /**
+ * 跳过属性的值
+ */
+ @Override
+ public final void skipValue() {
+
+ }
+
+ /**
+ * 判断下一个非空白字节是否为{
+ *
+ */
+ @Override
+ public int readObjectB() {
+ short bt = readShort();
+ if (bt == Reader.SIGN_NULL) return bt;
+ if (bt != SIGN_OBJECTB) {
+ throw new ConvertException("a bson object must begin with " + (SIGN_OBJECTB)
+ + " (position = " + position + ") but '" + this.content[this.position] + "'");
+ }
+ return bt;
+ }
+
+ @Override
+ public void readObjectE() {
+ if (readShort() != SIGN_OBJECTE) {
+ throw new ConvertException("a bson object must end with " + (SIGN_OBJECTE)
+ + " (position = " + position + ") but '" + this.content[this.position] + "'");
+ }
+ }
+
+ @Override
+ public int readMapB() {
+ return readArrayB();
+ }
+
+ @Override
+ public void readMapE() {
+ }
+
+ /**
+ * 判断下一个非空白字节是否为[
+ *
+ * @return
+ */
+ @Override
+ public int readArrayB() {
+ return readShort();
+ }
+
+ @Override
+ public void readArrayE() {
+ }
+
+ /**
+ * 判断下一个非空白字节是否:
+ */
+ @Override
+ public void skipBlank() {
+ }
+
+ /**
+ * 判断对象是否存在下一个属性或者数组是否存在下一个元素
+ *
+ * @return
+ */
+ @Override
+ public boolean hasNext() {
+ byte b = readByte();
+ if (b == SIGN_HASNEXT) return true;
+ if (b != SIGN_NONEXT) throw new ConvertException("hasNext option must be (" + (SIGN_HASNEXT)
+ + " or " + (SIGN_NONEXT) + ") but '" + b + "' at position(" + this.position + ")");
+ return false;
+ }
+
+ @Override
+ public DeMember readField(final AtomicInteger index, final DeMember[] members) {
+ final String exceptedfield = readSmallString();
+ final int len = members.length;
+ int v = index.get();
+ if (v >= len) {
+ v = 0;
+ index.set(0);
+ }
+ for (int k = v; k < len; k++) {
+ if (exceptedfield.equals(members[k].getAttribute().field())) {
+ index.set(k);
+ return members[k];
+ }
+ }
+ for (int k = 0; k < v; k++) {
+ if (exceptedfield.equals(members[k].getAttribute().field())) {
+ index.set(k);
+ return members[k];
+ }
+ }
+ return null;
+ }
+
+ //------------------------------------------------------------
+ @Override
+ public boolean readBoolean() {
+ return content[++this.position] == 1;
+ }
+
+ @Override
+ public byte readByte() {
+ return content[++this.position];
+ }
+
+ @Override
+ public char readChar() {
+ return (char) ((0xff00 & (content[++this.position] << 8)) | (0xff & content[++this.position]));
+ }
+
+ @Override
+ public short readShort() {
+ return (short) ((0xff00 & (content[++this.position] << 8)) | (0xff & content[++this.position]));
+ }
+
+ @Override
+ public int readInt() {
+ return ((content[++this.position] & 0xff) << 24) | ((content[++this.position] & 0xff) << 16)
+ | ((content[++this.position] & 0xff) << 8) | (content[++this.position] & 0xff);
+ }
+
+ @Override
+ public long readLong() {
+ return ((((long) content[++this.position] & 0xff) << 56)
+ | (((long) content[++this.position] & 0xff) << 48)
+ | (((long) content[++this.position] & 0xff) << 40)
+ | (((long) content[++this.position] & 0xff) << 32)
+ | (((long) content[++this.position] & 0xff) << 24)
+ | (((long) content[++this.position] & 0xff) << 16)
+ | (((long) content[++this.position] & 0xff) << 8)
+ | (((long) content[++this.position] & 0xff)));
+ }
+
+ @Override
+ public float readFloat() {
+ return Float.intBitsToFloat(readInt());
+ }
+
+ @Override
+ public double readDouble() {
+ return Double.longBitsToDouble(readLong());
+ }
+
+ @Override
+ public String readClassName() {
+ return readSmallString();
+ }
+
+ @Override
+ public String readSmallString() {
+ int len = 0xff & readByte();
+ if (len == 0) return "";
+ String value = new String(content, ++this.position, len);
+ this.position += len - 1;
+ return value;
+ }
+
+ @Override
+ public String readString() {
+ int len = readInt();
+ if (len == SIGN_NULL) return null;
+ if (len == 0) return "";
+ String value = new String(Utility.decodeUTF8(content, ++this.position, len));
+ this.position += len - 1;
+ return value;
+ }
+
+}
diff --git a/src/com/wentch/redkale/convert/bson/BsonSimpledCoder.java b/src/com/wentch/redkale/convert/bson/BsonSimpledCoder.java
new file mode 100644
index 000000000..840e1fca3
--- /dev/null
+++ b/src/com/wentch/redkale/convert/bson/BsonSimpledCoder.java
@@ -0,0 +1,17 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.convert.bson;
+
+import com.wentch.redkale.convert.SimpledCoder;
+
+/**
+ *
+ * @author zhangjx
+ * @param
+ */
+public abstract class BsonSimpledCoder extends SimpledCoder {
+
+}
diff --git a/src/com/wentch/redkale/convert/bson/BsonWriter.java b/src/com/wentch/redkale/convert/bson/BsonWriter.java
new file mode 100644
index 000000000..d64382a0b
--- /dev/null
+++ b/src/com/wentch/redkale/convert/bson/BsonWriter.java
@@ -0,0 +1,236 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.convert.bson;
+
+import com.wentch.redkale.util.Utility;
+import com.wentch.redkale.util.Attribute;
+import com.wentch.redkale.convert.ConvertException;
+import com.wentch.redkale.convert.Reader;
+import com.wentch.redkale.convert.Writer;
+import com.wentch.redkale.util.ObjectPool.Poolable;
+
+/**
+ *
+ * @author zhangjx
+ */
+public final class BsonWriter implements Writer, Poolable {
+
+ private static final int defaultSize = Integer.getInteger("convert.bson.writer.buffer.defsize", 1024);
+
+ protected int count;
+
+ private byte[] content;
+
+ public byte[] toArray() {
+ if (count == content.length) return content;
+ byte[] newdata = new byte[count];
+ System.arraycopy(content, 0, newdata, 0, count);
+ return newdata;
+ }
+
+ public BsonWriter() {
+ this(defaultSize);
+ }
+
+ public BsonWriter(int size) {
+ this.content = new byte[size > 32 ? size : 32];
+ }
+
+ //-----------------------------------------------------------------------
+ //-----------------------------------------------------------------------
+ /**
+ * 返回指定至少指定长度的缓冲区
+ *
+ * @param len
+ * @return
+ */
+ public byte[] expand(int len) {
+ int newcount = count + len;
+ if (newcount <= content.length) return content;
+ byte[] newdata = new byte[Math.max(content.length * 3 / 2, newcount)];
+ System.arraycopy(content, 0, newdata, 0, count);
+ this.content = newdata;
+ return newdata;
+ }
+
+ public void writeTo(final byte ch) {
+ expand(1);
+ content[count++] = ch;
+ }
+
+ public void writeTo(final byte... chs) {
+ int len = chs.length;
+ expand(len);
+ System.arraycopy(chs, 0, content, count, len);
+ count += len;
+ }
+
+ public void writeTo(final byte[] chs, final int start, final int end) {
+ int len = end - start;
+ expand(len);
+ System.arraycopy(chs, start, content, count, len);
+ count += len;
+ }
+
+ @Override
+ public void prepare() {
+ }
+
+ @Override
+ public void release() {
+ this.count = 0;
+ if (this.content.length > defaultSize) {
+ this.content = new byte[defaultSize];
+ }
+ }
+
+ //------------------------------------------------------------------------
+ public final int count() {
+ return this.count;
+ }
+
+ public final void count(int count) {
+ if (count >= 0) this.count = count;
+ }
+
+ //-----------------------------------------------------------------------
+ @Override
+ public String toString() {
+ return new String(content, 0, count);
+ }
+
+ @Override
+ public void writeBoolean(boolean value) {
+ writeTo(value ? (byte) 1 : (byte) 0);
+ }
+
+ @Override
+ public void writeByte(byte value) {
+ writeTo(value);
+ }
+
+ @Override
+ public void writeChar(final char value) {
+ writeTo((byte) ((value & 0xFF00) >> 8), (byte) (value & 0xFF));
+ }
+
+ @Override
+ public void writeShort(short value) {
+ writeTo((byte) (value >> 8), (byte) value);
+ }
+
+ @Override
+ public void writeInt(int value) {
+ writeTo((byte) (value >> 24), (byte) (value >> 16), (byte) (value >> 8), (byte) value);
+ }
+
+ @Override
+ public void writeLong(long value) {
+ writeTo((byte) (value >> 56), (byte) (value >> 48), (byte) (value >> 40), (byte) (value >> 32),
+ (byte) (value >> 24), (byte) (value >> 16), (byte) (value >> 8), (byte) value);
+ }
+
+ @Override
+ public void writeFloat(float value) {
+ writeInt(Float.floatToIntBits(value));
+ }
+
+ @Override
+ public void writeDouble(double value) {
+ writeLong(Double.doubleToLongBits(value));
+ }
+
+ @Override
+ public void wirteClassName(Class clazz) {
+ writeSmallString(clazz == null ? "" : clazz.getName());
+ }
+
+ @Override
+ public final void writeObjectB(int fieldCount, Object obj) {
+ writeSmallString("");
+ writeShort(BsonReader.SIGN_OBJECTB);
+ }
+
+ @Override
+ public final void writeObjectE(Object obj) {
+ writeByte(BsonReader.SIGN_NONEXT);
+ writeShort(BsonReader.SIGN_OBJECTE);
+ }
+
+ @Override
+ public final void writeField(boolean comma, Attribute attribute) {
+ writeByte(BsonReader.SIGN_HASNEXT);
+ writeSmallString(attribute.field());
+ }
+
+ /**
+ * 对于类的字段名、枚举值这些长度一般不超过255且不会出现双字节字符的字符串采用writeSmallString处理, readSmallString用于读取
+ *
+ * @param value
+ */
+ @Override
+ public void writeSmallString(String value) {
+ if (value.isEmpty()) {
+ writeTo((byte) 0);
+ return;
+ }
+ char[] chars = Utility.charArray(value);
+ if (chars.length > 255) throw new ConvertException("'" + value + "' has very long length");
+ byte[] bytes = new byte[chars.length + 1];
+ bytes[0] = (byte) chars.length;
+ for (int i = 0; i < chars.length; i++) {
+ if (chars[i] > Byte.MAX_VALUE) throw new ConvertException("'" + value + "' has double-word");
+ bytes[i + 1] = (byte) chars[i];
+ }
+ writeTo(bytes);
+ }
+
+ @Override
+ public void writeString(String value) {
+ if (value == null) {
+ writeInt(Reader.SIGN_NULL);
+ return;
+ } else if (value.isEmpty()) {
+ writeInt(0);
+ return;
+ }
+ byte[] bytes = Utility.encodeUTF8(value);
+ writeInt(bytes.length);
+ writeTo(bytes);
+ }
+
+ @Override
+ public final void writeNull() {
+ writeShort(Reader.SIGN_NULL);
+ }
+
+ @Override
+ public void writeArrayB(int size) {
+ writeShort((short) size);
+ }
+
+ @Override
+ public void writeArrayMark() {
+ }
+
+ @Override
+ public void writeArrayE() {
+ }
+
+ @Override
+ public void writeMapB(int size) {
+ writeArrayB(size);
+ }
+
+ @Override
+ public void writeMapMark() {
+ }
+
+ @Override
+ public void writeMapE() {
+ }
+
+}
diff --git a/src/com/wentch/redkale/convert/ext/BigIntegerSimpledCoder.java b/src/com/wentch/redkale/convert/ext/BigIntegerSimpledCoder.java
new file mode 100644
index 000000000..735e85c3e
--- /dev/null
+++ b/src/com/wentch/redkale/convert/ext/BigIntegerSimpledCoder.java
@@ -0,0 +1,38 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.convert.ext;
+
+import com.wentch.redkale.convert.SimpledCoder;
+import com.wentch.redkale.convert.Writer;
+import com.wentch.redkale.convert.Reader;
+import java.math.BigInteger;
+
+/**
+ *
+ * @author zhangjx
+ * @param
+ * @param
+ */
+public final class BigIntegerSimpledCoder extends SimpledCoder {
+
+ public static final BigIntegerSimpledCoder instance = new BigIntegerSimpledCoder();
+
+ @Override
+ public void convertTo(W out, BigInteger value) {
+ if (value == null) {
+ out.writeNull();
+ return;
+ }
+ ByteArraySimpledCoder.instance.convertTo(out, value.toByteArray());
+ }
+
+ @Override
+ public BigInteger convertFrom(R in) {
+ byte[] bytes = ByteArraySimpledCoder.instance.convertFrom(in);
+ return bytes == null ? null : new BigInteger(bytes);
+ }
+
+}
diff --git a/src/com/wentch/redkale/convert/ext/BoolArraySimpledCoder.java b/src/com/wentch/redkale/convert/ext/BoolArraySimpledCoder.java
new file mode 100644
index 000000000..696386202
--- /dev/null
+++ b/src/com/wentch/redkale/convert/ext/BoolArraySimpledCoder.java
@@ -0,0 +1,68 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.convert.ext;
+
+import com.wentch.redkale.convert.Reader;
+import com.wentch.redkale.convert.SimpledCoder;
+import com.wentch.redkale.convert.Writer;
+
+/**
+ *
+ * @author zhangjx
+ * @param
+ * @param
+ */
+public final class BoolArraySimpledCoder extends SimpledCoder {
+
+ public static final BoolArraySimpledCoder instance = new BoolArraySimpledCoder();
+
+ @Override
+ public void convertTo(W out, boolean[] values) {
+ if (values == null) {
+ out.writeNull();
+ return;
+ }
+ out.writeArrayB(values.length);
+ boolean flag = false;
+ for (boolean v : values) {
+ if (flag) out.writeArrayMark();
+ out.writeBoolean(v);
+ flag = true;
+ }
+ out.writeArrayE();
+ }
+
+ @Override
+ public boolean[] convertFrom(R in) {
+ int len = in.readArrayB();
+ if (len == Reader.SIGN_NULL) {
+ return null;
+ } else if (len == Reader.SIGN_NOLENGTH) {
+ int size = 0;
+ boolean[] data = new boolean[8];
+ while (in.hasNext()) {
+ if (size >= data.length) {
+ boolean[] newdata = new boolean[data.length + 4];
+ System.arraycopy(data, 0, newdata, 0, size);
+ data = newdata;
+ }
+ data[size++] = in.readBoolean();
+ }
+ in.readArrayE();
+ boolean[] newdata = new boolean[size];
+ System.arraycopy(data, 0, newdata, 0, size);
+ return newdata;
+ } else {
+ boolean[] values = new boolean[len];
+ for (int i = 0; i < values.length; i++) {
+ values[i] = in.readBoolean();
+ }
+ in.readArrayE();
+ return values;
+ }
+ }
+
+}
diff --git a/src/com/wentch/redkale/convert/ext/BoolSimpledCoder.java b/src/com/wentch/redkale/convert/ext/BoolSimpledCoder.java
new file mode 100644
index 000000000..4b13eb923
--- /dev/null
+++ b/src/com/wentch/redkale/convert/ext/BoolSimpledCoder.java
@@ -0,0 +1,32 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.convert.ext;
+
+import com.wentch.redkale.convert.Reader;
+import com.wentch.redkale.convert.SimpledCoder;
+import com.wentch.redkale.convert.Writer;
+
+/**
+ *
+ * @author zhangjx
+ * @param
+ * @param
+ */
+public final class BoolSimpledCoder extends SimpledCoder {
+
+ public static final BoolSimpledCoder instance = new BoolSimpledCoder();
+
+ @Override
+ public void convertTo(W out, Boolean value) {
+ out.writeBoolean(value);
+ }
+
+ @Override
+ public Boolean convertFrom(R in) {
+ return in.readBoolean();
+ }
+
+}
diff --git a/src/com/wentch/redkale/convert/ext/ByteArraySimpledCoder.java b/src/com/wentch/redkale/convert/ext/ByteArraySimpledCoder.java
new file mode 100644
index 000000000..ffd09ccce
--- /dev/null
+++ b/src/com/wentch/redkale/convert/ext/ByteArraySimpledCoder.java
@@ -0,0 +1,68 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.convert.ext;
+
+import com.wentch.redkale.convert.Reader;
+import com.wentch.redkale.convert.SimpledCoder;
+import com.wentch.redkale.convert.Writer;
+
+/**
+ *
+ * @author zhangjx
+ * @param
+ * @param
+ */
+public final class ByteArraySimpledCoder extends SimpledCoder {
+
+ public static final ByteArraySimpledCoder instance = new ByteArraySimpledCoder();
+
+ @Override
+ public void convertTo(W out, byte[] values) {
+ if (values == null) {
+ out.writeNull();
+ return;
+ }
+ out.writeArrayB(values.length);
+ boolean flag = false;
+ for (byte v : values) {
+ if (flag) out.writeArrayMark();
+ out.writeByte(v);
+ flag = true;
+ }
+ out.writeArrayE();
+ }
+
+ @Override
+ public byte[] convertFrom(R in) {
+ int len = in.readArrayB();
+ if (len == Reader.SIGN_NULL) {
+ return null;
+ } else if (len == Reader.SIGN_NOLENGTH) {
+ int size = 0;
+ byte[] data = new byte[8];
+ while (in.hasNext()) {
+ if (size >= data.length) {
+ byte[] newdata = new byte[data.length + 4];
+ System.arraycopy(data, 0, newdata, 0, size);
+ data = newdata;
+ }
+ data[size++] = in.readByte();
+ }
+ in.readArrayE();
+ byte[] newdata = new byte[size];
+ System.arraycopy(data, 0, newdata, 0, size);
+ return newdata;
+ } else {
+ byte[] values = new byte[len];
+ for (int i = 0; i < values.length; i++) {
+ values[i] = in.readByte();
+ }
+ in.readArrayE();
+ return values;
+ }
+ }
+
+}
diff --git a/src/com/wentch/redkale/convert/ext/ByteSimpledCoder.java b/src/com/wentch/redkale/convert/ext/ByteSimpledCoder.java
new file mode 100644
index 000000000..e76a6e84c
--- /dev/null
+++ b/src/com/wentch/redkale/convert/ext/ByteSimpledCoder.java
@@ -0,0 +1,32 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.convert.ext;
+
+import com.wentch.redkale.convert.Reader;
+import com.wentch.redkale.convert.SimpledCoder;
+import com.wentch.redkale.convert.Writer;
+
+/**
+ *
+ * @author zhangjx
+ * @param
+ * @param
+ */
+public final class ByteSimpledCoder extends SimpledCoder {
+
+ public static final ByteSimpledCoder instance = new ByteSimpledCoder();
+
+ @Override
+ public void convertTo(W out, Byte value) {
+ out.writeByte(value);
+ }
+
+ @Override
+ public Byte convertFrom(R in) {
+ return in.readByte();
+ }
+
+}
diff --git a/src/com/wentch/redkale/convert/ext/CharArraySimpledCoder.java b/src/com/wentch/redkale/convert/ext/CharArraySimpledCoder.java
new file mode 100644
index 000000000..9b5be5edb
--- /dev/null
+++ b/src/com/wentch/redkale/convert/ext/CharArraySimpledCoder.java
@@ -0,0 +1,68 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.convert.ext;
+
+import com.wentch.redkale.convert.Reader;
+import com.wentch.redkale.convert.SimpledCoder;
+import com.wentch.redkale.convert.Writer;
+
+/**
+ *
+ * @author zhangjx
+ * @param
+ * @param
+ */
+public final class CharArraySimpledCoder extends SimpledCoder {
+
+ public static final CharArraySimpledCoder instance = new CharArraySimpledCoder();
+
+ @Override
+ public void convertTo(W out, char[] values) {
+ if (values == null) {
+ out.writeNull();
+ return;
+ }
+ out.writeArrayB(values.length);
+ boolean flag = false;
+ for (char v : values) {
+ if (flag) out.writeArrayMark();
+ out.writeChar(v);
+ flag = true;
+ }
+ out.writeArrayE();
+ }
+
+ @Override
+ public char[] convertFrom(R in) {
+ int len = in.readArrayB();
+ if (len == Reader.SIGN_NULL) {
+ return null;
+ } else if (len == Reader.SIGN_NOLENGTH) {
+ int size = 0;
+ char[] data = new char[8];
+ while (in.hasNext()) {
+ if (size >= data.length) {
+ char[] newdata = new char[data.length + 4];
+ System.arraycopy(data, 0, newdata, 0, size);
+ data = newdata;
+ }
+ data[size++] = in.readChar();
+ }
+ in.readArrayE();
+ char[] newdata = new char[size];
+ System.arraycopy(data, 0, newdata, 0, size);
+ return newdata;
+ } else {
+ char[] values = new char[len];
+ for (int i = 0; i < values.length; i++) {
+ values[i] = in.readChar();
+ }
+ in.readArrayE();
+ return values;
+ }
+ }
+
+}
diff --git a/src/com/wentch/redkale/convert/ext/CharSimpledCoder.java b/src/com/wentch/redkale/convert/ext/CharSimpledCoder.java
new file mode 100644
index 000000000..26b501043
--- /dev/null
+++ b/src/com/wentch/redkale/convert/ext/CharSimpledCoder.java
@@ -0,0 +1,33 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+
+package com.wentch.redkale.convert.ext;
+
+import com.wentch.redkale.convert.Reader;
+import com.wentch.redkale.convert.SimpledCoder;
+import com.wentch.redkale.convert.Writer;
+
+/**
+ *
+ * @author zhangjx
+ * @param
+ * @param
+ */
+public final class CharSimpledCoder extends SimpledCoder {
+
+ public static final CharSimpledCoder instance = new CharSimpledCoder();
+
+ @Override
+ public void convertTo(W out, Character value) {
+ out.writeChar(value);
+ }
+
+ @Override
+ public Character convertFrom(R in) {
+ return in.readChar();
+ }
+
+}
diff --git a/src/com/wentch/redkale/convert/ext/DateSimpledCoder.java b/src/com/wentch/redkale/convert/ext/DateSimpledCoder.java
new file mode 100644
index 000000000..4df76df2f
--- /dev/null
+++ b/src/com/wentch/redkale/convert/ext/DateSimpledCoder.java
@@ -0,0 +1,33 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.convert.ext;
+
+import com.wentch.redkale.convert.Reader;
+import com.wentch.redkale.convert.SimpledCoder;
+import com.wentch.redkale.convert.Writer;
+import java.util.Date;
+
+/**
+ *
+ * @author zhangjx
+ * @param
+ * @param
+ */
+public final class DateSimpledCoder extends SimpledCoder {
+
+ public static final DateSimpledCoder instance = new DateSimpledCoder();
+
+ @Override
+ public void convertTo(W out, Date value) {
+ out.writeLong(value.getTime());
+ }
+
+ @Override
+ public Date convertFrom(R in) {
+ return new Date(in.readLong());
+ }
+
+}
diff --git a/src/com/wentch/redkale/convert/ext/DoubleArraySimpledCoder.java b/src/com/wentch/redkale/convert/ext/DoubleArraySimpledCoder.java
new file mode 100644
index 000000000..04aa3a543
--- /dev/null
+++ b/src/com/wentch/redkale/convert/ext/DoubleArraySimpledCoder.java
@@ -0,0 +1,68 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.convert.ext;
+
+import com.wentch.redkale.convert.Reader;
+import com.wentch.redkale.convert.SimpledCoder;
+import com.wentch.redkale.convert.Writer;
+
+/**
+ *
+ * @author zhangjx
+ * @param
+ * @param
+ */
+public final class DoubleArraySimpledCoder extends SimpledCoder {
+
+ public static final DoubleArraySimpledCoder instance = new DoubleArraySimpledCoder();
+
+ @Override
+ public void convertTo(W out, double[] values) {
+ if (values == null) {
+ out.writeNull();
+ return;
+ }
+ out.writeArrayB(values.length);
+ boolean flag = false;
+ for (double v : values) {
+ if (flag) out.writeArrayMark();
+ out.writeDouble(v);
+ flag = true;
+ }
+ out.writeArrayE();
+ }
+
+ @Override
+ public double[] convertFrom(R in) {
+ int len = in.readArrayB();
+ if (len == Reader.SIGN_NULL) {
+ return null;
+ } else if (len == Reader.SIGN_NOLENGTH) {
+ int size = 0;
+ double[] data = new double[8];
+ while (in.hasNext()) {
+ if (size >= data.length) {
+ double[] newdata = new double[data.length + 4];
+ System.arraycopy(data, 0, newdata, 0, size);
+ data = newdata;
+ }
+ data[size++] = in.readDouble();
+ }
+ in.readArrayE();
+ double[] newdata = new double[size];
+ System.arraycopy(data, 0, newdata, 0, size);
+ return newdata;
+ } else {
+ double[] values = new double[len];
+ for (int i = 0; i < values.length; i++) {
+ values[i] = in.readDouble();
+ }
+ in.readArrayE();
+ return values;
+ }
+ }
+
+}
diff --git a/src/com/wentch/redkale/convert/ext/DoubleSimpledCoder.java b/src/com/wentch/redkale/convert/ext/DoubleSimpledCoder.java
new file mode 100644
index 000000000..a56456562
--- /dev/null
+++ b/src/com/wentch/redkale/convert/ext/DoubleSimpledCoder.java
@@ -0,0 +1,32 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.wentch.redkale.convert.ext;
+
+import com.wentch.redkale.convert.Reader;
+import com.wentch.redkale.convert.SimpledCoder;
+import com.wentch.redkale.convert.Writer;
+
+/**
+ *
+ * @author zhangjx
+ * @param
+ * @param
+ */
+public final class DoubleSimpledCoder extends SimpledCoder