.Net Core中使用RabbitMQ(二)——使用IP地址访问RabbitMQ服务

现在,我们安装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" };

再次运行程序,可以正常执行了。

©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容