| | |
|---|
| | |
|
|---|
| | | private final IClient client;
|
|---|
| | | private IHeartbeat iHeartbeat;
|
|---|
| | |
|
|---|
| | | public void SetHeartbeat(IHeartbeat iHeartbeat) {
|
|---|
| | | this.iHeartbeat = iHeartbeat;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * 当前接收到数据的时间
|
|---|
| | | */
|
|---|
| | |
|---|
| | | /**
|
|---|
| | | * 记录所有SocketBoot
|
|---|
| | | */
|
|---|
| | | final static List<TcpSocketBoot> TCP_SOCKET_BOOT_LIST = new ArrayList<>();
|
|---|
| | | final static List<TcpSocketBoot> TCP_SOCKET_BOOT_LIST = new ArrayList();
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * 根据IP地址及端口获取当前socketBoot
|
|---|
| | | *
|
|---|
| | | * @param ipAddress
|
|---|
| | | * @param port
|
|---|
| | | * @return
|
|---|
| | |
|---|
| | | return null;
|
|---|
| | | }
|
|---|
| | | for (TcpSocketBoot tcpSocketBoot : TCP_SOCKET_BOOT_LIST) {
|
|---|
| | | if (ipAddress.equals(tcpSocketBoot.getClient().getOptions().getIp()) && tcpSocketBoot.getClient().getOptions().getPort() == port) {
|
|---|
| | | if(ipAddress.equals(tcpSocketBoot.getClient().getOptions().getIp())&& tcpSocketBoot.getClient().getOptions().getPort()==port)
|
|---|
| | | {
|
|---|
| | | return tcpSocketBoot;
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|---|
| | | public void run() {
|
|---|
| | | while (true) {
|
|---|
| | | try {
|
|---|
| | | if (!connected) {
|
|---|
| | | if(connected==false){
|
|---|
| | | Thread.sleep(100);
|
|---|
| | | continue;
|
|---|
| | | }
|
|---|
| | |
|---|
| | | });
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * 重新连接
|
|---|
| | | */
|
|---|
| | |
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * 发送无需回调
|
|---|
| | | *
|
|---|
| | | * @param msg 发送的数据
|
|---|
| | | */
|
|---|
| | | public void sendMsg(byte[] msg) {
|
|---|
| | |
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | |
|
|---|
| | | // /**
|
|---|
| | | // * 断开全部的Link网关连接
|
|---|
| | | // */
|
|---|
