从JQ接收信号驱动miniQMT，用Redis的pub/sub模式，大概20行可以搞定，做成多线程、异步、回调函数，速度毫秒级。 当然，stream模式，也是一个很好的必要的探索。

@jqz1226 可能是我想复杂了，因为redis的pub/sub模式有点问题，当消费者停了，发送者发送的数据会丢数据。所以我想着用redis stream试一下，用其他的消息队列也不会丢。

@量化致富 挺好。

@相逢一笑123 懂你，加油

国盛的miniQMT 无法云服务器运行，大家有什么好办法吗？

点赞支持

@燕飞扬 有啥报错么 我的国金miniqmt可以

@量化致富 国盛的qmt不支持云端运行

@xiaohui1108 我的国金qmt是在云服务器装的windows系统运行的，跟本地windows一样用的

@量化致富 国金的版本是支持云端的，所以没问题~~

大佬 ，多个策略推送到下单还是改不好，能给点提示吗！！谢谢

@妙手 不用改也都可以的，只是区分不出哪个策略来

回复换积分，还赞！

大佬 ，发现读取完数据 后，程序一直运行时，会重复打印 消费到的数据 [] ，这个能优化下吗,判断下有没有数据 def consume(self, consumer_name, id=">", block=60000, count=1, target=None): """ 消费数据 :param consumer_name: 消费者名称，建议传递ip :param id: 从哪开始消费，0为从头，$为最后一个条目 :param block: 无消息阻塞时间，毫秒，默认60秒，在60秒内有消息直接消费,0 时阻塞等待 :param count: 消费多少条，默认1 :param target: 业务处理回调方法 :return: """ streams = {self.stream_name: id} rst = self.redis.xreadgroup(self.consumer_group, consumer_name, streams, block=block, count=count) # 添加判断条件，仅当rst中有数据时打印 if rst: print(f'消费到的数据 {rst}') else: print("没有新的数据") # 或者可以选择不打印任何东西 if not rst or not rst[0] or not rst[0][1]: return # 遍历获取到的列表信息（可以消费多条，根据count） for item in rst[0][1]: try: # 余下代码不变...

@妙手 看漏了，下面有判断

@量化致富 改那里可以区分出来，我这样改可以不，是不是独立的二个子线程中运行，stream_names = ["smallgo", "smallgo1"] def consume(self, stream_names, consumer_name, id=">", block=60000, count=1, target=None): for stream_name in stream_names: streams = {stream_name: id} rst = self.redis.xreadgroup(self.consumer_group, consumer_name, streams, block=block, count=count) if not rst or not rst[0] or not rst[0][1]: continue for item in rst[0][1]: try: msgId, data = self.__get_data(item) if target and target(msgId, data): self.redis.xack(stream_name, self.consumer_group, msgId) except Exception as e: print("consumer is error:", repr(e))

加油加油!!

@妙手 不需要搞太多的stream_name。发送端，只需要改个stg的名称做区分,比如'xsz1','xsz2'等等。接收端，在biz_execute中，从data中已经解析了stg了，有 stg = data.get('stg', '')，可以根据他来区分不同的策略

@妙手 找print打印语句，把你不想要的去掉就行了