我感到有些无助,所以我在这里向集体智慧求助,希望能得到一种奇迹。
我已经使用默认设置在 Linux 机器上安装了 RabbitMQ。
当我使用这段代码(以及默认的 RabbitMQ 安装配置)时,一切都很好。
var connectionFactory = new ConnectionFactory();
connectionFactory.HostName = "192.168.0.12";
IConnection connection = connectionFactory.CreateConnection();
但是当我将用户添加到RabbitMQ并尝试使用以下代码时(用户名和密码已更改以保护隐私:)
var connectionFactory = new ConnectionFactory();
connectionFactory.HostName = "192.168.0.12";
connectionFactory.UserName = "user";
connectionFactory.Password = "password";
IConnection connection = connectionFactory.CreateConnection();
connectionFactory.CreateConnection()
方法会抛出以下异常:
BrokerUnreachableException
None of the specified endpoints were reachable
查看RabbitMQ日志文件,我发现它抱怨凭据:
{amqp_error,access_refused,
"PLAIN login refused: user 'user' - invalid credentials",
'connection.start_ok'}}
问题是我对用户名和密码非常有信心,但是我无论如何都找不到解决方案。
我一定是错过了什么显而易见的东西,但我想不出来是什么。 如果有任何有用的提示,我将不胜感激。
VirtualHost
和Protocol
。顺带一提。 - Kirk Woll