|
@@ -69,9 +69,6 @@ public class NettyClient {
|
|
|
kafkaProducer.send(msg);
|
|
|
}else {
|
|
|
log.info("给云端发送数据:[{}]", msg);
|
|
|
- log.info("channel:{}",channel);
|
|
|
- channel.isWritable();
|
|
|
- log.info("chanel结束");
|
|
|
if (channel.isWritable()) {
|
|
|
try {
|
|
|
//!!!!!!注意,NettyMessage<T>是有泛型的,如果把发送一个数据,接收方必须有一个和<T>的全限定类名完全一样的实体类,
|