python mq_python测试rabbitmq的消息收发

2024-04-25 20:25:24

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()

python mq_python测试rabbitmq的消息收发相关推荐

python测试rabbitmq的消息收发
send.py #!/usr/bin/env python # -*- coding: UTF-8 -*- import pika import random credentials = pika.P ...
【kafka连载二】windows测试kafka的消息收发
前提系统已启动zookeeper和kafka服务,若没有启动请执行以下操作启动zookeeper CMD窗口进入zookeeper的bin子目录执行.\zkServer.cmd 启动kafka C ...
Python之Rabbitmq发送消息
欢迎关注[无量测试之道]公众号,回复[领取资源], Python编程学习资源干货. Python+Appium框架APP的UI自动化. Python+Selenium框架Web的UI自动化. Pyth ...
第五节 RabbitMQ在C#端的应用-消息收发
原文:第五节 RabbitMQ在C#端的应用-消息收发版权声明:未经本人同意,不得转载该文章,谢谢 https://blog.csdn.net/phocus1/article/details/873 ...
Python+ZeroMQ使用REQ/REP模式快速实现消息收发
推荐图书: <Python程序设计(第3版)>,(ISBN:978-7-302-55083-9),董付国,清华大学出版社,2020年6月第1次印刷,2021年1月第6次印刷,山东省一流本科 ...
基于Python语言使用RabbitMQ消息队列（三）
发布/订阅前面的教程中我们已经创建了一个工作队列.在一个工作队列背后的假设是每个任务恰好会传递给一个工人.在这一部分里我们会做一些完全不同的东西--我们会发送消息给多个消费者.这就是所谓的" ...
Springboot 整合Websocket+Stomp协议+RabbitMQ做消息代理实例教程
前言如果你还没有了解过websocket,关于整合websocket的简单入门使用,可以先看看我这篇: <SpringBoot 整合WebSocket 简单实战案例> https://b ...
RabbitMQ 可靠消息传输实战--云平台技术栈12
导读:之前发布了云平台技术栈(ps:点击可查看),本文主要说一下其中的RabbitMQ! 作者:极客慧 https://my.oschina.net/jikeh/blog/2207127 可能是缓存架 ...
RabbitMQ的消息确认ACK机制
1.什么是消息确认ACK. 答:如果在处理消息的过程中,消费者的服务器在处理消息的时候出现异常,那么可能这条正在处理的消息就没有完成消息消费,数据就会丢失.为了确保数据不会丢失,RabbitMQ支持消 ...

最新文章

热门文章