Qt UDP的初步使用

 为了使用Qt自带的Socket进行网络编程,先必须熟悉Socket编程的原理,另外还需对Qt一些基本类的操作比较熟悉。由于刚接触不久,所以还是以看人家的代码来学习。这次主要是学Qt下UDP的编程,且熟悉一些Qt下代码的编写流程,所以本文参照的是《Qt及Qt Quick开发实战精解》一书中的第5个例子:局域网聊天工具中的UDP聊天部分。

     另外http://www.yafeilinux.com/ 上有其源码和相关教程下载。

     该程序实现的功能是:局域网内,每个用户登录到聊天软件,则软件界面的右端可以显示在线用户列表,分别显示的是用户名,主机名,ip地址。软件左边那大块是聊天内容显示界面,这里局域网相当于qq中的qq群,即群聊。每个人可以在聊天输入界面中输入文字并发送。其聊天界面如下:

    

     该程序实现的是每个用户登录既是客户端又是服务器端,这就需要看你站在哪个角度看问题了。简单的说,当用户发送信息给别人时就是客户端,当接收别人的信息是就可以看做是服务器端。

  下面分服务器端和客户端2部分来介绍。

  服务器端:建立一个UDP Socket并绑定在固定端口后,用信号与槽的方式进行监听是否有数据来临。如果用,接收其数据并分析数据的消息类型,如果消息是新用户登录则更新用户列表并在聊天显示窗口中添加新用户上线通知;同理,如果是用户下线,则在用户列表中删除该用户且在聊天显示窗口中显示下线通知;如果是聊天消息,则接收该消息并且在窗口中显示。其流程图如下:

    

  客户端:首先当客户端登录时,获取本机的用户名,计算机名和ip地址,并广播给局域网的服务器更新用户列表。然后当客户端需要发送信息时,则在聊天输入栏中输入信息并按发送键发送聊天内容,当然于此同时也广播本地系统的各种信息。其流程图如下:

   

  程序主要代码和注释如下:

widget.h:

复制代码
#ifndef WIDGET_H
#define WIDGET_H#include <QWidget>
class QUdpSocket;namespace Ui {
class Widget;
}// 枚举变量标志信息的类型,分别为消息,新用户加入,用户退出,文件名,拒绝接受文件
enum MessageType{Message, NewParticipant, ParticipantLeft, FileName, Refuse};class Widget : public QWidget
{Q_OBJECTpublic:explicit Widget(QWidget *parent = 0);~Widget();protected:void newParticipant(QString userName,QString localHostName, QString ipAddress);void participantLeft(QString userName,QString localHostName, QString time);void sendMessage(MessageType type, QString serverAddress="");QString getIP();QString getUserName();QString getMessage();private:Ui::Widget *ui;QUdpSocket *udpSocket;qint16 port;private slots:void processPendingDatagrams();void on_sendButton_clicked();
};#endif // WIDGET_H
复制代码

widget.cpp:

复制代码
#include "widget.h"
#include "ui_widget.h"
#include <QUdpSocket>
#include <QHostInfo>
#include <QMessageBox>
#include <QScrollBar>
#include <QDateTime>
#include <QNetworkInterface>
#include <QProcess>Widget::Widget(QWidget *parent) :QWidget(parent),ui(new Ui::Widget)
{ui->setupUi(this);udpSocket = new QUdpSocket(this);//创建一个QUdpSocket类对象,该类提供了Udp的许多相关操作port = 45454;//此处的bind是个重载函数,连接本机的port端口,采用ShareAddress模式(即允许其它的服务连接到相同的地址和端口,特别是//用在多客户端监听同一个服务器端口等时特别有效),和ReuseAddressHint模式(重新连接服务器)udpSocket->bind(port, QUdpSocket::ShareAddress | QUdpSocket::ReuseAddressHint);//readyRead()信号是每当有新的数据来临时就被触发connect(udpSocket, SIGNAL(readyRead()), this, SLOT(processPendingDatagrams()));sendMessage(NewParticipant);//打开软件时就向外发射本地信息,让其他在线用户得到通知
}Widget::~Widget()
{delete ui;
}// 使用UDP广播发送信息,MessageType是指头文件中的枚举数据类型
//sendMessage即把本机的主机名,用户名+(消息内容后ip地址)广播出去
void Widget::sendMessage(MessageType type, QString serverAddress)
{QByteArray data;    //字节数组//QDataStream类是将序列化的二进制数据送到io设备,因为其属性为只写QDataStream out(&data, QIODevice::WriteOnly);QString localHostName = QHostInfo::localHostName();//返回主机名,QHostInfo包含了一些关于主机的静态函数QString address = getIP();    //调用自己类中的getIP()函数//将type,getUserName(),localHostName按照先后顺序送到out数据流中,消息类型type在最前面out << type << getUserName() << localHostName;switch(type){case Message :if (ui->messageTextEdit->toPlainText() == "") {    //将输入框里的文字转化成纯文本发送//当发送的文本为空时创建一个警告信息窗口,tr函数为译本函数,即译码后面的text内容QMessageBox::warning(0,tr("警告"),tr("发送内容不能为空"),QMessageBox::Ok);    return;}out << address << getMessage();//将ip地址和得到的消息内容输入out数据流ui->messageBrowser->verticalScrollBar()    //返回垂直条->setValue(ui->messageBrowser->verticalScrollBar()->maximum());//设置垂直滑动条的最大值break;case NewParticipant :out << address;    //为什么此时只是输出地址这一项呢?因为此时不需要传递聊天内容break;case ParticipantLeft :break;case FileName :break;case Refuse :break;}//一个udpSocket已经于一个端口bind在一起了,这里的data是out流中的data,最多可以传送8192个字节,但是建议不要超过//512个字节,因为这样虽然可以传送成功,但是这些数据需要在ip层分组,QHostAddress::Broadcast是指发送数据的目的地址//这里为本机所在地址的广播组内所有机器,即局域网广播发送udpSocket->writeDatagram(data,data.length(),QHostAddress::Broadcast, port);//将data中的数据发送
}// 接收UDP信息
void Widget::processPendingDatagrams()
{//hasPendingDatagrams返回true时表示至少有一个数据报在等待被读取while(udpSocket->hasPendingDatagrams()){QByteArray datagram;//pendingDatagramSize为返回第一个在等待读取报文的size,resize函数是把datagram的size归一化到参数size的大小一样datagram.resize(udpSocket->pendingDatagramSize());//将读取到的不大于datagram.size()大小数据输入到datagram.data()中,datagram.data()返回的是一个字节数组中存储//数据位置的指针udpSocket->readDatagram(datagram.data(), datagram.size());QDataStream in(&datagram, QIODevice::ReadOnly);//因为其属性为只读,所以是输入int messageType;    //此处的int为qint32,在Qt中,qint8为char,qint16为uintin >> messageType;    //读取1个32位长度的整型数据到messageTyep中
        QString userName,localHostName,ipAddress,message;QString time = QDateTime::currentDateTime().toString("yyyy-MM-dd hh:mm:ss");//将当前的时间转化到括号中的形式switch(messageType){case Message://in>>后面如果为Qstring,则表示读取一个直到出现'\0'的字符串in >> userName >> localHostName >> ipAddress >> message;ui->messageBrowser->setTextColor(Qt::blue);//设置文本颜色ui->messageBrowser->setCurrentFont(QFont("Times New Roman",12));//设置字体大小//     ui->messageBrowser->append("[ " +userName+" ] "+ time);//输出的格式为用户名加时间显示//输出的格式为主机名加时间显示,但输出完后为什么会自动换行呢?ui->messageBrowser->append("[ " +localHostName+" ] "+ time);ui->messageBrowser->append(message);//消息输出break;case NewParticipant:in >>userName >>localHostName >>ipAddress;newParticipant(userName,localHostName,ipAddress);break;case ParticipantLeft:in >>userName >>localHostName;participantLeft(userName,localHostName,time);break;case FileName:break;case Refuse:break;}}
}// 处理新用户加入
void Widget::newParticipant(QString userName, QString localHostName, QString ipAddress)
{//此处的findItems表示找到与内容localHostName匹配的item,其匹配是基于变体的匹配模式bool isEmpty = ui->userTableWidget->findItems(localHostName, Qt::MatchExactly).isEmpty();if (isEmpty) {    //没有找到相应的主机名//新建3个小的item,分别为user,host,ipQTableWidgetItem *user = new QTableWidgetItem(userName);QTableWidgetItem *host = new QTableWidgetItem(localHostName);QTableWidgetItem *ip = new QTableWidgetItem(ipAddress);ui->userTableWidget->insertRow(0);//先设置的是第0行,即新来的用户放在最上面ui->userTableWidget->setItem(0,0,user);//第0行的第1列...ui->userTableWidget->setItem(0,1,host);ui->userTableWidget->setItem(0,2,ip);ui->messageBrowser->setTextColor(Qt::gray);ui->messageBrowser->setCurrentFont(QFont("Times New Roman",10));//arg为返回后面文本的一个副本,%1表示输出的内容按照第1个.arg后面的输出?ui->messageBrowser->append(tr("%1 在线!").arg(userName));ui->userNumLabel->setText(tr("在线人数:%1").arg(ui->userTableWidget->rowCount()));//在线人数为条目的行数
sendMessage(NewParticipant);//该句的功能是让新来的用户也能收到其它在线用户的信息,可拥于更新自己的好友列表
    }
}// 处理用户离开
void Widget::participantLeft(QString userName, QString localHostName, QString time)
{//找到第一个对应的主机名int rowNum = ui->userTableWidget->findItems(localHostName, Qt::MatchExactly).first()->row();ui->userTableWidget->removeRow(rowNum);    //此句执行完后,rowCount()内容会自动减1ui->messageBrowser->setTextColor(Qt::gray);//设置文本颜色为灰色ui->messageBrowser->setCurrentFont(QFont("Times New Roman", 10));ui->messageBrowser->append(tr("%1 于 %2 离开!").arg(userName).arg(time));ui->userNumLabel->setText(tr("在线人数:%1").arg(ui->userTableWidget->rowCount()));
}// 获取ip地址,获取本机ip地址(其协议为ipv4的ip地址)
QString Widget::getIP()
{//QList是Qt中一个容器模板类,是一个数组指针?QList<QHostAddress> list = QNetworkInterface::allAddresses();//此处的所有地址是指ipv4和ipv6的地址//foreach (variable, container),此处为按照容器list中条目的顺序进行迭代foreach (QHostAddress address, list) {    if(address.protocol() == QAbstractSocket::IPv4Protocol)return address.toString();}return 0;
}// 获取用户名
QString Widget::getUserName()
{QStringList envVariables;//将后面5个string存到envVariables环境变量中envVariables << "USERNAME.*" << "USER.*" << "USERDOMAIN.*"<< "HOSTNAME.*" << "DOMAINNAME.*";//系统中关于环境变量的信息存在environment中QStringList environment = QProcess::systemEnvironment();foreach (QString string, envVariables) {//indexOf为返回第一个匹配list的索引,QRegExp类是用规则表达式进行模式匹配的类int index = environment.indexOf(QRegExp(string));if (index != -1) {//stringList中存的是environment.at(index)中出现'='号前的字符串QStringList stringList = environment.at(index).split('=');if (stringList.size() == 2) {return stringList.at(1);//at(0)为文字"USERNAME.",at(1)为用户名break;}}}return "unknown";
}// 获得要发送的消息
QString Widget::getMessage()
{QString msg = ui->messageTextEdit->toHtml();//转化成html语言进行发送
ui->messageTextEdit->clear();//发送完后清空输入框ui->messageTextEdit->setFocus();//重新设置光标输入焦点,即焦点保持不变return msg;
}// 发送消息
void Widget::on_sendButton_clicked()
{sendMessage(Message);
}
复制代码

main:

复制代码
#include <QtGui/QApplication>
#include "widget.h"
#include <QTextCodec>    //处理不同语言编码的类int main(int argc, char *argv[])
{QApplication a(argc, argv);QTextCodec::setCodecForTr(QTextCodec::codecForLocale());//对不同的文字选择不同的编码
    Widget w;w.show();return a.exec();
}
复制代码

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/433127.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

下列哪一项不是计算机网络的典型应用,09级计算机信息网络试卷A

…………密…………封…………线…………内…………请…………不…………要…………答…………题…………河北工程大学11~12学年第二学期期末考试试卷A一、填空题(每空1分&#xff0c;共10分)1、在因特网中&#xff0c;远程登录Telnet系统采用的应用工作模式为____客户机&#…

hdu 4452

今天模拟赛的一个模拟题&#xff1b; 每次看到这种题就感觉很繁琐&#xff1b; 这次静下心来写写&#xff0c;感觉还不错&#xff01;就是很多错误&#xff0c;浪费了一点时间&#xff1b; 代码&#xff1a; 1 #include<cstdio>2 #include<cstring>3 using namespa…

openpyxl 绘制饼形图_好享学丨快速上手Pythonmatplotlib 箱线图绘制,学术人必备

好享学是高下制图推出的关于数据可视化经验分享栏目&#xff0c;我们将定期与您分享各界优秀人士的制图经验&#xff0c;一同学习。01. 引言箱线图(Boxplot) 是一种用作显示一组数据分散情况资料的统计图表&#xff0c;本期推文就如何使用matplotlib和seaborn 绘制出高度定制化…

揭开Socket编程的面纱

对TCP/IP、UDP、Socket编程这些词你不会很陌生吧&#xff1f;随着网络技术的发展&#xff0c;这些词充斥着我们的耳朵。那么我想问&#xff1a; 1. 什么是TCP/IP、UDP&#xff1f; 2. Socket在哪里呢&#xff1f; 3. Socket是什么呢&#xff1f; 4. 你会使用它们吗&#xff1f;…

socket中的函数遇见EINTR的处理

这几天&#xff0c;写服务器代码过程当中&#xff0c;遇见EINRT信号的问题&#xff0c;我是借鉴 《unp 》&#xff0c;采用continue或者goto again循环解决的。但是感觉这个还是很有必要记录一下。网络上查找到的信息很多。下面是我查找到的和EINTR有关的介绍&#xff1a;1 ht…

vue 如何获取图片的原图尺寸_公众号封面图片尺寸是多少?如何在公众号里制作封面图?...

公众号文章封面图是自己动手制作还是直接使用网络图片呢&#xff1f;在刚开始接触公众号运营时&#xff0c;我的大部分插图和封面图都是直接选择网络图片&#xff0c;后来才发现&#xff0c;自己制作的封面图更能传达文章的内容&#xff0c;阅读效果更好。其实很多做公众号的人…

信号中断 与 慢系统调用

1. 术语 1.1. 慢系统调用&#xff08;Slow system call&#xff09; 该术语适用于那些可能永远阻塞的系统调用。永远阻塞的系统调用是指调用永远无法返回&#xff0c;多数网络支持函数都属于这一类。如&#xff1a;若没有客户连接到服务器上&#xff0c;那么服务器的accept调用…

delete hive_Hive高级调优

Hive调优策略Hive作为大数据领域常用的数据仓库组件&#xff0c;在设计和开发阶段需要注意效率。影响Hive效率的不仅仅是数据量过大;数据倾斜、数据冗余、job(小文件多)或I/O过多、MapReduce分配不合理等因素都对Hive的效率有影响。对Hive的调优既包含对HiveQL语句本身的优化&a…

联想计算机如何设置用户名和密码,联想电脑怎样设密码?联想电脑设置密码方法步骤【图文】...

现代 人最重要的是什么呢?在笔者看来是隐私。如今由于我们的社会比较发达&#xff0c;而信息传播的速度有非常广泛&#xff0c;加上各种隐私被盗取或者偷窥&#xff0c;让现代人的生活总是充斥着不安&#xff0c;所以我们各类的电子设备诸如手机&#xff0c;电脑加密是非常有必…

em算法 实例 正态分布_EM算法解GMM

看了很多介绍EM算法的文章&#xff0c;但是他们都没有代码&#xff0c;所以在这里写出来。Jensen 不等式参考期望最大算法Jensen不等式在优化理论中大量用到&#xff0c;首先来回顾下凸函数和凹函数的定义。假设 是定义域为实数的函数&#xff0c;如果对于所有的 &#xff0c; …

wifi 小米pro 驱动 黑苹果_搞定小米黑苹果自带WIF,又可省一个USB接口了

首先声明我的是小米笔记本PRO版本的&#xff0c;其他版本的没有经过测试&#xff0c;但理论都是没有问题的&#xff0c;其他版本的朋友&#xff0c;喜欢折腾的话&#xff0c;可以试试&#xff01;自用版本关于小米笔记本安装黑苹果&#xff0c;网上一直都有很多链接&#xff0c…

代理模式 委派模式 策略模式_策略模式

在策略模式(Strategy Pattern)中&#xff0c;一个类的行为或其算法可以在运行时更改。这种类型的设计模式属于行为型模式。在策略模式中&#xff0c;我们创建表示各种策略的对象和一个行为随着策略对象改变而改变的 context 对象。策略对象改变 context 对象的执行算法。介绍意…

例2-1

#include<stdio.h> int main(void) {printf("Hello World!\n");return 0; } 转载于:https://www.cnblogs.com/520zy/p/3348951.html

java第七章jdbc课后简答题_Java周测题08.13

1.关于Mybatis的描述正确的是&#xff1a;Mybatis是持久层框架&#xff0c;Mybatis封装了JDBC&#xff0c;Mybatis简化了代码的编辑和使用&#xff0c;Mybatis是一个半ORM&#xff08;对象关系映射&#xff09;框架&#xff0c;Mybatis采用了OCP(对象关系映射)的方式封装了数据…

linux中probe函数中传递的参数来源(上)

linux中probe函数传递参数的寻找&#xff08;上&#xff09; 上一篇中&#xff0c;我们追踪了probe函数在何时调用&#xff0c;知道了满足什么条件会调用probe函数&#xff0c;但probe函数中传递的参数我们并不知道在何时定义&#xff0c;到底是谁定义的&#xff0c;反正不是我…

linux中probe函数传递参数的寻找(下)

linux中probe函数传递参数的寻找&#xff08;下&#xff09; 通过追寻driver的脚步&#xff0c;我们有了努力的方向&#xff1a;只有找到spi_bus_type的填充device即可&#xff0c;下面该从device去打通&#xff0c;当两个连通之日&#xff0c;也是任督二脉打通之时。先从设备定…

服务器部署 配置jetty运行参数_Zookeeper+websocket实现对分布式服务器的实时监控...

Zookeeper简介Zookeeper是Hadoop的一个子项目&#xff0c;它是分布式系统中的协调系统。简单来说就是一个Zookeeper注册同步中心&#xff0c;内部结构为一个树形目录&#xff0c;每个节点上可以存放一定量(默认的数据量上限是1M&#xff0c;但是可以通过调整参数修改)的数据&am…

Python Interview Question and Answers

引文&#xff1a;http://ilian.i-n-i.org/python-interview-question-and-answers/ For the last few weeks I have been interviewing several people for Python/Django developers so I thought that it might be helpful to show the questions I am asking together with …

软件工程项目总结_复旦大学软件工程实验室来ASE实验室交流

2020年12月11日下午&#xff0c;复旦大学彭鑫教授一行与我院多智能体软件工程实验室开展科研工作交流。本次交流会议旨在为双方建立沟通桥梁&#xff0c;探讨研究问题&#xff0c;谋划后续合作&#xff0c;促使双方增进了解、加强互动、互相学习、共同进步。学院党委书记、多智…

windows无法发现任何计算机或设备,Win10系统提示windows无法与设备或资源通信如何解决...

最近有win10系统用户发现电脑无法打开网页&#xff0c;然后进行网络诊断的时候&#xff0c;提示“Windows无法与设备或资源(主DNS) 通信”&#xff0c;该怎么解决这样的问题呢&#xff1f;接下来给大家带来Win10系统提示windows无法与设备或资源通信的具体解决步骤。一、更改DN…