95992828九五至尊2

音信的发出和保管882828九五至尊手机版

一月 26th, 2019  |  882828九五至尊手机版

上一讲说了rabbitmq在windows环境的安顿,如今日主要说一下音信在发生后,怎样去查看音信,事实上,rabbitmq为我们提供了成效强大的管理插件,大家假如打开这几个插件即可,它也是一个网站,端口是15672,走Http协议的,它每秒会从音讯服务器中拉取最新的音讯,以便让咱们看到最新的queue!

上一讲说了rabbitmq在windows环境的配备,而明天首要说一下音信在发出后,怎么着去查看新闻,事实上,rabbitmq为我们提供了作用强大的管理插件,大家假若打开那些插件即可,它也是一个网站,端口是15672,走Http协议的,它每秒会从音信服务器中拉取最新的音讯,以便让大家看看最新的queue!

一 开始新闻管理连串

一 开始音讯管理种类

1 打开命令行工具

1 打开命令行工具

882828九五至尊手机版 1

882828九五至尊手机版 2

2 输入上面发号施令来拉开新闻管理种类

2 输入下边发号施令来打开新闻管理连串

rabbitmq-plugins enable rabbitmq_management 

rabbitmq-plugins enable rabbitmq_management 

3
在浏览器中输入http://127.0.0.1:15672,用户名和密码都是guest,然后就可以查看我们的队列信息了

3
在浏览器中输入http://127.0.0.1:15672,用户名和密码都是guest,然后就可以查看我们的队列信息了

882828九五至尊手机版 3

882828九五至尊手机版 4


像RabbitMQ推送音信


像RabbitMQ推送信息

1 安装C#相应的包包

1 安装C#对应的包包

<packages>
  <package id="RabbitMQ.Client" version="3.6.6" targetFramework="net45" />
</packages>
<packages>
  <package id="RabbitMQ.Client" version="3.6.6" targetFramework="net45" />
</packages>

2 编写测试代码

2 编写测试代码

  var factory = new ConnectionFactory() { HostName = "localhost" };
            using (var connection = factory.CreateConnection())
            {
                using (var channel = connection.CreateModel())
                {
                    //声明queue
                    channel.QueueDeclare(queue: "hello",//队列名
                                         durable: false,//是否持久化
                                         exclusive: false,//排它性
                                         autoDelete: false,//一旦客户端连接断开则自动删除queue
                                         arguments: null);//如果安装了队列优先级插件则可以设置优先级

                    string message = "Hello Lind!";//待发送的消息
                    var body = Encoding.UTF8.GetBytes(message);

                    channel.BasicPublish(exchange: "",//exchange名称
                                         routingKey: "hello",//如果存在exchange,则消息被发送到名称为hello的queue的客户端
                                         basicProperties: null,
                                         body: body);//消息体
                    Console.WriteLine(" [x] Sent {0}", message);
                }
            }
  var factory = new ConnectionFactory() { HostName = "localhost" };
            using (var connection = factory.CreateConnection())
            {
                using (var channel = connection.CreateModel())
                {
                    //声明queue
                    channel.QueueDeclare(queue: "hello",//队列名
                                         durable: false,//是否持久化
                                         exclusive: false,//排它性
                                         autoDelete: false,//一旦客户端连接断开则自动删除queue
                                         arguments: null);//如果安装了队列优先级插件则可以设置优先级

                    string message = "Hello Lind!";//待发送的消息
                    var body = Encoding.UTF8.GetBytes(message);

                    channel.BasicPublish(exchange: "",//exchange名称
                                         routingKey: "hello",//如果存在exchange,则消息被发送到名称为hello的queue的客户端
                                         basicProperties: null,
                                         body: body);//消息体
                    Console.WriteLine(" [x] Sent {0}", message);
                }
            }


RabbitMQ在命令行里的其余指令介绍


RabbitMQ在命令行里的其余指令介绍

后台管理15672系统,是通过向rabbitmq中开启一个插件来促成的,而在指令行中大家还足以干很多事,上边看一下:

后台管理15672系统,是透过向rabbitmq中开启一个插件来达成的,而在指令行中大家还足以干很多事,上边看一下:

1). 服务器启动与关闭

1). 服务器启动与关闭

      启动: rabbitmq-server –detached

      启动: rabbitmq-server –detached

      关闭:rabbitmqctl stop

      关闭:rabbitmqctl stop

      若单机有几个实例,则在rabbitmqctlh后加–n 指定名称

      若单机有七个实例,则在rabbitmqctlh后加–n 指定名称

2). 插件管理

2). 插件管理

      开启某个插件:rabbitmq-pluginsenable xxx

      开启某个插件:rabbitmq-pluginsenable xxx

      关闭某个插件:rabbitmq-pluginsdisablexxx

      关闭某个插件:rabbitmq-pluginsdisablexxx

      注意:重启服务器后生效。

      注意:重启服务器后生效。

3).virtual_host管理

3).virtual_host管理

      新建virtual_host: rabbitmqctladd_vhost  xxx

      新建virtual_host: rabbitmqctladd_vhost  xxx

      撤销virtual_host:rabbitmqctl  delete_vhost xxx

      撤销virtual_host:rabbitmqctl  delete_vhost xxx

4). 用户管理

4). 用户管理

      新建用户:rabbitmqctl add_user xxxpwd

      新建用户:rabbitmqctl add_user xxxpwd

      删除用户:   rabbitmqctl delete_user xxx

      删除用户:   rabbitmqctl delete_user xxx

      改密码: rabbimqctlchange_password {username} {newpassword}

      改密码: rabbimqctlchange_password {username} {newpassword}

      设置用户角色:rabbitmqctlset_user_tags {username} {tag …}

      设置用户角色:rabbitmqctlset_user_tags {username} {tag …}

                  Tag可以为 administrator,monitoring, management

                  Tag可以为 administrator,monitoring, management

谢谢各位的读书,下一讲我们将介绍MQ里的拉音信!

谢谢各位的开卷,下一讲大家将介绍MQ里的拉新闻!

相关文章

Your Comments

近期评论

    功能


    网站地图xml地图