如何强制关闭客户端连接rabbitmq

Question

我有一个使用 rabbitmq 代理的客户端服务器应用程序。客户端连接到 rabbitmq 并向服务器发送消息。在某些时候，如果服务器决定此客户端不应连接到 rabbitmq，我希望能够强制断开客户端与 rabbitmq 边界的连接。请注意，在我的情况下，我不想向客户端发送消息以断开连接，在服务器端我只想强制断开此客户端与 rabbitmq 的连接。

无法找到 api 执行此操作。提供任何帮助。

Answer 1

您可以通过两种方式使用管理 console plug-in：

手动，转到连接并"force close"。

通过 HTTP API 使用 "delete" /api/connections/name，这里有一个 python 示例：

import urllib2, base64
def calljsonAPI(rabbitmqhost, api):
    request = urllib2.Request("http://" + rabbitmqhost + ":15672/api/" + api);
    base64string = base64.encodestring('%s:%s' % ('guest', 'guest')).replace('\n', '')
    request.add_header("Authorization", "Basic %s" % base64string);
    request.get_method = lambda: 'DELETE';
    urllib2.urlopen(request);
if __name__ == '__main__':
    RabbitmqHost = "localhost";
    #here you should get the connection detail through the api, 
   calljsonAPI(RabbitmqHost, "connections/127.0.0.1%3A49258%20-%3E%20127.0.0.1%3A5672");

Answer 2

您可以将 rabbitmqctl 用于 close/force-close 连接：

rabbitmqctl close_connection <connectionpid> <explanation>

<connectionpid> 来自：

rabbitmqctl list_connections

#or 

rabbitmqctl list_consumers

如何强制关闭客户端连接rabbitmq

how to force close a client connection rabbitmq

rabbitmq

pika

python-pika