一、下载NuGet支持的RabbitMQ.Client客户端库与安装RabbitMQ服务。

1、安装客户端库操作服务。

一、RabbitMQ安装与测试连接

 

2、安装服务。 https://www.rabbitmq.com/install-windows.html

步骤一、下载Erlang。

步骤二、下载RabbitMQ服务

一、RabbitMQ安装与测试连接

 

采纳版本。

一、RabbitMQ安装与测试连接

 

一、RabbitMQ安装与测试连接

 一、RabbitMQ安装与测试连接

下载实践:

 一、RabbitMQ安装与测试连接

 一、RabbitMQ安装与测试连接

 一、RabbitMQ安装与测试连接

 

3、运行服务:

1、执行rabbitmq命令行工具(rabbitmqctl ):

  rabbitmqctl -q status       //打印了一些rabbitmq服务状态信息,包括内存,硬盘,和使用erlong的版本信息

  rabbitmqctl list_queues     //查看所有队列消息

一、RabbitMQ安装与测试连接

 一、RabbitMQ安装与测试连接 

RabbitMQ GUID使用:

安装了Rabbitmq后,默认也安装了该管理工具,执行命令即可启动:

  rabbitmq-plugins enable rabbitmq_management(先定位到rabbitmq安装目录) 

启动后,直接在浏览器地址输入:http://localhost:15672/   账号密码都是:guest    

 一、RabbitMQ安装与测试连接

4、添加用户、授权、登录:

一、RabbitMQ安装与测试连接

一、RabbitMQ安装与测试连接

5、代码测试:

为了展示RabbitMQ的基本使用,我们发送一个HelloWorld消息,然后接收并处理:

首先创建一个控制台程序,用来将消息发送到RabbitMQ的消息队列中,代码如下:

一、RabbitMQ安装与测试连接
        static void Main(string[] args)
        {
            var factory = new ConnectionFactory();
            factory.HostName = "localhost";
            factory.UserName = "Bruce";
            factory.Password = "Bruce123456";
            using (var connection = factory.CreateConnection())
            {
                using (var channel = connection.CreateModel())
                {
                    //1、创建名为queue1队列。
                    channel.QueueDeclare("queue1", false, false, false, null);
                    string message = "Hello World2";
                    var body = Encoding.UTF8.GetBytes(message);
                    //2、消息是实体对象的话,需要序列化和然后转化为二进制数组。
                    channel.BasicPublish("", "queue1", null, body);
                    Console.WriteLine(" set {0}", message);
                }
            }
        }
View Code

相关文章: