QTcpServer与QTcpSocket通讯

TCP
        TCP是一个基于流的协议。对于应用程序，数据表现为一个长长的流，而不是一个大大的平面文件。基于TCP的高层协议通常是基于行的或者基于块的。
          ●、基于行的协议把数据作为一行文本进行传输，每行都以一个换行符结尾。
          ●、基于块的协议把数据作为二进制块进行传输，每块是由一个size大小字段和紧跟它的一个size字节的数据组成。
        QTcpSocket通过器父类QAbstractSocket继承了QIODevice，因此他可以通过使用QTextStream和QDataStream来进行读取和写入。
        QTcpServer类在服务器端处理来自TCP客户端连接数据，需要注意的是，该类直接继承于QObject基类，而不是QAbstractSocket抽象套接字类。

一 QTcpServer

#ifndef VXMAINWINDOW_H
#define VXMAINWINDOW_H

#include 
#include 
#include

class QPushButton;
class QTextEdit;

class CVxMainWindow : public QWidget
{
 Q_OBJECT

public:
 CVxMainWindow(QWidget *parent = NULL);
 ~CVxMainWindow();
protected:
 void resizeEvent(QResizeEvent *);
private slots:
 void Btn_ListenClickedSlot();
 void Btn_StopListenClickedSlot();
 void newConnectionSlot();
 void dataReceived();
private:
 QTcpServer *m_pServer;
 QTcpSocket *m_pSocket;

QPushButton *m_pBtn_Listen;
 QPushButton *m_pBtn_StopListen;
 QTextEdit   *m_pEdt_Info;
};

#endif // VXMAINWINDOW_H

#include "VxMainWindow.h"

#include

CVxMainWindow::CVxMainWindow(QWidget *parent)
 : QWidget(parent)
{
 m_pBtn_Listen     = new QPushButton(QObject::tr("开始监听"), this);
 m_pBtn_StopListen = new QPushButton(QObject::tr("停止监听"), this);
 m_pEdt_Info = new QTextEdit(this);
 m_pServer = new QTcpServer(this);
 
 connect(m_pBtn_Listen,     SIGNAL(clicked()), this, SLOT(Btn_ListenClickedSlot()));
 connect(m_pBtn_StopListen, SIGNAL(clicked()), this, SLOT(Btn_StopListenClickedSlot()));
 connect(m_pServer, SIGNAL(newConnection()), this, SLOT(newConnectionSlot()));
}

CVxMainWindow::~CVxMainWindow()
{

}

void CVxMainWindow::resizeEvent(QResizeEvent *)
{
 m_pBtn_Listen->setGeometry(10, 5, 80, 20);
 m_pBtn_StopListen->setGeometry(100, 5, 80, 20);
 m_pEdt_Info->setGeometry(0, 30, width(), height() - 30);
}

void CVxMainWindow::Btn_ListenClickedSlot()
{
 if (!m_pServer->isListening())
 {
  if (m_pServer->listen(QHostAddress::Any, 8080)) 
  {
   m_pEdt_Info->append(QObject::tr("打开监听端口成功！"));
  }
  else
  {
   m_pEdt_Info->append(QObject::tr("打开监听端口失败！"));
  }
 }
 else
 {
  m_pEdt_Info->append(QObject::tr("正在监听中...！"));
 }
}

void CVxMainWindow::Btn_StopListenClickedSlot()
{
 if (m_pServer->isListening())
 {
  m_pServer->close();
  m_pEdt_Info->append(QObject::tr("停止监听！"));
 }
}

void CVxMainWindow::newConnectionSlot()
{
 m_pEdt_Info->append(QObject::tr("有新客户端连接到服务器"));
 m_pSocket = m_pServer->nextPendingConnection();
 connect(m_pSocket, SIGNAL(disconnected()), m_pSocket, SLOT(deleteLater()));
 connect(m_pSocket, SIGNAL(readyRead()),this, SLOT(dataReceived()));

int length = 0;
 QString vMsgStr = QObject::tr("Welcome");
 if((length=m_pSocket->write(vMsgStr.toLatin1(),vMsgStr.length()))!=vMsgStr.length())
 {

}
}

