一起谈.NET技术,NET下RabbitMQ实践 [配置篇]

     这个系列目前计划写四篇,分别是配置,示例,WCF发布,实战。当然不排除加餐情况。

     介绍:

     rabbitMQ是一个在AMQP协议标准基础上完整的,可服用的企业消息系统。他遵循Mozilla Public License开源协议。采用 Erlang 实现的工业级的消息队列(MQ)服务器。

     RabbitMQ的官方站:http://www.rabbitmq.com/    
     AMQP(高级消息队列协议) 是一个异步消息传递所使用的应用层协议规范,作为线路层协议,而不是API(例如JMS),AMQP 客户端能够无视消息的来源任意发送和接受信息。AMQP的原始用途只是为金融界提供一个可以彼此协作的消息协议,而现在的目标则是为通用消息队列架构提供通用构建工具。因此,面向消息的中间件 (MOM)系统,例如发布/订阅队列,没有作为基本元素实现。反而通过发送简化的AMQ实体,用户被赋予了构建例如这些实体的能力。这些实体也是规范的一 部分,形成了在线路层协议顶端的一个层级:AMQP模型。这个模型统一了消息模式,诸如之前提到的发布/订阅,队列,事务以及流数据,并且添加了额外的特性,例如更易于扩展,基于内容的路由。    
     目前该开源项目已非常成熟,并应用于金融系统等领域,具有高并发效率,高可靠性等特点,并提供了相应的.net客户端实现(含源码)。

     .NET客户端下载链接:http://www.rabbitmq.com/dotnet.html, 目前最新版本号 2.1.1。网上有许多关于在linux平台上的rabbitmq的(包括集群)安装的介绍,如下:
     linux: http://www.javaeye.com/wiki/topic/640537    
     下面是在window环境下的配置:
     首先需要下载erlang运行时环境(Windows binary): http://erlang.org/download.html。选择要安装的程序版本,比如:http://erlang.org/download/otp_win32_R12B-5.exe
     注:本文环境安装在了D盘,形如: D:\Program Files (x86)\erl5.6.5。下面设置一下环境变量:          接着下载RabbitMQ Server(目前最新版本为2.1.1),链接如下:http://www.rabbitmq.com/server.html。下载并安装其中的window安装包到D盘下:
     注: 源码链接http://www.rabbitmq.com/releases/rabbitmq-server/v2.1.1/rabbitmq-server-2.1.1.zip。在CMD命令行下运行上面的rabbitmq server程序:  

D:\rabbitmq\sbin>rabbitmq-server

Activating RabbitMQ plugins ...
0 plugins activated:
        .....
starting file handle cache server                                     ...done
  starting worker pool                                                  ...done
  starting database                                                     ...done
  starting codec correctness check                                      ...done
  -- external infrastructure ready
  starting exchange type registry                                       ...done
  starting exchange type topic                                          ...done
  starting exchange type headers                                        ...done
  starting exchange type fanout                                         ...done
  starting exchange type direct                                         ...done
  starting statistics event manager                                     ...done
  starting logging server                                               ...done
  -- kernel ready
  starting node monitor                                                 ...done
  starting cluster delegate                                             ...done
  starting guid generator                                               ...done
  starting alarm handler                                                ...done
  starting memory monitor                                               ...done
  -- core initialized
  starting empty DB check                                               ...done
  starting exchange recovery                                            ...done
  starting queue supervisor and queue recovery                          ...done
  -- message delivery logic ready
  starting error log relay                                              ...done
  starting networking                                                   ...done
  -- network listeners available

  broker running

      这样rabbitmq server就运行起来了。在使用rabbitmq之前,如果对该项目不太了解的话,可以看一下这两个速成链接:

     AMQP和RabbitMQ入门      rabbitmq 学习-6-rabbitmq基础   
      下面我们使用rabbitmqctl控制台命令(位于D:\rabbitmq\sbin>)来配置vhost,创建用户,密码,绑定权限等。首先创建vhosts,命令如下:
      添加创建虚拟主机:      

D:\rabbitmq\sbin>rabbitmqctl add_vhost dnt_mq   

//注:删除虚拟主机 rabbitmqctl delete_vhost vhostpath

     用下面指定就可以显示出所有虚拟主机信息:   

D:\rabbitmq\sbin>rabbitmqctl list_vhosts
     Listing vhosts ...
     /   (根目录)
     dnt_mq

     下面添加用户和密码(用户名daizhj, 密码:617595):   

D:\rabbitmq\sbin>rabbitmqctl add_user daizhj 617595  //注:修改用户密码:rabbitmqctl change_password username newpassword

      绑定用户权限: 

D:\rabbitmq\sbin>rabbitmqctl set_permissions -p dnt_mq daizhj ".*" ".*" ".*"
   Setting permissions for user "daizhj" in vhost "dnt_mq" ...

      列出用户权限:

D:\rabbitmq\sbin>rabbitmqctl list_user_permissions daizhj  

//注:清除用户权限 rabbitmqctl clear_permissions [-p vhostpath] username
     Listing permissions for user "daizhj" ...
     dnt_mq  .*      .*      .*      client

       到这里,就完成了单机上rabbitmq的环境配置。在下一篇文章中,将会介绍使用其.net客户端进行简单的开发。  

时间: 2024-07-29 22:05:10

一起谈.NET技术,NET下RabbitMQ实践 [配置篇]的相关文章

