| | |
|---|
| | | @Component |
|---|
| | | public class SecondDataConsumer implements ConsumerSeekAware { |
|---|
| | | |
|---|
| | | @KafkaListener(topics = "second_data", groupId = "SecondsDataGroup998") |
|---|
| | | @KafkaListener(topics = "second_data", groupId = "SecondsDataGroup997") |
|---|
| | | 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); |
|---|
| | |
|---|
| | | //判断消息书否数据该socket |
|---|
| | | String messageMac = (String) message.get("mac"); |
|---|
| | | String mac = socket.getMac(); |
|---|
| | | if(!mac.equals(messageMac)) |
|---|
| | | if(!mac.equalsIgnoreCase(messageMac)) |
|---|
| | | continue; |
|---|
| | | //取出基本信息 |
|---|
| | | Map<String, Device> devicesInfo = socket.getDevicesInfo(); |
|---|