void CVxMainWindow::dataReceived()
{
 while(m_pSocket->bytesAvailable())
 {       
  QByteArray vTemp;
  vTemp = m_pSocket->readLine();

QString vTempStr(vTemp);
  m_pEdt_Info->append(vTempStr);

int length = 0;
  QString vMsgStr = QObject::tr("回复：") + vTempStr;
  if((length=m_pSocket->write(vMsgStr.toLatin1(),vMsgStr.length()))!=vMsgStr.length())
  {

}
 }
}

二 QTcpSocket

#ifndef VXMAINWINDOW_H
#define VXMAINWINDOW_H

#include 
#include 
#include

class QPushButton;
class QTextEdit;
class QLineEdit;

class CVxMainWindow : public QWidget
{
 Q_OBJECT

public:
 CVxMainWindow(QWidget *parent = NULL);
 ~CVxMainWindow();
protected:
 void resizeEvent(QResizeEvent *);
private slots:
 void Btn_ConnectClickedSlot();
 void Btn_DisConnectClickedSlot();
 void Btn_SendClickedSlot();
 void connectedSlot();
 void disconnectedSlot();
 void dataReceived();
 void displayError(QAbstractSocket::SocketError);
private:
 QTcpSocket *m_pSocket;
 QHostAddress m_HostAddress;

QPushButton *m_pBtn_Connect;
 QPushButton *m_pBtn_DisConnect;
 QTextEdit   *m_pEdt_Info;
 QLineEdit   *m_pEdt_Send;
 QPushButton *m_pBtn_Send;
};

#endif // VXMAINWINDOW_H

#include "VxMainWindow.h"

#include

CVxMainWindow::CVxMainWindow(QWidget *parent)
 : QWidget(parent)
{
 m_pBtn_Connect    = new QPushButton(QObject::tr("连接服务器"), this);
 m_pBtn_DisConnect = new QPushButton(QObject::tr("断开连接"), this);
 m_pEdt_Send       = new QLineEdit(this);
 m_pBtn_Send       = new QPushButton(QObject::tr("发送"), this);
 m_pEdt_Info = new QTextEdit(this);
 m_pSocket = new QTcpSocket(this);

connect(m_pBtn_Connect,    SIGNAL(clicked()), this, SLOT(Btn_ConnectClickedSlot()));
 connect(m_pBtn_DisConnect, SIGNAL(clicked()), this, SLOT(Btn_DisConnectClickedSlot()));
 connect(m_pBtn_Send,       SIGNAL(clicked()), this, SLOT(Btn_SendClickedSlot()));
 connect(m_pSocket, SIGNAL(connected()), this, SLOT(connectedSlot()));
 connect(m_pSocket, SIGNAL(disconnected()), this, SLOT(disconnectedSlot()));
 connect(m_pSocket, SIGNAL(readyRead()),this, SLOT(dataReceived()));
 connect(m_pSocket, SIGNAL(error(QAbstractSocket::SocketError)), this, SLOT(displayError(QAbstractSocket::SocketError)));
}

CVxMainWindow::~CVxMainWindow()
{

}

void CVxMainWindow::resizeEvent(QResizeEvent *)
{
 m_pBtn_Connect->setGeometry(10, 5, 80, 20);
 m_pBtn_DisConnect->setGeometry(100, 5, 80, 20);
 m_pEdt_Send->setGeometry(10, 30, 150, 20);
 m_pBtn_Send->setGeometry(170, 30, 80, 20);
 m_pEdt_Info->setGeometry(0, 60, width(), height() - 60);
}

void CVxMainWindow::Btn_ConnectClickedSlot()
{
 m_HostAddress.setAddress(QObject::tr("127.0.0.1"));
 m_pSocket->connectToHost(m_HostAddress, 8080);
}

