bifromqio / bifromq

A Multi-Tenancy MQTT broker adopting Serverless architecture
https://bifromq.io
Apache License 2.0
619 stars 61 forks source link

客户端订阅了2个共享组,取消订阅其中一个,竟然收不到另一个topic的消息了 #91

Closed masterOcean closed 3 months ago

masterOcean commented 3 months ago

客户端订阅了2个共享组,取消订阅其中一个,竟然收不到另一个topic的消息了

  1. 150个客户端订阅了 $share/code2/zh/test/4,之后成功收到 topic = zh/test/4 的消息,
  2. 再订阅 $share/code1/zh/test/2, 之后 zh/test/4 和 zh/test/2 的消息都能收到。
  3. 取消订阅 $share/code1/zh/test/2
  4. 但客户端竟然也收不到 topic = zh/test/4 的消息了。DistedEvt 打印如下, fanout=1 说明找到了一个订阅者吧,但这期间没有其他客户端订阅 zh/test/4 和 zh/test/2
    messagePack {
    topic: "zh/test/4"
    message {
    messageId: 18446744073709551615
    payload: "555"
    timestamp: 1719318299123
    expiryInterval: 2147483647
    }
    }
    ], fanout=1)

BifroMQ

Configurations

OS(please complete the following information):

JVM:

Performance Related

Additional context Add any other context about the problem here.