~jinersong/ruleprocess.git

			@@ -5,6 +5,7 @@
			"basic.com/pubsub/cache.git/shardmap"
			"basic.com/pubsub/protomsg.git"
			"basic.com/valib/gopherdiscovery.git"
			"basic.com/valib/logger.git"
			"errors"
			"fmt"
			"github.com/gogo/protobuf/proto"
			@@ -18,6 +19,7 @@
			PREFIX_RULE = "RULE_"
			SERVER_KEY = "SERVERINFO"
			PREFIX_SDK = "SDK_"
			PREFIX_SO = "SO"
			)

			var cMap *shardmap.ShardMap
			@@ -53,6 +55,8 @@
			initServerInfo()//初始化服务器配置信息

			initSdks() //初始化sdk列表信息

			initSoData()

			initChan <- true
			}
			@@ -202,4 +206,23 @@
			} else {
			return sdk,errors.New("sdk not found")
			}
			}

			func initSoData() {
			var api dbapi.SoApi
			soinfos := api.FindAll()
			logger.Debug("=====================注册表信息：")
			for _,soinfo :=range soinfos {
			logger.Debug(soinfo)
			cMap.Set(PREFIX_SO+soinfo.SdkId,soinfo)
			}
			}

			func GetSoInfoById(sdkId string) (sdk protomsg.SoInfo,err error){
			obj,b :=cMap.Get(PREFIX_SO + sdkId)
			if b {
			return obj.(protomsg.SoInfo),nil
			} else {
			return sdk,errors.New("sdk not found")
			}
			}