在禁用HTTP端口时检查RabbitMQ是否已启动并运行的方法可以通过以下步骤进行:
import socket
def check_rabbitmq_running():
rabbitmq_host = 'localhost' # RabbitMQ的主机地址
rabbitmq_port = 5672 # RabbitMQ的默认端口号
try:
# 创建一个TCP套接字并尝试连接到RabbitMQ主机和端口
sock = socket.create_connection((rabbitmq_host, rabbitmq_port), timeout=5)
sock.close()
return True
except (socket.timeout, ConnectionRefusedError):
return False
if check_rabbitmq_running():
print("RabbitMQ已启动并运行")
else:
print("RabbitMQ未启动或未运行")
import requests
def check_rabbitmq_running():
rabbitmq_host = 'localhost' # RabbitMQ的主机地址
rabbitmq_port = 15672 # RabbitMQ的管理插件默认端口号
rabbitmq_username = 'guest' # RabbitMQ的用户名
rabbitmq_password = 'guest' # RabbitMQ的密码
try:
# 发送HTTP GET请求到RabbitMQ的API端点获取运行状态信息
response = requests.get(f"http://{rabbitmq_host}:{rabbitmq_port}/api/overview",
auth=(rabbitmq_username, rabbitmq_password),
timeout=5)
if response.status_code == 200:
return True
else:
return False
except (requests.exceptions.Timeout, requests.exceptions.ConnectionError):
return False
if check_rabbitmq_running():
print("RabbitMQ已启动并运行")
else:
print("RabbitMQ未启动或未运行")
请注意,以上示例代码仅提供了检查RabbitMQ是否已启动并运行的基本方法,具体的实现方式可能因环境和需求而有所不同。在实际应用中,您可能需要根据自己的情况进行适当的调整和扩展。
领取专属 10元无门槛券
手把手带您无忧上云