RabbitMQ实战1.消息代理01.消息代理02.安装RabbitMQ03.生产者-消费者模式04.队列操作

01.消息代理

你要买菜,是不是直接去地里跟农民伯伯砍价?

你要吃肉,是不是直接去养鸡户家里,让他现场杀鸡?

肯定不是,这种直接与生产者交易的成本太大了!大到不可承受。因此有了中间商的存在。中间商将生产者与消费者的所有环节都透明化,使最终的交易流程极其简单。

于是,我们才得以直接在菜市场,甚至在网上商城直接选购琳琅满目的商品,只需要支付价钱,就能将商品拿回家。我们不需要知道一颗青菜背后的主人是谁,住在哪里,性格如何; 菜农也不需要考虑自己的菜最终会到哪个人的餐桌。

将这个场景映射到软件领域:一个系统中有多个服务,如,1.发表说说 2.消息推送 3.记录日志

用户程心是个大v,发了一条说说:“出于对人类世界及三体世界的爱,我决定参加执剑人的选举!”

发表动态后,她的五十亿粉丝都会收到消息,同时日志模块会记录她这个行为。

如果让发表说说这个服务直接同步阻塞地调用消息推送和记录日志这两个服务。那很可能程心每次发表说说都会卡住,要等到另外两个服务完成才能响应。

此时,就需要用到消息代理,程心在发表说说后只需要做一件事,将这个消息发送到消息代理中心。而其他功能模块会从消息代理中心获取消息,再进行后续的逻辑处理。这样就将系统进行了解耦,后续即使再增加其他的服务,如发送邮件给云天明,都不需要再改动发表说说的代码,其他服务只需要对接消息代理即可。

RabbitMQ 就是一个成熟,优秀,应用广泛的消息代理服务。

02.安装RabbitMQ

RabbitMQ的安装方式详情见官网描述

以mac为例:

brew install rabbitmq

加入环境变量

vim ~/.zshrc
# export PATH="/usr/local/sbin:$PATH"

服务启动

brew services start rabbitmq

浏览器访问 http://localhost:15672/

账号密码都是guest

RabbitMQ页面

03.生产者-消费者模式

RabbitMQ对于绝大多数编程语言都提供了良好的支持,详情页面

本教程以python为例,首先安装pika库

pip install pika

接下来要实现一个简单的生产者-消息者的消息功能:

  1. 生产者将消息推送到RabbitMQ
  2. 消息者从RabbitMQ获取消息

生产--消费

新建 send.py 作为生产者

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))  # 建立连接
channel = connection.channel()  # 创建信道

channel.queue_declare(queue='hello')  # 声明队列

channel.basic_publish(exchange='',  # 默认的交换机
                      routing_key='hello',  # 路由键
                      body='Hello World!')  # 消息体
print(" [x] Sent 'Hello World!'")
connection.close()  # 关闭连接

在RabbitMQ中,消息是不能直接发送到队列中的,这个过程需要通过交换机(exchange)来进行。但是为了不让细节拖累我们的进度,这里我们只需要知道如何使用由空字符串表示的默认交换机即可。默认交换机比较特别,它允许我们指定消息究竟需要投递到哪个具体的队列中,队列名字需要在routing_key参数中指定

新建 receive.py 作为消费者

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
channel = connection.channel()

channel.queue_declare(queue='hello')  # 生产者与消费者都声明队列,避免队列不存在 


def callback(ch, method, properties, body):
    print(" [x] Received %r" % body)


channel.basic_consume(callback,  # 消费者获取消息后的回调函数
                      queue='hello',  # 指定要消费的队列名称
                      no_ack=True)

print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()  # 开始消费,程序会一直处于等待响应中

为什么消费者和生产者都要声明队列?

因为生产者与消费者有可能是在不同机器运行的,我们不知道哪个会先运行,倘若先运行的程序没有声明队列,两者就不能进行通信。因此最安全的方式就是两者都进行声明队列,如果队列已经存在,RabbitMQ会自动忽略

执行结果:

消息投递

生产者与消费者的启动顺序可以自由安排

04.队列操作

☁  rabbitMq [master] ⚡ rabbitmqctl list_queues # 显示所有队列
Timeout: 60.0 seconds ...
Listing queues for vhost / ...
task_queue  0
hello-queue 0
hello   0
topic_single_queue  0
☁  rabbitMq [master] ⚡ rabbitmqadmin delete queue name=task_queue # 删除某个队列
queue deleted

参考文献: https://www.rabbitmq.com/tutorials/tutorial-one-python.html

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏IT技术精选文摘

LVS集群的体系结构

1.引言 在过去的十几年中,Internet从几个研究机构相连为信息共享的网络发展成为拥有大量应用和服务的全球性网络,它正成为人们生活中不可缺少的 一部分。虽...

27880
来自专栏zhangdd.com

ntp服务器查看状态命令ntpstat及ntpq -p 说明及差别详解

NTP服务器【Network Time Protocol(NTP)】是用来使计算机时间同步化的一种协议,它可以使计算机对其服务器或时钟源(如石英钟,GPS等等)...

33820
来自专栏coding

django2.0入门教程第一节启动开发模式下的服务器

17420
来自专栏逢魔安全实验室

渗透基础-SSH后门分析总结

? ? 对于UNIX系统来说,ssh服务端作为最广泛应用的远程管理服务并且有一定对外开放的必然性,必然引起黑客关注,所以ssh类的后门也是uni...

82440
来自专栏FreeBuf

断网让女神求你:制作一个廉价的WIFI干扰器

干扰WiFi运行有很多方法,最近玩esp8266模块放狗找资料,偶然发现一个干扰wifi信号的廉价方法,特与大家分享。我这里使用的是相对便宜的NodeMCU(约...

30770
来自专栏IT技术精选文摘

窥探Nginx内部实现:如何为性能和规模进行设计

NGINX在网络性能方面处于领先地位,这一切都是由于软件的设计方式。尽管许多Web服务器和应用程序服务器使用简单的线程或基于进程的架构,但NGINX具有复杂的事...

21350
来自专栏小白课代表

软件分享 | 3DS MAX 2018安装教程

3D Studio Max,常简称为3d Max或3dsMAX,是Discreet公司开发的(后被Autodesk公司合并)基于PC系统的三维动画渲染和制作软件...

11910
来自专栏域名资讯

域名被墙了的解决办法有哪些?

  如果域名ping的通却打不开网站(排除服务器宕机),用代理可以打开一般说明域名被封了。假如域名下的网站非法信息多,敏感,又不整改,会直接被GFW墙掉,结果就...

3.8K50
来自专栏信安之路

线下赛ASP靶机漏洞利用分析

继上次发表 记一次线下赛靶机攻击过程 后,看到反响不错,特此再写一篇,关于一台 ASP 靶机漏洞利用过程。

53100
来自专栏知识分享

邪恶改装2:用单片机实现一次简单的wifi密码欺骗

         前段时间用TPYBoard v202 做了一个简单的WIFI干扰攻击器(ps :没有看过的小伙伴,可以看一下:http://www.freeb...

15730

扫码关注云+社区

领取腾讯云代金券