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

#ifndef TCPCLIENT_H
#define TCPCLIENT_H
 
#include <QDialog>
#include <QListWidget>
#include <QLineEdit>
#include <QPushButton>
#include <QLabel>
#include <QGridLayout>
#include <QtNetWork/QHostAddress>
#include <QtNetWork/QTcpSocket>
 
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 <QMessageBox>
#include <QHostInfo>
 
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 <QDialog>
#include <QListWidget>
#include <QLabel>
#include <QLineEdit>
#include <QPushButton>
#include <QGridLayout>
#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 <QtNetWork/QTcpSocket>
#include <QObject>
 
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 <QtNetWork/QTcpServer>
#include <QObject>
#include "tcpclientsocket.h"
 
class Server : public QTcpServer
{
 Q_OBJECT
public:
 Server(QObject *parent=0,int port=0);
 QList<TcpClientSocket*> 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;i<tcpClientSocketList.count();i++)
 {
  QTcpSocket *item = tcpClientSocketList.at(i);
  if(item->write(msg.toLatin1(),length)!=length)
  {
   continue;
  }
 }
}
 
void Server::slotDisconnected(int descriptor)
{
 for(int i=0;i<tcpClientSocketList.count();i++)
 {
  QTcpSocket *item = tcpClientSocketList.at(i);
  if(item->socketDescriptor()==descriptor)
  {
   tcpClientSocketList.removeAt(i);
   return;
  }
 }
 return;
}

实现后的界面：

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

# 即时通信架构  # Qt中TCP协议通信详解  # QT实现简单TCP通信  # Qt实现简单的TCP通信  # QT编写tcp通信工具(Client篇)  # QT网络通信TCP客户端实现详解  # Qt TCP网络通信学习  # Qt网络编程实现TCP通信  # QT5实现简单的TCP通信的实现  # 基于QT的TCP通信服务的实现  # Qt TCP实现简单通信功能  # 头文件  # 服务端  # 给大家  # 的是  # 客户端  # 这是  # 希望能  # 还有一个  # 写到  # 就将  # 这篇  # 小编  # 大家多多  # 有一个  # 网络编程  # 即时通信  # 发送消息  # 先写  # slotEnter  # slotConnected 

相关栏目： 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571 】

相关推荐： JavaScript中如何操作剪贴板_ClipboardAPI怎么用  网站制作报价单模板图片,小松挖机官方网站报价？  Laravel如何获取当前用户信息_Laravel Auth门面获取用户ID  Laravel怎么实现软删除SoftDeletes_Laravel模型回收站功能与数据恢复【步骤】  广州网站制作公司哪家好一点,广州欧莱雅百库网络科技有限公司官网？  如何在 Pandas 中基于一列条件计算另一列的分组均值  JS中页面与页面之间超链接跳转中文乱码问题的解决办法  网页设计与网站制作内容,怎样注册网站？  Android Socket接口实现即时通讯实例代码  JS中对数组元素进行增删改移的方法总结  ,南京靠谱的征婚网站？  HTML 中动态设置元素 name 属性的正确语法详解  Laravel如何与Vue.js集成_Laravel + Vue前后端分离项目搭建指南  如何批量查询域名的建站时间记录？  Linux系统命令中tree命令详解  惠州网站建设制作推广,惠州市华视达文化传媒有限公司怎么样？  Laravel如何安装使用Debugbar工具栏_Laravel性能调试与SQL监控插件【步骤】  如何用PHP快速搭建高效网站？分步指南  JavaScript常见的五种数组去重的方式  Python高阶函数应用_函数作为参数说明【指导】  如何用y主机助手快速搭建网站？  Laravel Seeder怎么填充数据_Laravel数据库填充器的使用方法与技巧  Laravel中DTO是什么概念_在Laravel项目中使用数据传输对象(DTO)  MySQL查询结果复制到新表的方法(更新、插入)  Laravel如何使用查询构建器？（Query Builder高级用法）  Laravel怎么清理缓存_Laravel optimize clear命令详解  长沙企业网站制作哪家好,长沙水业集团官方网站？  手机钓鱼网站怎么制作视频,怎样拦截钓鱼网站。怎么办？  如何快速搭建高效服务器建站系统？  Laravel如何使用Guzzle调用外部接口_Laravel发起HTTP请求与JSON数据解析【详解】  高防网站服务器：DDoS防御与BGP线路的AI智能防护方案  Laravel如何自定义错误页面（404, 500）？（代码示例）  如何挑选最适合建站的高性能VPS主机？  laravel怎么为应用开启和关闭维护模式_laravel应用维护模式开启与关闭方法  Laravel如何部署到服务器_线上部署Laravel项目的完整流程与步骤  Laravel怎么集成Vue.js_Laravel Mix配置Vue开发环境  阿里云高弹*务器配置方案｜支持分布式架构与多节点部署  香港服务器网站测试全流程：性能评估、SEO加载与移动适配优化  手机网站制作与建设方案,手机网站如何建设？  Windows11怎样设置电源计划_Windows11电源计划调整攻略【指南】  Laravel的.env文件有什么用_Laravel环境变量配置与管理详解  网站设计制作书签怎么做,怎样将网页添加到书签/主页书签/桌面？  laravel怎么使用数据库工厂（Factory）生成带有关联模型的数据_laravel Factory生成关联数据方法  UC浏览器如何切换小说阅读源_UC浏览器阅读源切换【方法】  Laravel如何优化应用性能？（缓存和优化命令）  Laravel如何处理JSON字段的查询和更新_Laravel JSON列操作与查询技巧  HTML5建模怎么导出为FBX格式_FBX格式兼容性及导出步骤【指南】  Laravel如何设置定时任务（Cron Job）_Laravel调度器与任务计划配置  Laravel如何实现登录错误次数限制_Laravel自带LoginThrottles限流配置【方法】  javascript中的数组方法有哪些_如何利用数组方法简化数据处理