刚安装的python如何使用-python中RabbitMQ的使用(安装和简单教程)
1,简介
RabbitMQ(Rabbit Message Queue)是流行的开源消息队列系统,用erlang语言开发。
1.1关键词说明:
Broker:消息队列服务器实体。
Exchange:消息交换机,它指定消息按什么规则,路由到哪个队列。
Queue:消息队列载体,每个消息都会被投入到一个或多个队列。
Binding:绑定,它的作用就是把exchange和queue按照路由规则绑定起来。
Routing Key:路由关键字,exchange根据这个关键字进行消息投递。
vhost:虚拟主机,一个broker里可以开设多个vhost,用作不同用户的权限分离。
producer:消息生产者,就是投递消息的程序。
consumer:消息消费者,就是接受消息的程序。
channel:消息通道,在客户端的每个连接里,可建立多个channel,每个channel代表一个会话任务。
1.2消息队列运行机制:
(1)客户端连接到消息队列服务器,打开一个channel。
(2)客户端声明一个exchange,并设置相关属性。
(3)客户端声明一个queue,并设置相关属性。
(4)客户端使用routing key,在exchange和queue之间建立好绑定关系。
(5)客户端投递消息到exchange。
(6)exchange接收到消息后,就根据消息的key和已经设置的binding,将消息投递到一个或多个队列里。
注:在声明一个队列后,如果将其持久化,则下次不需要进行声明,因为该队列已经在rabbitMQ中了!!!
例如下面的例子中都为首次声明一个队列!!!
1.3exchange类型:
1.Direct交换机
特点:依据key进行投递
例如绑定时设置了routing key为”hello”,那么客户端提交的消息,只有设置了key为”hello”的才会投递到队列。
2.Topic交换机
特点:对key模式匹配后进行投递,符号”#”匹配一个或多个词,符号”*”匹配一个词
例如”abc.#”匹配”abc.def.ghi”,”abc.*”只匹配”abc.def”。
3.Fanout交换机
特点:不需要key,采取广播模式,一个消息进来时,投递到与该交换机绑定的所有队列
2.构建环境
2.1在windows环境下安装rabbitmq,教程如下:
2.2安装pika模块
python使用rabbitmq服务,可以使用现成的类库pika、txAMQP或者py-amqplib,这里选择了pika。
在命令行中直接使用pip命令:
pip install pika
3.示例测试
实例的内容就是从send.py发送消息到rabbitmq,receive.py从rabbitmq接收send.py发送的信息。
P表示produce,生产者的意思,也可以称为发送者,实例中表现为send.py;
C表示consumer,消费者的意思,也可以称为接收者,实例中表现为receive.py;
中间红色的表示队列的意思,实例中表现为hello队列。
send.py
1 #!/usr/bin/env python3
2 #-*- coding: utf-8 -*-
3
4 importpika5 importrandom6
7 #新建连接,rabbitmq安装在本地则hostname为'localhost'
8 hostname = '192.168.1.133'
9 parameters =pika.ConnectionParameters(hostname)10 connection =pika.BlockingConnection(parameters)11
12 #创建通道
13 channel =connection.channel()14 #声明一个队列,生产者和消费者都要声明一个相同的队列,用来防止万一某一方挂了,另一方能正常运行
15 channel.queue_declare(queue='hello')16
17 number = random.randint(1, 1000)18 body = 'hello world:%s' %number19 #交换机; 队列名,写明将消息发往哪个队列; 消息内容
20 #routing_key在使用匿名交换机的时候才需要指定,表示发送到哪个队列
21 channel.basic_publish(exchange='', routing_key='hello', body=body)22 print "[x] Sent %s" %body23 connection.close()
receive.py
1 #!/usr/bin/env python3
2 #-*- coding: utf-8 -*-
3
4 importpika5
6 hostname = '192.168.1.133'
7 parameters =pika.ConnectionParameters(hostname)8 connection =pika.BlockingConnection(parameters)9
10 #创建通道
11 channel =connection.channel()12 channel.queue_declare(queue='hello')13
14
15 defcallback(ch, method, properties, body):16 print "[x] Received %r" %(body,)17
18 #告诉rabbitmq使用callback来接收信息
19 channel.basic_consume(callback, queue='hello', no_ack=True)20
21 #开始接收信息,并进入阻塞状态,队列里有信息才会调用callback进行处理,按ctrl+c退出
22 print '[*] Waiting for messages. To exit press CTRL+C'
23 channel.start_consuming()
我们先运行send.py发送消息:
再运行receive.py接收消息:
刚安装的python如何使用-python中RabbitMQ的使用(安装和简单教程)相关推荐
- python在数据分析的应用_Python运用于数据分析的简单教程
这篇文章主要介绍了Python运用于数据分析的简单教程,主要介绍了如何运用Python来进行数据导入.变化.统计和假设检验等基本的数据分析,需要的朋友可以参考下 我这里来分享一下如何通过Python来 ...
- linux vnc的小黑点和鼠标不同步_vnc安装步骤,vnc在Linux中的7个安装步骤
首先要知道的是,VNC是什么.VNC(Virtual Network Computing ),一种使用RFB协议的显示屏画面分享及远程操作软件.它与操作系统无关, 我个人使用的[IIS7服务器管理工具 ...
- oracle win2008安装图解,win7 64位操作系统中Oracle 11g + plsql安装教程详解(图解)
先去网上把下面列表里的文件下载下来,百度一搜索到处都是~~~ 我来解释一下以上目录都是什么: instantclient-basic-win32-11.2.0.1.0.zip 这个文件是配置文件,现在 ...
- 怎样下载python模块sublime text3中_Python3.7.3安装教程并集成Sublime Text3
前言: 由于sublime text3比较轻量,而且界面也很美观,与Python3可以友好集成,本教程就来说说Python3安装教程并集成sublime text3 环境:Windows 10 一.P ...
- python安装scrapy框架命令_python爬虫中scrapy框架是否安装成功及简单创建
判断框架是否安装成功,在新建的爬虫文件夹下打开盘符中框输入cmd,在命令中输入scrapy,若显示如下图所示,则说明成功安装爬虫框架: 查看当前版本:在刚刚打开的命令框内输入scrapy versio ...
- windows和linux中RabbitMQ客户端下载安装
RabbitMQ的安装与客户端的简单实用 本文主要内容是RabbitMQ的安装步骤[Windows系统与linux上的安装]及客户端的简单使用. Windows上安装 1 安装Erlang 下载erl ...
- python智能模块_Python模块常用的几种安装方式
Python模块安装方法 一.方法1: 单文件模块 直接把文件拷贝到 $python_dir/Lib 二.方法2: 多文件模块,带setup.py 下载模块包,进行解压,进入模块文件夹,执行: pyt ...
- python实验原理_【python】《统计学原理实验教程(Python)》书中代码实现
代码已经上传至GitHub <统计学原理实验教程(Python)>书中代码实现 简介 <统计学原理实验教程(Python)>是厦门大学出版社在2019年出版的图书,主要通过py ...
- Python中optionParser模块的使用方法实例教程
Python中optionParser模块的使用方法实例教程 转载 2014-08-29 投稿:shichen2014 我要评论 这篇文章主要介绍了Python中optionParser模 ...
- Linux中man手册的安装以及使用详解
Linux中man手册的安装以及使用详解 linux中man手册的安装以及使用详解 man手册是什么 man手册是干嘛的 man手册如何安装 man手册如何使用 举例讲解 我们来看一下man手册的目录 ...
最新文章
- 数字签名、私钥、公钥
- 量子计算赛道上的巨头拉锯战
- Libgdx New 3D API 教程之 -- 使用Libgdx加载模型
- oracle查询数据库启动时的参数文件,【Oracle】数据库启动阶段参数文件、控制文件的问题处理...
- Docker日志日期时间精确查询
- android 城市列表数据,用RecyclerView写的城市列表
- java sleep方法_一文搞懂 Java 线程中断!
- 11条建议让你成为优秀的JavaScript程序员
- 搜索互联网缓存页面 How to View the Cached Page of any URL or Website
- 设某微型计算机内存ram区,微机原理第三章习题.doc
- 微软公司软件开发模式简介
- laravel php artisan migrate 数据迁移时出现的[HY000][1045]错误
- Python线程池简介
- Win7原版|MSDN Windows7 SP1官方原版ISO镜像下载(全版本)
- java 动态统计报表_java统计图表FineReport制作动态图表
- c#量化交易_全市场股票量化交易
- 【Sql】sql server2008附加数据库:错误9003
- Android9.0 紧急号码配置
- 设置文字最后一行,末尾自定义
- Kaggle Learn 数据泄露(data leakage)的几个例子