无法连接到正在获取RabbitMQ的rabitmq流,流,客户端,StreamSystemInitializationException:“无法到达端点”错误

ql3eal8s  于 2023-02-22  发布在  RabbitMQ
关注(0)|答案(1)|浏览(264)

我正在尝试创建一个新的rabbitmq流,我的rabbitmq安装在docker中。
下面是我实施的步骤。
1.在Docker中TCP端口5672下安装RabbitMQ
1.启用rabbit流和流管理
1.在我的项目中安装rabbitmq.stream.client nuget
1.

creating connection as below
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";

1.当我执行我得到波纹管错误
异常发生在客户端。'无法到达端点'
谁能告诉我这个错误的解决方法?
谢谢你Anil
我想连接到流,创建流并向流发送消息。

ruyhziif

ruyhziif1#

您需要启用流插件。您可以通过提供环境来实现

rabbitmq-plugins enable rabbitmq_stream

或通过Docker执行:

docker exec rabbitmq rabbitmq-plugins enable rabbitmq_stream

确保通过环境(-e)选项公开流的默认端口5552和localhost,例如:

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

相关问题