| | |
| | | if (udpSocketBoot == null) { |
| | | udpSocketBoot = UdpClient.init(UDP_PORT, getUdpOptions()); |
| | | udpSocketBoot.bind(); |
| | | |
| | | LogUtils.i("初始化Socket udp"); |
| | | } |
| | | } 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) { |
| | | //移除监听 |
| | |
| | | try { |
| | | AuthenticateResponse bean = getAuthenticateResponseBean(msg); |
| | | if (bean != null) { |
| | | if (bean.getCode().equals("200")) { |
| | | if (bean.getCode().equals("200") || bean.getCode().equals("0")) { |
| | | String localSecret = ""; |
| | | String gatewayId = ""; |
| | | String ipAddress = ""; |