1
int index = type - DEF_PROT_BASE;

1
协议 1000 -> 下标 0 -> dealRegisterRq
2
协议 1001 -> 下标 1 -> 服务端不处理回复协议，元素为空
3
协议 1002 -> 下标 2 -> dealLoginRq

1
class Kernel {
2
public:
3
    static Kernel* pKernel;
4

5
    using DealFunc = void (Kernel::*)(char*, int, unsigned long);
6

7
    Kernel();
8
    ~Kernel();
9

10
    void setProtocolFunArray();
11
    bool startServer();
12
    void endServer();
13
    void dealData(char* data, int len, unsigned long from);
14
    void dealRegisterRq(char* data, int len, unsigned long from);
15
    void dealLoginRq(char* data, int len, unsigned long from);
16

17
private:
18
    INetMediator* m_pMediator;
19
    CMySql m_sql;
20
    DealFunc m_protFuncArr[PROTO_COUNT];
21
};

1
void Kernel::setProtocolFunArray()
2
{
3
    cout << __func__ << endl;
4

5
    memset(m_protFuncArr, 0, sizeof(m_protFuncArr));
6

7
    m_protFuncArr[DEF_PROT_REGISTER_RQ - DEF_PROT_BASE]
8
        = &Kernel::dealRegisterRq;
9
    m_protFuncArr[DEF_PROT_LOGIN_RQ - DEF_PROT_BASE]
10
        = &Kernel::dealLoginRq;
11
}

1
bool Kernel::startServer()
2
{
3
    cout << __func__ << endl;
4
    setProtocolFunArray();
5

6
    // 打开网络、连接数据库
7
    // ...
8
}

1
void Kernel::dealData(char* data, int len, unsigned long from)
2
{
3
    cout << __func__ << endl;
4

5
    protType type = *(protType*)data;
6
    int index = type - DEF_PROT_BASE;
7

8
    if (index >= 0 && index < PROTO_COUNT) {
9
        DealFunc pF = m_protFuncArr[index];
10
        if (pF) {
11
            (this->*pF)(data, len, from);
12
        }
13
        else {
14
            cout << "type2: " << type << endl;
15
        }
16
    }
17
    else {
18
        cout << "type1: " << type << endl;
19
    }
20

21
    delete[] data;
22
}

1
(this->*pF)(data, len, from);

1
delete[] data;

1
CREATE TABLE t_user (
2
    id BIGINT NOT NULL AUTO_INCREMENT,
3
    nick VARCHAR(30) NOT NULL UNIQUE,
4
    tel VARCHAR(11) NOT NULL UNIQUE,
5
    pass VARCHAR(20) NOT NULL,
6
    feeling VARCHAR(100),
7
    iconid INT,
8
    PRIMARY KEY (id)
9
);

1
CREATE TABLE t_friend (
2
    idA BIGINT,
3
    idB BIGINT
4
);

1
idA = 1, idB = 2
2
idA = 2, idB = 1

1
收到注册请求
2
    |
3
    +-- 按昵称查询
4
    |      +-- 查到：回复“昵称已被注册”，结束
5
    |
6
    +-- 按手机号查询
7
    |      +-- 查到：回复“手机号已被注册”，结束
8
    |
9
    +-- 昵称和手机号都不存在
10
           +-- 插入用户信息
11
           +-- 回复“注册成功”

1
#define REGISTER_SUCC 0
2
#define REGISTER_NICK_EXISTS 1
3
#define REGISTER_TEL_EXISTS 2

1
m_sql.SelectMySql(sql, columnCount, listRes);

1
if (listRes.size() != 0) {
2
    // 查到了数据
3
}

1
char sql[1024] = "";
2
sprintf_s(sql,
3
          "select nick from t_user where nick = '%s';",
4
          rq->nick);

1
void Kernel::deal_registerRs(char* pbuf, int len, unsigned long ul)
2
{
3
    PROT_REGISTER_RS* pRegisterRs = (PROT_REGISTER_RS*)pbuf;
4

5
    if (pRegisterRs->result == REGISTER_SUCC) {
6
        QMessageBox::information(m_pLogin, "提示", "注册成功");
7
    }
8
    else if (pRegisterRs->result == REGISTER_NICK_EXISTS) {
9
        QMessageBox::information(m_pLogin, "提示", "注册失败，昵称已被注册");
10
    }
11
    else if (pRegisterRs->result == REGISTER_TEL_EXISTS) {
12
        QMessageBox::information(m_pLogin, "提示", "注册失败，电话号已被注册");
13
    }
14
}