void CVxMainWindow::Btn_DisConnectClickedSlot()
{
 m_pSocket->disconnectFromHost();
}

void CVxMainWindow::Btn_SendClickedSlot()
{
 int length = 0;
 QString vMsgStr = m_pEdt_Send->text();
 if((length = m_pSocket->write(vMsgStr.toLatin1(),vMsgStr.length())) != vMsgStr.length())
 {
  m_pEdt_Info->append(QObject::tr("发送信息失败：") + vMsgStr);
 }
}

void CVxMainWindow::connectedSlot()
{
 m_pEdt_Info->append(QObject::tr("成功连接到服务器！"));
}

void CVxMainWindow::disconnectedSlot()
{
 m_pEdt_Info->append(QObject::tr("断开与服务器的连接！"));
}

void CVxMainWindow::dataReceived()
{
 while(m_pSocket->bytesAvailable())
 {       
  QString vTemp;
  vTemp = m_pSocket->readLine();          
  m_pEdt_Info->append(vTemp);
 }
}

void CVxMainWindow::displayError(QAbstractSocket::SocketError)
{

}

以上代码在发送和接受串中带中文时会出现乱码,下面提供另外的发送和接受方法:

1 发送:

void XXX()
{
 // 用于暂存我们要发送的数据
 QByteArray block; 
 // 使用数据流写入数据
 QDataStream out(&block,QIODevice::WriteOnly);
 // 设置数据流的版本，客户端和服务器端使用的版本要相同
 out.setVersion(QDataStream::Qt_4_7);
 out<<(quint16) 0;

out<<qobject::tr("您好啊!");
 out.device()->seek(0);
 out<<(quint16)(block.size() - sizeof(quint16));
 m_pSocket->write(block);
}

2 接受:

void CVxMainWindow::dataReceived()
{
 QString vTempStr;  
 quint16 blockSize = 0;

QDataStream in(m_pSocket);
 // 设置数据流版本，这里要和服务器端相同
 in.setVersion(QDataStream::Qt_4_7);
 // 如果是刚开始接收数据
 if(blockSize == 0) 
 {
  //判断接收的数据是否有两字节，也就是文件的大小信息
  //如果有则保存到blockSize变量中，没有则返回，继续接收数据
  if(m_pSocket->bytesAvailable() < (int)sizeof(quint16)) return;
  in >> blockSize;
 }
 // 如果没有得到全部的数据，则返回，继续接收数据
 if(m_pSocket->bytesAvailable() < blockSize) return;
 in >> vTempStr;
 m_pEdt_Info->append(vTempStr);
}

http://blog.chinaunix.net/uid-20718335-id-1993063.html

时间： 2024-11-06 05:16:35

QTcpServer与QTcpSocket通讯的相关文章

qt QTcpServer与QTcpSocket通讯

分类: C/C++ TCP        TCP是一个基于流的协议.对于应用程序,数据表现为一个长长的流,而不是一个大大的平面文件.基于TCP的高层协议通常是基于行的或者基于块的.          ●.基于行的协议把数据作为一行文本进行传输,每行都以一个换行符结尾.          ●.基于块的协议把数据作为二进制块进行传输,每块是由一个size大小字段和紧跟它的一个size字节的数据组成.        QTcpSocket通过器父类QAbstractSocket继承了QIODevice,

基于QTcpSocket和QTcpServer的Tcp通讯以及QDataStream序列化数据

最近要在QT下开发Tcp通讯,发送序列化数据以便于接收. 这里涉及到几个问题: 1.QTcpSocket.QTcpServer的通讯 2.QDataStream序列化数据 多的不说,直接上干货!!! 客户端: tcpclient.h 1 #ifndef TCPCLIENT_H 2 #define TCPCLIENT_H 3 4 #include <QMainWindow> 5 #include <qt4/Qt/qtcpsocket.h> 6 #include <Qt/qhos

QT5 网络通讯

