Types & classes — github.com/daoshenzzg/socket-mqtt

CodeHub MCPcopy Create free account

hub / github.com/daoshenzzg/socket-mqtt / types & classes

Types & classes80 in github.com/daoshenzzg/socket-mqtt

⨍ Functions 418◇ Types & classes 80

ClassAESEncrypt

@author daoshenzzg@163.com @date 2019/1/14 10:46

src/main/java/com/yb/socket/encrypt/AESEncrypt.java:14

ClassAddressUtil

@author daoshenzzg@163.com @date 2018/12/30 16:42

src/main/java/com/yb/socket/util/AddressUtil.java:14

@author daoshenzzg@163.com @date 2018/12/30 13:36

src/main/java/com/yb/socket/App.java:7

Unit test for simple App.

src/test/java/com/yb/socket/AppTest.java:10

ClassBaseClient

@author daoshenzzg@163.com @date 2018/12/30 16:23

src/main/java/com/yb/socket/service/client/BaseClient.java:30

ClassBaseEncrypt

@author daoshenzzg@163.com @date 2019/1/14 10:43

src/main/java/com/yb/socket/encrypt/BaseEncrypt.java:9

ClassBaseMessage

@author daoshenzzg@163.com @date 2018/12/30 15:18

src/main/java/com/yb/socket/pojo/BaseMessage.java:9

ClassCenterMock1

@author daoshenzzg@163.com @date 2019/1/4 14:47

src/test/java/com/yb/socket/center/CenterMock1.java:11

ClassCenterMock2

@author daoshenzzg@163.com @date 2019/1/7 22:18

src/test/java/com/yb/socket/center/CenterMock2.java:11

ClassCenterMockMessageEventListener

@author daoshenzzg@163.com @date 2019/1/4 14:48

src/test/java/com/yb/socket/center/CenterMockMessageEventListener.java:19

@author daoshenzzg@163.com @date 2019/2/26 14:58

src/test/java/com/yb/socket/push/server/ChannelDO.java:7

InterfaceChannelEventListener

通道事件监听器 @author daoshenzzg@163.com @date 2018/12/30 16:21

src/main/java/com/yb/socket/listener/ChannelEventListener.java:14

InterfaceChannelHandlerFunc

@author daoshenzzg@163.com @date 2022-03-10 14:52

src/main/java/com/yb/socket/service/ChannelHandlerFunc.java:9

@author daoshenzzg@163.com @date 2018/12/30 16:41

src/main/java/com/yb/socket/service/client/Client.java:27

ClassClientDispatchHandler

@author daoshenzzg@163.com @date 2018/12/30 16:25

src/main/java/com/yb/socket/service/client/ClientDispatchHandler.java:16

ClassClientHeartbeatHandler

@author daoshenzzg@163.com @date 2018/12/30 16:33

src/main/java/com/yb/socket/service/client/ClientHeartbeatHandler.java:17

ClassClientTest

@author daoshenzzg@163.com @date 2022-04-29 15:55

src/test/java/com/yb/socket/service/protocol/ClientTest.java:18

ClassClientTest

@author daoshenzzg@163.com @date 2018/12/30 18:43

src/test/java/com/yb/socket/service/normal/ClientTest.java:16

ClassClientTest

@author daoshenzzg@163.com @date 2019/1/7 22:32

src/test/java/com/yb/socket/center/ClientTest.java:13

InterfaceCompression

@author daoshenzzg@163.com @date 2019/1/14 11:09

src/main/java/com/yb/socket/compression/Compression.java:9

ClassConnectionProxy

src/main/java/com/yb/socket/datasource/HsqlDataSource.java:188

ClassCountHandler

Server统计信息Handle 放在pipeline的最后，因为channelInactive和channelActive事件处理中用到了Server里的最新channels size @author daoshenzzg@163.com @date 2019/1/11 16:53

src/main/java/com/yb/socket/count/CountHandler.java:16

@author daoshenzzg@163.com @date 2019/1/11 16:55

src/main/java/com/yb/socket/count/CountInfo.java:10

ClassDatabaseTest

@author daoshenzzg@163.com @date 2019/1/14 15:47

src/test/java/com/yb/socket/push/database/DatabaseTest.java:13

ClassDefaultExceptionListener

@author daoshenzzg@163.com @date 2018/12/30 16:19

src/main/java/com/yb/socket/listener/DefaultExceptionListener.java:12

ClassDefaultMessageEventListener

@author daoshenzzg@163.com @date 2018/12/30 16:18

src/main/java/com/yb/socket/listener/DefaultMessageEventListener.java:15

ClassDefaultMqttMessageEventListener

@author daoshenzzg@163.com @date 2019/1/4 11:17

