消息中间件RabbitMQ02：账号的注册、点对点推送信息

一、默认用户登录和账号注册

1.登录

        安装好了RMQ之后，我们可以访问如下地址： 

RabbitMQ Management

        输入默认的管理员密码，4.1.0的管理员账号和密码是：

guest
guest

 2.添加账号

consumer
consumer

添加成功后：

 

角色的对比： 

标签 (中文)	标签 (英文)	描述
管理	Management	用户可以访问管理插件。
政策制定者	Policymaker	用户可以访问管理插件，并管理他们有权访问的虚拟主机（vhosts）的策略和参数。
监听	Monitoring	用户可以访问管理插件，查看所有连接、通道以及节点相关信息。
管理员	Administrator	用户可以做监控可以做的所有事情，管理用户、虚拟主机和权限，关闭其他用户的连接，管理所有虚拟主机的策略和参数。

3.添加用户权限

         我们刚刚添加了用户consumer，但是他不具备任何权限，我们可以为他配置权限，先点击进去

 

 

 

 二、HelloWorld入门Demo

1.编写消费者代码并运行

class Program
{static async Task Main(string[] args){// 01 RabbitMQ 配置string hostname = "localhost";  // RabbitMQ 主机名string username = "consumer";   // RabbitMQ 账号string password = "consumer";   // RabbitMQ 密码string queueName = "hello";     // 队列名称,和生产者保持一致var factory = new ConnectionFactory() { HostName = hostname, UserName = username, Password = password };// 02 创建连接using (var connection = await factory.CreateConnectionAsync())using (var channel = await connection.CreateChannelAsync()){// 03 声明一个队列（队列名称，MQ持久化 重启不丢失=true，队列私有化 仅供第一个消费者使用=true，无人使用 自动删除=true ，附加参数）await channel.QueueDeclareAsync(queueName, false, false, false, null);// 04 创建消费者实例var consumer = new AsyncEventingBasicConsumer(channel);// 05 设置消息到达时的回调函数（相当于接收消息后，需要执行的方法）consumer.ReceivedAsync +=  async (model, ea) =>{var body = ea.Body.ToArray();var message = Encoding.UTF8.GetString(body);//将消息转换为字符串Console.WriteLine($"消费者接受了信息：{message}");// 处理完消息后手动签收确认消息await channel.BasicAckAsync(ea.DeliveryTag, false);Console.WriteLine("消息已确认: " + message);};// 06 启动消费者，开始接收消息（队列名称，需要手动签收消息=false，回调函数）await channel.BasicConsumeAsync(queueName, false, consumer);Console.WriteLine("消费者可点击Enter退出...");Console.ReadLine();}}
}

此时我们可以观察到，管理网站的变化：

 

2.编写生产者代码并运行 

class Program
{static async Task Main(string[] args)  // 将Main方法修改为异步方法{// 01 RabbitMQ 配置string hostname = "localhost";  // RabbitMQ 主机名string username = "guest";      // RabbitMQ 账号string password = "guest";      // RabbitMQ 密码string queueName = "hello";     // 队列名称var factory = new ConnectionFactory() { HostName = hostname, UserName = username, Password = password };// 02 创建连接using (var connection = await factory.CreateConnectionAsync())  // 使用CreateConnectionAsync方法using (var channel = await connection.CreateChannelAsync()){// 03 声明一个队列（队列名称，MQ持久化 重启不丢失=true，队列私有化 仅供第一个消费者使用=true，无人使用 自动删除=true ，附加参数）await channel.QueueDeclareAsync(queueName, false, false, false, null);// 04 编辑消息内容（存成字节数组形式）string message = "Hello, World!";byte[] body = Encoding.UTF8.GetBytes(message);// 05 发送消息到队列（交换机名称 没用到可为空，队列名称，字节数组形式的消息内容）await channel.BasicPublishAsync(string.Empty, queueName, body);Console.WriteLine($"生产者发送了消息： {message}");}Console.WriteLine("生产者可点击Enter退出...");Console.ReadLine();}
}

此时观察控制台程序，说明已经完成“生产者-MQ-消费者”流程：