leaf 和cocos creator 游戏实战（二）注册与登陆

mongodb的安装及配置，参考下文：

https://blog.csdn.net/heshushun/article/details/77776706

proto注册协议扩展：

1.服务端：

2.客户端：

把lobby.proto 复制到LeafServerCocosClient node_modules.bin文件夹下,把proto文件编译成静态文件使用:

pbjs -t static-module -w commonjs -o protocol.js lobby.proto
pbts -o protocol.d.ts protocol.js

把protocol.js 和protocol.d.ts拷贝到LeafServerCocosClient assets\script\protocol文件夹中.

3.lobby.proto：

syntax = "proto3";
package msg;

enum Result {
    REGISTER_SUCCESS=0;
    REGISTER_FAIL=1;
    LOGIN_SUCCESS=2;
    LOGIN_FAIL=3;
}

message Test {
    string Test = 2;
}

// 用户登陆协议
message UserLogin  {
    string LoginName = 1;   // 用户名
    string LoginPW =2;      // 密码
}
// 注册协议
message UserRegister {
    string LoginName =1;    // 用户名
    string LoginPW =2;      // 密码
}
// 消息返回协议
message UserResult {
    Result RetResult =1;
    string ErrorInfo = 2;
}

// 玩家有角色的情况
message UserST {
    string UID    =1;       // 账号ID
    string ServerID =2;     // 服务器ID
    string RoleUID  =3;     // 角色UID
    string RoleName =4;     // 角色名字
    string RoleLev =5;      // 角色等级
    string Coin  =6;        // 金币
    // 其他的暂时不做定义
}

向当前模块（game 模块）注册 消息处理函数

func init() {
    handler(&msg.UserLogin{}, handleUserLogin)
    handler(&msg.UserRegister{}, handleUserRegister)
}

处理相关消息

func handleUserRegister(args []interface{}) {
    m := args[0].(*msg.UserRegister)
    a := args[1].(gate.Agent)
    name :=m.GetLoginName()
    pwd :=m.GetLoginPW()
    log.Debug("receive UserRegister name=%v", m.GetLoginName())

    reg := regexp.MustCompile(`/^[a-zA-Z\d]\w{2,10}[a-zA-Z\d]$/`)
    matched := reg.FindString(name)
    if(matched!=" "){
        log.Debug("UserRegister name is licit", )
    }
    err := mongodbmgr.Find("game","login",bson.M{"name":name,})
    if err == nil {
        fmt.Println(err)
        log.Debug("UserRegister find in fail", )
        retBuf := &msg.UserResult{
            RetResult: msg.Result_REGISTER_FAIL,
            ErrorInfo:"账号已存在！",
        }
        a.WriteMsg(retBuf)
    }
    err =mongodbmgr.Insert("game","login",bson.M{"name":name,"password":pwd})
    if err != nil {
        fmt.Println(err)
        log.Debug("UserRegister write in fail", )
        retBuf := &msg.UserResult{
            RetResult: msg.Result_REGISTER_FAIL,
            ErrorInfo:"注册失败，请稍后再试！",
        }
        a.WriteMsg(retBuf)
    } else{
        log.Debug("UserRegister write in success", )
        retBuf := &msg.UserResult{
            RetResult: msg.Result_REGISTER_SUCCESS,
        }
        a.WriteMsg(retBuf)
    }
}

func handleUserLogin(args []interface{}) {
    m := args[0].(*msg.UserLogin)
    a := args[1].(gate.Agent)
    log.Debug("receive UserLogin name=%v", m.GetLoginName())

    retBuf := &msg.UserResult{
        RetResult: msg.Result_LOGIN_SUCCESS,
        ErrorInfo:"登陆失败，请稍后再试！",
    }
    a.WriteMsg(retBuf)
}

初始化时连接mongodb

package mongodbmgr

import (
    "fmt"
    "github.com/name5566/leaf/db/mongodb"
    "github.com/name5566/leaf/log"
    "gopkg.in/mgo.v2"
    "gopkg.in/mgo.v2/bson"
)

// 连接消息
var dialContext = new(mongodb.DialContext)

func init() {
    Connect()
}
func Connect() {
    c, err := mongodb.Dial("localhost", 10)
    if err != nil {
        fmt.Println(err)
        return
    }
    //defer c.Close()
    // index
    c.EnsureUniqueIndex("game", "login", []string{"name"})
    log.Release("mongodb Connect success")
    dialContext = c

    Test()
}
func Test() {
    err :=Find("game","login",bson.M{"name":"hello"})
    if err == nil {
        log.Debug("Test have data,regFail!", )
    }else{
        err =Insert("game","login",bson.M{"name":"hello","password":"123456"})
        if err != nil {
            fmt.Println(err)
            log.Debug("Test write in fail", )
        }
    }
}

func Example() {
    c, err := mongodb.Dial("localhost", 10)
    if err != nil {
        fmt.Println(err)
        return
    }
    defer c.Close()

    // session
    s := c.Ref()
    defer c.UnRef(s)
    err = s.DB("test").C("counters").RemoveId("test")
    if err != nil && err != mgo.ErrNotFound {
        fmt.Println(err)
        return
    }

    // auto increment
    err = c.EnsureCounter("test", "counters", "test")
    if err != nil {
        fmt.Println(err)
        return
    }
    for i := 0; i < 3; i++ {
        id, err := c.NextSeq("test", "counters", "test")
        if err != nil {
            fmt.Println(err)
            return
        }
        fmt.Println(id)
    }

    // index
    c.EnsureUniqueIndex("test", "counters", []string{"key1"})

    // Output:
    // 1
    // 2
    // 3
}

