daoshenzzg / socket-mqtt Goto Github PK

Hi,mqtt是否支持集群，另外，是否支持mqtt用户名和密码？

您好 可以加一个 您的 qq 交流么，我是 android 开发的。临时过来 写这个 很多不太懂
另外一个问题就是 我看你这个 app 不是启动项把？

因为netty4之后BytBuf加入了计数器概念
我们在创建Server的时候开启了异步执行，如下图：

这个时候呢，在代码执行到ServerDispatchHandler.channelRead()这个方法时，里面有这么一句代码 eventDispatcher.dispatchMessageEvent(ctx, channel, msg);

这句代码的实现是这样的：

因为是异步的情况，在我们还没有读取ByteBuf数据时就已经先执行了如下图这句代码：

这时候ByteBuf已经被释放了，所以我们抛出了io.netty.util.IllegalReferenceCountException: refCnt: 0异常。
解决方法：
1. 改为同步执行

2. 修改作者代码

@service("ClientServiceImpl")
public class ClientServiceImpl implements IClientService {

public String messageSend(String ip,Integer port,String message){
    MsgDecoder decoder = new MsgDecoder();
    MsgEncoder encoder = new MsgEncoder();
    Client client=new Client();
    client.setIp(ip);
    client.setPort(port);
    client.setConnectTimeout(10000);
    client.setCheckHeartbeat(false);
    client.addChannelHandler("decoder", decoder);
    client.addChannelHandler("encoder", encoder);
    client.connect();
    Request request = new Request();
    request.setSequence(1);
    request.setMessage(message);
    Response response=null;
    try {
        response = client.sendWithSync(request, 30000);
        client.shutdown();
        return response.getResult().toString();
    }catch (Exception e){
        client.shutdown();
        log.error("消息发送失败:{},指令:{}",e.getMessage(),message);
        throw new RestfulEx(RestfulStatus.H500,"消息发送失败!");
    }finally {
        //强制回收内存
        client=null;
        decoder=null;
        encoder=null;
        request=null;
        response=null;
        System.gc();
    }
}

}

请问下 这个项目的日志是打印在哪里呢？我想测试，但没找到打印日志和日志配置文件

生产项目应用过吗

// Server端默认使用业务处理线程池。
this.openExecutor = true;

在这种情况下，使用MQTT协议发布消息的时候，dispatchMessageEvent 的时候会出现传值异常，无法解析内容部分，引发IllegalReferenceCountException异常

后面新建了一个类ServerIdleStateHandler并继承IdleStateHandler，添加注解@ChannelHandler.Sharable
，在com/yb/socket/service/server/Server.java中，将原来的IdleStateHandler换成ServerIdleStateHandler才解决。
问题二：注册中心这个怎么使用呢？有没有交流群或者文档之类的，是用tcp客户端连接注册注册中心吗？

是不是写在下图的位置

我用mqttfx测试了一下，除了连接，其他的发送，接收都不走
if (msg instanceof MqttMessage) {
MqttMessage message = (MqttMessage) msg;
MqttMessageType messageType = message.fixedHeader().messageType();
switch (messageType) {
case CONNECT:
this.connect(channel, (MqttConnectMessage) message);
break;
case PUBLISH:
this.publish(channel, (MqttPublishMessage) message);
break;
case SUBSCRIBE:
this.subscribe(channel, (MqttSubscribeMessage) message);
break;
case UNSUBSCRIBE:
this.unSubscribe(channel, (MqttUnsubscribeMessage) message);
break;
case PINGREQ:
this.pingReq(channel, message);
break;
case DISCONNECT:
this.disConnect(channel, message);
break;
default:
if (logger.isDebugEnabled()) {
logger.debug("Nonsupport server message type of '{}'.", messageType);
}
break;
}
}
这段代码