码迷,mamicode.com
首页 > 其他好文 > 详细

9、Khala实现0.01版QQ

时间:2016-01-03 21:03:44      阅读:236      评论:0      收藏:0      [点我收藏+]

标签:

  这次来个有界面的。

  登录界面:

技术分享

技术分享

  主界面:

技术分享

技术分享

 

1、服务端开发:

  只需创建一个类ChatType(./examples/HelloKhala/src/ChatType.cpp),在该类型中,核心为创建的两个消息事件,一个为onCurrFriends,用于获取当前在线用户;一个为onSendMsg,用于向具体用户发送消息。

  客户端请求当前的在线用户的信息,发送请求消息。该请求消息由onCurrFriends解析。onCurrFriends首先获取所有类型为ChatType的在线用户的id,然后再遍历这些id,根据id获取具体的用户信息,并将这些信息以json形式进行处理,设置类型为CHAT_TYPE,并最终将该json消息发送给请求的客户端。

bool ChatType::onCurrFriends(khala::InfoNodePtr& infoNodePtr, Json::Value& msg,
        khala::Timestamp time) {
    Json::Value res;
    //返回给请求用户的消息类型
    res[MSG_TYPE] = CHAT_FRIENDS;
    res["result"] = "true";
    khala::NodeManager* nodeManager = getNodeManager();
    //获取类型为ChatType的在线用户的id
    std::vector<uint> currIds = nodeManager->getNodeIDs(
            infoNodePtr->getNodeType());
    for (std::vector<uint>::iterator it = currIds.begin(); it != currIds.end();
            ++it) {
        khala::InfoNodePtr usrInfoNode;
        //根据id获取具体用户的信息
        if (nodeManager->find(*it, usrInfoNode)) {
            Json::Value usrJs;
            usrJs[KEY_ID] = *it;
            UsrInfo* usrInfo = boost::any_cast<UsrInfo*>(
                    usrInfoNode->getExtraContext());
            usrJs["name"] = usrInfo->getName();
            res["data"].append(usrJs);
        }
    }
    //发送json消息
    Json::FastWriter jwriter;
    std::string sendStr = jwriter.write(res);
    infoNodePtr->send(sendStr);
    return true;
}

 

  客户端用户A请求发送消息msg给用户B,该请求消息由onSendMsg解析。onSendMsg获取消息msg,根据用户B的id获取用户B的对象,并将msg以json进行消息处理后设置消息类型为CHAT_REV,并发送给用户B。同时记录发送结果,并将结果以json形式进行处理,最后设置消息类型为CHAT_SEND将该结果返回给用户A。

bool ChatType::onSendMsg(khala::InfoNodePtr& infoNodePtr, Json::Value& msg,
        khala::Timestamp time) {
    Json::Value res;
    //返回给请求发送用户的消息类型
    res[MSG_TYPE] = CHAT_SEND;
    //获取目的用户的id
    uint friendId = msg[KEY_FRIEND_ID].asUInt();
    //得到待发送消息
    std::string sendMsg = msg[CHAT_MSG].asString();
    res[FRIEND_NAME] = msg[FRIEND_NAME].asString();
    res[CHAT_MSG] = sendMsg;
    khala::InfoNodePtr friendNodePtr;
    //根据目的用户的id获取目的用户的对象
    if (this->getNodeManager()->find(friendId, friendNodePtr)) {
        Json::Value sendJs;
        //发送给目的用户的消息类型
        sendJs[MSG_TYPE] = CHAT_REV;
        //发送给目的用户的消息
        sendJs[CHAT_MSG] = sendMsg;
        UsrInfo* usrInfo = boost::any_cast<UsrInfo*>(
                infoNodePtr->getExtraContext());
        if (usrInfo == 0) {
            return false;
        }
        //发送用户的姓名和id
        sendJs[SEND_NAME] = usrInfo->getName();
        sendJs[KEY_FRIEND_ID] = infoNodePtr->getId();
        //将该json消息发送给目的用户
        Json::FastWriter jwriter;
        std::string sendStr = jwriter.write(sendJs);
        friendNodePtr->send(sendStr);
        //向请求用户标示结果为成功
        res["result"] = "true";
    } else {
        //向请求用户标示结果为失败
        res["result"] = "false";
    }
    //将发送结果返回给请求用户
    Json::FastWriter jwriter;
    std::string sendStr = jwriter.write(res);
    infoNodePtr->send(sendStr);
    return true;
}

 

2、客户端开发:

  主要工作,拖界面,写控件响应事件!(废话)

  主要创建2个线程,一个为消息发送线程,一个为消息接收线程。

  消息发送线程:建立一个多生产者单消费者模型,每个窗口作为一个生产者,消息发送线程作为单独的消费者,选择System.Collections.Queue作为中间缓存。窗口将待发送json消息通过生产者接口发送给缓存容器。一旦缓存容器中存在待发送的消息,发送线程便被唤醒,从缓存中读取消息,对消息进行处理(选择utf8对字符进行处理,并添加长度头解决粘包问题),最终通过套接字发送给服务端。

  消息接收线程:以阻塞方式通过套接字循环接收消息,并将消息以字节形式保存在接收缓存中,通过长度头从接收缓存中获取每条完整的消息。再对该消息进行字符处理,解析为json形式,并根据消息类型将完整的消息通过SendMessage()发送给相应的窗口句柄进行处理。

  在每个具体窗口中,通过重写DefWndProc()来获取接收线程获取到的具体消息,并根据接收到的json消息编写窗口响应函数。

  具体客户端的代码就不贴了,不会C#,代码写得丑…

 

  最近应该会重写设备生命周期部分的代码,之前生命周期的超时检测部分设计实现得太丑陋,自己都看不下去了。争取少改动主要接口吧,阿门...

9、Khala实现0.01版QQ

标签:

原文地址:http://www.cnblogs.com/moyangvip/p/5093823.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!