使用 Python 构建 RabbitMQ 应用
RabbitMQ 是一个基于 高级消息队列协议 (AMQP) 的强大的消息代理。由于 AMQP 规范的特性,它很容易从许多平台连接,包括 Python。在这篇博客文章中,我们将
- 创建一个简单的股票行情 Python 应用
- 创建一个经纪人 Python 应用,决定何时买卖。
- 比较 pika(RabbitMQ 团队创建的 AMQP 库)和 py-amqplib。
顺便说一句
这篇博客文章中编写的代码仅供演示之用。不要依赖这些算法来进行财务建议。言归正传,让我们编写一些代码吧!
构建股票行情
消息解决方案的一个很好的例子是股票行情系统。证券交易所向代理发布消息,指示股票名称、价格和时间。import pickle
import random
import time
class Ticker(object):
def __init__(self, publisher, qname):
self.publisher = publisher
# This quickly creates four random stock symbols
chars = range(ord("A"), ord("Z")+1)
def random_letter(): return chr(random.choice(chars))
self.stock_symbols = [random_letter…