如何使用Cloud foundry Rabbit MQ服务启用Turbine流

Question

我正在尝试将Hystrix CircuitBreaker集成到我的示例应用程序中，我有两个应用程序，一个用作服务器，另一个用作客户端。我可以看到Hystrix.stream表单客户端，CircuitBreaker也运行得很好。

现在我正在使用Turbine stream在一个DashBoard中尝试多个客户端。

在服务器端，我添加了2个依赖项，如下所示：

spring-cloud-starter-turbine-stream
spring-cloud-starter-stream.rabbit

和应用程序上的注释@EnableTurbineStream。

在客户端，我添加了以下依赖项：

spring-cloud-starter-hystrix-stream
spring-cloud-starter-stream.rabbit

这两个应用程序都部署在Pivotal Cloud Foundry中，并绑定到适用于PCF的Rabbit Mq服务。

在客户端部署上，我看到以下例外：

java.io.IOException :null
Caused by : com.rabbitmq.client.ShutDownSignalException :  channel error     :protocol method : #method<channel.close><reply-code=406, reply-test=PRECONDITION-FAILED - equivalent arg 'type' for exchange 'spring.cloud.hystrix.stream' in vhost '' : receieved 'topic' but current is 'Direct', class-id=40, methid-id=10>

在使用Turbine服务器时，我得到了

data : {type : ping}


Management port on turbine server is set to -1.

在Rabbit MQ中推送Hystrix流是否需要在客户端和服务器端进行任何MQ配置？任何帮助都将不胜感激。

Answer 1

客户端错误告诉您，您正在尝试声明一个已经存在但类型冲突的交换。您可以通过更改交换名称或只删除旧名称来修复它。或者简单地删除服务并在Cloud Foundry中重新创建它，