StreamBridge RabbitMQ 连接在 Cloud Foundry 上被拒绝
StreamBridge RabbitMQ Connection Denied on Cloud Foundry
我正在尝试遵循参考 link (StreamBridge) 并创建了一个简单的 HTTP 侦听器应用程序,它接收 POST 消息,使用模式 class 验证传入消息 & forward 对 RMQ 的请求。当我使用 SCDF 部署 war(在 CF 中)时,我看到 RMQ 连接被拒绝错误。但是,如果我使用 cf push 部署 war,它就可以正常工作。我是否需要在 StreamBridge WAR 中进行任何其他 RMQ 配置?我什至比较了 RMQ Connection 的环境变量,它在两个应用程序中看起来都一样(SCDF 部署的应用程序和 cf 推送应用程序)。
org.springframework.messaging.MessageHandlingException:消息处理程序发生错误[org.springframework.integration.amqp.outbound.AmqpOutboundEndpoint@6478a81c];嵌套异常是 org.springframework.amqp.AmqpConnectException: java.net.ConnectException: Connection refused (Connection refused), failedMessage=GenericMessage [payload=byte[25], headers={contentType=application/json, id=9720e9cb-3fa1- 1634-2e4c-55a24fa68c8b,时间戳=1619097558777}]] 根本原因
我设法解决了 StreamBridge 的问题。我没有找到关于 RMQ 连接(cf 推送与流部署)的不同行为的解释,但是通过在创建流时将 RMQ 详细信息(主机、用户名、密码和端口)作为参数传递就可以了。
我正在尝试遵循参考 link (StreamBridge) 并创建了一个简单的 HTTP 侦听器应用程序,它接收 POST 消息,使用模式 class 验证传入消息 & forward 对 RMQ 的请求。当我使用 SCDF 部署 war(在 CF 中)时,我看到 RMQ 连接被拒绝错误。但是,如果我使用 cf push 部署 war,它就可以正常工作。我是否需要在 StreamBridge WAR 中进行任何其他 RMQ 配置?我什至比较了 RMQ Connection 的环境变量,它在两个应用程序中看起来都一样(SCDF 部署的应用程序和 cf 推送应用程序)。
org.springframework.messaging.MessageHandlingException:消息处理程序发生错误[org.springframework.integration.amqp.outbound.AmqpOutboundEndpoint@6478a81c];嵌套异常是 org.springframework.amqp.AmqpConnectException: java.net.ConnectException: Connection refused (Connection refused), failedMessage=GenericMessage [payload=byte[25], headers={contentType=application/json, id=9720e9cb-3fa1- 1634-2e4c-55a24fa68c8b,时间戳=1619097558777}]] 根本原因
我设法解决了 StreamBridge 的问题。我没有找到关于 RMQ 连接(cf 推送与流部署)的不同行为的解释,但是通过在创建流时将 RMQ 详细信息(主机、用户名、密码和端口)作为参数传递就可以了。