现在,我们安装RabbitMQ web 管理插件,在RabbitMQ 命令行中输入:
rabbitmq-plugins.bat enable rabbitmq_management
就可以启动web 插件

图片.png
在浏览器中访问localhost:15672/用guest/guest可以登录到管理网站。创建一个新的用户:

图片.png
然后还要设置一下这个用户的访问权限:

图片.png
我们修改一下代码,使用ip地址访问RabbitMQ Server,
using RabbitMQ.Client;
using System;
using System.Text;
namespace RabbitMQFirst
{
class Program
{
static void Main(string[] args)
{
//var factory = new ConnectionFactory() { HostName = "localhost" };
var factory = new ConnectionFactory() { HostName = "192.168.0.2" };
using (var connection = factory.CreateConnection())
using (var channel = connection.CreateModel())
{
channel.QueueDeclare(queue: "message",
durable: false,
exclusive: false,
autoDelete: false,
arguments: null);
Console.WriteLine("输入需要传输的消息,输入Exit退出");
var message = Console.ReadLine();
while (message != "Exit")
{
var body = Encoding.UTF8.GetBytes(message);
channel.BasicPublish(exchange: "",
routingKey: "message",
basicProperties: null,
body: body);
Console.WriteLine(" 发送消息 {0}", message);
message = Console.ReadLine();
}
}
Console.WriteLine("按回车退出");
Console.ReadLine();
}
}
}
运行程序,会发生错误:ACCESS_REFUSED,这是因为guest用户被禁止访问,现在再修改一下代码,使用刚才创建的用户:
var factory = new ConnectionFactory() { HostName = "192.168.0.2",UserName="zl", Password="123456" };
再次运行程序,可以正常执行了。