作为中间件，可以选中SQL、HttpServer、MQ，我只是想求简单。1）不需要学习复杂的新知识，Redis一看就能懂；2）不需要自己搭建服务器，Redis Cloud免费；3）代码量要少，Redis十几行代码就搞定了。基于0学习成本和0经济成本，所以选择了Redis。 ## 一、交易端代码： ``` import json import redis def order(sig): mycmd = '{} {} zxjg {} -notip'.format(sig['action'], sig['zqdm'], sig['qty']) print(mycmd) def main(): r = redis.Redis( host='redis-12798.c291.ap-southeast-2-1.ec2.cloud.redislabs.com', port=12798, password='xxxxxxxxxxxxxxxxxxxxxxxxxxxx') ps = r.pubsub() ps.subscribe('myChannel') for item in ps.listen(): # keep listening, and print the message in the channel if item['type'] == 'message': signals = item['data'].decode('utf-8') if signals == 'exit': break else: signal_list = json.loads(signals) for sig in signal_list: print(sig) order(sig) if __name__ == '__main__': main() ``` ## 二、JQ发送交易信号  ## 三、交易端运行结果  ## 四、总结 1）无需自备云服务器，经济成本0；无需学习新知识，学习成本0。 2）十几行代码完成，简洁清晰。 3）消息队列的不重复、不遗漏、不乱序，完全由Redis完成，不用操心。 4）N个策略驱动一个账户，还是一个策略驱动N个账户，都不是梦。 ##五、研究展望 1）上面的代码，仅仅是个基本模型，需要根据实际需求进一步扩展； 2）Redis的可靠性，还有待实践检验； 3）著名的消息队列（MQ）平台，比如ActiveMQ、RabbitMQ、RocketMQ、Kafka，聚宽支持RabbitMQ（import pika），如果考虑商业级别的应用，对稳定性要求极高的，可以考虑RabbitMQ。