|
@ -6,6 +6,7 @@ import io.netty.buffer.ByteBuf; |
|
|
import io.netty.channel.ChannelHandler; |
|
|
import io.netty.channel.ChannelHandler; |
|
|
import io.netty.channel.ChannelHandlerContext; |
|
|
import io.netty.channel.ChannelHandlerContext; |
|
|
import io.netty.channel.ChannelInboundHandlerAdapter; |
|
|
import io.netty.channel.ChannelInboundHandlerAdapter; |
|
|
|
|
|
import lombok.extern.slf4j.Slf4j; |
|
|
import org.springframework.stereotype.Component; |
|
|
import org.springframework.stereotype.Component; |
|
|
|
|
|
|
|
|
import javax.annotation.Resource; |
|
|
import javax.annotation.Resource; |
|
@ -14,6 +15,7 @@ import java.nio.charset.Charset; |
|
|
/** |
|
|
/** |
|
|
* @author 逗 |
|
|
* @author 逗 |
|
|
*/ |
|
|
*/ |
|
|
|
|
|
@Slf4j |
|
|
@ChannelHandler.Sharable |
|
|
@ChannelHandler.Sharable |
|
|
@Component |
|
|
@Component |
|
|
public class SimpleClientHandler extends ChannelInboundHandlerAdapter{ |
|
|
public class SimpleClientHandler extends ChannelInboundHandlerAdapter{ |
|
@ -24,7 +26,9 @@ public class SimpleClientHandler extends ChannelInboundHandlerAdapter{ |
|
|
public void channelRead(ChannelHandlerContext ctx, Object msg) { |
|
|
public void channelRead(ChannelHandlerContext ctx, Object msg) { |
|
|
if (msg instanceof ByteBuf) { |
|
|
if (msg instanceof ByteBuf) { |
|
|
String value = ((ByteBuf) msg).toString(Charset.defaultCharset()); |
|
|
String value = ((ByteBuf) msg).toString(Charset.defaultCharset()); |
|
|
System.out.println("服务器端返回的数据:" + value.substring(value.length()-3,value.length())); |
|
|
|
|
|
|
|
|
log.info("服务器端返回的数据:{}",value.substring(value.length() > 500 ? value.length()-300 : 0)); |
|
|
|
|
|
|
|
|
if(StrUtil.isNotEmpty(value) && value.lastIndexOf("not online") == -1) { |
|
|
if(StrUtil.isNotEmpty(value) && value.lastIndexOf("not online") == -1) { |
|
|
thermalImageryService.disposeMessage(value); |
|
|
thermalImageryService.disposeMessage(value); |
|
|
} |
|
|
} |
|
|