tx7do / kratos-transport

kratos transport layer extension
MIT License
340 stars 92 forks source link

死锁 #72

Closed cuijianguo closed 6 months ago

cuijianguo commented 8 months ago

https://github.com/tx7do/kratos-transport/blob/main/broker/subscriber.go 请问 第35 47行 不会造成死锁吗?

fredmuyu commented 6 months ago

我测试的时候也出现了该问题, 在stop mqtt 服务的时候,调用了 Clear,Clear调用了Unsubscribe,结果 mqtt里面的Unsubscribe又调用了Remove, 导致Clear跟Remove里面的sm.Lock()出现了死锁 @tx7do

tx7do commented 6 months ago

确实有问题。