| | |
| | | import com.ard.tianyu.domain.dto.signal.SignalInfo; |
| | | import com.ard.tianyu.domain.dto.state.UavState; |
| | | import com.ard.tianyu.domain.dto.telemetry.TelemetryData; |
| | | import com.ard.tianyu.component.netty.TyNettyTcpClient; |
| | | import com.ard.tianyu.component.netty.NettyTcpClient; |
| | | import com.ard.tianyu.component.netty.command.control.AbsAngleControlCmd; |
| | | import com.ard.tianyu.component.netty.command.control.AngleControlCmd; |
| | | import com.ard.tianyu.component.netty.command.control.SpeedControlCmd; |
| | |
| | | */ |
| | | private void sendMessage(String key, BaseCmd msg) { |
| | | try { |
| | | ChannelFuture future = TyNettyTcpClient.channels.get(key).getChannelFuture(); |
| | | ChannelFuture future = NettyTcpClient.channels.get(key).getChannelFuture(); |
| | | Channel channel = future.channel(); |
| | | if (channel.isActive()) { |
| | | InetSocketAddress ipSocket = (InetSocketAddress) channel.remoteAddress(); |