| | |
|---|
| | | public void listen(ConsumerRecord<String, String> record, Consumer consumer) throws Exception { |
|---|
| | | String messageStr = record.value(); |
|---|
| | | Map<String, Object> message = (Map<String, Object>) JSON.parse(messageStr); |
|---|
| | | log.info(message.toString()); |
|---|
| | | //long serverStartTime = System.currentTimeMillis(); |
|---|
| | | CopyOnWriteArraySet<SingleDeviceServer> sockets = SingleDeviceServer.sockets; |
|---|
| | | for (SingleDeviceServer socket : sockets) { |
|---|
| | |
|---|
| | | String showUnitKey = sensor.getShowUnitKey(); |
|---|
| | | String unitKey = sensor.getUnitKey(); |
|---|
| | | String unit = sensor.getUnit(); |
|---|
| | | //如果消息中没有该因子则退出循环 |
|---|
| | | if(message.get(code)==null) |
|---|
| | | continue; |
|---|
| | | //对数据保留两位小数，并且向下取整 |
|---|
| | | Double sourceDataD = Double.valueOf(String.valueOf(message.get(code))); |
|---|
| | | BigDecimal bg = new BigDecimal(sourceDataD); |
|---|
