socket-mqtt.zip
下载
MQTT 协议 队列
查看(8)

所属分类:开发技术 > Java
文件大小:74.44 KB
上传日期:2020-12-09 09:31
MD5:f8e1f4801e************ce43f78bf5
资源说明:这是一个基于Netty4.x + MQTT实现的Push推送基础框架。相比于原生Netty,socket-mqtt为C/S模式开发封装简单统一的编程模式,简单高性能的代码,统一的连接管理方案,统一的线程管理方案,网络基础问题的解决与支持:如心跳保持、压缩解压缩、编码与解码、加密与解密等,各种网络参数、连接池实现、监听器实现等可配置可替换,可实现对等集群,提供数据统计/监控组件,支持普通socket、MQTT、MQTT web socket协议。

[资源合计] 文件夹:35,文件:70

# 文件名称 大小 最后修改时间
1 socket-mqtt 0 Bytes 2020/12/9 9:29:11
2 socket-mqtt\pom.xml 2.6 KB 2019/9/5 13:48:50
3 socket-mqtt\src 0 Bytes 2020/12/9 9:28:43
4 socket-mqtt\src\main 0 Bytes 2020/12/9 9:28:43
5 socket-mqtt\src\main\java 0 Bytes 2020/12/9 9:28:43
6 socket-mqtt\src\main\java\com 0 Bytes 2020/12/9 9:28:43
7 socket-mqtt\src\main\java\com\yb 0 Bytes 2020/12/9 9:28:43
8 socket-mqtt\src\main\java\com\yb\socket 0 Bytes 2020/12/9 9:28:43
9 socket-mqtt\src\main\java\com\yb\socket\App.java 215 Bytes 2019/9/5 13:48:50
10 socket-mqtt\src\main\java\com\yb\socket\codec 0 Bytes 2020/12/9 9:28:43
11 socket-mqtt\src\main\java\com\yb\socket\codec\JsonDecoder.java 1.99 KB 2019/9/5 13:48:50
12 socket-mqtt\src\main\java\com\yb\socket\codec\JsonEncoder.java 2.15 KB 2019/9/5 13:48:50
13 socket-mqtt\src\main\java\com\yb\socket\codec\MqttWebSocketCodec.java 837 Bytes 2019/9/5 13:48:50
14 socket-mqtt\src\main\java\com\yb\socket\compression 0 Bytes 2020/12/9 9:28:43
15 socket-mqtt\src\main\java\com\yb\socket\compression\Compression.java 509 Bytes 2019/9/5 13:48:50
16 socket-mqtt\src\main\java\com\yb\socket\compression\GzipCompression.java 2.16 KB 2019/9/5 13:48:50
17 socket-mqtt\src\main\java\com\yb\socket\count 0 Bytes 2020/12/9 9:28:43
18 socket-mqtt\src\main\java\com\yb\socket\count\CountHandler.java 1.47 KB 2019/9/5 13:48:50
19 socket-mqtt\src\main\java\com\yb\socket\count\CountInfo.java 2.5 KB 2019/9/5 13:48:50
20 socket-mqtt\src\main\java\com\yb\socket\datasource 0 Bytes 2020/12/9 9:28:43
21 socket-mqtt\src\main\java\com\yb\socket\datasource\HsqlDataSource.java 7.82 KB 2019/9/5 13:48:50
22 socket-mqtt\src\main\java\com\yb\socket\encrypt 0 Bytes 2020/12/9 9:28:43
23 socket-mqtt\src\main\java\com\yb\socket\encrypt\AESEncrypt.java 1.92 KB 2019/9/5 13:48:50
24 socket-mqtt\src\main\java\com\yb\socket\encrypt\BaseEncrypt.java 691 Bytes 2019/9/5 13:48:50
25 socket-mqtt\src\main\java\com\yb\socket\encrypt\Encrypt.java 828 Bytes 2019/9/5 13:48:50
26 socket-mqtt\src\main\java\com\yb\socket\encrypt\RSAEncrypt.java 3.24 KB 2019/9/5 13:48:50
27 socket-mqtt\src\main\java\com\yb\socket\exception 0 Bytes 2020/12/9 9:28:43
28 socket-mqtt\src\main\java\com\yb\socket\exception\SocketRuntimeException.java 577 Bytes 2019/9/5 13:48:50
29 socket-mqtt\src\main\java\com\yb\socket\exception\SocketTimeoutException.java 575 Bytes 2019/9/5 13:48:50
30 socket-mqtt\src\main\java\com\yb\socket\future 0 Bytes 2020/12/9 9:28:43
31 socket-mqtt\src\main\java\com\yb\socket\future\InvokeFuture.java 4.15 KB 2019/9/5 13:48:50
32 socket-mqtt\src\main\java\com\yb\socket\future\InvokeFutureListener.java 337 Bytes 2019/9/5 13:48:50
33 socket-mqtt\src\main\java\com\yb\socket\listener 0 Bytes 2020/12/9 9:28:43
34 socket-mqtt\src\main\java\com\yb\socket\listener\ChannelEventListener.java 716 Bytes 2019/9/5 13:48:50
35 socket-mqtt\src\main\java\com\yb\socket\listener\DefaultExceptionListener.java 802 Bytes 2019/9/5 13:48:50
36 socket-mqtt\src\main\java\com\yb\socket\listener\DefaultMessageEventListener.java 1.91 KB 2019/9/5 13:48:50
37 socket-mqtt\src\main\java\com\yb\socket\listener\DefaultMqttMessageEventListener.java 4.42 KB 2019/9/5 13:48:50
38 socket-mqtt\src\main\java\com\yb\socket\listener\EventBehavior.java 252 Bytes 2019/9/5 13:48:50
39 socket-mqtt\src\main\java\com\yb\socket\listener\ExceptionEventListener.java 600 Bytes 2019/9/5 13:48:50
40 socket-mqtt\src\main\java\com\yb\socket\listener\MessageEventListener.java 543 Bytes 2019/9/5 13:48:50
41 socket-mqtt\src\main\java\com\yb\socket\pojo 0 Bytes 2020/12/9 9:28:43
42 socket-mqtt\src\main\java\com\yb\socket\pojo\BaseMessage.java 425 Bytes 2019/9/5 13:48:50
43 socket-mqtt\src\main\java\com\yb\socket\pojo\Heartbeat.java 513 Bytes 2019/9/5 13:48:50
44 socket-mqtt\src\main\java\com\yb\socket\pojo\MqttRequest.java 1.99 KB 2019/9/5 13:48:50
45 socket-mqtt\src\main\java\com\yb\socket\pojo\Request.java 760 Bytes 2019/9/5 13:48:50
46 socket-mqtt\src\main\java\com\yb\socket\pojo\Response.java 1.21 KB 2019/9/5 13:48:50
47 socket-mqtt\src\main\java\com\yb\socket\service 0 Bytes 2020/12/9 9:28:43
48 socket-mqtt\src\main\java\com\yb\socket\service\center 0 Bytes 2020/12/9 9:28:43
49 socket-mqtt\src\main\java\com\yb\socket\service\center\ServerStateReportJob.java 3.27 KB 2019/9/5 13:48:50
50 socket-mqtt\src\main\java\com\yb\socket\service\client 0 Bytes 2020/12/9 9:28:43
51 socket-mqtt\src\main\java\com\yb\socket\service\client\BaseClient.java 7.26 KB 2019/9/5 13:48:50
52 socket-mqtt\src\main\java\com\yb\socket\service\client\Client.java 8.51 KB 2019/9/5 13:48:50
53 socket-mqtt\src\main\java\com\yb\socket\service\client\ClientDispatchHandler.java 2.94 KB 2019/9/5 13:48:50
54 socket-mqtt\src\main\java\com\yb\socket\service\client\ClientHeartbeatHandler.java 1.43 KB 2019/9/5 13:48:50
55 socket-mqtt\src\main\java\com\yb\socket\service\EventDispatcher.java 4.92 KB 2019/9/5 13:48:50
56 socket-mqtt\src\main\java\com\yb\socket\service\server 0 Bytes 2020/12/9 9:28:43
57 socket-mqtt\src\main\java\com\yb\socket\service\server\Server.java 18.3 KB 2019/9/5 13:48:50
58 socket-mqtt\src\main\java\com\yb\socket\service\server\ServerContext.java 549 Bytes 2019/9/5 13:48:50
59 socket-mqtt\src\main\java\com\yb\socket\service\server\ServerDispatchHandler.java 3.08 KB 2019/9/5 13:48:50
60 socket-mqtt\src\main\java\com\yb\socket\service\server\ServerHeartbeatHandler.java 1.63 KB 2019/9/5 13:48:50
61 socket-mqtt\src\main\java\com\yb\socket\service\Service.java 9.08 KB 2019/9/5 13:48:50
62 socket-mqtt\src\main\java\com\yb\socket\service\SocketType.java 281 Bytes 2019/9/5 13:48:50
63 socket-mqtt\src\main\java\com\yb\socket\service\WrappedChannel.java 9.76 KB 2019/9/5 13:48:50
64 socket-mqtt\src\main\java\com\yb\socket\status 0 Bytes 2020/12/9 9:28:43
65 socket-mqtt\src\main\java\com\yb\socket\status\StatusMessageEventListener.java 6.26 KB 2019/9/5 13:48:50
66 socket-mqtt\src\main\java\com\yb\socket\status\StatusServer.java 3.47 KB 2019/9/5 13:48:50
67 socket-mqtt\src\main\java\com\yb\socket\util 0 Bytes 2020/12/9 9:28:43
68 socket-mqtt\src\main\java\com\yb\socket\util\AddressUtil.java 1.98 KB 2019/9/5 13:48:50
69 socket-mqtt\src\main\java\com\yb\socket\util\Sequence.java 1.1 KB 2019/9/5 13:48:50
70 socket-mqtt\src\test 0 Bytes 2020/12/9 9:28:43
71 socket-mqtt\src\test\java 0 Bytes 2020/12/9 9:28:43
72 socket-mqtt\src\test\java\com 0 Bytes 2020/12/9 9:28:43
73 socket-mqtt\src\test\java\com\yb 0 Bytes 2020/12/9 9:28:43
74 socket-mqtt\src\test\java\com\yb\socket 0 Bytes 2020/12/9 9:28:43
75 socket-mqtt\src\test\java\com\yb\socket\AppTest.java 679 Bytes 2019/9/5 13:48:50
76 socket-mqtt\src\test\java\com\yb\socket\center 0 Bytes 2020/12/9 9:28:43
77 socket-mqtt\src\test\java\com\yb\socket\center\CenterMock1.java 690 Bytes 2019/9/5 13:48:50
78 socket-mqtt\src\test\java\com\yb\socket\center\CenterMock2.java 675 Bytes 2019/9/5 13:48:50
79 socket-mqtt\src\test\java\com\yb\socket\center\CenterMockMessageEventListener.java 2.31 KB 2019/9/5 13:48:50
80 socket-mqtt\src\test\java\com\yb\socket\center\ClientTest.java 958 Bytes 2019/9/5 13:48:50
81 socket-mqtt\src\test\java\com\yb\socket\center\Server1.java 581 Bytes 2019/9/5 13:48:50
82 socket-mqtt\src\test\java\com\yb\socket\center\Server2.java 582 Bytes 2019/9/5 13:48:50
83 socket-mqtt\src\test\java\com\yb\socket\push 0 Bytes 2020/12/9 9:28:43
84 socket-mqtt\src\test\java\com\yb\socket\push\database 0 Bytes 2020/12/9 9:28:43
85 socket-mqtt\src\test\java\com\yb\socket\push\database\DatabaseTest.java 1.82 KB 2019/9/5 13:48:50
86 socket-mqtt\src\test\java\com\yb\socket\push\server 0 Bytes 2020/12/9 9:28:43
87 socket-mqtt\src\test\java\com\yb\socket\push\server\ChannelDO.java 889 Bytes 2019/9/5 13:48:50
88 socket-mqtt\src\test\java\com\yb\socket\push\server\MqttClientTest.java 3.41 KB 2019/9/5 13:48:50
89 socket-mqtt\src\test\java\com\yb\socket\push\server\MqttServerTest.java 2.06 KB 2019/9/5 13:48:50
90 socket-mqtt\src\test\java\com\yb\socket\push\server\ServerContext.java 582 Bytes 2019/9/5 13:48:50
91 socket-mqtt\src\test\java\com\yb\socket\push\server\SubscribeServer.java 2 KB 2019/9/5 13:48:50
92 socket-mqtt\src\test\java\com\yb\socket\push\server\TestMqttMessageEventListener.java 3.44 KB 2019/9/5 13:48:50
93 socket-mqtt\src\test\java\com\yb\socket\service 0 Bytes 2020/12/9 9:28:43
94 socket-mqtt\src\test\java\com\yb\socket\service\mqtt 0 Bytes 2020/12/9 9:28:43
95 socket-mqtt\src\test\java\com\yb\socket\service\mqtt\EchoMessageEventListener.java 1.26 KB 2019/9/5 13:48:50
96 socket-mqtt\src\test\java\com\yb\socket\service\mqtt\MqttClientTest1.java 3.43 KB 2019/9/5 13:48:50
97 socket-mqtt\src\test\java\com\yb\socket\service\mqtt\MqttClientTest2.java 2.41 KB 2019/9/5 13:48:50
98 socket-mqtt\src\test\java\com\yb\socket\service\mqtt\MqttServerTest.java 1.48 KB 2019/9/5 13:48:50
99 socket-mqtt\src\test\java\com\yb\socket\service\normal 0 Bytes 2020/12/9 9:28:43
100 socket-mqtt\src\test\java\com\yb\socket\service\normal\ClientTest.java 1.44 KB 2019/9/5 13:48:50
101 socket-mqtt\src\test\java\com\yb\socket\service\normal\JsonEchoMessageEventListener.java 1.2 KB 2019/9/5 13:48:50
102 socket-mqtt\src\test\java\com\yb\socket\service\normal\ServerTest.java 1.54 KB 2019/9/5 13:48:50
103 socket-mqtt\src\test\resources 0 Bytes 2020/12/9 9:28:43
104 socket-mqtt\src\test\resources\createTable.sql 378 Bytes 2019/9/5 13:48:50
105 socket-mqtt\src\test\resources\subscribe.xml 1.39 KB 2019/9/5 13:48:50

请留下有营养的评论,广告灌水一律拉黑处理,谢谢合作!