MCPcopy Create free account

hub / github.com/cosmoplat-dev/netty-server / functions

Functions104 in github.com/cosmoplat-dev/netty-server

↓ 7 callersMethodgetDeviceNo
(byte[] frame)
src/main/java/com/joker/collector/utils/FrameUtils.java:9
↓ 6 callersMethodtoString
(byte[] frame)
src/main/java/com/joker/collector/utils/FrameUtils.java:39
↓ 5 callersMethodwriteAndFlush
(ChannelHandlerContext ctx, byte[] msg)
src/main/java/com/joker/collector/utils/ChannelHandlerContextUtils.java:15
↓ 3 callersMethodupdateDeviceStatus
updateDeviceStatus: 更新设备在线状态 @author Joker @param deviceNo @param ctx @since JDK 1.8
src/main/java/com/joker/collector/controller/EqmController.java:135
↓ 2 callersMethodapiInfo
()
src/main/java/com/joker/collector/Swagger2.java:24
↓ 2 callersMethodenableSimple
允许单引号 允许不带引号的字段名称
src/main/java/com/joker/collector/utils/JsonMapper.java:199
↓ 2 callersMethodgetCurrentDevice
()
src/main/java/com/joker/collector/attribute/EqmContext.java:61
↓ 2 callersMethodgetDeviceCHC
()
src/main/java/com/joker/collector/attribute/EqmContext.java:37
↓ 2 callersMethodgetInstance
()
src/main/java/com/joker/collector/init/EqmContextMap.java:21
↓ 2 callersMethodgetInstance
创建只输出非Null且非Empty(如List.isEmpty)的属性到Json字符串的Mapper,建议在外部接口中使用.
src/main/java/com/joker/collector/utils/JsonMapper.java:78
↓ 2 callersMethodgetName
()
src/main/java/com/joker/collector/config/ServerPeriod.java:53
↓ 2 callersMethodtoJson
Object可以是POJO,也可以是Collection或数组。 如果对象为Null, 返回"null". 如果集合为空集合, 返回"[]".
src/main/java/com/joker/collector/utils/JsonMapper.java:98
↓ 1 callersMethodbossGroup
()
src/main/java/com/joker/collector/MultiServerApplication.java:76
↓ 1 callersMethodfromJson
反序列化POJO或简单Collection如List<String>. 如果JSON字符串为Null或"null"字符串, 返回Null. 如果JSON字符串为"[]", 返回空集合. 如需反序列化复杂Collection如List<MyBean>, 请使用fromJson(String,Jav
src/main/java/com/joker/collector/utils/JsonMapper.java:116
↓ 1 callersMethodgetValue
()
src/main/java/com/joker/collector/config/ServerPeriod.java:61
↓ 1 callersMethodgetWritingFrame
()
src/main/java/com/joker/collector/base/Device.java:7
↓ 1 callersMethodhandleResult
()
src/main/java/com/joker/collector/base/AbstractDevice.java:53
↓ 1 callersMethodheartbeat
heartbeat: 处理dtu的心跳报文 @author Joker @param ctx @param msg @since JDK 1.8
src/main/java/com/joker/collector/controller/EqmController.java:57
↓ 1 callersMethodisPacketBelongToDevice
Do the receive packet belong to current Meter ? @param msg receive packet @return Yes retrun true,No return false
src/main/java/com/joker/collector/base/AbstractDevice.java:33
↓ 1 callersMethodprocessReadingFrame
(byte[] readingFrame)
src/main/java/com/joker/collector/base/Device.java:5
↓ 1 callersMethodreadDevice
readDevice: 处理上传的数据报文 @author Joker @param ctx @param msg @since JDK 1.8
src/main/java/com/joker/collector/controller/EqmController.java:73
↓ 1 callersMethodrun
()
src/main/java/com/joker/collector/task/DataProcessor.java:35
↓ 1 callersMethodsaveRegisterInfo
saveRegisterInfo: 处理采集器(dtu)注册信息 @author Joker @param ctx @param msg @since JDK 1.8
src/main/java/com/joker/collector/controller/EqmController.java:98
↓ 1 callersMethodsetDeviceCHC
(ChannelHandlerContext deviceCHC)
src/main/java/com/joker/collector/attribute/EqmContext.java:41
↓ 1 callersMethodsetDeviceNo
(String deviceNo)
src/main/java/com/joker/collector/attribute/EqmContext.java:33
↓ 1 callersMethodstart
()
src/main/java/com/joker/collector/server/EqmServer.java:52
↓ 1 callersMethodtcpChannelOptions
()
src/main/java/com/joker/collector/MultiServerApplication.java:67
↓ 1 callersMethodtoHexString
(byte[] frame)
src/main/java/com/joker/collector/utils/FrameUtils.java:59
↓ 1 callersMethodtoJsonString
对象转换为JSON字符串 @param object @return
src/main/java/com/joker/collector/utils/JsonMapper.java:218
↓ 1 callersMethodvalidator
()
src/main/java/com/joker/collector/config/DatabaseConfiguration.java:32
↓ 1 callersMethodworkerGroup
()
src/main/java/com/joker/collector/MultiServerApplication.java:82
↓ 1 callersMethodwriteDevice
write one frame every time @param dtuContext
src/main/java/com/joker/collector/task/DataProcessor.java:54
MethodChannelGroupUtil
()
src/main/java/com/joker/collector/utils/ChannelGroupUtil.java:29
MethodDataProcessor
(ChannelHandlerContext ctx, AttributeKey<EqmContext> attrDtuContext)
src/main/java/com/joker/collector/task/DataProcessor.java:24
MethodEqmController
(AttributeKey<EqmContext> attreqmContext)
src/main/java/com/joker/collector/controller/EqmController.java:45
MethodJsonMapper
()
src/main/java/com/joker/collector/utils/JsonMapper.java:41
MethodServerPeriod
(String name, long value)
src/main/java/com/joker/collector/config/ServerPeriod.java:48
MethodanalyzeFrame
(byte[] frame)
src/main/java/com/joker/collector/base/AbstractDevice.java:51
Methodbootstrap
()
src/main/java/com/joker/collector/MultiServerApplication.java:48
MethodbuildWritingFrames
()
src/main/java/com/joker/collector/base/AbstractDevice.java:49
MethodchannelActive
客户端连接后触发 @see io.netty.channel.ChannelInboundHandlerAdapter#channelActive(io.netty.channel.ChannelHandlerContext)
src/main/java/com/joker/collector/handler/EqmServerHandler.java:44
MethodchannelInactive
channelInactive: 客户端断开连接后触发 @see io.netty.channel.ChannelInboundHandlerAdapter#channelInactive(io.netty.channel.ChannelHandlerContext)
src/main/java/com/joker/collector/handler/EqmServerHandler.java:59
MethodchannelRead0
channelRead0: Decoder发送数据后触发 @see io.netty.channel.SimpleChannelInboundHandler#channelRead0(io.netty.channel.ChannelHandlerContext, java.lang.Ob
src/main/java/com/joker/collector/handler/EqmServerHandler.java:74
MethodcreateCollectionType
構造泛型的Collection Type如: ArrayList<MyBean>, 则调用constructCollectionType(ArrayList.class,MyBean.class) HashMap <String,MyBean>, 则调用(HashMap.class,String.c
src/main/java/com/joker/collector/utils/JsonMapper.java:151
MethodcreateRestApi
()
src/main/java/com/joker/collector/Swagger2.java:18
Methoddecode
编码插件,接受到的数据在此处进行过滤,做拆包粘包处理等操作
src/main/java/com/joker/collector/codec/SocketDecoder.java:25
Methoddestroy
()
src/main/java/com/joker/collector/config/CrosFilter.java:25
MethoddoFilter
(ServletRequest req, ServletResponse res, FilterChain chain)
src/main/java/com/joker/collector/config/CrosFilter.java:30
MethodenableEnumUseToString
設定是否使用Enum的toString函數來讀寫Enum, 為False時時使用Enum的name()函數來讀寫Enum, 默認為False. 注意本函數一定要在Mapper創建後, 所有的讀寫動作之前調用.
src/main/java/com/joker/collector/utils/JsonMapper.java:181
MethodenableJaxbAnnotation
支持使用Jaxb的Annotation,使得POJO上的annotation不用与Jackson耦合。 默认会先查找jaxb的annotation,如果找不到再找jackson的。
src/main/java/com/joker/collector/utils/JsonMapper.java:190
Methodencode
(ChannelHandlerContext ctx, byte[] msg, List<Object> out)
src/main/java/com/joker/collector/codec/SocketEncoder.java:28
MethodexceptionCaught
(ChannelHandlerContext ctx, Throwable cause)
src/main/java/com/joker/collector/codec/SocketDecoder.java:41
MethodexceptionCaught
(ChannelHandlerContext ctx, Throwable cause)
src/main/java/com/joker/collector/handler/EqmServerHandler.java:83
MethodfloatIeeeConvert
(int[] data, int index)
src/main/java/com/joker/collector/utils/FrameUtils.java:18
MethodfromJsonString
JSON字符串转换为对象 @param jsonString @param clazz @return
src/main/java/com/joker/collector/utils/JsonMapper.java:229
MethodgetBacklog
()
src/main/java/com/joker/collector/config/ConfigBean.java:62
MethodgetBossCount
()
src/main/java/com/joker/collector/config/ConfigBean.java:38
MethodgetCmdCHC
()
src/main/java/com/joker/collector/attribute/EqmContext.java:45
MethodgetCmdQueue
()
src/main/java/com/joker/collector/attribute/EqmContext.java:53
MethodgetCollectorNo
(byte[] msg)
src/main/java/com/joker/collector/utils/FrameUtils.java:68
MethodgetDatabaseName
()
src/main/java/com/joker/collector/config/DatabaseConfiguration.java:37
MethodgetDelay
()
src/main/java/com/joker/collector/config/ConfigBean.java:78
MethodgetDeviceNo
()
src/main/java/com/joker/collector/attribute/EqmContext.java:29
MethodgetHeartbeat
()
src/main/java/com/joker/collector/config/ConfigBean.java:70
MethodgetInstance
()
src/main/java/com/joker/collector/utils/ChannelGroupUtil.java:31
MethodgetMapper
取出Mapper做进一步的设置或使用其他序列化API.
src/main/java/com/joker/collector/utils/JsonMapper.java:208
MethodgetReadPeriod
()
src/main/java/com/joker/collector/config/ConfigBean.java:86
MethodgetServerBootstrap
()
src/main/java/com/joker/collector/server/EqmServer.java:63
MethodgetServerPort
()
src/main/java/com/joker/collector/server/EqmServer.java:71
MethodgetServerPort
()
src/main/java/com/joker/collector/config/ConfigBean.java:30
MethodgetSpringContextHolder
()
src/main/java/com/joker/collector/config/SpringContextHolderConfig.java:9
MethodgetWorkerCount
()
src/main/java/com/joker/collector/config/ConfigBean.java:46
MethodgetWritingFrame
()
src/main/java/com/joker/collector/base/AbstractDevice.java:44
MethodheartBeat
()
src/main/java/com/joker/collector/task/HeartProcessor.java:18
Methodinit
(FilterConfig config)
src/main/java/com/joker/collector/config/CrosFilter.java:43
MethodinitChannel
(SocketChannel socketChannel)
src/main/java/com/joker/collector/initializer/EqmServerInitializer.java:26
MethodisKeepalive
()
src/main/java/com/joker/collector/config/ConfigBean.java:54
Methodmain
(String[] args)
src/main/java/com/joker/collector/MultiServerApplication.java:39
MethodmongoClient
()
src/main/java/com/joker/collector/config/DatabaseConfiguration.java:42
MethodnonDefaultMapper
创建只输出初始值被改变的属性到Json字符串的Mapper, 最节约的存储方式,建议在内部接口中使用。
src/main/java/com/joker/collector/utils/JsonMapper.java:88
Methodport
()
src/main/java/com/joker/collector/MultiServerApplication.java:88
MethodprocessReadingFrame
(byte[] readingFrame)
src/main/java/com/joker/collector/base/AbstractDevice.java:12
Methodserialize
(Object value, JsonGenerator jgen, SerializerProvider provider)
src/main/java/com/joker/collector/utils/JsonMapper.java:56
MethodsetBacklog
(Integer backlog)
src/main/java/com/joker/collector/config/ConfigBean.java:66
MethodsetBossCount
(Integer bossCount)
src/main/java/com/joker/collector/config/ConfigBean.java:42
MethodsetCmdCHC
(ChannelHandlerContext cmdCHC)
src/main/java/com/joker/collector/attribute/EqmContext.java:49
MethodsetCmdQueue
(Device cmdQueue)
src/main/java/com/joker/collector/attribute/EqmContext.java:57
MethodsetCurrentDevice
(Device currentDevice)
src/main/java/com/joker/collector/attribute/EqmContext.java:65
MethodsetDelay
(Integer delay)
src/main/java/com/joker/collector/config/ConfigBean.java:82
MethodsetHeartbeat
(Integer heartbeat)
src/main/java/com/joker/collector/config/ConfigBean.java:74
MethodsetKeepalive
(boolean keepalive)
src/main/java/com/joker/collector/config/ConfigBean.java:58
MethodsetName
(String name)
src/main/java/com/joker/collector/config/ServerPeriod.java:57
MethodsetReadPeriod
(Integer readPeriod)
src/main/java/com/joker/collector/config/ConfigBean.java:90
MethodsetServerBootstrap
(ServerBootstrap serverBootstrap)
src/main/java/com/joker/collector/server/EqmServer.java:67
MethodsetServerPort
(int serverPort)
src/main/java/com/joker/collector/server/EqmServer.java:75
MethodsetServerPort
(Integer serverPort)
src/main/java/com/joker/collector/config/ConfigBean.java:34
MethodsetValue
(long value)
src/main/java/com/joker/collector/config/ServerPeriod.java:65
MethodsetWorkerCount
(Integer workerCount)
src/main/java/com/joker/collector/config/ConfigBean.java:50
Methodstop
()
src/main/java/com/joker/collector/server/EqmServer.java:57
MethodtoJsonP
輸出JSONP格式數據.
src/main/java/com/joker/collector/utils/JsonMapper.java:173
next →1–100 of 104, ranked by callers