如何检测客户端掉线 about coolpy7 HOT 11 CLOSED

from coolpy7.

请把你在使用的客户端库告诉我，我去复现一下。

from coolpy7.

我用的是
github.com/eclipse/paho.mqtt.golang
谢谢

from coolpy7.

from coolpy7.

是的，没有特殊的环境的

from coolpy7.

from coolpy7.

请参考这个订阅示例：https://github.com/Coolpy7/coolpy7_benchmark/blob/master/clients_samples/paho_golang_sub_client.go
这里有两点需要说明：1.SetDefaultPublishHandler里的处理代码必须没有阻塞，需要现在这样的代码去处理接收处理逻辑。2.如果网络环境极为不稳定，可以把我注释掉的自动重连功能开启，再把clear session设置为false.

from coolpy7.

谢谢，马上试下

from coolpy7.

按上面的例子已经理好，谢谢

from coolpy7.

from coolpy7.

还有一个问题需要注意，不然的话很可能会把系统的cpu用尽，原因是for goruntine时没有没有做时间中断，所以cpu会一直占用很高，解决办法是增加for的time.sleep，代码如下：

for {
		select {
		case incoming := <-d.Choke:
			//d.mqttHandler(incoming.Client, incoming.Message)
		case <-d.Quit:
			return
		default:
			time.Sleep(20*time.Millisecond) //必须增加此句代码让for行业适当的中断时间，cpu才能合理释放。
		}
	}

from coolpy7.