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)    
connection = pika.BlockingConnection(parameters)    
channel = connection.channel()    
    
#channel.queue_declare(queue=‘hello‘)    
number = random.randint(1,1000)  
body = ‘hello world:%s‘ %number  
channel.basic_publish(exchange=‘‘,    
                      routing_key=‘hello‘,    
                      body=body)    
print " [x] Sent %s" %body    
connection.close()

receice.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)    
connection = pika.BlockingConnection(parameters)    
channel = connection.channel()    
    
#channel.queue_declare(queue=‘hello‘)    
number = random.randint(1,1000)  
body = ‘hello world:%s‘ %number  
channel.basic_publish(exchange=‘‘,    
                      routing_key=‘hello‘,    
                      body=body)    
print " [x] Sent %s" %body    
connection.close()
时间: 2024-11-08 09:35:36

python测试rabbitmq的消息收发的相关文章

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.bas

python之rabbitMQ

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

用 Python、 RabbitMQ 和 Nameko 实现微服务

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

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

RabbitMQ (消息队列)专题学习07 RPC

(使用Java客户端) 一.概述 在Work Queue的章节中我们学习了如何使用Work Queue分配耗时的任务给多个工作者,但是如果我们需要运行一个函数在远程计算机上,这是一个完全不同的情景,这种模式通常被称之为RPC. 在本章节的学习中,我们将使用RabbitMQ来构建一个RPC系统:一个远程客户端和一个可扩展的RPC服务器,我们没有任何费时的任务进行分配,我们将创建一个虚拟的RPC服务返回Fibonacci数. 1.1.客户端接口(Client Interface) 为了说明一个RPC

python - 操作RabbitMQ

python - 操作RabbitMQ 介绍 RabbitMQ是一个在AMQP基础上完整的,可复用的企业消息系统.他遵循Mozilla Public License开源协议.MQ全称为Message Queue, 消息队列(MQ)是一种应用程序对应用程序的通信方法.应用程序通过读写出入队列的消息(针对应用程序的数据)来通信,而无需专用连接来链接它们.消 息传递指的是程序之间通过在消息中发送数据进行通信,而不是通过直接调用彼此来通信,直接调用通常是用于诸如远程过程调用的技术.排队指的是应用程序通过

文成小盆友python-num12 Redis发布与订阅补充,python操作rabbitMQ

本篇主要内容: redis发布与订阅补充 python操作rabbitMQ 一,redis 发布与订阅补充 如下一个简单的监控模型,通过这个模式所有的收听者都能收听到一份数据. 用代码来实现一个redis的订阅者何消费者. 定义一个类: import redis class Redis_helper(): def __init__(self): self.__conn = redis.Redis(host='192.168.11.87') #创建一个连接 def pub(self, mes, c

使用python实现微信模板消息

#!/usr/bin/env python #-*- coding:utf-8 -*- import urllib2,json import datetime,time from config import * import sys reload(sys) sys.setdefaultencoding("utf-8") class WechatPush():     def __init__(self,appid,secrect,file_name):         # 传入appi