mrniko:基于Java实现的Socket.IO服务器。实时Java框架

【实例简介】
mrniko:基于Java实现的Socket.IO服务器。实时Java框架源码下载
这是一个基于Netty服务器框架的开源Java实现的Socket.IO服务器。支持1.x - 4.x版本的Socket.IO客户端，支持xhr-polling和websocket传输，提供了诸如命名空间、房间、acknowledgment等功能，性能优越。
【实例截图】
【核心代码】
文件清单
└── netty-socketio-84176e768d968d60f2f4aac40e9408a9f1749d10
    ├── checkstyle.xml
    ├── header.txt
    ├── LICENSE.txt
    ├── pom.xml
    ├── README.md
    └── src
        ├── main
        │   └── java
        │       ├── com
        │       │   └── corundumstudio
        │       │       └── socketio
        │       │           ├── ack
        │       │           │   ├── AckManager.java
        │       │           │   └── AckSchedulerKey.java
        │       │           ├── AckCallback.java
        │       │           ├── AckMode.java
        │       │           ├── AckRequest.java
        │       │           ├── annotation
        │       │           │   ├── AnnotationScanner.java
        │       │           │   ├── OnConnect.java
        │       │           │   ├── OnConnectScanner.java
        │       │           │   ├── OnDisconnect.java
        │       │           │   ├── OnDisconnectScanner.java
        │       │           │   ├── OnEvent.java
        │       │           │   ├── OnEventScanner.java
        │       │           │   ├── ScannerEngine.java
        │       │           │   └── SpringAnnotationScanner.java
        │       │           ├── AuthorizationListener.java
        │       │           ├── AuthorizationResult.java
        │       │           ├── AuthTokenListener.java
        │       │           ├── AuthTokenResult.java
        │       │           ├── BroadcastAckCallback.java
        │       │           ├── BroadcastOperations.java
        │       │           ├── ClientOperations.java
        │       │           ├── Configuration.java
        │       │           ├── DisconnectableHub.java
        │       │           ├── Disconnectable.java
        │       │           ├── handler
        │       │           │   ├── AuthorizeHandler.java
        │       │           │   ├── ClientHead.java
        │       │           │   ├── ClientsBox.java
        │       │           │   ├── EncoderHandler.java
        │       │           │   ├── InPacketHandler.java
        │       │           │   ├── PacketListener.java
        │       │           │   ├── SocketIOException.java
        │       │           │   ├── SuccessAuthorizationListener.java
        │       │           │   ├── TransportState.java
        │       │           │   └── WrongUrlHandler.java
        │       │           ├── HandshakeData.java
        │       │           ├── JsonSupportWrapper.java
        │       │           ├── listener
        │       │           │   ├── ClientListeners.java
        │       │           │   ├── ConnectListener.java
        │       │           │   ├── DataListener.java
        │       │           │   ├── DefaultExceptionListener.java
        │       │           │   ├── DisconnectListener.java
        │       │           │   ├── EventInterceptor.java
        │       │           │   ├── ExceptionListenerAdapter.java
        │       │           │   ├── ExceptionListener.java
        │       │           │   ├── MultiTypeEventListener.java
        │       │           │   ├── PingListener.java
        │       │           │   └── PongListener.java
        │       │           ├── messages
        │       │           │   ├── HttpErrorMessage.java
        │       │           │   ├── HttpMessage.java
        │       │           │   ├── OutPacketMessage.java
        │       │           │   ├── PacketsMessage.java
        │       │           │   ├── XHROptionsMessage.java
        │       │           │   └── XHRPostMessage.java
        │       │           ├── misc
        │       │           │   ├── CompositeIterable.java
        │       │           │   ├── CompositeIterator.java
        │       │           │   └── IterableCollection.java
        │       │           ├── MultiRoomBroadcastOperations.java
        │       │           ├── MultiTypeAckCallback.java
        │       │           ├── MultiTypeArgs.java
        │       │           ├── namespace
        │       │           │   ├── EventEntry.java
        │       │           │   ├── Namespace.java
        │       │           │   └── NamespacesHub.java
        │       │           ├── protocol
        │       │           │   ├── AckArgs.java
        │       │           │   ├── AuthPacket.java
        │       │           │   ├── ConnPacket.java
        │       │           │   ├── EngineIOVersion.java
        │       │           │   ├── Event.java
        │       │           │   ├── JacksonJsonSupport.java
        │       │           │   ├── JsonSupport.java
        │       │           │   ├── PacketDecoder.java
        │       │           │   ├── PacketEncoder.java
        │       │           │   ├── Packet.java
        │       │           │   ├── PacketType.java
        │       │           │   └── UTF8CharsScanner.java
        │       │           ├── scheduler
        │       │           │   ├── CancelableScheduler.java
        │       │           │   ├── HashedWheelScheduler.java
        │       │           │   ├── HashedWheelTimeoutScheduler.java
        │       │           │   └── SchedulerKey.java
        │       │           ├── SingleRoomBroadcastOperations.java
        │       │           ├── SocketConfig.java
        │       │           ├── SocketIOChannelInitializer.java
        │       │           ├── SocketIOClient.java
        │       │           ├── SocketIONamespace.java
        │       │           ├── SocketIOServer.java
        │       │           ├── store
        │       │           │   ├── HazelcastPubSubStore.java
        │       │           │   ├── HazelcastStoreFactory.java
        │       │           │   ├── HazelcastStore.java
        │       │           │   ├── MemoryPubSubStore.java
        │       │           │   ├── MemoryStoreFactory.java
        │       │           │   ├── MemoryStore.java
        │       │           │   ├── pubsub
        │       │           │   │   ├── BaseStoreFactory.java
        │       │           │   │   ├── BulkJoinLeaveMessage.java
        │       │           │   │   ├── ConnectMessage.java
        │       │           │   │   ├── DisconnectMessage.java
        │       │           │   │   ├── DispatchMessage.java
        │       │           │   │   ├── JoinLeaveMessage.java
        │       │           │   │   ├── PubSubListener.java
        │       │           │   │   ├── PubSubMessage.java
        │       │           │   │   ├── PubSubStore.java
        │       │           │   │   └── PubSubType.java
        │       │           │   ├── RedissonPubSubStore.java
        │       │           │   ├── RedissonStoreFactory.java
        │       │           │   ├── RedissonStore.java
        │       │           │   ├── StoreFactory.java
        │       │           │   └── Store.java
        │       │           ├── transport
        │       │           │   ├── NamespaceClient.java
        │       │           │   ├── PollingTransport.java
        │       │           │   └── WebSocketTransport.java
        │       │           ├── Transport.java
        │       │           └── VoidAckCallback.java
        │       └── module-info.java
        └── test
            └── java
                └── com
                    └── corundumstudio
                        └── socketio
                            ├── JoinIteratorsTest.java
                            ├── parser
                            │   ├── DecoderAckPacketTest.java
                            │   ├── DecoderBaseTest.java
                            │   ├── DecoderConnectionPacketTest.java
                            │   ├── DecoderEventPacketTest.java
                            │   ├── DecoderJsonPacketTest.java
                            │   ├── DecoderMessagePacketTest.java
                            │   ├── EncoderAckPacketTest.java
                            │   ├── EncoderBaseTest.java
                            │   ├── EncoderConnectionPacketTest.java
                            │   ├── EncoderEventPacketTest.java
                            │   ├── EncoderMessagePacketTest.java
                            │   └── PayloadTest.java
                            ├── protocol
                            │   └── PacketTest.java
                            └── transport
                                └── WebSocketTransportTest.java

27 directories, 131 files