QT5 TCP网络通讯 服务器与客户端建立连接listen() - connectToHost();  触发newPendingConnect信号 实时数据通讯write(); read();  触发readyRead信号 通讯主要使用的类: QTcpServer  Class QTcpServer类提供了一个基于TCP的服务器.这个类可以接受传入的TCP连接.您可以指定端口或让QTcpServer自动选择一个端口.您可以收听特定地址或所有机器的地址.调用listen()让服务器侦听传入的连接.

QT5在VS2013中找不到QtNetwork或QTcpSocket或QTcpSocket等头文件

一.首先是要有相关的库文件 方法一:手动添加库文件Qt5Networkd.lib 对项目进行右键,找到相关的属性,然后查看Linker中input部分的红色选项中是否含有Qt5Networkd.lib 如果没有,则必须添加Qt5Networkd.lib,直接通过键盘写入即可. 方法二:在建立项目时,添加Network选项即可   二.然后在程序中加入相应的头文件     在程序中,如果想一劳永逸,就写#include <QtNetwork/QtNetwork>,里面就包含了QTcpServer

QTcpSocket使用过程中的一些问题记录

目前,在将原来C的socket通讯改为使用Qt类库QTcpSocket通讯,在修改过程中遇到不少问题,在此将问题一并记录,以备后面使用. 采用的通讯方式:QTimer定时器.QThread多线程和QTcpSocket通讯.QTimer设置定时通讯间隔(10s),QThread运行定时器响应函数,QTcpSocket进行数据发送. 1.问题一:QTcpSocket对象创建和使用要在同一个线程,否则报错. 错误描述:QObject:Cannot create children for a paren

5.关于QT中的网络编程，QTcpSocket，QUdpSocket

?? 1 新建一个项目:TCPServer.pro A  改动TCPServer.pro,注意:假设是想使用网络库.须要加上network SOURCES += \ TcpServer.cpp \ TcpClient.cpp HEADERS += \ TcpServer.h \ TcpClient.h QT += gui widgets network CONFIG += C++11 B 新建例如以下文件,由于要用到网络库,所以加上network C 编写IP选择下拉选,头文件ChooseInt

Qt浅谈之十六：TCP和UDP（之一）

一.简介 Qt使用QtNetwork模块来进行网络编程,提供了一层统一的套接字抽象用于编写不同层次的网络程序,避免了应用套接字进行网络编的繁琐(因有时需引用底层操作系统的相关数据结构).有较底层次的类如QTcpSocket.QTcpServer和QUdpSocket等来表示低层的网络概念:还有高层次的类如QNetworkRequest.QNetworkReply和QNetworkAccessManager使用相同的协议来执行网络操作:也提供了QNetworkConfiguration.QNetw

QT网络编程----TCP客户端（2）

一.客户端 在客户端里与服务器进行连接,一旦连接成功,就会发出connected()信号,这时就进行文件的发送. 发送数据时我们先发送了数据的大小信息.这一次,我们要先发送文件的总大小,然后文件名长度,然后是文件名,这三部分我们合称为文件头结构,最后再发送文件数据.所以在发送函数里我们就要进行相应的处理,当然,在服务器的接收函数里我们也要进行相应的处理.对于文件大小,这次我们使用了qint64,它是64位的,可以表示一个很大的文件了. 1.同前一节,我们新建工程,将工程命名为"tcpSender

基于QT的在线打字练习软件助手（C/S模型）good

简介   通过基于QT中QTcpServer和QTcpSocket以及UI编程,实现了基于TCP协议的C/S模型在线打字练习软件助手,服务端处理各客户端打字数据,以及显示在线打字客户列表即实时更新打字数据.客户端可实现离线打字练习以及在线打字练习,其中在线打字练习可以与在线用户比拼打字速度,并显示排名. 服务端 客户端登陆 离线打字主界面 在线打字主界面 特点 界面清爽,操作友好 能够在线与人拼打字速度 局域网内即可轻松实现运行 上线.下线稳定可靠 编译与运行   该打字软件助手是基于Qt Cr