基于 stomp.py 的持久客户端填充 ActiveMQ 中的订阅者列表

Posted

技术标签:

【中文标题】基于 stomp.py 的持久客户端填充 ActiveMQ 中的订阅者列表【英文标题】:stomp.py based durable client fills up subscribers list in ActiveMQ 【发布时间】:2011-04-16 00:09:43 【问题描述】:

我对 ActiveMQ 上的持久客户端有疑问。我在 Python 中使用 stomp.py。

 conn.start()
 conn.connect(wait=True, header = 'client-id': 'myhostname' )
 conn.subscribe(
            '/topic/testTopic', ack='auto',
            headers = 
                'activemq.subscriptionName': 'myhostname',
                'selector': "clientid <> '%s'" % 'myhostname'
            
)

从我的代码中可以看出,我将 clientId 设置为我自己的主机名。如随附的屏幕截图(如下)所示,clientId 显示为类似于“ID:Atlas....”。

问题是每次我断开我的基于 stomp.py 的客户端时,我下次再次连接时都会得到一个新的“clientId”。这会导致 ActiveMQ 中的订阅者列表填满: (上图显示了我的 ActiveMQ 代理上的一个订阅者。下次我断开连接然后连接时,上面的条目仍会保留,并且会添加另一个条目。很快我的列表中有很多订阅者。

奇怪的是选择器 100% 工作(我通过将 更改为 = 来验证这一点,以便消息返回给我),所以 clientId 必须以某种方式工作。

【问题讨论】:

【参考方案1】:

我解决了,整个问题是由于一个简单的拼写错误。行:

conn.connect(wait=True, header = 'client-id': 'myhostname' )

应包含复数形式的“标题”。

【讨论】:

看起来他们在以后的版本中修复了这个问题。 kwarg 现在是“标题”

以上是关于基于 stomp.py 的持久客户端填充 ActiveMQ 中的订阅者列表的主要内容,如果未能解决你的问题,请参考以下文章

stomp.py heartbeats 参数的函数

activemq之python使用stomp协议

基于LNMT的session持久机制的多种方法

用于持久订阅的 stomp 协议常规序列

Sentinel dashboard持久化,持久化到nacos和数据库中(基于sentinel 1.8.2)

Facebook Messenger 嵌套持久菜单错误