当前位置: 开发笔记 > 运维 > 正文

QT网络编程Tcp下C/S架构的即时通信实例

作者：宁波南诚装饰_886 | 来源：互联网 | 2022-02-21 08:48

下面小编就为大家带来一篇QT网络编程Tcp下CS架构的即时通信实例。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧

先写一个客户端，实现简单的，能加入聊天，以及加入服务器的界面。

#ifndef TCPCLIENT_H
#define TCPCLIENT_H
 
#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include 
 
class TcpClient : public QDialog
{
 Q_OBJECT
 
public:
 TcpClient(QWidget *parent = 0,Qt::WindowFlags f=0);
 ~TcpClient();
private:
 QListWidget *contentListWidget;
 QLineEdit *sendLineEdit;
 QPushButton *sendBtn;
 QLabel *userNameLabel;
 QLineEdit *userNameLineEdit;
 QLabel *serverIPLabel;
 QLineEdit *serverIPLineEdit;
 QLabel *portLabel;
 QLineEdit *portLineEdit;
 QPushButton *enterBtn;
 QGridLayout *mainLayout;
 bool status;
 int port;
 QHostAddress *serverIP;
 QString userName;
 QTcpSocket *tcpSocket;
public slots:
 void slotEnter();
 void slotConnected();
 void slotDisconnected();
 void dataReceived();
 void slotSend();
};
 
#endif // TCPCLIENT_H

有一个加入服务器的按钮，还有一个发送消息的按钮，在头文件，先定义两个函数。

#include "tcpclient.h"
#include 
#include 
 
TcpClient::TcpClient(QWidget *parent,Qt::WindowFlags f)
 : QDialog(parent,f)
{
 setWindowTitle(tr("TCP Client"));
 
 cOntentListWidget= new QListWidget;
 
 sendLineEdit = new QLineEdit;
 sendBtn = new QPushButton(tr("send"));
 
 userNameLabel = new QLabel(tr("name"));
 userNameLineEdit = new QLineEdit;
 
 serverIPLabel = new QLabel(tr("server"));
 serverIPLineEdit = new QLineEdit;
 
 portLabel = new QLabel(tr("port"));
 portLineEdit = new QLineEdit;
 
 enterBtn= new QPushButton(tr("join chat"));
 
 mainLayout = new QGridLayout(this);
 mainLayout->addWidget(contentListWidget,0,0,1,2);
 mainLayout->addWidget(sendLineEdit,1,0);
 mainLayout->addWidget(sendBtn,1,1);
 mainLayout->addWidget(userNameLabel,2,0);
 mainLayout->addWidget(userNameLineEdit,2,1);
 mainLayout->addWidget(serverIPLabel,3,0);
 mainLayout->addWidget(serverIPLineEdit,3,1);
 mainLayout->addWidget(portLabel,4,0);
 mainLayout->addWidget(portLineEdit,4,1);
 mainLayout->addWidget(enterBtn,5,0,1,2);
 
 status = false;
 
 port = 8010;
 portLineEdit->setText(QString::number(port));
 
 serverIP =new QHostAddress();
 
 connect(enterBtn,SIGNAL(clicked()),this,SLOT(slotEnter()));
 connect(sendBtn,SIGNAL(clicked()),this,SLOT(slotSend()));
 
 sendBtn->setEnabled(false);
}
 
TcpClient::~TcpClient()
{
 
}
 
