文件名称:learning_rabbitmq:我在学习有关RabbitMQ时编写的代码
文件大小:10KB
文件格式:ZIP
更新时间:2024-05-19 15:34:06
Python
py-amqp的RabbitMQ教程代码 评论,建议,更正 这是我在学习有关编写的python代码。 目录partN_...包含我遵循Rabbitmq python编写的代码。 该教程是为pika库编写的,但是我了库。 rabbits_and_warrens目录包含我在跟随Jason Williams对RabbitMQ进行介绍之后编写的代码。 如果您发现任何问题或有建议,我很想听听他们的意见。 我不清楚的一件事是channel.wait()和connection.drain_events()之间的区别。 如果有人可以回答我,我将非常有义务:-) 另外,pyamqp中的connection.drain_events是否真的等同于pika的connection.process_data_events ,还是我只是错误地将其弥补了?
【文件预览】:
learning_rabbitmq-master
----.gitignore(9B)
----rabbits_and_warrens()
--------rabbits_and_warrens.py(723B)
--------rabbit_and_warrens_producer.py(590B)
----part4_routing()
--------receive_logs_direct.py(907B)
--------emit_log_direct.py(484B)
----part1_hello_world()
--------send.py(328B)
--------receive.py(479B)
----README.md(1KB)
----part3_pubsub()
--------receive_logs.py(607B)
--------emit_log.py(438B)
----part2_work_queues()
--------worker.py(757B)
--------new_task.py(437B)
----part5_topics()
--------receive_logs_topic.py(908B)
--------emit_log_topic.py(500B)
----part6_rpc()
--------rpc_client.py(1KB)
--------rpc_server.py(1KB)