NET下RabbitMQ实践 [配置篇]

这个系列目前计划写四篇,分别是配置,示例,WCF发布,实战.当然不排除加餐情况. 介绍: rabbitMQ是一个在AMQP协议标准基础上完整的,可服用的企业消息系统.他遵循Mozilla Public License开源协议.采用 Erlang 实现的工业级的消息队列(MQ)服务器. RabbitMQ的官方站:http://www.rabbitmq.com/          AMQP(高级消息队列协议) 是一个异步消息传递所使用的应用层协议规范,作为线路层协议,而不是API(例如JMS),AM

NET 下RabbitMQ实践 [实战篇]

之前的文章中,介绍了如何将RabbitMQ以WCF方式进行发布.今天就介绍一下我们产品中如何使用RabbitMQ的! 在Discuz!NT企业版中,提供了对HTTP错误日志的记录功能,这一点对企业版非常重要,另外存储错误日志使用了MongoDB,理由很简单,MongoDB的添加操作飞快,即使数量过亿之后插入速度依旧不减.     在开始正文之前,先说明一下本文的代码分析顺序,即:程序入口==>RabbitMQ客户端===>RabbitMQ服务端.好了,闲话少说,开始正文!     首先是程序入

NET下RabbitMQ实践 [示例篇]

在上一篇文章中,介绍了在window环境下安装erlang,rabbitmq-server,以免配置用户,权限,虚拟机等内容.今天将会介绍如果使用rabbitmq进行简单的消息入队,出队操作,因为本文演示的环境要用到上文中配置的环境,所以要运行本文sample,请先按上一篇中完成相应环境配置.         首先,我们下载官方的.net客户端软件,链接:http://www.rabbitmq.com/dotnet.html.下载并安装之后,将安装目录下的这两个DLL文件复制到我们示例项目中,并

一起谈.NET技术,NET下RabbitMQ实践 [WCF发布篇]

在之前的两篇文章中,主要介绍了RabbitMQ环境配置,简单示例的编写.今天将会介绍如何使用WCF将RabbitMQ列队以服务的方式进行发布. 注:因为RabbitMQ的官方.net客户端中包括了WCF的SAMPLE代码演示,很适合初学者,所以我就偷了个懒,直接对照它的SAMPLE来说明了,算是借花献佛吧,呵呵.首先我们下载相应源码(基于.NET 3.0),本文主要对该源码包中的代码进行讲解,链接如下:    Binary, compiled for .NET 3.0 and newer (zi

NET下RabbitMQ实践 [WCF发布篇]

在之前的两篇文章中,主要介绍了RabbitMQ环境配置,简单示例的编写.今天将会介绍如何使用WCF将RabbitMQ列队以服务的方式进行发布. 注:因为RabbitMQ的官方.net客户端中包括了WCF的SAMPLE代码演示,很适合初学者,所以我就偷了个懒,直接对照它的SAMPLE来说明了,算是借花献佛吧,呵呵.首先我们下载相应源码(基于.NET 3.0),本文主要对该源码包中的代码进行讲解,链接如下:    Binary, compiled for .NET 3.0 and newer (zi

一起谈.NET技术,NHibernate3剖析:Mapping篇之ConfORM实战(2):原理

ConfORM概述 在上一节中,我用一个简单的例子描述了ConfORM简单使用.留下了很多疑问,大家不解为何使用ConfORM以及怎么使用ConfORM,其内部原理是什么.这节,我们先注重了解一些ConfORM的原理. 你可以到http://code.google.com/p/codeconform/ 获取ConfORM ConfORM重要接口 ConfORM的核心就是实例化一个ObjectRelationalMapper对象和Mapper对象,配置Domain对象,调用Mapper对象的Com

一起谈.NET技术,NHibernate3剖析:Mapping篇之ConfORM实战(1):概览

ORuM思想浮出 对于ORM(Object Relational Mapping)我们太熟悉了,但是我们从另一个角度可以想象出ORuM(Object Relational un-Mapping)的思想理念.我们在程序中仅仅定义Domain, 而想有个工具可以帮助我们"自动化"实现Mapping,我们无需按传统的ORM思想那样为Domain手动编码Mapping. ORuM对于使用者来说更像ORAM(Object-Relational Auto-Mapping)或者ORIM(Object

一起谈.NET技术,重温数据库访问——故事篇

本文想借用故事的方式来说一下ADO.net的工作方式.虽然现在都ORM了,但是了解一下ADO.net还是有必要的. 在茫茫的大海上有许多的岛,其中一个岛的名字叫做"应用程序岛".这座岛上商业非常发达,高楼大厦.店铺林立.但是岛的面积不够大,没有地方建立仓库.所以市长决定,把临近的一座小岛开发出来,专门作为数据仓库来使用,这座岛的名字就叫"数据库岛". 市长在数据库岛上面建立了一个MSSQL数据库,这样各个商场.超市就可以把自己的货物放进去了.两个岛相邻很近,为了便于

一起谈.NET技术,NHibernate3剖析:Mapping篇之ConfORM实战(5):Component语义

Component语义 使用ConfORM"映射"组件,我们无需特别设置,ConfORM内部会根据Domain定义来判定组件,一般而言,没有主键的类就是组件. [Test]public void ComponentMappingDemo(){//show how work with components and how ConfORM understands OOPvar orm = new ObjectRelationalMapper();var mapper = new Mappe