void TcpClient::slotEnter()
{
 if(!status)
 {
  QString ip = serverIPLineEdit->text();
  if(!serverIP->setAddress(ip))
  {
   QMessageBox::information(this,tr("error"),tr("server ip address error!"));
   return;
  }
 
  if(userNameLineEdit->text()=="")
  {
   QMessageBox::information(this,tr("error"),tr("User name error!"));
   return;
  }
 
  userName=userNameLineEdit->text();
 
  tcpSocket = new QTcpSocket(this);
  connect(tcpSocket,SIGNAL(connected()),this,SLOT(slotConnected()));
  connect(tcpSocket,SIGNAL(disconnected()),this,SLOT(slotDisconnected()));
  connect(tcpSocket,SIGNAL(readyRead()),this,SLOT(dataReceived()));
 
  tcpSocket->connectToHost(*serverIP,port);
 
  status=true;
 }
 else
 {
  int length=0;
  QString msg=userName+tr(":Leave Chat Room");
  if((length=tcpSocket->write(msg.toLatin1(),msg.length()))!=msg. length())
  {
   return;
  }
 
  tcpSocket->disconnectFromHost();
 
  status=false;
 }
}
 
void TcpClient::slotConnected()
{
 sendBtn->setEnabled(true);
 enterBtn->setText(tr("离开"));
 
 int length=0;
 QString msg=userName+tr(":Enter Chat Room");
 if((length=tcpSocket->write(msg.toLatin1(),msg.length()))!=msg.length())
 {
  return;
 }
}
 
void TcpClient::slotSend()
{
 if(sendLineEdit->text()=="")
 {
  return ;
 }
 
 QString msg=userName+":"+sendLineEdit->text();
 
 tcpSocket->write(msg.toLatin1(),msg.length());
 sendLineEdit->clear();
}
 
void TcpClient::slotDisconnected()
{
 sendBtn->setEnabled(false);
 enterBtn->setText(tr("join chat"));
}
 
void TcpClient::dataReceived()
{
 while(tcpSocket->bytesAvailable()>0)
 {
  QByteArray datagram;
  datagram.resize(tcpSocket->bytesAvailable());
 
  tcpSocket->read(datagram.data(),datagram.size());
 
  QString msg=datagram.data();
  contentListWidget->addItem(msg.left(datagram.size()));
 }
}

实现界面布局。在Enter槽函数中，确定加入还是离开的服务器的功能。如果加入了，就将消息，写到tcpsocket中，构造消。

服务端的头文件：

#ifndef TCPSERVER_H
#define TCPSERVER_H
 
#include 
#include 
#include 
#include 
#include 
#include 
#include "server.h"
 
class TcpServer : public QDialog
{
 Q_OBJECT
 
public:
 TcpServer(QWidget *parent = 0,Qt::WindowFlags f=0);
 ~TcpServer();
private:
 QListWidget *ContentListWidget;
 QLabel *PortLabel;
 QLineEdit *PortLineEdit;
 QPushButton *CreateBtn;
 QGridLayout *mainLayout;
 int port;
 Server *server;
public slots:
 void slotCreateServer();
 void updateServer(QString,int);
};
 
#endif // TCPSERVER_H

这是服务端的界面的，把消息显示而已。实现这个布局。

#include "tcpserver.h"
 
TcpServer::TcpServer(QWidget *parent,Qt::WindowFlags f)
 : QDialog(parent,f)
{
 setWindowTitle(tr("TCP Server"));
 
 COntentListWidget= new QListWidget;
 
 PortLabel = new QLabel(tr(" port"));
 PortLineEdit = new QLineEdit;
 
 CreateBtn = new QPushButton(tr("create chat"));
 mainLayout = new QGridLayout(this);
 mainLayout->addWidget(ContentListWidget,0,0,1,2);
 mainLayout->addWidget(PortLabel,1,0);
 mainLayout->addWidget(PortLineEdit,1,1);
 mainLayout->addWidget(CreateBtn,2,0,1,2);
 
 port=8010;
 PortLineEdit->setText(QString::number(port));
 
 connect(CreateBtn,SIGNAL(clicked()),this,SLOT(slotCreateServer()));
}
 
TcpServer::~TcpServer()
{
 
}
 
void TcpServer::slotCreateServer()
{
 server = new Server(this,port);
 connect(server,SIGNAL(updateServer(QString,int)),this,SLOT(updateServer(QString,int)));
 
 CreateBtn->setEnabled(false);
}
 