src/main/java/com/yb/socket/listener/DefaultMqttMessageEventListener.java:15

ClassEchoMessageEventListener

@author daoshenzzg@163.com @date 2019/1/4 15:10

src/test/java/com/yb/socket/service/mqtt/EchoMessageEventListener.java:15

InterfaceEncrypt

@author daoshenzzg@163.com @date 2019/1/14 10:41

src/main/java/com/yb/socket/encrypt/Encrypt.java:7

EnumEventBehavior

@author daoshenzzg@163.com @date 2018/12/30 16:15

src/main/java/com/yb/socket/listener/EventBehavior.java:7

ClassEventDispatcher

事件分发器(分发消息、通道、异常事件给相应的监听器，允许使用线程池模型以使worker线程迅速返回) @author daoshenzzg@163.com @date 2018/12/30 16:26

src/main/java/com/yb/socket/service/EventDispatcher.java:20

InterfaceExceptionEventListener

异常监听器 @author daoshenzzg@163.com @date 2018/12/30 16:20

src/main/java/com/yb/socket/listener/ExceptionEventListener.java:15

ClassGzipCompression

@author daoshenzzg@163.com @date 2019/1/14 11:11

src/main/java/com/yb/socket/compression/GzipCompression.java:13

心跳消息 @author daoshenzzg@163.com @date 2018/12/30 15:19

src/main/java/com/yb/socket/pojo/Heartbeat.java:11

ClassHsqlDataSource

针对hsqldb的简单datasource实现 @author daoshenzzg@163.com @date 2019/1/14 11:19

src/main/java/com/yb/socket/datasource/HsqlDataSource.java:20

ClassInvokeFuture

@author daoshenzzg@163.com @date 2018/12/30 15:04

src/main/java/com/yb/socket/future/InvokeFuture.java:19

InterfaceInvokeFutureListener

InvokeFuture监听器 @author daoshenzzg@163.com @date 2018/12/30 15:05

src/main/java/com/yb/socket/future/InvokeFutureListener.java:9

ClassJsonDecoder

Json 解码器 @author daoshenzzg@163.com @date 2018/12/30 16:55

src/main/java/com/yb/socket/codec/JsonDecoder.java:22

ClassJsonEchoMessageEventListener

@author daoshenzzg@163.com @date 2019/1/3 21:45

src/test/java/com/yb/socket/service/normal/JsonEchoMessageEventListener.java:16

ClassJsonEncoder

Json 编码器 @author daoshenzzg@163.com @date 2018/12/30 16:56

src/main/java/com/yb/socket/codec/JsonEncoder.java:23

InterfaceMessageEventListener

消息监听器 @author daoshenzzg@163.com @date 2018/12/30 16:15

src/main/java/com/yb/socket/listener/MessageEventListener.java:14

EnumMessageTypeEnum

@author daoshenzzg@163.com @date 2022-04-29 15:41

src/main/java/com/yb/socket/codec/protocol/MessageTypeEnum.java:10

ClassMqttClientTest

@author daoshenzzg@163.com @date 2018/12/30 18:40

src/test/java/com/yb/socket/push/server/MqttClientTest.java:12

ClassMqttClientTest1

@author daoshenzzg@163.com @date 2018/12/30 18:40

src/test/java/com/yb/socket/service/mqtt/MqttClientTest1.java:12

ClassMqttClientTest2

@author daoshenzzg@163.com @date 2018/12/30 18:40

src/test/java/com/yb/socket/service/mqtt/MqttClientTest2.java:12

ClassMqttRequest

Mqtt 请求消息 @author daoshenzzg@163.com @date 2019/1/7 09:14

src/main/java/com/yb/socket/pojo/MqttRequest.java:11

ClassMqttServerTest

@author daoshenzzg@163.com @date 2018/12/30 18:41

src/test/java/com/yb/socket/service/mqtt/MqttServerTest.java:15

ClassMqttServerTest

@author daoshenzzg@163.com @date 2018/12/30 18:41

src/test/java/com/yb/socket/push/server/MqttServerTest.java:19

ClassMqttWebSocketCodec

WebSocket Mqtt消息编解码器 @author daoshenzzg@163.com @date 2019/1/3 19:04

src/main/java/com/yb/socket/codec/MqttWebSocketCodec.java:16

ClassMqttWsServerTest

MQTT web socket @author daoshenzzg@163.com @date 2018/12/30 18:41

src/test/java/com/yb/socket/service/mqttws/MqttWsServerTest.java:17

@author daoshenzzg@163.com @date 2022-04-29 15:36

src/main/java/com/yb/socket/codec/protocol/Protocol.java:20

ClassProtocolDecoder

自定义解码器粘包拆包处理 @author daoshenzzg@163.com @date 2022-04-29 15:46

