自定義QQ機器人，實現關鍵字回復

使用第三方接口，可以很輕松的實現QQ機器人的自定義：打開源代碼->找到相應接口（私聊或群聊或其他）->自定義自己的內容->編譯生成*.dll動態庫->放入下載好的酷Q相應文件夾->登陸酷Q（最好用小號）。

這里主要強調有兩個方面：

1、如何實現自定義的對人友好化：即不需要編程知識也可以自定義實現。可以把關鍵字、回復內容放入一個配置文檔內，這樣只需修該配置文檔即可。我使用的是xml。在源代碼添加一個xmlLoader類即可解決問題

2、如何提高機器人處理消息的性能：給程序添加一個專門處理消息的線程。其中自己在使用互斥鎖時不夠熟練，應記得及時解鎖，否則會出現函數堵塞。

具體代碼如下：

#pragma once
#include "qqSupport.h"
#include <list>
#include "tinyxml/tinyxml.h"

using namespace std;

class xmlLoader
{
public:
    string getXmlPath()
    {
        string xP = getPath();
        string xmlPath = xP + "config.xml";

        return xmlPath;
    }


    int loadXml(string xmlPath)
    {
        //加載xml文件
        TiXmlDocument* doc = new TiXmlDocument();
        if (doc == NULL)
        {
            return -1;
        }
        doc->LoadFile(xmlPath);

        TiXmlElement* xmlRoot = doc->RootElement();
        TiXmlElement* xmlChildDef = xmlRoot->FirstChildElement("default");
        defaultAnswer = xmlChildDef->GetText();


        TiXmlElement* xmlChild = xmlRoot->FirstChildElement("match");
        while (xmlChild)
        {
            TiXmlElement* xmlKW = xmlChild->FirstChildElement("keyword");
            TiXmlElement* xmlAS = xmlChild->FirstChildElement("answer");
            msgContent mC;
            mC.keyword = xmlKW->GetText();
            mC.answer = xmlAS->GetText();

            m_msgContentList.push_back(mC);
            //addLog(mC.keyword.c_str());
            //addLog(mC.anwser.c_str());

            xmlChild = xmlChild->NextSiblingElement("match");
        }

        return 0;
    }

    string findAnswer(int type,string msg)
    {
        //根據關鍵字找答案
        for (list<msgContent>::iterator iter = m_msgContentList.begin();
            iter != m_msgContentList.end(); iter++)
        {
            
            msgContent& mC = *iter;
            addLog(mC.keyword.c_str());
            addLog(msg.c_str());
            addLog(mC.answer.c_str());
            if ((int)msg.find(mC.keyword)>0)
            {
                //addLog("有答案");
                return mC.answer;
            }
        }

        return defaultAnswer;
    }

private:
    struct msgContent //xml內容
    {
        string keyword;
        string answer;
    };
    list<msgContent> m_msgContentList; //保存到列表
    string defaultAnswer;
};

#pragma once
#include "afos/AfMutex.h"
#include "afos/AfThread.h"
#include "xmlLoader.h"
#include <list>

using namespace std;

class syncTask:public AfThread
{
public:
    int startService();
    void stopService();
    int addMsg(int type, int64_t from, const char *msg);
private:
    int ThreadMain();
private:
    struct recvMsg   //收到的信息
    {
        int type;
        int64_t from;
        string msg;
    };

private:

    list<recvMsg> m_recvMsgList;   //保存信息到列表
    AfMutex m_mutex;  //互斥鎖
    bool m_quitFlag;
    xmlLoader m_loader;  //加載xml類
};


void myIniti();

void myEexit();

void msgToThread(int type,int64_t from,const char *msg);

#include "myplugin.h"
#include "xmlLoader.h"
#include "qqSupport.h"


syncTask m_serviceTask;

int syncTask::startService()
{
    std::string xp = m_loader.getXmlPath();
    if (m_loader.loadXml(xp)<0)
    {
        return -1;
        //addLog("不能加載xml");
    }
    m_quitFlag = false;

    //進入線程
    this->Run();

    return 0;
}


void syncTask::stopService()
{
    m_quitFlag = true;
    Join(this);
}


int syncTask::ThreadMain()
{
    //addLog("進入線程");
    while (!m_quitFlag)
    {
        AfThread::Msleep(50);

        bool flag=false;
        recvMsg rM;
        m_mutex.Lock();//加鎖
        if (m_recvMsgList.size()>0)
        {
            flag = true;
            rM = m_recvMsgList.front();
            addLog(rM.msg.c_str());
            m_recvMsgList.pop_front();
            //addLog("有消息進入");
        }
        m_mutex.Unlock();
        if (!flag)
        {
            continue;
        }
        std::string answer = m_loader.findAnswer(rM.type, rM.msg);
        sendMsg(rM.type, rM.from, answer.c_str());
    }
    return 0;
}


int syncTask::addMsg(int type, int64_t from, const char * msg)
{
    recvMsg rM;
    rM.type = type;
    rM.from = from;
    rM.msg = msg;

    m_mutex.Lock();//加鎖
    if (m_recvMsgList.size()<100)
    {
        m_recvMsgList.push_back(rM);
    }
    m_mutex.Unlock();
    
    return 0;
}



void myIniti()
{
    m_serviceTask.startService();
}

void myEexit()
{
    m_serviceTask.stopService();
}

void msgToThread(int type, int64_t from, const char *msg)
{
    m_serviceTask.addMsg(type, from, msg);
}

#pragma once
#include "stdafx.h"
#include <string>
#include "cqp.h"
#include "appmain.h"

void sendMsg(int type, int64_t from, std::string msg);
void addLog(const char* msg);
std::string getPath();