void TcpServer::updateServer(QString msg,int length)
{
 ContentListWidget->addItem(msg.left(length));
}

创建TCP的套接字，以便实现服务端和客户端的通信。

#ifndef TCPCLIENTSOCKET_H
#define TCPCLIENTSOCKET_H
 
#include 
#include 
 
class TcpClientSocket : public QTcpSocket
{
 Q_OBJECT
public:
 TcpClientSocket();
signals:
 void updateClients(QString,int);
 void disconnected(int);
protected slots:
 void dataReceived();
 void slotDisconnected();
};
 
#endif // TCPCLIENTSOCKET_H

以上是头文件，具体的是：

#include "tcpclientsocket.h"
 
TcpClientSocket::TcpClientSocket()
{
 connect(this,SIGNAL(readyRead()),this,SLOT(dataReceived()));
 connect(this,SIGNAL(disconnected()),this,SLOT(slotDisconnected()));
}
 
void TcpClientSocket::dataReceived()
{
 while(bytesAvailable()>0)
 {
  int length = bytesAvailable();
  char buf[1024];
  read(buf,length);
 
  QString msg=buf;
  emit updateClients(msg,length);
 }
}
 
void TcpClientSocket::slotDisconnected()
{
 emit disconnected(this->socketDescriptor());
}

实现服务器，头文件：

#ifndef SERVER_H
#define SERVER_H
 
#include 
#include 
#include "tcpclientsocket.h"
 
class Server : public QTcpServer
{
 Q_OBJECT
public:
 Server(QObject *parent=0,int port=0);
 QList tcpClientSocketList;
signals:
 void updateServer(QString,int);
public slots:
 void updateClients(QString,int);
 void slotDisconnected(int);
protected:
 void incomingConnection(int socketDescriptor);
};
 
#endif // SERVER_H

#include "server.h"
 
Server::Server(QObject *parent,int port)
 :QTcpServer(parent)
{
 listen(QHostAddress::Any,port);
}
 
void Server::incomingConnection(int socketDescriptor)
{
 TcpClientSocket *tcpClientSocket = new TcpClientSocket;
 connect(tcpClientSocket,SIGNAL(updateClients(QString,int)),this,SLOT(updateClients(QString,int)));
 connect(tcpClientSocket,SIGNAL(disconnected(int)),this,SLOT(slotDisconnected(int)));
 
 tcpClientSocket->setSocketDescriptor(socketDescriptor);
 
 tcpClientSocketList.append(tcpClientSocket);
}
 
void Server::updateClients(QString msg,int length)
{
 emit updateServer(msg,length);
 for(int i=0;iwrite(msg.toLatin1(),length)!=length)
  {
   continue;
  }
 }
}
 
void Server::slotDisconnected(int descriptor)
{
 for(int i=0;isocketDescriptor()==descriptor)
  {
   tcpClientSocketList.removeAt(i);
   return;
  }
 }
 return;
}

实现后的界面：

以上这篇QT网络编程Tcp下C/S架构的即时通信实例就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持。

服务器

推荐阅读

ubuntu
探索Ubuntu One：Canonical推出的高效云服务

Ubuntu One是由Ubuntu的操作系统提供商Canonical推出的一款综合性网络服务，旨在帮助用户存储、同步及分享文件。该服务不仅支持多种操作系统，还提供了丰富的功能以满足不同用户的需求。 ... [详细]

蜡笔小新 2024-12-12 21:43:09
服务器
Redis RDB与AOF持久化方式详解及其差异

本文深入探讨了Redis中的两种主要持久化方式——RDB（Redis Database）和AOF（Append Only File），并详细解析了两者的实现机制、优缺点以及在实际应用中的选择策略。 ... [详细]

蜡笔小新 2024-12-12 20:41:22
服务器
开发笔记:哈希的应用

开发笔记:哈希的应用 ... [详细]

蜡笔小新 2024-12-12 16:13:22
服务器
解决Vue项目离线创建问题

