| | |
|---|
| | | public void listen(ConsumerRecord<String, String> record , Consumer consumer) throws Exception { |
|---|
| | | String messageStr = record.value(); |
|---|
| | | Map<String,String> message = (Map<String,String>)JSON.parse(messageStr); |
|---|
| | | System.out.println(message); |
|---|
| | | //System.out.println(message); |
|---|
| | | CopyOnWriteArraySet<SingleDeviceServer> sockets = SingleDeviceServer.sockets; |
|---|
| | | for (SingleDeviceServer socket : sockets) { |
|---|
| | | //判断消息书否数据该socket |
|---|
| | | socket.sendMessage(message.toString()); |
|---|
| | | } |
|---|
| | | System.out.println(message); |
|---|
| | | // System.out.println(message); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