func Find(db string, collection string, docs interface{}) error{
    c:=dialContext
    s := c.Ref()
    defer c.UnRef(s)

    type person struct {
        Id_ bson.ObjectId `bson:"_id"`
        Name string `bson:"name"`
    };
    user:=new(person);
    err := s.DB(db).C(collection).Find(docs).One(&user)
    //idStr:=user.Id_.Hex()
    //fmt.Println(idStr)
    if err != nil {
        fmt.Println(err)
        return err
    }

    return err;
}

// goroutine safe
func Insert(db string, collection string, docs interface{}) error {
    c:=dialContext
    s := c.Ref()
    defer c.UnRef(s)

    //// 创建索引
    //index := mgo.Index{
    //  Key:        []string{"name"}, // 索引字段， 默认升序,若需降序在字段前加-
    //  Unique:     true,             // 唯一索引 同 mysql 唯一索引
    //  DropDups:   true,             // 索引重复替换旧文档,Unique为true时失效
    //  Background: true,             // 后台创建索引
    //}
    //if err := s.DB(db).C(collection).EnsureIndex(index); err != nil {
    //  fmt.Println(err)
    //  return err
    //}
    //if err := s.DB(db).C(collection).EnsureIndexKey("$2dsphere:location"); err != nil { // 创建一个范围索引
    //  fmt.Println(err)
    //  return err
    //}

    err := s.DB(db).C(collection).Insert(docs)
    if err != nil {
        fmt.Println(err)
        return err
    }

    return err
}

Cocos creator客户端注册及登陆

简单的合法性判断 工具 类

import messageDialog from './MessageDialog';
interface CheckRet{
    ret:boolean,
    msg:string
}
interface message{
    title:string,
    text:string
}
export default class Utils {
    //检测用户名是否合法
    static check_usr(str:string):CheckRet{
        let c=<CheckRet>{};
        var b :RegExp=/^[a-zA-Z\d]\w{2,10}[a-zA-Z\d]$/;
        if (b.test(str)) {
            c.ret = true;
            c.msg = "用戶名合法";
        }
        else {
            c.ret = false;
            c.msg = "用戶名不合法";
        }

        return c;
    }
    
    
    //判断密码输入是否合法，一个是长度，一个是没有特殊字符
    static check_psw(str:string):CheckRet{
        let c=<CheckRet>{};
        if(str.length > 5 && str.length<21){
            c.ret = true;
            c.msg = "";
        }else {
            c.ret = false;
            c.msg = "密码长度不合规范";
        }
        var b:RegExp =/^[a-zA-Z\d]\w{2,10}[a-zA-Z\d]$/;
        if (b.test(str)) {
            c.ret = true;
            c.msg = "";
        }else {
            c.ret = false;
            c.msg = "密码字符不合规范";
        }

        return c;
    }

        
    //判断手机号码格式是否合法
    static check_tel(str:string):CheckRet{
        let c=<CheckRet>{};
        var regx=/^(?:13\d|15\d|18[123456789])-?\d{5}(\d{3}|\*{3})$/;
        if(regx.test(str)){
            c.ret = true;
            c.msg = "";
        }else{
            c.ret = false;
            c.msg = "手机号不合规范";
        }

        return c;
    }
    
        
    //判断邮箱地址格式是否合法
    static check_mail(str:string):CheckRet{
        let c=<CheckRet>{};
        var regm = /^[a-zA-Z0-9_-]+@[a-zA-Z0-9_-]+(\.[a-zA-Z0-9_-]+)+$/;//验证Mail的正则表达式,^[a-zA-Z0-9_-]:开头必须为字母,下划线,数字,
        if (str.match(regm)){
            c.ret = true;
            c.msg = "";
            
        } else{
            c.ret = false;
            c.msg = "邮箱地址不合规范";
        }

        return c;
    }

    static showTips(title:string,text:string){
        messageDialog.getInstance().showTips({title:title,text:text})
    }
}

注册流程

import NetMessageCtrl  from './NetMessageCtrl';
import Utils from './Utils';
const {ccclass, property} = cc._decorator

@ccclass
export default class Register extends cc.Component {

    @property(cc.EditBox)
    Name: cc.EditBox = null;

    @property(cc.EditBox)
    Pwd: cc.EditBox = null;

    onLoad(){
           
    }

    onBtnPanel(){
        this.node.parent.active = false
    }

    onBtnComfirm(){
        var name = this.Name.string;
        var pwd = this.Pwd.string;
        if(name && pwd){
            let check = Utils.check_usr(name)
            let checkPwd = Utils.check_psw(name)
            if(check.ret){
                if(checkPwd.ret){
                    NetMessageCtrl.getInstance().sendRegister(name,pwd);
                }
                else{
                    Utils.showTips("提示",checkPwd.msg)
                }
            }
            else{
                Utils.showTips("提示",check.msg)
            }
        }
        else{
            Utils.showTips("提示","请输入完整注册数据")
        }
    }
}

处理收到的回信

dealMessage(id: number,data: Uint8Array ){
      switch(id){
            case netConfig.ProtocolId.Test:
                this.dealTest(data)
                break;
            case netConfig.ProtocolId.UserResult:
                this.dealUserResult(data)
                break;
            default:
                break;
        }
    }

  //注册登陆登一系列用户行为的结果都通过netConfig.ProtocolId.UserResult协议返回
   dealUserResult(data: Uint8Array){
        console.log("get UserResult message!");
        let gameMsg = msg.UserResult.decode(data);
        console.log(gameMsg);
    }

Example gihub地址：

server: https://github.com/ddkgo/LeafServerExample.git

client: https://github.com/ddkgo/LeafServerCocosClient.git