socket-mqtt.zip
所属分类:开发技术 > 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协议。
本站所提供资源仅作为个人学习、交流使用,不可用于任何商业目的与用途。本站不保证标准的完整性,不承担任何技术和版权问题。若发现您的权利被侵害,请点击【举报】按钮,我们会尽快处理。
# | 文件名称 | 大小 | 最后修改时间 |
---|---|---|---|
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 |
请留下有营养的评论,广告灌水一律拉黑处理,谢谢合作!
上一资源: 数据库设计60个技巧.pdf.zip
下一资源: 计算机网络(第7版)-谢希仁.zip