当使用vue-cli工具通过命令`vue init webpack demo`创建Vue项目时，可能会遇到连接超时错误，这通常是因为网络问题导致无法访问远程服务器。本文将介绍如何通过离线方式成功创建Vue项目。 ... [详细]

蜡笔小新 2024-12-12 15:45:52
server
解决MyBatis与MySQL时间戳字段的时区差异问题

本文探讨了在使用阿里云RDS实例时遇到的一个时区问题。该问题导致系统时间与预期时间相差13小时。通过深入分析，发现问题是由于名为CST的时区存在多种解释，特别是在MySQL和Java之间进行时区协商时出现的误解。 ... [详细]

蜡笔小新 2024-12-12 15:28:16
server
双版本 Rails 环境下的 Sprockets 清单管理 - Rails 3 与 Rails 4 兼容性探讨

探讨在同时运行 Rails 3 和 Rails 4 的环境中，如何有效地管理和同步 Sprockets 清单文件，以支持无中断的资产加载及回滚功能。 ... [详细]

蜡笔小新 2024-12-12 15:22:42
server
导入大csv文件到mysql（CSV导入）

导入大csv文件到mysql（CSV导入） ... [详细]

蜡笔小新 2024-12-12 15:01:40
服务器
浪潮AI服务器NF5488A5在MLPerf基准测试中刷新多项纪录

近日，国际权威AI基准测试平台MLPerf发布了最新的推理测试结果，浪潮AI服务器NF5488A5在此次测试中创造了18项性能纪录，显著提升了数据中心AI推理性能。 ... [详细]

蜡笔小新 2024-12-12 13:57:17
dns
笔记本无线网络安全配置指南：快速入门版

本文详细介绍了如何为笔记本电脑配置无线网络连接，确保其安全性和稳定性，适合初学者快速上手。 ... [详细]

蜡笔小新 2024-12-12 13:49:13
ubuntu
在Linode上远程运行Xubuntu - Running Xubuntu Remotely on Linode

本文介绍了如何在Linode服务器上以root用户身份安装Xubuntu，并解决尝试启动图形界面时遇到的'无屏幕找到'错误。 ... [详细]

蜡笔小新 2024-12-12 13:35:42
server
MySQL数据库备份与恢复实践

本文档详细介绍了2017年8月31日关于MySQL数据库备份与恢复的教学内容，包括MySQL日志功能、备份策略、备份工具及实战演练。 ... [详细]

蜡笔小新 2024-12-12 13:25:48
server
Zookeeper面试常见问题解析

本文详细介绍了Zookeeper中的ZAB协议、节点类型、ACL权限控制机制、角色分工、工作状态、Watch机制、常用客户端、分布式锁实现、默认通信框架以及消息广播和领导选举的流程。 ... [详细]

蜡笔小新 2024-12-12 12:41:06
server
muduo库网络模块源码解析：Socket封装与字节序转换

本文详细解析了muduo库中的Socket封装及字节序转换功能。主要涉及`Endian.h`和`SocketsOps.h`两个头文件，以及`Socket.h`和`InetAddress.h`类的实现。 ... [详细]

蜡笔小新 2024-12-12 12:33:50
server
解析EasyCVR平台国标GB28181协议下的TCP与UDP模式

在使用EasyCVR视频融合平台过程中，用户常遇到关于端口设置的问题，尤其是TCP和UDP模式的区别。本文将详细介绍这两种模式在GB28181协议下的具体应用及差异。 ... [详细]

蜡笔小新 2024-12-12 11:57:36
server
C# - 发送HTTPS请求时握手失败

本文探讨了在使用basicHttpBinding通过HTTPS发送请求时遇到的握手失败问题，分析了可能的原因及解决方案。 ... [详细]

蜡笔小新 2024-12-12 11:54:28

宁波南诚装饰_886

这个家伙很懒，什么也没留下！

Tags | 热门标签

RankList | 热门文章