代码修改为支持集群