自定义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();