无法连接到 rabitmq 流获取 RabbitMQ.Stream.Client.StreamSystemInitialisationException: 'no endpoints could be reached' 错误

Question

我正在尝试创建一个新的 rabbitmq 流，我的 rabbitmq 安装在 docker 中。

以下是我实施的步骤。

1. 在 docker 中的 TCP 端口 5672 下安装了 RabbitMQ

2. 启用兔子流和流管理

3. 在我的项目中安装了 rabbitmq.stream.client nuget

4. creating connection as below
   

5. var config = new StreamSystemConfig
   {
       UserName = "guest",
       Password = "guest",
       VirtualHost = "/"
   };
   // Connect to the broker and create the system object
   // the entry point for the client.
   // Create it once and reuse it.
   var system = await StreamSystem.Create(config);
   
   const string stream = "my_first_stream";
   

6. 当我执行时，我得到了吼叫错误

   RabbitMQ.Stream.Client.StreamSystemInitialisationException：“无法到达端点”

谁能告诉我这个错误的解决方案？

谢谢阿尼尔

我想连接到流并创建流并将消息发送到流。

Answer 1

您需要启用流插件。 您可以通过提供环境来做到这一点

rabbitmq-plugins enable rabbitmq_stream

或者通过 docker exec:

docker exec rabbitmq rabbitmq-plugins enable rabbitmq_stream

确保通过环境 (-e) 选项公开流默认端口 5552 和本地主机，例如：

docker run -it --rm --name rabbitmq -p 5672:5672 -p 15672:15672 -p 5552:5552 -e RABBITMQ_SERVER_ADDITIONAL_ERL_ARGS='-rabbitmq_stream advertised_host localhost' rabbitmq:3.11-management