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()
转载于:https://blog.51cto.com/yanconggod/1953785
python测试rabbitmq的消息收发相关推荐
- python mq_python测试rabbitmq的消息收发
send.py#!/usr/bin/env python # -*- coding: UTF-8 -*- import pika import random credentials = pika.Pl ...
- Python之Rabbitmq发送消息
欢迎关注[无量测试之道]公众号,回复[领取资源], Python编程学习资源干货. Python+Appium框架APP的UI自动化. Python+Selenium框架Web的UI自动化. Pyth ...
- python测试rabbitmq简易实例
生产者 import pika #coding=utf8 credentials = pika.PlainCredentials('guest', '密码') connection = pika.Bl ...
- 【kafka连载二】windows测试kafka的消息收发
前提 系统已启动zookeeper和kafka服务,若没有启动请执行以下操作 启动zookeeper CMD窗口进入zookeeper的bin子目录执行.\zkServer.cmd 启动kafka C ...
- 第五节 RabbitMQ在C#端的应用-消息收发
原文:第五节 RabbitMQ在C#端的应用-消息收发 版权声明:未经本人同意,不得转载该文章,谢谢 https://blog.csdn.net/phocus1/article/details/873 ...
- 千兆以太网PHY芯片调试-88E1111(RGMII接口-数据收发ECHO测试) Verilog实现python测试
千兆以太网PHY芯片调试-基于RGMII接口的88E1111(数据收发ECHO测试) 先放结果: Py测试代码: import socket #网络通信 TCP,UDP DST_IP = '192.1 ...
- 刚安装的python如何使用-python中RabbitMQ的使用(安装和简单教程)
1,简介 RabbitMQ(Rabbit Message Queue)是流行的开源消息队列系统,用erlang语言开发. 1.1关键词说明: Broker:消息队列服务器实体. Exchange:消息 ...
- Python菜鸟之路:Python基础-Python操作RabbitMQ
RabbitMQ简介 rabbitmq中文翻译的话,主要还是mq字母上:Message Queue,即消息队列的意思.rabbitmq服务类似于mysql.apache服务,只是提供的功能不一样.ra ...
- python之rabbitMQ
一.简单的rabbitMQ队列通信 由上图可知,数据是先发给exchange交换器,exchage再发给相应队列.pika模块是python对rabbitMQ的API接口.接收端有一个回调函数,一接收 ...
最新文章
- OpenCV4Android开发实录(2): 使用OpenCV3.4.1库实现人脸检测
- 让你的输入框使用Google云语音输入技术
- Self20171218_TestNG+Maven+IDEA环境搭建
- li:hover背景色
- XML能否替换HTML,XML DOM
- python代码该怎么简化_Python开发简化代码的六大技巧
- SQL 批量修改订单号
- 指针函数的一个范例,在单片机上运用它能让您的程序结构更明朗清晰,层次感强...
- oracle没有正常启动,Oracledbstart无法正常启动处理办法
- 整合MVC实现文件上传
- 大厂P5、P6、P7级程序员的简历长什么样?
- canvas 角度 弧度 换算
- 构建统一CIM数字底盘,实现基于BIM的全流程管控
- c# 计算一年有多少周
- std::packaged_task 源码分析
- 120 行代码实现纯 Web 剪辑视频
- windows10系统服务器失败怎么办,Win10系统启动Apache服务器一直失败怎么办
- 数字签名、证书,RSA加密、解密
- MT6572 拔掉充电器充电图标异常
- 远程桌面计算机断网,win10系统远程桌面连接一会自动断开的详细技巧
热门文章
- 人工智能可能成为我们检测COVID-19最有效的方法吗?
- IEEE论文:城市大脑,基于互联网大脑模型的智慧城市建设
- 揭秘|多伦多大学反人脸识别,身份欺骗成功率达99.5%
- 女程序员也有 35 岁危机焦虑吗?
- Java 25 岁,发展现状大曝光!程序员的机会来了
- 输入法大战,你用哪家输入法? | 每日趣闻
- 新功能:阿里云负载均衡SLB支持HTTPS虚拟主机功能(SNI)
- 二、配置QtDesigner、PyUIC及PyRcc
- Python web 开发:部署一个3行代码的wsgi app
- Go-Mega Tutorial 01 - Hello World