| | |
| | | udpSocketBoot.bind(); |
| | | } |
| | | } catch (Exception e) { |
| | | // return null; |
| | | LogUtils.e("初始化Socket udp异常"+e.getMessage()); |
| | | } |
| | | |
| | | return udpSocketBoot; |
| | |
| | | //2.构建监听Listener |
| | | // authEvent = |
| | | //3.监听网关广播的入网指令 |
| | | EventDispatcher.getInstance().remove(TopicConstant.GATEWAY_AUTH_BROADCAST); |
| | | EventDispatcher.getInstance().register(TopicConstant.GATEWAY_AUTH_BROADCAST, new EventListener() { |
| | | @Override |
| | | public void onMessage(Object msg) { |
| | | LogUtils.i("收到网关认证信息: "); |
| | | NetworkAccessBroadcastResponse bean = getNetworkAccessBroadcastResponse(msg); |
| | | if (bean != null) { |
| | | //移除监听 |