package com.flightfeather.obd.socket
|
|
import io.netty.channel.ChannelHandlerContext
|
import java.util.concurrent.ConcurrentHashMap
|
|
/**
|
* 用于保存连接的设备及对应的session通道
|
* Date: 2019.8.27
|
* @author riku
|
*/
|
class DeviceSession {
|
|
companion object{
|
private val deviceMap = ConcurrentHashMap<String, ChannelHandlerContext?>()
|
|
fun saveDevice(deviceCode: String?, channel: ChannelHandlerContext?) {
|
deviceCode?.let {
|
deviceMap.put(deviceCode, channel)
|
}
|
}
|
|
fun getDevice(deviceCode: String?): ChannelHandlerContext? {
|
return if (deviceMap.containsKey(deviceCode))
|
deviceMap[deviceCode]
|
else
|
null
|
}
|
}
|
}
|
