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