From 40b02e4d95dec063fead12d6cffc0cc13e102067 Mon Sep 17 00:00:00 2001
From: kamhung <22250530@qq.com>
Date: Wed, 9 Dec 2015 10:20:55 +0800
Subject: [PATCH]
---
src/com/wentch/redkale/boot/Application.java | 566 ------
src/com/wentch/redkale/boot/ClassFilter.java | 436 -----
.../wentch/redkale/boot/LogFileHandler.java | 267 ---
.../wentch/redkale/boot/NodeHttpServer.java | 133 --
src/com/wentch/redkale/boot/NodeProtocol.java | 19 -
src/com/wentch/redkale/boot/NodeServer.java | 442 -----
.../wentch/redkale/boot/NodeSncpServer.java | 69 -
.../wentch/redkale/convert/AnyEncoder.java | 40 -
.../wentch/redkale/convert/ArrayDecoder.java | 79 -
.../wentch/redkale/convert/ArrayEncoder.java | 75 -
.../redkale/convert/CollectionDecoder.java | 69 -
.../redkale/convert/CollectionEncoder.java | 65 -
src/com/wentch/redkale/convert/Convert.java | 26 -
.../wentch/redkale/convert/ConvertColumn.java | 44 -
.../redkale/convert/ConvertColumnEntry.java | 67 -
.../redkale/convert/ConvertColumns.java | 24 -
.../wentch/redkale/convert/ConvertEntity.java | 25 -
.../redkale/convert/ConvertException.java | 28 -
.../wentch/redkale/convert/ConvertType.java | 28 -
src/com/wentch/redkale/convert/DeMember.java | 64 -
.../wentch/redkale/convert/Decodeable.java | 27 -
src/com/wentch/redkale/convert/EnMember.java | 76 -
.../wentch/redkale/convert/Encodeable.java | 27 -
src/com/wentch/redkale/convert/Factory.java | 385 ----
src/com/wentch/redkale/convert/HashedMap.java | 70 -
.../wentch/redkale/convert/MapDecoder.java | 78 -
.../wentch/redkale/convert/MapEncoder.java | 62 -
.../wentch/redkale/convert/ObjectDecoder.java | 157 --
.../wentch/redkale/convert/ObjectEncoder.java | 233 ---
src/com/wentch/redkale/convert/Reader.java | 112 --
.../wentch/redkale/convert/SimpledCoder.java | 42 -
src/com/wentch/redkale/convert/Writer.java | 120 --
.../convert/bson/BsonByteBufferWriter.java | 134 --
.../redkale/convert/bson/BsonConvert.java | 155 --
.../redkale/convert/bson/BsonFactory.java | 62 -
.../redkale/convert/bson/BsonReader.java | 322 ----
.../convert/bson/BsonSimpledCoder.java | 17 -
.../redkale/convert/bson/BsonWriter.java | 297 ----
.../convert/ext/BigIntegerSimpledCoder.java | 38 -
.../convert/ext/BoolArraySimpledCoder.java | 68 -
.../redkale/convert/ext/BoolSimpledCoder.java | 32 -
.../convert/ext/ByteArraySimpledCoder.java | 68 -
.../redkale/convert/ext/ByteSimpledCoder.java | 32 -
.../convert/ext/CharArraySimpledCoder.java | 68 -
.../redkale/convert/ext/CharSimpledCoder.java | 33 -
.../convert/ext/DLongSimpledCoder.java | 40 -
.../redkale/convert/ext/DateSimpledCoder.java | 33 -
.../convert/ext/DoubleArraySimpledCoder.java | 68 -
.../convert/ext/DoubleSimpledCoder.java | 32 -
.../redkale/convert/ext/EnumSimpledCoder.java | 44 -
.../convert/ext/FloatArraySimpledCoder.java | 68 -
.../convert/ext/FloatSimpledCoder.java | 32 -
.../convert/ext/InetAddressSimpledCoder.java | 70 -
.../convert/ext/IntArraySimpledCoder.java | 68 -
.../redkale/convert/ext/IntSimpledCoder.java | 32 -
.../convert/ext/LongArraySimpledCoder.java | 68 -
.../redkale/convert/ext/LongSimpledCoder.java | 33 -
.../convert/ext/NumberSimpledCoder.java | 32 -
.../convert/ext/PatternSimpledCoder.java | 38 -
.../convert/ext/ShortArraySimpledCoder.java | 68 -
.../convert/ext/ShortSimpledCoder.java | 32 -
.../convert/ext/StringArraySimpledCoder.java | 68 -
.../convert/ext/StringSimpledCoder.java | 32 -
.../redkale/convert/ext/TypeSimpledCoder.java | 42 -
.../json/InetAddressJsonSimpledCoder.java | 68 -
.../convert/json/JsonByteBufferWriter.java | 348 ----
.../redkale/convert/json/JsonConvert.java | 137 --
.../redkale/convert/json/JsonFactory.java | 60 -
.../redkale/convert/json/JsonReader.java | 576 ------
.../convert/json/JsonSimpledCoder.java | 17 -
.../redkale/convert/json/JsonWriter.java | 268 ---
src/com/wentch/redkale/net/Async.java | 25 -
.../wentch/redkale/net/AsyncConnection.java | 570 ------
.../redkale/net/AsyncDatagramChannel.java | 1327 --------------
src/com/wentch/redkale/net/Context.java | 132 --
src/com/wentch/redkale/net/PrepareRunner.java | 98 --
.../wentch/redkale/net/PrepareServlet.java | 73 -
.../wentch/redkale/net/ProtocolServer.java | 185 --
src/com/wentch/redkale/net/Request.java | 112 --
src/com/wentch/redkale/net/Response.java | 228 ---
src/com/wentch/redkale/net/SSLBuilder.java | 160 --
src/com/wentch/redkale/net/Server.java | 188 --
src/com/wentch/redkale/net/Servlet.java | 27 -
src/com/wentch/redkale/net/Transport.java | 254 ---
src/com/wentch/redkale/net/WorkThread.java | 31 -
.../wentch/redkale/net/http/AuthIgnore.java | 22 -
.../redkale/net/http/BasedHttpServlet.java | 260 ---
.../redkale/net/http/HttpCacheable.java | 25 -
.../wentch/redkale/net/http/HttpContext.java | 59 -
.../redkale/net/http/HttpPrepareServlet.java | 152 --
.../wentch/redkale/net/http/HttpRequest.java | 531 ------
.../redkale/net/http/HttpResourceServlet.java | 260 ---
.../wentch/redkale/net/http/HttpResponse.java | 561 ------
.../wentch/redkale/net/http/HttpServer.java | 127 --
.../wentch/redkale/net/http/HttpServlet.java | 29 -
src/com/wentch/redkale/net/http/MimeType.java | 240 ---
.../wentch/redkale/net/http/MultiContext.java | 284 ---
.../wentch/redkale/net/http/MultiPart.java | 115 --
.../wentch/redkale/net/http/WebAction.java | 22 -
.../wentch/redkale/net/http/WebInitParam.java | 24 -
.../wentch/redkale/net/http/WebServlet.java | 28 -
.../wentch/redkale/net/http/WebSocket.java | 387 ----
.../redkale/net/http/WebSocketBinary.java | 23 -
.../redkale/net/http/WebSocketEngine.java | 92 -
.../redkale/net/http/WebSocketGroup.java | 128 --
.../redkale/net/http/WebSocketNode.java | 196 ---
.../redkale/net/http/WebSocketPacket.java | 123 --
.../redkale/net/http/WebSocketRunner.java | 529 ------
.../redkale/net/http/WebSocketServlet.java | 145 --
.../redkale/net/sncp/ServiceWrapper.java | 92 -
src/com/wentch/redkale/net/sncp/Sncp.java | 1108 ------------
src/com/wentch/redkale/net/sncp/SncpCall.java | 24 -
.../wentch/redkale/net/sncp/SncpClient.java | 406 -----
src/com/wentch/redkale/net/sncp/SncpDyn.java | 24 -
.../redkale/net/sncp/SncpDynServlet.java | 407 -----
.../wentch/redkale/net/sncp/SncpFuture.java | 94 -
.../redkale/net/sncp/SncpPrepareServlet.java | 94 -
.../wentch/redkale/net/sncp/SncpRemote.java | 23 -
.../wentch/redkale/net/sncp/SncpRequest.java | 148 --
.../wentch/redkale/net/sncp/SncpResponse.java | 83 -
.../wentch/redkale/net/sncp/SncpServer.java | 66 -
.../wentch/redkale/net/sncp/SncpServlet.java | 32 -
.../redkale/net/sncp/SncpTargetAddress.java | 24 -
.../service/DataCacheListenerService.java | 41 -
.../service/DataSQLListenerService.java | 118 --
.../redkale/service/DataSourceService.java | 341 ----
.../wentch/redkale/service/LocalService.java | 23 -
src/com/wentch/redkale/service/MultiRun.java | 30 -
src/com/wentch/redkale/service/RetResult.java | 113 --
src/com/wentch/redkale/service/Service.java | 43 -
.../redkale/service/WebSocketNodeService.java | 76 -
.../redkale/source/DataCacheListener.java | 21 -
.../source/DataCallArrayAttribute.java | 57 -
.../redkale/source/DataCallAttribute.java | 72 -
.../wentch/redkale/source/DataConnection.java | 29 -
.../redkale/source/DataDefaultSource.java | 1554 -----------------
.../redkale/source/DataSQLListener.java | 20 -
src/com/wentch/redkale/source/DataSource.java | 244 ---
.../redkale/source/DistributeGenerator.java | 44 -
.../wentch/redkale/source/EntityCache.java | 654 -------
src/com/wentch/redkale/source/EntityInfo.java | 371 ----
src/com/wentch/redkale/source/FilterBean.java | 15 -
.../wentch/redkale/source/FilterColumn.java | 46 -
.../wentch/redkale/source/FilterExpress.java | 46 -
.../wentch/redkale/source/FilterGroup.java | 62 -
.../wentch/redkale/source/FilterGroups.java | 23 -
.../redkale/source/FilterJoinColumn.java | 50 -
.../wentch/redkale/source/FilterJoinNode.java | 315 ----
src/com/wentch/redkale/source/FilterNode.java | 958 ----------
.../wentch/redkale/source/FilterNodeBean.java | 353 ----
src/com/wentch/redkale/source/Flipper.java | 111 --
.../wentch/redkale/source/JDBCPoolSource.java | 238 ---
src/com/wentch/redkale/source/Range.java | 284 ---
src/com/wentch/redkale/source/ReckonType.java | 21 -
.../wentch/redkale/source/VirtualEntity.java | 21 -
src/com/wentch/redkale/util/AnyValue.java | 434 -----
src/com/wentch/redkale/util/Attribute.java | 323 ----
src/com/wentch/redkale/util/AutoLoad.java | 24 -
src/com/wentch/redkale/util/ByteArray.java | 161 --
src/com/wentch/redkale/util/Creator.java | 207 ---
src/com/wentch/redkale/util/DLong.java | 81 -
.../redkale/util/DebugMethodVisitor.java | 150 --
src/com/wentch/redkale/util/Ignore.java | 22 -
src/com/wentch/redkale/util/LogLevel.java | 24 -
src/com/wentch/redkale/util/Nameable.java | 15 -
src/com/wentch/redkale/util/ObjectNode.java | 26 -
src/com/wentch/redkale/util/ObjectPool.java | 99 --
src/com/wentch/redkale/util/Reproduce.java | 132 --
.../wentch/redkale/util/ResourceFactory.java | 240 ---
src/com/wentch/redkale/util/SelectColumn.java | 136 --
src/com/wentch/redkale/util/Sheet.java | 88 -
src/com/wentch/redkale/util/TypeToken.java | 26 -
src/com/wentch/redkale/util/Utility.java | 517 ------
.../wentch/redkale/watch/WatchFactory.java | 99 --
src/com/wentch/redkale/watch/WatchNode.java | 21 -
src/com/wentch/redkale/watch/WatchNumber.java | 49 -
.../wentch/redkale/watch/WatchSupplier.java | 47 -
src/com/wentch/redkale/watch/Watchable.java | 34 -
178 files changed, 27401 deletions(-)
delete mode 100644 src/com/wentch/redkale/boot/Application.java
delete mode 100644 src/com/wentch/redkale/boot/ClassFilter.java
delete mode 100644 src/com/wentch/redkale/boot/LogFileHandler.java
delete mode 100644 src/com/wentch/redkale/boot/NodeHttpServer.java
delete mode 100644 src/com/wentch/redkale/boot/NodeProtocol.java
delete mode 100644 src/com/wentch/redkale/boot/NodeServer.java
delete mode 100644 src/com/wentch/redkale/boot/NodeSncpServer.java
delete mode 100644 src/com/wentch/redkale/convert/AnyEncoder.java
delete mode 100644 src/com/wentch/redkale/convert/ArrayDecoder.java
delete mode 100644 src/com/wentch/redkale/convert/ArrayEncoder.java
delete mode 100644 src/com/wentch/redkale/convert/CollectionDecoder.java
delete mode 100644 src/com/wentch/redkale/convert/CollectionEncoder.java
delete mode 100644 src/com/wentch/redkale/convert/Convert.java
delete mode 100644 src/com/wentch/redkale/convert/ConvertColumn.java
delete mode 100644 src/com/wentch/redkale/convert/ConvertColumnEntry.java
delete mode 100644 src/com/wentch/redkale/convert/ConvertColumns.java
delete mode 100644 src/com/wentch/redkale/convert/ConvertEntity.java
delete mode 100644 src/com/wentch/redkale/convert/ConvertException.java
delete mode 100644 src/com/wentch/redkale/convert/ConvertType.java
delete mode 100644 src/com/wentch/redkale/convert/DeMember.java
delete mode 100644 src/com/wentch/redkale/convert/Decodeable.java
delete mode 100644 src/com/wentch/redkale/convert/EnMember.java
delete mode 100644 src/com/wentch/redkale/convert/Encodeable.java
delete mode 100644 src/com/wentch/redkale/convert/Factory.java
delete mode 100644 src/com/wentch/redkale/convert/HashedMap.java
delete mode 100644 src/com/wentch/redkale/convert/MapDecoder.java
delete mode 100644 src/com/wentch/redkale/convert/MapEncoder.java
delete mode 100644 src/com/wentch/redkale/convert/ObjectDecoder.java
delete mode 100644 src/com/wentch/redkale/convert/ObjectEncoder.java
delete mode 100644 src/com/wentch/redkale/convert/Reader.java
delete mode 100644 src/com/wentch/redkale/convert/SimpledCoder.java
delete mode 100644 src/com/wentch/redkale/convert/Writer.java
delete mode 100644 src/com/wentch/redkale/convert/bson/BsonByteBufferWriter.java
delete mode 100644 src/com/wentch/redkale/convert/bson/BsonConvert.java
delete mode 100644 src/com/wentch/redkale/convert/bson/BsonFactory.java
delete mode 100644 src/com/wentch/redkale/convert/bson/BsonReader.java
delete mode 100644 src/com/wentch/redkale/convert/bson/BsonSimpledCoder.java
delete mode 100644 src/com/wentch/redkale/convert/bson/BsonWriter.java
delete mode 100644 src/com/wentch/redkale/convert/ext/BigIntegerSimpledCoder.java
delete mode 100644 src/com/wentch/redkale/convert/ext/BoolArraySimpledCoder.java
delete mode 100644 src/com/wentch/redkale/convert/ext/BoolSimpledCoder.java
delete mode 100644 src/com/wentch/redkale/convert/ext/ByteArraySimpledCoder.java
delete mode 100644 src/com/wentch/redkale/convert/ext/ByteSimpledCoder.java
delete mode 100644 src/com/wentch/redkale/convert/ext/CharArraySimpledCoder.java
delete mode 100644 src/com/wentch/redkale/convert/ext/CharSimpledCoder.java
delete mode 100644 src/com/wentch/redkale/convert/ext/DLongSimpledCoder.java
delete mode 100644 src/com/wentch/redkale/convert/ext/DateSimpledCoder.java
delete mode 100644 src/com/wentch/redkale/convert/ext/DoubleArraySimpledCoder.java
delete mode 100644 src/com/wentch/redkale/convert/ext/DoubleSimpledCoder.java
delete mode 100644 src/com/wentch/redkale/convert/ext/EnumSimpledCoder.java
delete mode 100644 src/com/wentch/redkale/convert/ext/FloatArraySimpledCoder.java
delete mode 100644 src/com/wentch/redkale/convert/ext/FloatSimpledCoder.java
delete mode 100644 src/com/wentch/redkale/convert/ext/InetAddressSimpledCoder.java
delete mode 100644 src/com/wentch/redkale/convert/ext/IntArraySimpledCoder.java
delete mode 100644 src/com/wentch/redkale/convert/ext/IntSimpledCoder.java
delete mode 100644 src/com/wentch/redkale/convert/ext/LongArraySimpledCoder.java
delete mode 100644 src/com/wentch/redkale/convert/ext/LongSimpledCoder.java
delete mode 100644 src/com/wentch/redkale/convert/ext/NumberSimpledCoder.java
delete mode 100644 src/com/wentch/redkale/convert/ext/PatternSimpledCoder.java
delete mode 100644 src/com/wentch/redkale/convert/ext/ShortArraySimpledCoder.java
delete mode 100644 src/com/wentch/redkale/convert/ext/ShortSimpledCoder.java
delete mode 100644 src/com/wentch/redkale/convert/ext/StringArraySimpledCoder.java
delete mode 100644 src/com/wentch/redkale/convert/ext/StringSimpledCoder.java
delete mode 100644 src/com/wentch/redkale/convert/ext/TypeSimpledCoder.java
delete mode 100644 src/com/wentch/redkale/convert/json/InetAddressJsonSimpledCoder.java
delete mode 100644 src/com/wentch/redkale/convert/json/JsonByteBufferWriter.java
delete mode 100644 src/com/wentch/redkale/convert/json/JsonConvert.java
delete mode 100644 src/com/wentch/redkale/convert/json/JsonFactory.java
delete mode 100644 src/com/wentch/redkale/convert/json/JsonReader.java
delete mode 100644 src/com/wentch/redkale/convert/json/JsonSimpledCoder.java
delete mode 100644 src/com/wentch/redkale/convert/json/JsonWriter.java
delete mode 100644 src/com/wentch/redkale/net/Async.java
delete mode 100644 src/com/wentch/redkale/net/AsyncConnection.java
delete mode 100644 src/com/wentch/redkale/net/AsyncDatagramChannel.java
delete mode 100644 src/com/wentch/redkale/net/Context.java
delete mode 100644 src/com/wentch/redkale/net/PrepareRunner.java
delete mode 100644 src/com/wentch/redkale/net/PrepareServlet.java
delete mode 100644 src/com/wentch/redkale/net/ProtocolServer.java
delete mode 100644 src/com/wentch/redkale/net/Request.java
delete mode 100644 src/com/wentch/redkale/net/Response.java
delete mode 100644 src/com/wentch/redkale/net/SSLBuilder.java
delete mode 100644 src/com/wentch/redkale/net/Server.java
delete mode 100644 src/com/wentch/redkale/net/Servlet.java
delete mode 100644 src/com/wentch/redkale/net/Transport.java
delete mode 100644 src/com/wentch/redkale/net/WorkThread.java
delete mode 100644 src/com/wentch/redkale/net/http/AuthIgnore.java
delete mode 100644 src/com/wentch/redkale/net/http/BasedHttpServlet.java
delete mode 100644 src/com/wentch/redkale/net/http/HttpCacheable.java
delete mode 100644 src/com/wentch/redkale/net/http/HttpContext.java
delete mode 100644 src/com/wentch/redkale/net/http/HttpPrepareServlet.java
delete mode 100644 src/com/wentch/redkale/net/http/HttpRequest.java
delete mode 100644 src/com/wentch/redkale/net/http/HttpResourceServlet.java
delete mode 100644 src/com/wentch/redkale/net/http/HttpResponse.java
delete mode 100644 src/com/wentch/redkale/net/http/HttpServer.java
delete mode 100644 src/com/wentch/redkale/net/http/HttpServlet.java
delete mode 100644 src/com/wentch/redkale/net/http/MimeType.java
delete mode 100644 src/com/wentch/redkale/net/http/MultiContext.java
delete mode 100644 src/com/wentch/redkale/net/http/MultiPart.java
delete mode 100644 src/com/wentch/redkale/net/http/WebAction.java
delete mode 100644 src/com/wentch/redkale/net/http/WebInitParam.java
delete mode 100644 src/com/wentch/redkale/net/http/WebServlet.java
delete mode 100644 src/com/wentch/redkale/net/http/WebSocket.java
delete mode 100644 src/com/wentch/redkale/net/http/WebSocketBinary.java
delete mode 100644 src/com/wentch/redkale/net/http/WebSocketEngine.java
delete mode 100644 src/com/wentch/redkale/net/http/WebSocketGroup.java
delete mode 100644 src/com/wentch/redkale/net/http/WebSocketNode.java
delete mode 100644 src/com/wentch/redkale/net/http/WebSocketPacket.java
delete mode 100644 src/com/wentch/redkale/net/http/WebSocketRunner.java
delete mode 100644 src/com/wentch/redkale/net/http/WebSocketServlet.java
delete mode 100644 src/com/wentch/redkale/net/sncp/ServiceWrapper.java
delete mode 100644 src/com/wentch/redkale/net/sncp/Sncp.java
delete mode 100644 src/com/wentch/redkale/net/sncp/SncpCall.java
delete mode 100644 src/com/wentch/redkale/net/sncp/SncpClient.java
delete mode 100644 src/com/wentch/redkale/net/sncp/SncpDyn.java
delete mode 100644 src/com/wentch/redkale/net/sncp/SncpDynServlet.java
delete mode 100644 src/com/wentch/redkale/net/sncp/SncpFuture.java
delete mode 100644 src/com/wentch/redkale/net/sncp/SncpPrepareServlet.java
delete mode 100644 src/com/wentch/redkale/net/sncp/SncpRemote.java
delete mode 100644 src/com/wentch/redkale/net/sncp/SncpRequest.java
delete mode 100644 src/com/wentch/redkale/net/sncp/SncpResponse.java
delete mode 100644 src/com/wentch/redkale/net/sncp/SncpServer.java
delete mode 100644 src/com/wentch/redkale/net/sncp/SncpServlet.java
delete mode 100644 src/com/wentch/redkale/net/sncp/SncpTargetAddress.java
delete mode 100644 src/com/wentch/redkale/service/DataCacheListenerService.java
delete mode 100644 src/com/wentch/redkale/service/DataSQLListenerService.java
delete mode 100644 src/com/wentch/redkale/service/DataSourceService.java
delete mode 100644 src/com/wentch/redkale/service/LocalService.java
delete mode 100644 src/com/wentch/redkale/service/MultiRun.java
delete mode 100644 src/com/wentch/redkale/service/RetResult.java
delete mode 100644 src/com/wentch/redkale/service/Service.java
delete mode 100644 src/com/wentch/redkale/service/WebSocketNodeService.java
delete mode 100644 src/com/wentch/redkale/source/DataCacheListener.java
delete mode 100644 src/com/wentch/redkale/source/DataCallArrayAttribute.java
delete mode 100644 src/com/wentch/redkale/source/DataCallAttribute.java
delete mode 100644 src/com/wentch/redkale/source/DataConnection.java
delete mode 100644 src/com/wentch/redkale/source/DataDefaultSource.java
delete mode 100644 src/com/wentch/redkale/source/DataSQLListener.java
delete mode 100644 src/com/wentch/redkale/source/DataSource.java
delete mode 100644 src/com/wentch/redkale/source/DistributeGenerator.java
delete mode 100644 src/com/wentch/redkale/source/EntityCache.java
delete mode 100644 src/com/wentch/redkale/source/EntityInfo.java
delete mode 100644 src/com/wentch/redkale/source/FilterBean.java
delete mode 100644 src/com/wentch/redkale/source/FilterColumn.java
delete mode 100644 src/com/wentch/redkale/source/FilterExpress.java
delete mode 100644 src/com/wentch/redkale/source/FilterGroup.java
delete mode 100644 src/com/wentch/redkale/source/FilterGroups.java
delete mode 100644 src/com/wentch/redkale/source/FilterJoinColumn.java
delete mode 100644 src/com/wentch/redkale/source/FilterJoinNode.java
delete mode 100644 src/com/wentch/redkale/source/FilterNode.java
delete mode 100644 src/com/wentch/redkale/source/FilterNodeBean.java
delete mode 100644 src/com/wentch/redkale/source/Flipper.java
delete mode 100644 src/com/wentch/redkale/source/JDBCPoolSource.java
delete mode 100644 src/com/wentch/redkale/source/Range.java
delete mode 100644 src/com/wentch/redkale/source/ReckonType.java
delete mode 100644 src/com/wentch/redkale/source/VirtualEntity.java
delete mode 100644 src/com/wentch/redkale/util/AnyValue.java
delete mode 100644 src/com/wentch/redkale/util/Attribute.java
delete mode 100644 src/com/wentch/redkale/util/AutoLoad.java
delete mode 100644 src/com/wentch/redkale/util/ByteArray.java
delete mode 100644 src/com/wentch/redkale/util/Creator.java
delete mode 100644 src/com/wentch/redkale/util/DLong.java
delete mode 100644 src/com/wentch/redkale/util/DebugMethodVisitor.java
delete mode 100644 src/com/wentch/redkale/util/Ignore.java
delete mode 100644 src/com/wentch/redkale/util/LogLevel.java
delete mode 100644 src/com/wentch/redkale/util/Nameable.java
delete mode 100644 src/com/wentch/redkale/util/ObjectNode.java
delete mode 100644 src/com/wentch/redkale/util/ObjectPool.java
delete mode 100644 src/com/wentch/redkale/util/Reproduce.java
delete mode 100644 src/com/wentch/redkale/util/ResourceFactory.java
delete mode 100644 src/com/wentch/redkale/util/SelectColumn.java
delete mode 100644 src/com/wentch/redkale/util/Sheet.java
delete mode 100644 src/com/wentch/redkale/util/TypeToken.java
delete mode 100644 src/com/wentch/redkale/util/Utility.java
delete mode 100644 src/com/wentch/redkale/watch/WatchFactory.java
delete mode 100644 src/com/wentch/redkale/watch/WatchNode.java
delete mode 100644 src/com/wentch/redkale/watch/WatchNumber.java
delete mode 100644 src/com/wentch/redkale/watch/WatchSupplier.java
delete mode 100644 src/com/wentch/redkale/watch/Watchable.java
diff --git a/src/com/wentch/redkale/boot/Application.java b/src/com/wentch/redkale/boot/Application.java
deleted file mode 100644
index 443f6bec1..000000000
--- a/src/com/wentch/redkale/boot/Application.java
+++ /dev/null
@@ -1,566 +0,0 @@
-/*
- * 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.boot.ClassFilter.FilterEntry;
-import com.wentch.redkale.convert.bson.*;
-import com.wentch.redkale.convert.json.*;
-import com.wentch.redkale.net.*;
-import com.wentch.redkale.net.sncp.*;
-import com.wentch.redkale.service.*;
-import com.wentch.redkale.source.*;
-import com.wentch.redkale.util.*;
-import com.wentch.redkale.util.AnyValue.DefaultAnyValue;
-import com.wentch.redkale.watch.*;
-import java.io.*;
-import java.net.*;
-import java.nio.*;
-import java.nio.channels.*;
-import java.nio.file.*;
-import java.util.*;
-import java.util.concurrent.*;
-import java.util.concurrent.atomic.*;
-import java.util.function.*;
-import java.util.logging.*;
-import javax.xml.parsers.*;
-import org.w3c.dom.*;
-
-/**
- * 编译时需要加入: -XDignore.symbol.file=true
- *
- * 进程启动类,程序启动后读取application.xml,进行classpath扫描动态加载Service与Servlet
- * 优先加载所有SNCP协议的服务, 再加载其他协议服务,
- * 最后进行Service、Servlet与其他资源之间的依赖注入。
- *
- *
- * @author zhangjx
- */
-public final class Application {
-
- //当前进程启动的时间, 类型: long
- public static final String RESNAME_APP_TIME = "APP_TIME";
-
- //当前进程的根目录, 类型:String
- public static final String RESNAME_APP_HOME = "APP_HOME";
-
- //application.xml 文件中resources节点的内容, 类型: AnyValue
- public static final String RESNAME_APP_GRES = "APP_GRES";
-
- //当前进程节点的name, 类型:String
- public static final String RESNAME_APP_NODE = "APP_NODE";
-
- //当前进程节点的IP地址, 类型:InetAddress、String
- public static final String RESNAME_APP_ADDR = "APP_ADDR";
-
- //当前SNCP Server的IP地址+端口集合 类型: Map、HashMap
- public static final String RESNAME_APP_NODES = "APP_NODES";
-
- //当前Service的IP地址+端口 类型: SocketAddress、InetSocketAddress、String
- public static final String RESNAME_SERVER_ADDR = "SERVER_ADDR"; // SERVER_ADDR
-
- //当前SNCP Server所属的组 类型: String
- public static final String RESNAME_SERVER_GROUP = "SERVER_GROUP";
-
- //当前Service所属的组 类型: Set、String[]
- public static final String RESNAME_SNCP_GROUPS = Sncp.RESNAME_SNCP_GROUPS; // SNCP_GROUPS
-
- protected final Map globalNodes = new HashMap<>();
-
- private final Map> globalGroups = new HashMap<>();
-
- protected final List transports = new ArrayList<>();
-
- protected final InetAddress localAddress;
-
- protected final List sources = new CopyOnWriteArrayList<>();
-
- protected final List servers = new CopyOnWriteArrayList<>();
-
- protected CountDownLatch servicecdl; //会出现两次赋值
-
- //--------------------------------------------------------------------------------------------
- private final ResourceFactory factory = ResourceFactory.root();
-
- private final WatchFactory watch = WatchFactory.root();
-
- private File home;
-
- private final Logger logger;
-
- private final AnyValue config;
-
- private final long startTime = System.currentTimeMillis();
-
- private final CountDownLatch serversLatch;
-
- private Application(final AnyValue config) {
- this.config = config;
-
- final File root = new File(System.getProperty(RESNAME_APP_HOME));
- this.factory.register(RESNAME_APP_TIME, long.class, this.startTime);
- this.factory.register(RESNAME_APP_HOME, Path.class, root.toPath());
- this.factory.register(RESNAME_APP_HOME, File.class, root);
- try {
- this.factory.register(RESNAME_APP_HOME, root.getCanonicalPath());
- this.home = root.getCanonicalFile();
- } catch (IOException e) {
- throw new RuntimeException(e);
- }
- String localaddr = config.getValue("address", "").trim();
- this.localAddress = localaddr.isEmpty() ? Utility.localInetAddress() : new InetSocketAddress(localaddr, 0).getAddress();
- Application.this.factory.register(RESNAME_APP_ADDR, Application.this.localAddress.getHostAddress());
- Application.this.factory.register(RESNAME_APP_ADDR, InetAddress.class, Application.this.localAddress);
- {
- String node = config.getValue("node", "").trim();
- if (node.isEmpty()) {
- StringBuilder sb = new StringBuilder();
- byte[] bs = this.localAddress.getAddress();
- int v1 = bs[bs.length - 2] & 0xff;
- int v2 = bs[bs.length - 1] & 0xff;
- if (v1 <= 0xf) sb.append('0');
- sb.append(Integer.toHexString(v1));
- if (v2 <= 0xf) sb.append('0');
- sb.append(Integer.toHexString(v2));
- node = sb.toString();
- }
- Application.this.factory.register(RESNAME_APP_NODE, node);
- System.setProperty(RESNAME_APP_NODE, node);
- }
- //以下是初始化日志配置
- final File logconf = new File(root, "conf/logging.properties");
- if (logconf.isFile() && logconf.canRead()) {
- try {
- final String rootpath = root.getCanonicalPath().replace('\\', '/');
- FileInputStream fin = new FileInputStream(logconf);
- Properties properties = new Properties();
- properties.load(fin);
- fin.close();
- properties.entrySet().stream().forEach(x -> {
- x.setValue(x.getValue().toString().replace("${APP_HOME}", rootpath));
- });
-
- if (properties.getProperty("java.util.logging.FileHandler.formatter") == null) {
- properties.setProperty("java.util.logging.FileHandler.formatter", LogFileHandler.LoggingFormater.class.getName());
- }
- if (properties.getProperty("java.util.logging.ConsoleHandler.formatter") == null) {
- properties.setProperty("java.util.logging.ConsoleHandler.formatter", LogFileHandler.LoggingFormater.class.getName());
- }
- String fileHandlerPattern = properties.getProperty("java.util.logging.FileHandler.pattern");
- if (fileHandlerPattern != null && fileHandlerPattern.contains("%d")) {
- final String fileHandlerClass = LogFileHandler.class.getName();
- Properties prop = new Properties();
- final String handlers = properties.getProperty("handlers");
- if (handlers != null && handlers.contains("java.util.logging.FileHandler")) {
- prop.setProperty("handlers", handlers.replace("java.util.logging.FileHandler", fileHandlerClass));
- }
- if (!prop.isEmpty()) {
- String prefix = fileHandlerClass + ".";
- properties.entrySet().stream().forEach(x -> {
- if (x.getKey().toString().startsWith("java.util.logging.FileHandler.")) {
- prop.put(x.getKey().toString().replace("java.util.logging.FileHandler.", prefix), x.getValue());
- }
- });
- prop.entrySet().stream().forEach(x -> {
- properties.put(x.getKey(), x.getValue());
- });
- }
- properties.put(SncpClient.class.getSimpleName() + ".handlers", LogFileHandler.SncpLogFileHandler.class.getName());
- }
- ByteArrayOutputStream out = new ByteArrayOutputStream();
- final PrintStream ps = new PrintStream(out);
- properties.forEach((x, y) -> ps.println(x + "=" + y));
- LogManager.getLogManager().readConfiguration(new ByteArrayInputStream(out.toByteArray()));
- } catch (Exception e) {
- Logger.getLogger(this.getClass().getSimpleName()).log(Level.WARNING, "init logger configuration error", e);
- }
- }
- this.logger = Logger.getLogger(this.getClass().getSimpleName());
- this.serversLatch = new CountDownLatch(config.getAnyValues("server").length + 1);
- }
-
- public ResourceFactory getResourceFactory() {
- return factory;
- }
-
- public WatchFactory getWatchFactory() {
- return watch;
- }
-
- public File getHome() {
- return home;
- }
-
- public long getStartTime() {
- return startTime;
- }
-
- private void initLogging() {
-
- }
-
- public void init() throws Exception {
- System.setProperty("java.util.concurrent.ForkJoinPool.common.parallelism", "" + Runtime.getRuntime().availableProcessors() * 4);
- System.setProperty("convert.bson.pool.size", "128");
- System.setProperty("convert.json.pool.size", "128");
- System.setProperty("convert.bson.writer.buffer.defsize", "4096");
- System.setProperty("convert.json.writer.buffer.defsize", "4096");
-
- File persist = new File(this.home, "conf/persistence.xml");
- final String homepath = this.home.getCanonicalPath();
- if (persist.isFile()) System.setProperty(DataDefaultSource.DATASOURCE_CONFPATH, persist.getCanonicalPath());
- logger.log(Level.INFO, RESNAME_APP_HOME + "=" + homepath + "\r\n" + RESNAME_APP_ADDR + "=" + this.localAddress.getHostAddress());
- String lib = config.getValue("lib", "").trim().replace("${APP_HOME}", homepath);
- lib = lib.isEmpty() ? (homepath + "/conf") : (lib + ";" + homepath + "/conf");
- Server.loadLib(logger, lib);
- initLogging();
- if (this.localAddress != null) {
- byte[] bs = this.localAddress.getAddress();
- int v = (0xff & bs[bs.length - 2]) % 10 * 100 + (0xff & bs[bs.length - 1]);
- this.factory.register("property.datasource.nodeid", "" + v);
- }
- //------------------------------------------------------------------------
- final AnyValue resources = config.getAnyValue("resources");
- if (resources != null) {
- factory.register(RESNAME_APP_GRES, AnyValue.class, resources);
- final AnyValue properties = resources.getAnyValue("properties");
- if (properties != null) {
- String dfloads = properties.getValue("load");
- if (dfloads != null) {
- for (String dfload : dfloads.split(";")) {
- if (dfload.trim().isEmpty()) continue;
- dfload = dfload.trim().replace("${APP_HOME}", home.getCanonicalPath()).replace('\\', '/');
- final File df = (dfload.indexOf('/') < 0) ? new File(home, "conf/" + dfload) : new File(dfload);
- if (df.isFile()) {
- Properties ps = new Properties();
- InputStream in = new FileInputStream(df);
- ps.load(in);
- in.close();
- ps.forEach((x, y) -> factory.register("property." + x, y));
- }
- }
- }
- for (AnyValue prop : properties.getAnyValues("property")) {
- String name = prop.getValue("name");
- String value = prop.getValue("value");
- if (name == null || value == null) continue;
- if (name.startsWith("system.property.")) {
- System.setProperty(name.substring("system.property.".length()), value);
- } else {
- factory.register("property." + name, value);
- }
- }
- }
- }
- this.factory.register(BsonFactory.root());
- this.factory.register(JsonFactory.root());
- this.factory.register(BsonFactory.root().getConvert());
- this.factory.register(JsonFactory.root().getConvert());
- initResources();
- }
-
- private void initResources() throws Exception {
- //-------------------------------------------------------------------------
- final AnyValue resources = config.getAnyValue("resources");
- if (resources != null) {
- //------------------------------------------------------------------------
-
- for (AnyValue conf : resources.getAnyValues("group")) {
- final String group = conf.getValue("name", "");
- String protocol = conf.getValue("protocol", Transport.DEFAULT_PROTOCOL).toUpperCase();
- if (!"TCP".equalsIgnoreCase(protocol) && !"UDP".equalsIgnoreCase(protocol)) {
- throw new RuntimeException("Not supported Transport Protocol " + conf.getValue("protocol"));
- }
- Set addrs = globalGroups.get(group);
- if (addrs == null) {
- addrs = new LinkedHashSet<>();
- globalGroups.put(group, addrs);
- }
- for (AnyValue node : conf.getAnyValues("node")) {
- final InetSocketAddress addr = new InetSocketAddress(node.getValue("addr"), node.getIntValue("port"));
- addrs.add(addr);
- String oldgroup = globalNodes.get(addr);
- if (oldgroup != null) throw new RuntimeException(addr + " had one more group " + (globalNodes.get(addr)));
- globalNodes.put(addr, group);
- }
- }
- }
- //------------------------------------------------------------------------
- }
-
- private void startSelfServer() throws Exception {
- final Application application = this;
- new Thread() {
- {
- setName("Application-Control-Thread");
- }
-
- @Override
- public void run() {
- try {
- final DatagramChannel channel = DatagramChannel.open();
- channel.configureBlocking(true);
- channel.socket().setSoTimeout(3000);
- channel.bind(new InetSocketAddress(config.getValue("host", "127.0.0.1"), config.getIntValue("port")));
- boolean loop = true;
- ByteBuffer buffer = ByteBuffer.allocateDirect(1024);
- while (loop) {
- buffer.clear();
- SocketAddress address = channel.receive(buffer);
- buffer.flip();
- byte[] bytes = new byte[buffer.remaining()];
- buffer.get(bytes);
- if ("SHUTDOWN".equalsIgnoreCase(new String(bytes))) {
- try {
- long s = System.currentTimeMillis();
- logger.info(application.getClass().getSimpleName() + " shutdowning");
- application.shutdown();
- buffer.clear();
- buffer.put("SHUTDOWN OK".getBytes());
- buffer.flip();
- channel.send(buffer, address);
- long e = System.currentTimeMillis() - s;
- logger.info(application.getClass().getSimpleName() + " shutdown in " + e + " ms");
- application.serversLatch.countDown();
- System.exit(0);
- } catch (Exception ex) {
- logger.log(Level.INFO, "SHUTDOWN FAIL", ex);
- buffer.clear();
- buffer.put("SHUTDOWN FAIL".getBytes());
- buffer.flip();
- channel.send(buffer, address);
- }
- }
- }
- } catch (Exception e) {
- logger.log(Level.INFO, "Control fail", e);
- System.exit(1);
- }
- }
- }.start();
- }
-
- private void sendShutDown() throws Exception {
- final DatagramChannel channel = DatagramChannel.open();
- channel.configureBlocking(true);
- channel.connect(new InetSocketAddress(config.getValue("host", "127.0.0.1"), config.getIntValue("port")));
- ByteBuffer buffer = ByteBuffer.allocate(128);
- buffer.put("SHUTDOWN".getBytes());
- buffer.flip();
- channel.write(buffer);
- buffer.clear();
- channel.configureBlocking(false);
- channel.read(buffer);
- buffer.flip();
- byte[] bytes = new byte[buffer.remaining()];
- buffer.get(bytes);
- channel.close();
- logger.info(new String(bytes));
- Thread.sleep(500);
- }
-
- public void start() throws Exception {
- final AnyValue[] entrys = config.getAnyValues("server");
- CountDownLatch timecd = new CountDownLatch(entrys.length);
- final List sncps = new ArrayList<>();
- final List others = new ArrayList<>();
- for (final AnyValue entry : entrys) {
- if (entry.getValue("protocol", "").toUpperCase().startsWith("SNCP")) {
- sncps.add(entry);
- } else {
- others.add(entry);
- }
- }
- if (!sncps.isEmpty() && globalNodes.isEmpty()) throw new RuntimeException("found SNCP Server node but not found node info.");
-
- factory.register(RESNAME_APP_NODES, new TypeToken