大佬们。是这样的，我们有个 k 线的计算模块，就是每次有成交数据(目前每秒可能有数十笔吧，高峰期会高不少)就要去刷新 k 线。
目前是单机运行的，k 线中的数据都是直接存在内存中，每个 market 都是单独线程计算的，通过 kafka 接收成交记录然后计算结果，最后持久化（目前是通过 kafka 异步写）。
现在问题是我们希望改成集群，但是个人感觉如果将数据存储在 redis，每次更新时要先加分布式锁，然后读、计算、写，这样性能我感觉可能远不如单机运行。但是单机运行存在宕机可能，现在不知道咋整了
Select Language