package com.hdl.sdk.link.core.connect;
|
|
import com.google.gson.JsonObject;
|
import com.hdl.sdk.link.common.config.TopicConstant;
|
import com.hdl.sdk.link.common.exception.HDLLinkException;
|
import com.hdl.sdk.link.common.utils.IdUtils;
|
import com.hdl.sdk.link.common.utils.LogUtils;
|
import com.hdl.sdk.link.common.utils.gson.GsonConvert;
|
import com.hdl.sdk.link.core.bean.LinkRequest;
|
import com.hdl.sdk.link.core.bean.LinkResponse;
|
import com.hdl.sdk.link.core.bean.gateway.GatewayBean;
|
import com.hdl.sdk.link.core.bean.request.BroadcastRequest;
|
import com.hdl.sdk.link.core.callback.HDLLinkResponseCallBack;
|
import com.hdl.sdk.link.core.config.HDLLinkConfig;
|
import com.hdl.sdk.link.core.protocol.LinkMessageDecoder;
|
import com.hdl.sdk.link.core.protocol.LinkMessageEncoder;
|
import com.hdl.sdk.link.gateway.HDLLinkLocalGateway;
|
import com.hdl.sdk.link.socket.TcpSocketBoot;
|
import com.hdl.sdk.link.socket.SocketOptions;
|
import com.hdl.sdk.link.socket.client.IHeartbeat;
|
import com.hdl.sdk.link.socket.client.TcpClient;
|
import com.hdl.sdk.link.socket.codec.MessagePipeLine;
|
import com.hdl.sdk.link.socket.listener.ConnectStatusListener;
|
|
/**
|
* Created by Tong on 2021/9/26.
|
* 1、通过Udp 组播或者广播搜索网关
|
* 2、通过Udp 获取Tcp ip 端口统一8586
|
*/
|
public class HDLTcpConnect {
|
|
/**
|
* tcp默认端口
|
*/
|
private static final int TCP_PORT = 8586;
|
|
|
private ConnectStatusListener statusListener;
|
|
private HDLTcpConnect() {
|
statusListener = new ConnectStatusListener() {
|
@Override
|
public void onConnecting() {
|
broadcastRequest();
|
}
|
|
@Override
|
public void onConnected() {
|
|
}
|
|
@Override
|
public void onConnectFailed() {
|
|
}
|
};
|
}
|
|
/**
|
* 广播自身信息给主网关
|
*/
|
private void broadcastRequest() {
|
String time = String.valueOf(System.currentTimeMillis());
|
if (null == HDLLinkConfig.getInstance().getDeviceInfoBean()) {
|
LogUtils.i("DeviceInfoBean为空，请设置当前对象");
|
return;
|
}
|
BroadcastRequest request = new BroadcastRequest(IdUtils.getUUId(), time, HDLLinkConfig.getInstance().getDeviceInfoBean(), "200");
|
HDLUdpConnect.getInstance().udpSendMsg(TopicConstant.BROADCAST, GsonConvert.getGson().toJson(request), true);
|
HDLUdpConnect.getInstance().udpSendMsg(TopicConstant.BROADCAST, GsonConvert.getGson().toJson(request), true, new HDLLinkResponseCallBack() {
|
@Override
|
public void onSuccess(LinkResponse msg) {
|
LogUtils.i("广播信息给主网关成功！");
|
}
|
|
@Override
|
public void onError(HDLLinkException e) {
|
|
}
|
});
|
HDLUdpConnect.getInstance().udpSendMsg(TopicConstant.BROADCAST, GsonConvert.getGson().toJson(request), true);
|
}
|
|
private static class SingletonInstance {
|
private static final HDLTcpConnect INSTANCE = new HDLTcpConnect();
|
}
|
|
public static HDLTcpConnect getInstance() {
|
return SingletonInstance.INSTANCE;
|
}
|
|
/**
|
* 通过IP及端口找出连接客户端，如果当前没有连接。主要是针对调试软件使用，支持连接主网关、从网关
|
*
|
* @param ip 连接的网关IP
|
* @return
|
*/
|
public static synchronized TcpSocketBoot getTcpSocketBoot(String ip) {
|
return initTcp(ip);
|
}
|
|
static int dddd;
|
/**
|
* 初始化tcp连接
|
*
|
* @param ip 连接的网关IP
|
* @return
|
*/
|
public static synchronized TcpSocketBoot initTcp(String ip) {
|
int port = TCP_PORT;
|
TcpSocketBoot tcpSocketBoot = TcpSocketBoot.getByEndPoint(ip, port);
|
|
if (null == tcpSocketBoot) {
|
final SocketOptions options = new SocketOptions();
|
final MessagePipeLine pipeLine = new MessagePipeLine();
|
pipeLine.add(new LinkMessageDecoder());
|
pipeLine.add(new LinkMessageEncoder());
|
options.setHandleMessage(pipeLine);
|
tcpSocketBoot = TcpClient.init(ip, port, options);
|
tcpSocketBoot.SetHeartbeat(new IHeartbeat() {
|
@Override
|
public void heartbeat() {
|
|
String time = String.valueOf(System.currentTimeMillis());
|
|
JsonObject jsonObject = new JsonObject();
|
jsonObject.addProperty("id", IdUtils.getUUId());
|
jsonObject.addProperty("time_stamp", time);
|
|
GatewayBean gatewayBean= HDLLinkLocalGateway.getInstance().getGatewayByOidOrGatewayId(ip);
|
if(gatewayBean==null){
|
return;
|
}
|
String topic = String.format(TopicConstant.HEARTBEAT, gatewayBean.getOid());
|
|
LinkRequest request = new LinkRequest(topic, jsonObject.toString(), false);
|
new HDLConnectHelper(ip, request, null, true).send();
|
}
|
});
|
}
|
return tcpSocketBoot;
|
}
|
}
|
