python测试rabbitmq简易实例

生产者

import pika
#coding=utf8
credentials = pika.PlainCredentials(‘guest‘, ‘密码‘)
connection = pika.BlockingConnection(pika.ConnectionParameters(‘IP‘,5672,‘/‘,credentials))
channel = connection.channel()
channel.queue_declare(queue=‘hello‘)

channel.basic_publish(exchange=‘‘,
                  routing_key=‘hello‘,
                  body=‘rabbitmq test!‘)
print("开始队列")
connection.close()

 

消费者

import pika
#coding=utf8
credentials = pika.PlainCredentials(‘guest‘, ‘密码‘)
connection = pika.BlockingConnection(pika.ConnectionParameters(‘IP‘,5672,‘/‘,credentials))
channel = connection.channel()

# rabbitmq消费端仍然使用此方法创建队列。这样做的意思是:若是没有就创建。和发送端道理道理。目的是为了保证队列一定会有
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.‘)
channel.start_consuming()

  

原文地址:https://www.cnblogs.com/uglyliu/p/8519693.html

时间: 2024-11-08 09:35:40

python测试rabbitmq简易实例的相关文章

python测试rabbitmq的消息收发

send.py #!/usr/bin/env python    # -*- coding: UTF-8 -*-  import pika   import random            credentials = pika.PlainCredentials('root', '123456')   #这里可以连接远程IP,请记得打开远程端口     parameters = pika.ConnectionParameters('139.x.x.x',5672,'/',credentials

python测试mysql写入性能完整实例

这篇文章主要介绍了python测试mysql写入性能完整实例,具有一定借鉴价值,需要的朋友可以参考下 本文主要研究的是python测试mysql写入性能,分享了一则完整代码,具体介绍如下. 测试环境: (1) 阿里云服务器centos 6.5 (2) 2G内存 (3) 普通硬盘 (4) mysql 5.1.73 数据库存储引擎为 InnoDB (5) python 2.7 (6) 客户端模块 mysql.connector 测试方法: (1) 普通写入 (2) 批量写入 (3) 事务加批量写入

python中RabbitMQ的使用(安装和简单教程)

1,简介 RabbitMQ(Rabbit Message Queue)是流行的开源消息队列系统,用erlang语言开发. 1.1关键词说明: Broker:消息队列服务器实体.Exchange:消息交换机,它指定消息按什么规则,路由到哪个队列.Queue:消息队列载体,每个消息都会被投入到一个或多个队列.Binding:绑定,它的作用就是把exchange和queue按照路由规则绑定起来.Routing Key:路由关键字,exchange根据这个关键字进行消息投递.vhost:虚拟主机,一个b

Python之路【第九篇】:Python操作 RabbitMQ、Redis、Memcache、SQLAlchemy

Python之路[第九篇]:Python操作 RabbitMQ.Redis.Memcache.SQLAlchemy Memcached Memcached 是一个高性能的分布式内存对象缓存系统,用于动态Web应用以减轻数据库负载.它通过在内存中缓存数据和对象来减少读取数据库的次数,从而提高动态.数据库驱动网站的速度.Memcached基于一个存储键/值对的hashmap.其守护进程(daemon )是用C写的,但是客户端可以用任何语言来编写,并通过memcached协议与守护进程通信. Memc

python之rabbitMQ

一.简单的rabbitMQ队列通信 由上图可知,数据是先发给exchange交换器,exchage再发给相应队列.pika模块是python对rabbitMQ的API接口.接收端有一个回调函数,一接收到数据就调用该函数.一条消息被一个消费者接收后,该消息就从队列删除.OK,了解上面的知识后,先来看看一个简单的rabbitMQ列队通信. send端:  1 import pika 2 #连上rabbitMQ 3 connection=pika.BlockingConnection(pika.Con

# 进程/线程/协程 # IO:同步/异步/阻塞/非阻塞 # greenlet gevent # 事件驱动与异步IO # Select\Poll\Epoll异步IO 以及selectors模块 # Python队列/RabbitMQ队列

1 # 进程/线程/协程 2 # IO:同步/异步/阻塞/非阻塞 3 # greenlet gevent 4 # 事件驱动与异步IO 5 # Select\Poll\Epoll异步IO 以及selectors模块 6 # Python队列/RabbitMQ队列 7 8 ############################################################################################## 9 1.什么是进程?进程和程序之间有什么

用 Python、 RabbitMQ 和 Nameko 实现微服务

用 Python. RabbitMQ 和 Nameko 实现微服务 原创 07-17 17:57 首页 Linux中国 "微服务是一股新浪潮" - 现如今,将项目拆分成多个独立的.可扩展的服务是保障代码演变的最好选择.在 Python 的世界里,有个叫做 "Nameko" 的框架,它将微服务的实现变得简单并且强大. 微服务 在最近的几年里,"微服务架构"如雨后春笋般涌现.它用于描述一种特定的软件应用设计方式,这种方式使得应用可以由多个独立部署的服

基于Python的接口测试框架实例

文章来源:http://www.jb51.net/article/96481.htm 下面小编就为大家带来一篇基于Python的接口测试框架实例.小编觉得挺不错的,现在就分享给大家,也给大家做个参考.一起跟随小编过来看看吧 背景 最近公司在做消息推送,那么自然就会产生很多接口,测试的过程中需要调用接口,我就突然觉得是不是可以自己写一个测试框架? 说干就干,由于现有的接口测试工具Jmeter.SoupUI等学习周期有点长,干脆自己写一个吧,不求人,所有功能自己都能一清二楚. 当然,写工具造轮子只是

python快速搭建简易的FTP服务器

上回说到,使用python搭建一个简易的web下载服务器,但是这个简易的服务器客户端不能够上传文件.这次来搭建一个简易的ftp服务器,来提供文件的下载和上传功能. 一.首先我们来安装提供服务的pyftpdlib模块pip install pyftpdlib二.然后通过python的-m选项将pyftpdlib模块简单的独立服务器运行起来.这时我们想要共享那个目录,只需在该目录下运行命令即可python -m pyftpdlib-m 以模块的方式启动验证:到这里,一个简单的FTP服务器已经搭建成功