Hprose 全名是高性能远程对象服务引擎.rar

/**********************************************************\ | | | hprose | | | | Official WebSite: http://www.hprose.com/ | | http://www.hprose.org/ | | | \**********************************************************/ /**********************************************************\ * * * HproseService.java * * * * hprose service class for Java. * * * * LastModified: Oct 16, 2016 * * Author: Ma Bingyao <andot@hprose.com> * * * \**********************************************************/ package hprose.server; import hprose.common.HandlerManager; import hprose.common.HproseContext; import hprose.common.HproseException; import hprose.common.HproseFilter; import hprose.common.HproseMethod; import hprose.common.HproseMethods; import hprose.common.HproseResultMode; import hprose.io.ByteBufferStream; import hprose.io.HproseMode; import static hprose.io.HproseTags.TagArgument; import static hprose.io.HproseTags.TagCall; import static hprose.io.HproseTags.TagEnd; import static hprose.io.HproseTags.TagError; import static hprose.io.HproseTags.TagFunctions; import static hprose.io.HproseTags.TagList; import static hprose.io.HproseTags.TagOpenbrace; import static hprose.io.HproseTags.TagResult; import static hprose.io.HproseTags.TagTrue; import hprose.io.serialize.Writer; import hprose.io.unserialize.Reader; import hprose.util.StrUtil; import hprose.util.concurrent.Action; import hprose.util.concurrent.AsyncFunc; import hprose.util.concurrent.Call; import hprose.util.concurrent.Func; import hprose.util.concurrent.Promise; import hprose.util.concurrent.Reducer; import hprose.util.concurrent.Threads; import java.io.IOException; import java.lang.reflect.Method; import java.lang.reflect.Type; import java.nio.ByteBuffer; import java.util.ArrayList; import java.util.Collections; import java.util.List; import java.util.UUID; import java.util.concurrent.Callable; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentLinkedQueue; import java.util.concurrent.ExecutionException; import java.util.concurrent.Executors; import java.util.concurrent.Future; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; import java.util.concurrent.atomic.AtomicInteger; public abstract class HproseService extends HandlerManager implements HproseClients { private static volatile ScheduledExecutorService timerService = Executors.newSingleThreadScheduledExecutor(); static { Threads.registerShutdownHandler(new Runnable() { public void run() { ScheduledExecutorService timer = timerService; timerService = Executors.newSingleThreadScheduledExecutor(); timer.shutdownNow(); } }); } public HproseService() { add("call", new Callable<String>() { public String call() throws Exception { return UUID.randomUUID().toString(); } }, "#", true); } private final ArrayList<HproseFilter> filters = new ArrayList<HproseFilter>(); private HproseMode mode = HproseMode.MemberMode; private boolean debugEnabled = false; private int errorDelay = 10000; protected HproseServiceEvent event = null; protected HproseMethods globalMethods = null; private final static ThreadLocal<ServiceContext> currentContext = new ThreadLocal<ServiceContext>(); public static ServiceContext getCurrentContext() { return currentContext.get(); } public HproseMethods getGlobalMethods() { if (globalMethods == null) { globalMethods = new HproseMethods(); } return globalMethods; } public void setGlobalMethods(HproseMethods methods) { this.globalMethods = methods; } public final HproseMode getMode() { return mode; } public final void setMode(HproseMode mode) { this.mode = mode; } public final boolean isDebugEnabled() { return debugEnabled; } public final void setDebugEnabled(boolean enabled) { debugEnabled = enabled; } public int getErrorDelay() { return errorDelay; } public void setErrorDelay(int errorDelay) { this.errorDelay = errorDelay; } public final HproseServiceEvent getEvent() { return this.event; } public final void setEvent(HproseServiceEvent event) { this.event = event; } public final HproseFilter getFilter() { if (filters.isEmpty()) { return null; } return filters.get(0); } public final void setFilter(HproseFilter filter) { if (!filters.isEmpty()) { filters.clear(); } if (filter != null) { filters.add(filter); } } public final HproseService addFilter(HproseFilter filter) { if (filter != null) { filters.add(filter); } return this; } public final boolean removeFilter(HproseFilter filter) { return filters.remove(filter); } public final HproseService add(Method method, Object obj, String aliasName) { getGlobalMethods().addMethod(method, obj, aliasName); return this; } public final HproseService add(Method method, Object obj, String aliasName, HproseResultMode mode) { getGlobalMethods().addMethod(method, obj, aliasName, mode); return this; } public final HproseService add(Method method, Object obj, String aliasName, boolean simple) { getGlobalMethods().addMethod(method, obj, aliasName, simple); return this; } public final HproseService add(Method method, Object obj, String aliasName, HproseResultMode mode, boolean simple) { getGlobalMethods().addMethod(method, obj, aliasName, mode, simple); return this; } public final HproseService add(Method method, Object obj, String aliasName, HproseResultMode mode, boolean simple, boolean oneway) { getGlobalMethods().addMethod(method, obj, aliasName, mode, simple, oneway); return this; } public final HproseService add(Method method, Object obj) { getGlobalMethods().addMethod(method, obj); return this; } public final HproseService add(Method method, Object obj, HproseResultMode mode) { getGlobalMethods().addMethod(method, obj, mode); return this; } public final HproseService add(Method method, Object obj, boolean simple) { getGlobalMethods().addMethod(method, obj, simple); return this; } public final HproseService add(Method method, Object obj, HproseResultMode mode, boolean simple) { getGlobalMethods().addMethod(method, obj, mode, simple); return this; } public final HproseService add(Method method, Object obj, HproseResultMode mode, boolean simple, boolean oneway) { getGlobalMethods().addMethod(method, obj, mode, simple, oneway); return this; } public final HproseService add(String methodName, Object obj, Class<?>[] paramTypes, String aliasName) throws NoSuchMethodException { getGlobalMethods().addMethod(methodName, obj, paramTypes, aliasName); return this; } public final HproseService add(String methodName, Object obj, Class<?>[] paramTypes, String aliasN