src/main/java/com/yb/socket/codec/protocol/ProtocolDecoder.java:16

ClassProtocolEchoMessageEventListener

@author daoshenzzg@163.com @date 2022-04-29 15:53

src/test/java/com/yb/socket/service/protocol/ProtocolEchoMessageEventListener.java:19

ClassProtocolEncoder

@author daoshenzzg@163.com @date 2022-04-29 15:46

src/main/java/com/yb/socket/codec/protocol/ProtocolEncoder.java:13

ClassProtocolRequest

请求消息 @author daoshenzzg@163.com @date 2022-04-29 15:14

src/main/java/com/yb/socket/pojo/protocol/ProtocolRequest.java:15

ClassProtocolResponse

响应消息 @author daoshenzzg@163.com @date 2022-04-29 15:21

src/main/java/com/yb/socket/pojo/protocol/ProtocolResponse.java:15

ClassRSAEncrypt

@author daoshenzzg@163.com @date 2019/1/14 10:49

src/main/java/com/yb/socket/encrypt/RSAEncrypt.java:13

请求消息 @author daoshenzzg@163.com @date 2018/12/30 15:20

src/main/java/com/yb/socket/pojo/Request.java:11

响应消息 @author daoshenzzg@163.com @date 2018/12/30 15:21

src/main/java/com/yb/socket/pojo/Response.java:11

@author daoshenzzg@163.com @date 2018/12/30 18:31

src/main/java/com/yb/socket/util/Sequence.java:13

Socket Server @author daoshenzzg@163.com @date 2018/12/30 14:44

src/main/java/com/yb/socket/service/server/Server.java:54

@author daoshenzzg@163.com @date 2019/1/7 22:30

src/test/java/com/yb/socket/center/Server1.java:10

@author daoshenzzg@163.com @date 2019/1/7 22:31

src/test/java/com/yb/socket/center/Server2.java:10

ClassServerContext

@author daoshenzzg@163.com @date 2019/2/26 16:32

src/test/java/com/yb/socket/push/server/ServerContext.java:9

ClassServerContext

全局共享的Server服务 @author daoshenzzg@163.com @date 2018/12/30 14:48

src/main/java/com/yb/socket/service/server/ServerContext.java:9

ClassServerDispatchHandler

@author daoshenzzg@163.com @date 2018/12/30 16:47

src/main/java/com/yb/socket/service/server/ServerDispatchHandler.java:16

ClassServerHeartbeatHandler

@author daoshenzzg@163.com @date 2018/12/30 16:13

src/main/java/com/yb/socket/service/server/ServerHeartbeatHandler.java:16

ClassServerStateReportJob

@author daoshenzzg@163.com @date 2018/12/30 16:51

src/main/java/com/yb/socket/service/center/ServerStateReportJob.java:17

ClassServerTest

@author daoshenzzg@163.com @date 2022-04-29 15:52

src/test/java/com/yb/socket/service/protocol/ServerTest.java:12

ClassServerTest

@author daoshenzzg@163.com @date 2018/12/30 18:44

src/test/java/com/yb/socket/service/normal/ServerTest.java:16

@author daoshenzzg@163.com @date 2018/12/30 13:55

src/main/java/com/yb/socket/service/Service.java:18

ClassShutdownHook

src/main/java/com/yb/socket/service/Service.java:321

ClassSocketRuntimeException

@author daoshenzzg@163.com @date 2018/12/30 15:08

src/main/java/com/yb/socket/exception/SocketRuntimeException.java:7

ClassSocketTimeoutException

@author daoshenzzg@163.com @date 2018/12/30 15:10

src/main/java/com/yb/socket/exception/SocketTimeoutException.java:7

@author daoshenzzg@163.com @date 2018/12/30 13:47

src/main/java/com/yb/socket/service/SocketType.java:7

ClassStatusMessageEventListener

@author daoshenzzg@163.com @date 2018/12/30 18:24

src/main/java/com/yb/socket/status/StatusMessageEventListener.java:20

ClassStatusServer

@author daoshenzzg@163.com @date 2018/12/30 18:23

src/main/java/com/yb/socket/status/StatusServer.java:26

ClassSubscribeServer

@author daoshenzzg@163.com @date 2019/2/26 14:31

src/test/java/com/yb/socket/push/server/SubscribeServer.java:15

ClassTestMqttMessageEventListener

@author daoshenzzg@163.com @date 2019/2/26 14:27

src/test/java/com/yb/socket/push/server/TestMqttMessageEventListener.java:18

ClassWrappedChannel

@author daoshenzzg@163.com @date 2018/12/30 15:15

src/main/java/com/yb/socket/service/WrappedChannel.java:24