美文网首页
Linux下Qtcpserver总结

Linux下Qtcpserver总结

作者: Jeremy_Ji | 来源:发表于2019-01-18 21:24 被阅读36次

    期末大作业是要做一个网络聊天室,于是学习了一个开源的项目,里面能够学习的东西还是蛮多的,在这里做一下总结。

    项目地址

    Group6ChatRoom

    QT环境配置

    嵌入式项目,要求程序可以在Linux上面可以跑,选择使用Qt,C++毕竟是面向对象的编程语言,用来封装方法还是很方便的。
    系统使用的是deepin,深度商店还是比较方便的直接下载Qt Creator,环境配置比GTK+省略了不少东西。
    项目.pro中添加support

    # 对网络请求必须加上network
    QT       += core gui network
    

    QTcpServer用法总结

    头函数需要添加库文件

    #include <QTcpSocket>
    #include <QTcpServer>
    

    槽函数也是自己定义,连接和断开时候的事件。
    这里是传入线程指针,server端接受到client连接请求时候的socket描述符,会为对应的描述符创建对应线程去处理这个请求。

        void on_client_connected(ClientThread* clientThread);
        void on_client_disconnected(ClientThread* clientThread);
    

    头文件中声明

    protected:
        //重新实现该方法用来接受client,并创建线程处理该连接
        void incomingConnection(qintptr socketDescriptor) override;
    

    该方法在代码中实现,为

     void Server::incomingConnection(qintptr socketDescriptor){
        qDebug() << socketDescriptor << " 连接中...";
        QTcpSocket *socket = new QTcpSocket();
        ClientThread *cliThread = new ClientThread(socketDescriptor,socket,this);
    
        //为连接进来的线程绑定事件
        connect(cliThread, SIGNAL(finished()),cliThread,SLOT(deleteLater()));
        connect(cliThread, SIGNAL(connected(ClientThread*)),this,SIGNAL(connected(ClientThread*)));
        connect(cliThread, SIGNAL(connected(ClientThread*)),this,SLOT(on_client_connected(ClientThread*)));
        ·
        ·
        ·
        connect(cliThread, SIGNAL(clientDisconnected(ClientThread*)),this,SIGNAL(clientDisconnected(ClientThread*)));
       
    
        //将socket转移到线程处理
        socket->moveToThread(cliThread);
        cliThread->start(); //启用线程
    }
    

    服务端开启监听,等待连接

    使用QTcpServer的异步模式,需要覆盖其中的一个listen函数,在调用listen()相当于开启一个循环(不会调用waitForNewConnection()一种阻塞方法或者叫做同步),关键代码。

    //默认使用host即“127.0.0.1”
        //调用listen函数,在指定的端口号中进行任意监听 ps:Any参数表示任意IPv4地址0.0.0.0
        if(!this->listen(QHostAddress::Any,port)){
            qDebug() << "无法启动服务端!";//log
            return false;
        }
        else{
            qDebug() << "server 监听中...";//log
            return true;
        }
    

    该方法需要设置ip以及端口号,使用函数获取或者手动输入也可以。

    客户端连接到服务端

    关键代码,试图连接到主机host的指定端口 并立即return。

    //获取地址
        QHostAddress servAddr(serverIP);
        ·
        ·
        //设置ip和端口号
        connectToHost(servAddr,this->port);
        waitForConnected(30000); //设置超时时间为30秒.
    
    

    QTcpSocket数据传送

    qt中的该类提供了一个tcp套接字,面向传输,面向连接的可靠的传输协议。

    /** 将消息发送给所有线程*/
    void Server::sendTextToAll(QString text,ClientThread* except){
        //用于暂存要发送的数据
        QByteArray block;
        //使用数据流写入数据 只写(设置为ReadWrite则为读写)
        QDataStream out(&block,QIODevice::WriteOnly);
        //设置数据流的版本,客户端server与服务端Client版本需要相同
        out.setVersion(QDataStream::Qt_5_8);
    
        //设置初始值为0,设置长度
        out << (quint32)0 << text;
    
        //回到字节流的起始位置
        out.device()->seek(0);
        //重置字节流长度
        out << (quint32)(block.size() - sizeof(quint32));
        qDebug() << "block.size() = " << block.size();//调试用(打印出block的长度)
    
        qint64 x = 0;
        //遍历线程列表
        foreach(ClientThread* eachClient,clientThreadList){
            if(except != NULL && eachClient == except)
                continue;
            x = 0;
            while(x < block.size()){
                //向套接字缓存中写入数据(主要)
                qint64 y = eachClient->getTcpSocket()->write(block);
                x+=y;
                //缓冲池在首次连接的时候没有数据,在首次连接成功时候打印出发送者
                qDebug() << eachClient->getUsername()<< "/sent" << x ;//调试用(输出发送者)
            }
            qDebug() << "-----";
        }
    }
    

    有关正则消息验证

    client 与 server 两端是分离的,可以开启多个client端,每一端发送的数据都要经过server的接收处理,分组转发。所以这里的思路是,所有向server端发送数据时候,对应的数据类型在Qstring字符串上进行处理(比如前面加上特定的字符:/pm就代表一条私聊消息),之后server在经过正则验证,不同的数据触发不同的信号。
    总结一下capture(QRegularExpression类使用正则表达式提供模式匹配)

            //私法消息的格式
            QString psersonal="/pm:"+currentTime+myUsername+text
    
            //私人消息的验证
            QRegularExpression regex_private("^/pm:(.*)/(.*) : (.*)\n$");
            ·
            ·
            //
            QString senderName = match.captured(2);
            QString time = match.captured(1);
            QString text = match.captured(3);
    

    分别提取对应括号中的文本信息。

    相关文章

      网友评论

          本文标题:Linux下Qtcpserver总结

          本文链接:https://www.haomeiwen.com/subject/cvyodqtx.html