我RabbitMQ
在我的应用程序中使用聊天模块。它适用于本地服务器,但不知何故我无法连接到remote
RabbitMQ 服务器。当我尝试发送消息时,我不断收到此错误。
接收到的连接:<RMQConnection: 0x6000022e2eb0> disconnectedWithError: Error Domain=GCDAsyncSocketErrorDomain Code=7 "Socket closed by remote peer" UserInfo={NSLocalizedDescription=Socket close by remote peer}
我的快速代码如下所示:
func getRabbitMQUrl() -> String{
var components = URLComponents()
components.scheme = "amqps"
components.host = "[broker-id].mq.[region].amazon.aws.com"
components.user = "[username]"
components.password = "[passowrd]"
components.port = 5671
let url = components.url?.absoluteString ?? "-"
print("RabbitMQ URL", url)
return url
}
let uri = getRabbitMQUrl()
let conn = RMQConnection(uri: uri, delegate: RMQConnectionDelegateLogger())
conn.start()
let ch = conn.createChannel()
let q = ch.queue(UUID().uuidString, options: .durable)
let exc = ch.direct("my-exchange-name-here")
q.bind(exc, routingKey: "my-routing-key")
q.subscribe({(_ message: RMQMessage) -> Void in
print("Message received")
})
在使用本地服务器时,我设置了 uri "amqp://[username]:[password]@localhost:5672"
,这按预期工作。
PS:当我设置此订阅者时,我没有收到任何有关连接或任何错误消息。所以我认为它连接到服务器没有任何问题。
但是,当我从 iOS 应用程序发送消息时,后端会发布它,因此 iOS 应用程序应该会收到它。正是在这个时候,它给了我上面的错误!
编辑:尽管 C# 后端能够使用 RabbitMQ 远程服务器成功发布和订阅消息。失败的只是iOS客户端!
任何帮助,将不胜感激!