diff --git a/README.md b/README.md index ba5a7fe9d..9f967e5a9 100644 --- a/README.md +++ b/README.md @@ -1,3 +1,441 @@ # go_dreamfactory -梦工厂服务端项目 \ No newline at end of file +梦工厂服务端项目 + +### 项目构架说明 +``` +.vscode #vscode 编辑器环境配置项 包含服务调试运行配置 +bin #服务运行和发布环境 包含服务的执行文件以及相关依赖配置 + conf + gateway_1.yaml #服务配置 网关服务的配置依赖文件 + worker_1.yaml #服务配置 工作服务的配置依赖文件 + json #项目策划配置文件 + log #服务运行输出日志文件目录 +cmd #命令行工具集 +comm #项目通用常量和类型定义 + core #模块名以及rpc方法名等等的定义 + usersession #用户的会话对象实现 实现跨服与用户通信 +lego #lego 微服务框架包 + base #基础服务容器的定义 + core #lego服务和模块设计相关 + sys #一些通用的系统工具集合 + utils #一些公用的方法工具集合 +modules #项目业务功能模块集合 + friend #好友模块 提供好像系统相关业务功能 在worker服务下运行 + gateway #网关模块 提供网关服务以及用户连接对象管理功能 在gateway服务容器下运行 + mail #邮件模块 提供邮箱相关业务功能 在worker服务下运行 + pack #背包模块 提供用户背包管理相关业务功能 在worker服务下运行 + user #用户模块 提供登录祖册相关业务功能 在worker服务下运行 + web #web模块 提供一些http服务支持 在web服务下运行 + core.go #一些模块集合内通用的接口和类型定义 + gate_comp.go #模块网关组件 用户注册接收用户的消息 业务模块自定义api组件继承此组件即可 + modulebase.go #基础模块 业务模块都应继承此模块 内部封装有一些通用的接口 方便业务开发 +pb #服务协议以及数据类型定义 + proto #proto的定义文件目录 +services #服务定义目录 + gateway #网关服务 定义网关服务容器 只运行网关服务模块 + web #web服务 提供一些http服务功能 前期测试和后期运维可能需要 + worker #工作服务 游戏的业务模块都会在这个服务容器中运行 + servicebase.go #基础服务容器定义 可以实现服务的底层通用接口的实现 + comp_gateroute.go #网关服务组件 用于接收从网关服务发出的用户协议并分发给本服务内各个模块处理 +sys #公用系统工具集 + cache #缓存管理系统 封装游戏类缓存数据的处理接口 + db #存储管理系统 封装游戏mgo数据库相关数据处理接口 + configure #配置管理中心 负责加载更新管理项目中使用到的各类配置文件数据 +utils #公用方法工具集 +``` + +### 服务容器的定义说明 +- service 容器定义 项目可更具情况组合拆分业务到具体的服务中 +``` +var ( + conf = flag.String("conf", "./conf/worker.yaml", "获取需要启动的服务配置文件") //启动服务的Id +) + +func main() { + flag.Parse() + s := NewService( + rpcx.SetConfPath(*conf), //指定配置文件路径 + rpcx.SetVersion("1.0.0.0"), //设置服务版本号 + ) + //每一个服务都只是一个进程容器，服务提供的功能业务取决服务绑定了哪些组件和模块 + s.OnInstallComp( //装备组件 + services.NewGateRouteComp(), //装备接收用户消息的组件 + ) + lego.Run(s, //装备模块 + user.NewModule(), //装备用户模块 + pack.NewModule(), //装备背包模块 + mail.NewModule(), //装备邮件模块 + ) + +} + +func NewService(ops ...rpcx.Option) core.IService { + s := new(Service) + s.Configure(ops...) + return s +} + +//继承基础服务对象 方便后期通用接口的扩展 +type Service struct { + services.ServiceBase +} + +//初始化服务中需要用到的系统工具 +func (this *Service) InitSys() { + this.ServiceBase.InitSys() + //初始化缓存系统 + if err := cache.OnInit(this.GetSettings().Sys["cache"]); err != nil { + panic(fmt.Sprintf("init sys.cache err: %s", err.Error())) + } else { + log.Infof("init sys.cache success!") + } + //初始化存储系统 + if err := db.OnInit(this.GetSettings().Sys["db"]); err != nil { + panic(fmt.Sprintf("init sys.db err: %s", err.Error())) + } else { + log.Infof("init sys.db success!") + } +} +``` + +### 模块容器的定义说明 +pack/module.go 每个模块目录必须有一个模块对象 一般将相同类型的业务分为一个模块中实现， 模块也只是一个容器,模块中具体实现功能的单元为模块组件对象，模块启动是装备具体的业务组件集合实现相关的业务功能 +``` +func NewModule() core.IModule { + m := new(Pack) + return m +} + +//模块结构对象 继承基础模块对象 +type Pack struct { + modules.ModuleBase + api_comp *Api_Comp + configure_comp *Configure_Comp +} + +//模块类型确定 模块名称 +func (this *Pack) GetType() core.M_Modules { + return comm.SM_PackModule +} +//服务启动相关模块时调用的接口 +func (this *Pack) Init(service core.IService, module core.IModule, options core.IModuleOptions) (err error) { + err = this.ModuleBase.Init(service, module, options) + return +} +//模块启动时装备业务组件 可更具自己的业务划分 自己定义业务组件 +func (this *Pack) OnInstallComp() { + this.ModuleBase.OnInstallComp() + //用户背包相关协议处理组件 + this.api_comp = this.RegisterComp(new(Api_Comp)).(*Api_Comp) + //背包系统的相关配置管理组件 + this.configure_comp = this.RegisterComp(new(Configure_Comp)).(*Configure_Comp) +} +``` +pack/api_comp.go 背包用户api组件 用于接收处理用具背包请求协议 +``` +//Api 组件继承于模块网关组件 modules.MComp_GateComp 内部通过反射机制将当前组件内处理协议的接口注册到 comp_gateroute.go 网关服务组件中，之后服务组件就可以把接收到的用户消息分发给当前api组件 +type Api_Comp struct { + modules.MComp_GateComp + module *Pack +} +//每个组件都可以通过组件初始化接口拿到 当前服务容器对象以及所属的模块对象 +func (this *Api_Comp) Init(service core.IService, module core.IModule, comp core.IModuleComp, options core.IModuleOptions) (err error) { + this.MComp_GateComp.Init(service, module, comp, options) + this.module = module.(*Pack) + return +} + +///查询用户背包数据 处理用处的消息接口 统一 func(ctx context.Context, session comm.IUserSession, req 消息结构对象)(err error)/////ctx 上下文控制器 可以管理方法调用中生成的多个协程 以及传递一些元数据 +//session 用户的会话对象 可以使用此对象给用户发送消息以及关闭用户的连接对象 +//req 协议处理函数接收到具体消息数据对象 +func (this *Api_Comp) QueryUserPackReq(ctx context.Context, session comm.IUserSession, req *pb.QueryUserPackReq) (err error) { + var ( + code pb.ErrorCode + pack *pb.DB_UserPackData + grids []*pb.DB_GridData + ) + defer func() { + session.SendMsg(string(this.module.GetType()), "queryuserpackresp", code, &pb.QueryUserPackResp{Grids: grids}) + }() + if !session.IsLogin() { + code = pb.ErrorCode_NoLogin + return + } + //通过缓存读取到用户的背包信息 + if pack, err = cache.Defsys.Pack_QueryUserPack(session.GetUserId()); err != nil { + log.Errorf("QueryUserPackReq err:%v", err) + code = pb.ErrorCode_CacheReadError + return + } else { + grids = this.module.configure_comp.GetPackItemByType(pack, req.IType) + } + return +} +``` + +### 客户端发送消息到服务器处理的流程介绍 + - 前后端通用协议结构定义 pb/proto/comm.proto + ``` + message UserMessage { + string MainType =1; //消息的主id 默认为具体的业务模块名称 + string SubType = 2; //消息的副id 默认为具体处理消息的函数名 + ErrorCode Code = 3; //服务端回应客户端返回的错误码 pb/proto/errorcode.proto 定义 + bytes Data = 4; //具体的消息体内容 + } + ``` + - 网关服务接收用户协议的处理 modules/gateway/agent.go + ``` + //用户代理对象 + type Agent struct { + gateway IGateway + wsConn *websocket.Conn + sessionId string + uId string + writeChan chan *pb.UserMessage + closeSignal chan bool + state int32 //状态 0 关闭 1 运行 2 关闭中 + wg sync.WaitGroup + } + + //读取用户发送过来的消息 + func (this *Agent) readLoop() { + defer this.wg.Done() + var ( + data []byte + msg *pb.UserMessage = &pb.UserMessage{} + err error + ) + locp: + for { + if _, data, err = this.wsConn.ReadMessage(); err != nil { + log.Errorf("agent:%s uId:%s ReadMessage err:%v", this.sessionId, this.uId, err) + go this.Close() + break locp + } + //读取消息 并序列化到 UserMessage 结构对象 + if err = proto.Unmarshal(data, msg); err != nil { + log.Errorf("agent:%s uId:%s Unmarshal err:%v", this.sessionId, this.uId, err) + go this.Close() + break locp + } else { + //分发处理用户的消息请求 + this.messageDistribution(msg) + } + } + log.Debugf("agent:%s uId:%s readLoop end!", this.sessionId, this.uId) + } + + //分发用户消息 将用户消息采用负载的方式分到到 worker 类型的服务 + //此处后期会补充设计用户协议分化系统，暂时采用负载分发实现基本功能线 + func (this *Agent) messageDistribution(msg *pb.UserMessage) { + reply := &pb.RPCMessageReply{} + log.Debugf("agent:%s uId:%s MessageDistribution msg:%s.%s", this.sessionId, this.uId, msg.MainType, msg.SubType) + if err := this.gateway.Service().RpcCallByType("worker", string(comm.Rpc_GatewayRoute), context.Background(), &pb.AgentMessage{ + Ip: this.IP(), + UserSessionId: this.sessionId, + UserId: this.uId, + GatewayServiceId: this.gateway.Service().GetId(), + Method: fmt.Sprintf("%s.%s", msg.MainType, msg.SubType), + Message: msg.Data, + }, reply); err != nil { + log.Errorf("agent:%s uId:%s MessageDistribution err:%v", this.sessionId, this.uId, err) + } else { + log.Debugf("agent:%s uId:%s MessageDistribution reply:%v", this.sessionId, this.uId, reply) + } + } + + ``` + - Worker 服务如何接受用户的消息 services/comp_gateroute.go + ``` + //网关服务组件启动时会注册Rpc方法 接收网关服务那边发过来的用户消息 + func (this *SComp_GateRouteComp) Start() (err error) { + this.service.RegisterFunctionName(string(comm.Rpc_GatewayRoute), this.ReceiveMsg) //注册网关路由接收接口 + err = this.ServiceCompBase.Start() + return + } + + //具体接收用户消息的方法 此处消息分发需要当前服务内有模块注册处理消息的接口 没有注册的话 此处会打印错误日志 + //msghandles 为消息处理函数的管理对象 + func (this *SComp_GateRouteComp) ReceiveMsg(ctx context.Context, args *pb.AgentMessage, reply *pb.RPCMessageReply) error { + log.Debugf("SComp_GateRouteComp ReceiveMsg agent:%s uId:%d MessageDistribution msg:%s", args.UserSessionId, args.UserId, args.Method) + this.mrlock.RLock() + msghandle, ok := this.msghandles[args.Method] + this.mrlock.RUnlock() + if ok { + session := comm.NewUserSession(this.service, args.Ip, args.UserSessionId, args.GatewayServiceId, args.UserId) + msg := reflect.New(msghandle.msgType.Elem()).Interface() + if err := proto.Unmarshal(args.Message, msg.(proto.Message)); err != nil { + log.Errorf("UserMessage:%s Unmarshal err:%v", args.Method, err) + return err + } + msghandle.fn.Func.Call([]reflect.Value{msghandle.rcvr, reflect.ValueOf(ctx), reflect.ValueOf(session), reflect.ValueOf(msg)}) + } else { + reply.Code = pb.ErrorCode_ReqParameterError + // reply.Msg = pb.GetErrorCodeMsg(pb.ErrorCode_ReqParameterError) + } + return nil + } + ``` + - 业务模块 如何接受处理用户的消息 + ``` + #模块需要接受处理用户发送过来的消息需要装备一个继承modules/gate_comp.go 的模块网关组件，此组件启动是会自动把自身定义的消息处理函数注册到上面提到的服务网关组件services/comp_gateroute.go 中去，实现可以参考pack/api_comp.go 的定义 + /* + 模块 网关组件 接收处理用户传递消息 + */ + type MComp_GateComp struct { + cbase.ModuleCompBase + service base.IRPCXService + module core.IModule + comp core.IModuleComp + } + //组件启动是会通过反射把当前组件上定义的用户处理函数 统一注册到当前服务容器中的网关组件中 + func (this *MComp_GateComp) Start() (err error) { + if err = this.ModuleCompBase.Start(); err != nil { + return + } + var comp core.IServiceComp + //注册远程路由 + if comp, err = this.service.GetComp(comm.SC_ServiceGateRouteComp); err != nil { + return + } + this.suitableMethods(comp.(comm.ISC_GateRouteComp), reflect.TypeOf(this.comp)) + return + } + + //反射注册消息处理函数 + func (this *MComp_GateComp) suitableMethods(scomp comm.ISC_GateRouteComp, typ reflect.Type) { + for m := 0; m < typ.NumMethod(); m++ { + method := typ.Method(m) + mtype := method.Type + mname := method.Name + // Method must be exported. + if method.PkgPath != "" { + continue + } + // Method needs four ins: receiver, context.Context, *args, *reply. + if mtype.NumIn() != 4 { + continue + } + // First arg must be context.Context + ctxType := mtype.In(1) + if !ctxType.Implements(typeOfContext) { + continue + } + + // Second arg need not be a pointer. + argType := mtype.In(2) + if !argType.Implements(typeOfSession) { + continue + } + // Third arg must be a pointer. + replyType := mtype.In(3) + if replyType.Kind() != reflect.Ptr { + continue + } + // Reply type must be exported. + if !this.isExportedOrBuiltinType(replyType) { + continue + } + // Method needs one out. + if mtype.NumOut() != 1 { + continue + } + // The return type of the method must be error. + if returnType := mtype.Out(0); returnType != typeOfError { + continue + } + scomp.RegisterRoute(fmt.Sprintf("%s.%s", this.module.GetType(), strings.ToLower(mname)), reflect.ValueOf(this.comp), replyType, method) + } + } + ``` + - 消息处理函数如何给用户回复消息 + ``` + //每一个消息处理函数我们都会传递一个 IUserSession的对象 开发人员可以使用此对象向当前用户回复消息以及关闭连接等操作 + type IUserSession interface { + GetSessionId() string + GetUserId() string + GetIP() string + GetGatewayServiceId() string + IsLogin() bool + Build(uid string) (err error) + UnBuild(ServiceMethod string, msg proto.Message) (err error) + SendMsg(mainType, subType string, code pb.ErrorCode, msg proto.Message) (err error) + Close() (err error) + ToString() string + } + + + ///查询用户背包数据 + func (this *Api_Comp) QueryUserPackReq(ctx context.Context, session comm.IUserSession, req *pb.QueryUserPackReq) (err error) { + var ( + code pb.ErrorCode + pack *pb.DB_UserPackData + grids []*pb.DB_GridData + ) + defer func() { + session.SendMsg(string(this.module.GetType()), "queryuserpackresp", code, &pb.QueryUserPackResp{Grids: grids}) + }() + if !session.IsLogin() { + code = pb.ErrorCode_NoLogin + return + } + if pack, err = cache.Defsys.Pack_QueryUserPack(session.GetUserId()); err != nil { + log.Errorf("QueryUserPackReq err:%v", err) + code = pb.ErrorCode_CacheReadError + return + } else { + grids = this.module.configure_comp.GetPackItemByType(pack, req.IType) + } + return + } + ``` + - 消息处理函数如何给其他用户发送消息 + ``` + modules/modulebase.go 是所有业务模块的基础模块,大家在定义业务模块时注意继承此模块,此模块封装有给指定用户发送消息以及给多个用户同时发送消息的接口，后续一些通用的接口都会封装到这一层 方便上层业务模块快速调用,组件可以在Init方法中通过断言的方式获取到模块对象,在调用底层接口即可 + + //向目标用户发送消息 + func (this *ModuleBase) SendMsgToUser(mainType, subType string, msg proto.Message, user *pb.Cache_UserData) (err error) { + reply := &pb.RPCMessageReply{} + data, _ := proto.Marshal(msg) + if _, err = this.service.RpcGoById(user.GatewayServiceId, string(comm.Rpc_GatewayAgentSendMsg), context.Background(), &pb.AgentSendMessageReq{ + UserSessionId: user.SessionId, + MainType: mainType, + SubType: subType, + Data: data, + }, reply); err != nil { + log.Errorf("SendMsgToUser%d:%s [%s.%s] err:%v", user.UserData.UserId, user.SessionId, mainType, subType, err) + } + return + } + //向多个目标用户发送消息 + func (this *ModuleBase) SendMsgToUsers(mainType, subType string, msg proto.Message, user ...*pb.Cache_UserData) (err error) { + var ( + gateways map[string][]string = make(map[string][]string) + gateway []string + ok bool + ) + for _, v := range user { + if gateway, ok = gateways[v.GatewayServiceId]; !ok { + gateway = make([]string, 0) + gateways[v.GatewayServiceId] = gateway + } + gateway = append(gateway, v.SessionId) + } + reply := &pb.RPCMessageReply{} + data, _ := proto.Marshal(msg) + for k, v := range gateways { + if _, err = this.service.RpcGoById(k, string(comm.Rpc_GatewayAgentSendMsg), context.Background(), &pb.BatchMessageReq{ + UserSessionIds: v, + MainType: mainType, + SubType: subType, + Data: data, + }, reply); err != nil { + log.Errorf("SendMsgToUsers:%s->%s.%s err:%v", k, mainType, subType, err) + } + } + return + } + + + ``` \ No newline at end of file diff --git a/modules/pack/api_comp.go b/modules/pack/api_comp.go index 8d2cfbaf5..05014036d 100644 --- a/modules/pack/api_comp.go +++ b/modules/pack/api_comp.go @@ -67,7 +67,6 @@ func (this *Api_Comp) UseItemReq(ctx context.Context, session comm.IUserSession, code = pb.ErrorCode_NoLogin return } - return } diff --git a/sys/cache/options.go b/sys/cache/options.go index 2f11c6188..e42f945e2 100644 --- a/sys/cache/options.go +++ b/sys/cache/options.go @@ -12,6 +12,17 @@ type Options struct { Redis_Password string } +func Set_Redis_Addr(v []string) Option { + return func(o *Options) { + o.Redis_Addr = v + } +} + +func Set_Redis_Password(v string) Option { + return func(o *Options) { + o.Redis_Password = v + } +} func newOptions(config map[string]interface{}, opts ...Option) (Options, error) { options := Options{} if config != nil { diff --git a/sys/cache/pack.go b/sys/cache/pack.go index 15a96f42f..7cd16cd67 100644 --- a/sys/cache/pack.go +++ b/sys/cache/pack.go @@ -1,6 +1,7 @@ package cache import ( + "errors" "fmt" "go_dreamfactory/pb" "go_dreamfactory/sys/db" @@ -14,11 +15,22 @@ const ( //Redis ) const ( - GridCapMaxNum = 90 //单个格子的最大容量 + GridCapMaxNum = 99 //单个格子的最大容量 +) + +var ( + ItemNotEnoughError = errors.New("item not enough!") //物品不足 + NoFoundGirdError = errors.New("no found gvrid!") //未找到格子 + GirdAmountUpper = errors.New("grid amount upper!") //背包格子达到上限 ) type IPack interface { + ///查询用户背包 Pack_QueryUserPack(uId string) (pack *pb.DB_UserPackData, err error) + ///添加物品到背包 (可以加物品和减物品) + Pack_AddItemToUserPack(uId string, itemId int32, addnum int32) (err error) + //修改用户背包格子的标识 + Pack_ModifyPackGridIsNewItem(uId string, grids []int32) (err error) } ///查询用户背包数据 @@ -45,6 +57,7 @@ func (this *Cache) Pack_AddItemToUserPack(uId string, itemId int32, addnum int32 modifys []*pb.DB_GridData leftnum int64 num int64 + isNew bool ) if addnum == 0 { return @@ -52,10 +65,12 @@ func (this *Cache) Pack_AddItemToUserPack(uId string, itemId int32, addnum int32 if pack, err = this.Pack_QueryUserPack(uId); err != nil { return } + isNew = true leftnum = int64(addnum) modifys = make([]*pb.DB_GridData, 0) for _, v := range pack.Pack { if !v.IsEmpty && v.ItemId == itemId { + isNew = false num = int64(v.Amount) + int64(leftnum) if num < 0 { leftnum += int64(v.Amount) @@ -74,13 +89,120 @@ func (this *Cache) Pack_AddItemToUserPack(uId string, itemId int32, addnum int32 break } else { if v.Amount < GridCapMaxNum { - leftnum = int64(num - int64(v.Amount)) - v.Amount = uint32(num) + leftnum = int64(num - GridCapMaxNum) + v.Amount = uint32(GridCapMaxNum) modifys = append(modifys, v) } } } } } + if leftnum < 0 { //背包物品不够 + err = ItemNotEnoughError + return + } + if leftnum > 0 { //还没有放完 寻找空的格子填充 + for _, v := range pack.Pack { + if v.IsEmpty { + if leftnum <= GridCapMaxNum { + v.IsEmpty = false + v.ItemId = itemId + v.Amount = uint32(leftnum) + leftnum = 0 + modifys = append(modifys, v) + break + } else { + leftnum -= GridCapMaxNum + v.IsEmpty = false + v.ItemId = itemId + v.Amount = uint32(GridCapMaxNum) + modifys = append(modifys, v) + } + } + } + index := int32(len(pack.Pack)) + for leftnum > 0 { //需要补充格子 + if leftnum <= GridCapMaxNum { + modifys = append(modifys, &pb.DB_GridData{ + GridId: index, + IsEmpty: false, + ItemId: itemId, + Amount: uint32(leftnum), + IsNewItem: isNew, + }) + leftnum = 0 + break + } else { + leftnum -= GridCapMaxNum + modifys = append(modifys, &pb.DB_GridData{ + GridId: index, + IsEmpty: false, + ItemId: itemId, + Amount: uint32(GridCapMaxNum), + IsNewItem: isNew, + }) + index++ + } + } + } + if pack, err = db.Defsys.Pack_UpdateGridToUserPack(uId, modifys...); err == nil { + this.redis.Set(fmt.Sprintf(Redis_PackCache, uId), pack, -1) + } + return +} + +///修改指定格子的物品数量 +func (this *Cache) Pack_AddItemToUserPackByGrid(uId string, gridid int32, itemId int32, addnum int32) (err error) { + var ( + pack *pb.DB_UserPackData + grid *pb.DB_GridData + num int64 + amount int64 + ) + if addnum == 0 { + return + } + if pack, err = this.Pack_QueryUserPack(uId); err != nil { + return + } + if int32(len(pack.Pack)) <= gridid { + err = NoFoundGirdError + return + } + grid = pack.Pack[gridid] + if grid == nil { + err = NoFoundGirdError + return + } + amount = int64(grid.Amount) + if grid.IsEmpty { + amount = 0 + } else if grid.ItemId != itemId { + err = fmt.Errorf("target grid itemid:%d no is %d ", grid.ItemId, itemId) + } + num = amount + int64(addnum) + if num < 0 { + err = ItemNotEnoughError + } else { + if num > GridCapMaxNum { + err = GirdAmountUpper + return + } else { + if pack, err = db.Defsys.Pack_UpdateGridToUserPack(uId, grid); err == nil { + this.redis.Set(fmt.Sprintf(Redis_PackCache, uId), pack, -1) + } + } + } + return +} + +///修改目标格子的新获取标识 +func (this *Cache) Pack_ModifyPackGridIsNewItem(uId string, grids []int32) (err error) { + var ( + pack *pb.DB_UserPackData + ) + if pack, err = db.Defsys.Pack_ModifyPackGridIsNewItem(uId, grids); err == nil { + err = this.redis.Set(fmt.Sprintf(Redis_PackCache, uId), pack, -1) + } return } diff --git a/sys/cache/pack_test.go b/sys/cache/pack_test.go new file mode 100644 index 000000000..3466fd793 --- /dev/null +++ b/sys/cache/pack_test.go @@ -0,0 +1,21 @@ +package cache_test + +import ( + "fmt" + "go_dreamfactory/sys/cache" + "go_dreamfactory/sys/db" + "testing" +) + +func Test_Pack_AddItemToUserPack(t *testing.T) { + if err := db.OnInit(nil, db.Set_MongodbUrl("mongodb://admin:123456@10.0.0.9:27018"), db.Set_MongodbDatabase("dreamfactory")); err != nil { + fmt.Printf("err:%v\n", err) + return + } + if err := cache.OnInit(nil, cache.Set_Redis_Addr([]string{"10.0.0.9:9001", "10.0.0.9:9002", "10.0.0.9:9003", "10.0.1.45:9004", "10.0.1.45:9005", "10.0.1.45:9006"}), cache.Set_Redis_Password("")); err != nil { + fmt.Printf("err:%v\n", err) + return + } + err := cache.Defsys.Pack_AddItemToUserPack("liwei1dao", 1001, 100) + fmt.Printf("Pack_AddItemToUserPack err:%v\n", err) +} diff --git a/sys/db/options.go b/sys/db/options.go index eaa059085..7b3c1825d 100644 --- a/sys/db/options.go +++ b/sys/db/options.go @@ -12,6 +12,18 @@ type Options struct { MongodbDatabase string } +func Set_MongodbUrl(v string) Option { + return func(o *Options) { + o.MongodbUrl = v + } +} + +func Set_MongodbDatabase(v string) Option { + return func(o *Options) { + o.MongodbDatabase = v + } +} + func newOptions(config map[string]interface{}, opts ...Option) (Options, error) { options := Options{} if config != nil { diff --git a/sys/db/pack.go b/sys/db/pack.go index f56eea9d4..e333b803d 100644 --- a/sys/db/pack.go +++ b/sys/db/pack.go @@ -15,9 +15,14 @@ const ( //Redis ) type IPack interface { + ///初始化用户物品表 Pack_InitUserPack(uId string) (pack *pb.DB_UserPackData, err error) + ///查询用户背包 Pack_QueryUserPack(uId string) (pack *pb.DB_UserPackData, err error) + ///更新用户背包数据 Pack_UpdateGridToUserPack(uId string, grids ...*pb.DB_GridData) (pack *pb.DB_UserPackData, err error) + ///修改用户背包格子的标识 + Pack_ModifyPackGridIsNewItem(uId string, grids []int32) (pack *pb.DB_UserPackData, err error) } func (this *DB) Pack_InitUserPack(uId string) (pack *pb.DB_UserPackData, err error) {