hub / github.com/daoshenzzg/socket-mqtt

github.com/daoshenzzg/socket-mqtt @main

Chat with this repo

repository ↗ · DeepWiki ↗ · + Follow

498 symbols 1,338 edges 78 files 100 documented · 20%

Browse by type

⨍ Functions 418◇ Types & classes 80

What it actually does AI analysis from the code graph — generated when you open this

loading…

Extension points exported contracts — how you extend this code

MessageEventListener (Interface)

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

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

Encrypt (Interface)

@author daoshenzzg@163.com @date 2019/1/14 10:41 [6 implementers]

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

ExceptionEventListener (Interface)

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

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

ChannelEventListener (Interface)

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

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

Compression (Interface)

@author daoshenzzg@163.com @date 2019/1/14 11:09 [2 implementers]

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

Core symbols most depended-on inside this repo

get

called by 33

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

addChannelHandler

called by 21

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

called by 16

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

getCountInfo

called by 16

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

writeAndFlush

called by 14

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

called by 14

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

getSequence

called by 14

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

setSequence

called by 14

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

Shape

Method 418

Class 70

Interface 7

Enum 3

Languages

Java100%

Modules by API surface

src/main/java/com/yb/socket/service/Service.java48 symbols

src/main/java/com/yb/socket/service/WrappedChannel.java41 symbols

src/main/java/com/yb/socket/service/server/Server.java36 symbols

src/main/java/com/yb/socket/datasource/HsqlDataSource.java23 symbols

src/main/java/com/yb/socket/service/client/BaseClient.java17 symbols

src/main/java/com/yb/socket/pojo/MqttRequest.java17 symbols

src/main/java/com/yb/socket/future/InvokeFuture.java17 symbols

src/main/java/com/yb/socket/service/client/Client.java16 symbols

src/main/java/com/yb/socket/pojo/protocol/ProtocolResponse.java13 symbols

src/main/java/com/yb/socket/pojo/protocol/ProtocolRequest.java12 symbols

src/main/java/com/yb/socket/count/CountInfo.java12 symbols

src/main/java/com/yb/socket/service/EventDispatcher.java10 symbols

For agents

$ claude mcp add socket-mqtt \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact

github.com/daoshenzzg/socket-mqtt @main

Extension points exported contracts — how you extend this code

Core symbols most depended-on inside this repo

Shape

Languages

Modules by API surface

For agents

Ask about this repo answers extend the page