程序包 | 说明 |
---|---|
org.redkale.convert |
提供数据的序列化和反解析功能
|
org.redkale.net |
网络TCP/UDP基础服务包
|
org.redkale.net.http |
HTTP协议包,提供HTTP协议服务器
|
org.redkale.net.sncp |
SNCP协议包,提供SNCP协议服务器
|
org.redkale.source |
数据源(数据库、缓存)操作包
|
org.redkale.util |
Redkale工具包
|
限定符和类型 | 字段和说明 |
---|---|
protected Creator<java.util.Collection<T>> |
CollectionDecoder.creator |
protected Creator<java.util.Map<K,V>> |
MapDecoder.creator |
protected Creator<T> |
ObjectDecoder.creator |
protected Creator<java.util.stream.Stream<T>> |
StreamDecoder.creator |
限定符和类型 | 方法和说明 |
---|---|
<T> Creator<T> |
ConvertFactory.findCreator(java.lang.Class<T> type) |
<T> Creator<T> |
ConvertFactory.loadCreator(java.lang.Class<T> type) |
限定符和类型 | 方法和说明 |
---|---|
<E> void |
ConvertFactory.register(java.lang.Class<E> clazz,
Creator<? extends E> creator) |
构造器和说明 |
---|
CollectionDecoder(ConvertFactory factory,
java.lang.reflect.Type type,
java.lang.reflect.Type componentType,
Creator<java.util.Collection<T>> creator,
Decodeable<Reader,T> componentDecoder) |
MapDecoder(ConvertFactory factory,
java.lang.reflect.Type type,
java.lang.reflect.Type keyType,
java.lang.reflect.Type valueType,
Creator<java.util.Map<K,V>> creator,
Decodeable<Reader,K> keyDecoder,
Decodeable<Reader,V> valueDecoder) |
限定符和类型 | 方法和说明 |
---|---|
protected abstract Creator<Response> |
Server.createResponseCreator(ObjectPool<java.nio.ByteBuffer> bufferPool,
ObjectPool<Response> responsePool) |
限定符和类型 | 字段和说明 |
---|---|
protected java.util.concurrent.ConcurrentHashMap<java.lang.Class,Creator> |
HttpContext.asyncHandlerCreators |
限定符和类型 | 方法和说明 |
---|---|
protected Creator<Response> |
HttpServer.createResponseCreator(ObjectPool<java.nio.ByteBuffer> bufferPool,
ObjectPool<Response> responsePool) |
protected <H extends java.nio.channels.CompletionHandler> |
HttpContext.loadAsyncHandlerCreator(java.lang.Class<H> handlerClass) |
限定符和类型 | 方法和说明 |
---|---|
static ObjectPool<Response> |
HttpResponse.createPool(java.util.concurrent.atomic.AtomicLong creatCounter,
java.util.concurrent.atomic.AtomicLong cycleCounter,
int max,
Creator<Response> creator) |
限定符和类型 | 字段和说明 |
---|---|
protected Creator<? extends java.util.concurrent.CompletableFuture> |
SncpClient.SncpAction.futureCreator |
Creator<SncpAsyncHandler> |
SncpDynServlet.SncpServletAction.handlerCreator |
限定符和类型 | 方法和说明 |
---|---|
static Creator<SncpAsyncHandler> |
SncpAsyncHandler.Factory.createCreator(java.lang.Class<? extends java.nio.channels.CompletionHandler> handlerClass)
考虑点:
1、CompletionHandler子类是接口,且还有其他多个方法
2、CompletionHandler子类是类, 需要继承,且必须有空参数构造函数
3、CompletionHandler子类无论是接口还是类,都可能存在其他泛型
public class XXXAsyncHandler_DyncSncpAsyncHandler_4323 extends XXXAsyncHandler implements SncpAsyncHandler {
private SncpAsyncHandler sncphandler;
private CompletableFuture sncpfuture;
@ConstructorParameters({"sncphandler"})
public XXXAsyncHandler_DyncSncpAsyncHandler_4323(SncpAsyncHandler sncphandler) {
super();
this.sncphandler = sncphandler;
}
@Override
public void completed(Object result, Object attachment) {
sncphandler.completed(result, attachment);
}
@Override
public void failed(Throwable exc, Object attachment) {
sncphandler.failed(exc, attachment);
}
@Override
public Object[] sncp_getParams() {
return sncphandler.sncp_getParams();
}
@Override
public void sncp_setParams(Object... params) {
sncphandler.sncp_setParams(params);
}
@Override
public void sncp_setFuture(CompletableFuture future) {
this.sncpfuture = future;
}
@Override
public CompletableFuture sncp_getFuture() {
return this.sncpfuture;
}
}
|
protected Creator<Response> |
SncpServer.createResponseCreator(ObjectPool<java.nio.ByteBuffer> bufferPool,
ObjectPool<Response> responsePool) |
限定符和类型 | 方法和说明 |
---|---|
static ObjectPool<Response> |
SncpResponse.createPool(java.util.concurrent.atomic.AtomicLong creatCounter,
java.util.concurrent.atomic.AtomicLong cycleCounter,
int max,
Creator<Response> creator) |
限定符和类型 | 方法和说明 |
---|---|
Creator<T> |
EntityInfo.getCreator()
获取Entity构建器
|
限定符和类型 | 方法和说明 |
---|---|
static <T> Creator<T> |
Creator.create(java.lang.Class<T> clazz)
根据指定的class采用ASM技术生产Creator。
|
Creator<T> |
ObjectPool.getCreator() |
限定符和类型 | 方法和说明 |
---|---|
void |
ObjectPool.setCreator(Creator<T> creator) |
构造器和说明 |
---|
ObjectPool(java.util.concurrent.atomic.AtomicLong creatCounter,
java.util.concurrent.atomic.AtomicLong cycleCounter,
int max,
Creator<T> creator,
java.util.function.Consumer<T> prepare,
java.util.function.Predicate<T> recycler) |
ObjectPool(Creator<T> creator,
java.util.function.Consumer<T> prepare,
java.util.function.Predicate<T> recycler) |
ObjectPool(int max,
Creator<T> creator,
java.util.function.Consumer<T> prepare,
java.util.function.Predicate<T> recycler) |