我正在尝试创建一个新的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
我想连接到流,创建流并向流发送消息。
1条答案
按热度按时间ruyhziif1#
您需要启用流插件。您可以通过提供环境来实现
或通过Docker执行:
确保通过环境(-e)选项公开流的默认端口5552和localhost,例如: