基于QT的TCP通信服务的实现
目录
- 一、结构
- 1.1 套接字
- 1.2 socket通信流程
- 1.3 QTcpsocket
- 1.4 QTcpServer
- 二、设计UI
- 2.1 客户端UI
- 2.2 服务器端UI
- 三、核心代码
- 四、效果图
一、结构
1.1 套接字
应用层通过传输层进行数据通信时,TCP和UDP会遇到同时为多个应用程序进程提供并发服务的问题。多个TCP连接或多个应用程序进程可能需要 通过同一个TCP协议端口传输数据。为了区别不同的应用程序进程和连接,许多计算机操作系统为应用程序与TCP/IP协议交互提供了称为套接字 (Socket)的接口,区分不同应用程序进程间的网络通信和连接。
实际上套接字做的事情就是为我们通信的两端做一个连接
1.2 socket通信流程
对于TCP而言,socket通信的流程大概如下:
文章图片
1.3 QTcpsocket
对于客户端我们就使用的这个
QTcpsocket
类去请求服务器端,我们先看官方给的文档可以知道:文章图片
使用该类需要
#include
头文件,并且该类是继承QAbstractSocket
类的,而且我们发现对于这个类没有新增很多的函数,那么我们就应该去看它的父类,果不其然,父类中有很多的函数,我们后面进行TCP
通信其实也主要是用到父类的一些函数,所以看一下文档还是有必要的,对于每一个函数,你都能点进去看参数、以及描述文章图片
虽然
QAbstractSocket
有这么多的函数,但是我们实际上使用的函数就那么几个,我们后面一一介绍,我们现在先来说说QT
客户端创建网络连接的流程:1.我们需要
new
一个QTcpSocket
的对象,当然初始化只需要将当前的obj
传入即可,也就是this
,然后给这个对象的readyRead
创建一个凹槽做一些收到信号后的处理(比如将收到的数据显示在某个地方)。2.通过
connectToHost
函数去连接服务器,函数中传入ip
和port
(ip
要强转为QHostAddress
类)3.通过调用
waitForConnected
函数,来判断服务器是否连接超时,一般设置1000
,表示的是1s
未连接就超时,通过官方的文档我们能知道如果返回的是true
表示的是建立了连接,否则表示建立失败或未建立连接注意的是这里,只有使用
waitForConnected()
后,QTcpSocket
才真正尝试连接服务器,并返回是否连接的结果。4.当我们的客户端接收到
readyRead
的信号,我们就可以通过readAll()
函数读取服务器返回的信息,同样的我们也可以通过write()
函数向服务器发送信息注意的是这里服务端读到的数据是一个
QByteArray
类型的,我们写入的数据可以是Qstring
类型的,当然也可以是QByteArray
那么这就是客户端的通信流程了
1.4 QTcpServer
对于服务器端我们需要用到
QTcpServer
类,同样在官网的文档我们能得到这个类的一些基本信息:文章图片
服务端的流程:
1.首先创建一个
QTcpServer
类,并初始化,然后给这个对象的 QTcpServer::newConnection()
建立一个凹槽,用于处理与客户端建立连接后要做的一些事情,例如继续为QTcpSocket::readyRead
创建一个凹槽进行数据读取操作、为QTcpSocket::disconnected
创建凹槽用于对服务端失联后的操作……2.通过
listen(QHostAddress::Any,port)
函数监听所有的ip
请求3.当有新的客户端连接服务器的时候,会自动触发
newConnection()
信号函数,然后我们可以通过通过QTcpSocket * nextPendingConnection()
成员函数来获取当前连接上的新的客户端类.然后再对QTcpSocket
来进行信号槽绑定(这里可以写一个客户端的池但是我这里为了方便就只写了一个客户端连接的情况)4.对于数据的读取的话,由于我们这里只写了一个客户端的情况,那么就可以直接给这个
QTcpSocket
对象绑定和客户端相同的事件就好二、设计UI 我们直接使用
QT Creator
自带的绘制工具,简单绘制一下就好,界面不重要,重要是控件的objectName
经量设置合理一点,下面是我的设置:2.1 客户端UI
文章图片
【基于QT的TCP通信服务的实现】
2.2 服务器端UI
文章图片
三、核心代码 对于客户端来说:
mainwindow.cpp
#include "mainwindow.h"#include "ui_mainwindow.h"#include#include #include MainWindow::MainWindow(QWidget *parent): QMainWindow(parent), ui(new Ui::MainWindow){setWindowTitle(QString("客户端")); ui->setupUi(this); ui->port_2->setText("8899"); ui->ip->setText("127.0.0.1"); //刚开始 客户端的 [断开服务] 按钮不可用ui->disconnect->setDisabled(true); //创建一个监听器服务对象//Tcpserverm_tcp=new QTcpSocket(this); //客户端 被动的接收服务器信号connect(m_tcp,&QTcpSocket::readyRead,this,[=](){QByteArray array=m_tcp->readAll(); ui->record->append("服务端说:"+array); }); //客户端断开connect(m_tcp,&QTcpSocket::disconnected,this,[=](){m_status->setPixmap(QPixmap(":/a/tmp/disconnect.png").scaled(20,20)); ui->record->append("断开链接服务器"); ui->connect->setDisabled(false); ui->disconnect->setDisabled(true); }); //操作状态栏图标connect(m_tcp,&QTcpSocket::connected,this,[=](){m_status->setPixmap(QPixmap(":/a/tmp/connect.png").scaled(20,20)); ui->record->append("已经链接成功服务器"); //操作按钮互斥,链接成功了,自然链接按钮不能用只有断开按钮可以用ui->connect->setDisabled(true); ui->disconnect->setDisabled(false); }); //增加一点动画效果状态栏的颜色变化m_status =new QLabel; //状态栏的图片添加ui->statusbar->addWidget(new QLabel("链接状态:")); ui->statusbar->addWidget(m_status); //装到菜单状态栏}MainWindow::~MainWindow(){delete ui; }//点击监听服务,自然而然去启动监听服务void MainWindow::on_send_clicked(){//把发出信息框的数据拿到,通过socket套接字发送出去QString string=ui->sendmsg->toPlainText(); m_tcp->write(string.toUtf8()); ui->record->append("客户端说:"+string); ui->sendmsg->clear(); }void MainWindow::on_connect_clicked(){//获取 IP 端口才能链接QStringip=ui->ip->text(); unsignedshort port=ui->port_2->text().toUShort(); qDebug("click_on_connect state = %d\n",m_tcp->state()); m_tcp->connectToHost(QHostAddress(ip),port); if(m_tcp->waitForConnected(1000)) {qDebug("connected !\n"); ui->record->clear(); }elseqDebug("connect out time limit !\n"); }void MainWindow::on_disconnect_clicked(){qDebug("loc1 state = %d\n",m_tcp->state()); m_tcp->disconnectFromHost(); qDebug("loc2 state = %d\n",m_tcp->state()); if(m_tcp->state() == QAbstractSocket::UnconnectedState|| m_tcp->waitForDisconnected(1000))qDebug("Disconnected!\n"); elseqDebug("Disconnect fail!\n"); m_tcp->close(); ui->connect->setDisabled(false); ui->disconnect->setDisabled(false); }
对于服务器来说:
mainwindow.cpp
#include "mainwindow.h"#include "ui_mainwindow.h"#include#include #include MainWindow::MainWindow(QWidget *parent): QMainWindow(parent), ui(new Ui::MainWindow){ui->setupUi(this); ui->port_2->setText("8899"); //创建一个监听器服务对象//Tcpserverm_s=new QTcpServer(this); m_tcp = new QTcpSocket; //启动监听通过点击监听按钮实现,并且在按钮转到的槽函数实现监听//上述完成监听,就等待用户/客户端的链接connect(m_s,&QTcpServer::newConnection,this,[=](){//状态栏变色m_status->setPixmap(QPixmap(":/a/tmp/connect.png").scaled(20,20)); //程序到此步骤证明有用户链接,启用socket通信传输并解析数据//实例此次通信对象nextPendingConnection得到一个可供通信的套接字对象m_tcp=m_s->nextPendingConnection(); QString client_ip = m_tcp->peerAddress().toString().split("::ffff:")[1]; quint16 client_port = m_tcp->peerPort(); ui->record->append(tr("%1:%2 connected!\n").arg(client_ip).arg(client_port)); //进行对象处理,检测传输的数据,利用connect对tcp套接字操作connect(m_tcp,&QTcpSocket::readyRead,this,[=](){QByteArray array = m_tcp->readAll(); ui->record->append("客户端说:"+array); }); //客户端断开操作connect(m_tcp,&QTcpSocket::disconnected,this,[=](){QString client_ip = m_tcp->peerAddress().toString().split("::ffff:")[1]; quint16 client_port = m_tcp->peerPort(); ui->record->append(tr("%1:%2 Disconnected!\n").arg(client_ip).arg(client_port)); m_tcp->disconnectFromHost(); if(m_tcp->state() == QAbstractSocket::UnconnectedState|| m_tcp->waitForDisconnected(1000))qDebug("Disconnected!\n"); elseqDebug("Disconnect fail!\n"); m_status->setPixmap(QPixmap(":/a/tmp/disconnect.png").scaled(20,20)); }); }); //增加一点动画效果状态栏的颜色变化m_status =new QLabel; //状态栏的图片添加//m_status->setPixmap(QPixmap(":/a/tmp/connect.png").scaled(20,20)); ui->statusbar->addWidget(new QLabel("链接状态:")); ui->statusbar->addWidget(m_status); //装到菜单状态栏}MainWindow::~MainWindow(){delete ui; }//点击监听服务,自然而然去启动监听服务void MainWindow::on_setlisten_clicked(){setWindowTitle("服务器"); //得到窗口 lineedit窗口的端口号unsignedshortport=ui->port_2->text().toShort(); //进行监听ip端口m_s->listen(QHostAddress::Any,port); ui->setlisten->setDisabled(true); }void MainWindow::on_send_clicked(){//把发出信息框的数据拿到,通过socket套接字发送出去QString string=ui->sendmsg->toPlainText(); m_tcp->write(string.toUtf8()); ui->record->append("服务端说:"+string); ui->sendmsg->clear(); }
四、效果图
文章图片
文章图片
到此这篇关于基于QT的TCP通信服务的实现的文章就介绍到这了,更多相关QT TCP通信内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!
推荐阅读
- Python自动化办公之Word文件内容的读取
- c语言for、while和do-while循环之间的区别
- C++11生成随机数(random库)的使用
- Java|Java 替换字符串右侧出现的第一个子串方式
- 投稿|拓荒中东,中国游戏是如何从蓝海走向红海的?
- 消费|老板副业连亏两月,被爆拿员工绩效填补,韩束赚的钱去了哪儿?
- Spring 梳理 - javaConfig在App和webApp中的应用
- mapper加载的3种方法
- 如何精准的找到社交类APP软件开发服务商
- springmvc中@RequestMapping的使用