使用 Python 构建 RabbitMQ 应用
RabbitMQ 是一个基于 高级消息队列协议 (AMQP) 的强大消息中间件。由于 AMQP 规范的通用性,可以轻松地从包括 Python 在内的许多平台连接到它。在本篇博文中,我们将
- 创建一个简单的股票行情 Python 应用
- 创建一个决定何时买卖的经纪商 Python 应用。
- 比较由 RabbitMQ 团队创建的 AMQP 库 pika 和 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…