RabbitMQ安装配置和基于EasyNetQ驱动的基础使用

简介:

RabbitMQ基本概念和原理

1.AMQP,即Advanced Message Queuing Protocol,高级消息队列协议,是应用层协议的一个开放标准,为面向消息的中间件设计。

2.RabbitMQ是一个开源的AMQP实现,服务器端用Erlang语言编写。

3.Channel 

  Channel是我们与RabbitMQ打交道的最重要的一个接口,我们大部分的业务操作是在Channel这个接口中完成的,包括定义Queue、定义Exchange、绑定Queue与Exchange、发布消息等。

4.Exchange(生产者将消息发送到Exchange(交换器),由Exchange将消息路由到一个或多个Queue中(或者丢弃),RabbitMQ常用的Exchange Type有fanout、direct、topic、headers这四种)

5.Queue(RabbitMQ的内部对象,用于存储消息)

6.基本工作原理

 客户端(生产者) send Message -->Exchange (交换机通过不同的类型将消息保存到对应的queue)-->Queue  

 客户端(消费者)通过订阅来消费queue中的消息。

 以上基础概念整理来源于 RabbitMQ基础概念详细介绍 

在Windows系统中安装RabbitMQ

  1. 下载安装erlang (我用的是otp_win64_19.3版本)  

      下载地址 http://www.erlang.org/downloads(根据操作系统选择32还64位)  

  2. 下载安装rabbitmq-server(我用的是rabbitmq-server-3.6.10版本)

     下载地址 http://www.rabbitmq.com/install-windows.html

     安装好后,在看装目录下看到

    

     接下来用启用DOS命令

a. cd 到sbin目录下,我的安装目录是D:\RabbitMQServer\rabbitmq_server-3.6.10\sbin, 输入D: 回车,cd  RabbitMQServer\rabbitmq_server-3.6.10\sbin

 

b. 查看安装是否成功命令 :rabbitmqctl status

c.安装管理插件命令:rabbitmq-plugins enable rabbitmq_management

安装成功,在浏览器中输入 http://127.0.0.1:15672/

 

输入来宾账号 guest 密码 guest ,成功登陆进来,是不是有点小激动。

 guest 账号是管理员账号,可以添加Exchanges,Queues,Admin。但我们一般不使用guest账号,继续用命令来添加账号和权限。

d:添加用户:rabbitmqctl.bat add_user username password

 

e:添加“超级管理员”角色: rabbitmqctl.bat set_user_tags username administrator

 

mymq账号也是超级管理员了,Can access virtual hosts :No access ,可以看到还没有能够访问的虚拟机,接下来添加虚拟机。

f: 添加虚拟机:  rabbitmqctl add_vhost vhostName

 myvhost虚拟机并没有Users,接下来给虚拟机绑定账号。

g:定虚拟机和用户权限:rabbitmqctl set_permissions -p 虚拟机名称 账户名 ".*" ".*" ".*"

 

h:处于习惯我一般删除掉guest账号:rabbitmqctl.bat delete_user username

 好了,重新登陆管理页面,一切正常,接下来开始实战了。 

EasyNetQ的基本使用

项目中安装EasyNetQ

EasyNetQ是依赖于RabbitMQ.Client的,所以会被一并安装到项目中。

Publish发布消息

 

Model有个Queue的特性,定义Queue名称和Exchange名称。然后直接用Publish方法把Msg通过Model指定的交换机推送到指定队列去。

运行代码,看看MQ的管理页面。

 已经创建了Model指定的交换机TestQueue.Exchange, Type:topic , Features:D 。D:Durable 说明默认创建的交换机是持久化的。

 因为还没有订阅消息,所以在Queues中还看不到对应的队列。

 Subscribe订阅消息

  

 为什么要在订阅代码上套一个while(true)了? 是为了把控制台程序模拟成Windows服务,因为控制台程序运行一闪而过,没办法真正订阅到MQ的消息。

 实际开发中,一般用Topself来把控制台程序发布成Windows服务,后面有时间再写一篇关于Topself的学习博客。

 再重复刚才的Publish操作,测试下整个流程。

 

自定义Topic

这样消息会被发送到名称为Test.开头的所有Queue队列中。

Send和Receive

通过send和receive可以将消息发送到指定队列。


本文转自  zddnd   51CTO博客,原文链接:http://blog.51cto.com/13013666/1943102
相关实践学习
消息队列RocketMQ版:基础消息收发功能体验
本实验场景介绍消息队列RocketMQ版的基础消息收发功能,涵盖实例创建、Topic、Group资源创建以及消息收发体验等基础功能模块。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
相关文章
|
消息中间件 Java Maven
微服务技术系列教程(34) - SpringCloud-使用RabbitMQ实现消息驱动
微服务技术系列教程(34) - SpringCloud-使用RabbitMQ实现消息驱动
210 0
|
4月前
|
消息中间件 Java RocketMQ
微服务架构师的福音:深度解析Spring Cloud RocketMQ,打造高可靠消息驱动系统的不二之选!
【8月更文挑战第29天】Spring Cloud RocketMQ结合了Spring Cloud生态与RocketMQ消息中间件的优势,简化了RocketMQ在微服务中的集成,使开发者能更专注业务逻辑。通过配置依赖和连接信息,可轻松搭建消息生产和消费流程,支持消息过滤、转换及分布式事务等功能,确保微服务间解耦的同时,提升了系统的稳定性和效率。掌握其应用,有助于构建复杂分布式系统。
73 0
|
7月前
|
消息中间件 Java RocketMQ
Spring Cloud RocketMQ:构建可靠消息驱动的微服务架构
【4月更文挑战第28天】消息队列在微服务架构中扮演着至关重要的角色,能够实现服务之间的解耦、异步通信以及数据分发。Spring Cloud RocketMQ作为Apache RocketMQ的Spring Cloud集成,为微服务架构提供了可靠的消息传输机制。
262 1
|
消息中间件 Java Linux
Rocketmq-消息驱动
Rocketmq-消息驱动
190 0
Rocketmq-消息驱动
|
消息中间件 Java Linux
|
消息中间件 网络安全 数据安全/隐私保护
【安装配置RabbitMQ】
【安装配置RabbitMQ】
120 0
【安装配置RabbitMQ】
|
消息中间件 开发工具 C语言
RabbitMQ系列(一)--------安装配置
安装RabbitMQ 前提先要配置好环境 需要先安装Erlang
105 0
RabbitMQ系列(一)--------安装配置
|
消息中间件 监控 关系型数据库
RabbitMQ基本概念和Linux安装配置RabbitMQ
RabbitMQ基本概念和Linux安装配置RabbitMQ
212 1
|
消息中间件 网络协议 Java
SpringCloudStream学习(一)RabbitMQ基础
SpringCloudStream学习(一)RabbitMQ基础
155 0
SpringCloudStream学习(一)RabbitMQ基础
EMQ
|
数据采集 缓存 JSON
Neuron v2.2.2 发布:MQTT插件功能提升 、新增OPC DA驱动
工业协议网关软件Neuron v2.2.2对MQTT插件、SDK开发包及其他商业驱动插件进行了优化和更新,为工业领域用户提供更加高效便捷的数据采集。
EMQ
307 0
Neuron v2.2.2 发布:MQTT插件功能提升 、新增OPC DA驱动