-1

我遇到了问题，我无法连接到 amazon mq 上的在线 activemq 代理。这是我的代码 +++++++++++++++++++++++++++++++++++++

import time
import sys
import os
import stomp
from stomp import *
#import pika

user = os.getenv("admin")
password = os.getenv("password")
host = os.getenv("stomp+ssl://online_host:61614")
port = os.getenv("61614")
destination = sys.argv[1:2] or ["/topic/event"]
destination = destination[0]

messages = 1000
data = "Hello World from Python"
conn = stomp.Connection(host_and_ports=[(host, port)])
#conn.set_listener('print', PrintingListener())
#conn.start()
conn.connect(login=user, passcode=password)

for i in range(0, messages):
    conn.send(data, destination=destination, persistent='false')

conn.send("SHUTDOWN", destination=destination, persistent='false')

conn.disconnect(receipt=None)

++++++++++++++++++++++++++++++++++++++++++++++++++++你能请帮帮我。我收到一个错误，因为 ++++++++++++++++++++++++++++++++++++++ 无法连接到主机无，端口无 Traceback（最近一次调用最后）：文件“C:\Users\navee\PycharmProjects\apachekafka\venv\lib\site-packages\stomp\transport.py”，第 730 行，在尝试连接 self.socket = socket.create_connection( host_and_port, self.__timeout) 文件“C:\Users\navee\AppData\Local\Programs\Python\Python38-32\lib\socket.py”，第 787 行，在 getaddrinfo(host, port, 0, SOCK_STREAM）：文件“C:\Users\navee\AppData\Local\Programs\Python\Python38-32\lib\socket.py”，第 914 行，在 getaddrinfo 中用于 _socket.getaddrinfo（主机、端口、系列、类型，原型，标志）：socket.gaierror：

+++++++++++++++++++++++++++++++++++++++++++++++++++

4

2 回答 2

0

我也有类似的问题。尝试了以下。 无法在 python 中使用 STOMP 连接到 MQ 代理

虽然对我不起作用.. !! 干杯..！

于 2020-02-11T08:11:14.877 回答
0

查看您记录的错误：

'无法连接到主机无，端口无'

看起来您的主机和端口环境变量不存在。

除了，

通过 ssl 进行通信时，您应该调用 conn.set_ssl

conn.set_ssl(for_hosts=[(host, port)])

并在连接时设置等待参数，这样你就不会在连接成功之前尝试发送

conn.connect(login=user, passcode=password, wait=True)
于 2020-02-11T15:35:04.377 回答