一个winform带你玩转rabbitMQ(三) 附源码

标签：des   winform   blog   http   io   os   ar   for   strong   

第一章. 安装,简介和初探

第二章. exchange，queue,binding介绍 订阅发布 工作队列(消费者集群)

本章收尾 介绍API CommandLine 以及其他功能

源码地址 https://github.com/dubing/MaoyaRabbit

RabbitMQ API

　　RabbitMQ Server提供了丰富的http api。

　　举个列子

　　需要HTTP基本身份验证。默认的用户名/密码为guest/guest。

　　这些返回值得意义我从官网搬来解释，为了避免翻译的问题导致大家理解的误差这里直接给出原文

　　又或者通过api查询虚拟主机
　　
　　许多api的URI需要一个虚拟主机路径的一部分的名字，因为名字只有唯一在一个虚拟主机识别物体。作为默认的虚拟主机称为“/”，这??将需要被编码为“％2F”。

　　在我的demo程序中对应的api功能可以通过这里的功能来实现

　　其更丰富的功能可以参考官网说明文档 http://hg.rabbitmq.com/rabbitmq-management/raw-file/3646dee55e02/priv/www-api/help.html

　　以及 http://hg.rabbitmq.com/rabbitmq-management/raw-file/rabbitmq_v3_3_5/priv/www/api/index.html

　　一般来说我们常用的我在应用程序中已经给出 例如查看所有队列等

 RabbitMQ CommandLine

　　除了丰富的http api，rabbitmq server自然也有其很全面命令行。

　　例如查询所有exchange。

　　查询所有队列以及他们包含的消息数目

　　rabbitmqctl更多的命令说明参考 http://www.rabbitmq.com/man/rabbitmqctl.1.man.html

Message的BasicGet于consume的区别

 　　consume的功能上一张介绍过，basicget更偏向于我们平时用过的其他类型的MessageQueue，它就是最基本的接受消息，consume的消费针对basicget来说属于一个长连接于短连接的区别。

消费者关系一旦确定，基本上默认它就是在侦听通道的消息是否在生产。而basicget则是由客户端手动来控制。

　　在demo中在下图所示处区分

　　如果你选择了消费消息，那么基本上代码层面是这样来完成的

                    var consumer = new QueueingBasicConsumer(channel);
                    channel.BasicQos(0, 1, false);
                    channel.BasicConsume(queue.name, rbAckTrue.Checked, consumer);
                    while (true)
                    {
                        var e = consumer.Queue.Dequeue();
                        MessageBox.Show(string.Format("队列{0}获取消息{1},线程id为{2}", queue.name, Encoding.ASCII.GetString(e.Body), Process.GetCurrentProcess().Id));
                        Thread.Sleep(1000);
                    }

上一章节介绍了 消费者如何做分布式或者说是集群，很多同学可能对server端的集群也很感兴趣，鉴于单机的应用程序这里就不多介绍了，给出官网的传送门

http://www.rabbitmq.com/clustering.html

本篇收尾 有点狗尾续貂的感觉 旨在按照之前的计划 放出源码 希望对大家有帮助 

一个winform带你玩转rabbitMQ(三) 附源码

标签：des   winform   blog   http   io   os   ar   for   strong   

原文地址：http://www.cnblogs.com/dubing/p/4021891.html