Qt聊天室项目（包括服务端和客户端）

【实例简介】

简单的qt聊天室项目包括服务端和客户端

【实例截图】qtc/c 聊天室项目

【核心代码】

TcpServer::TcpServer(QWidget *parent) :

 QMainWindow(parent),

 ui(new Ui::TcpServer)

{

 ui->setupUi(this);

 this->tcpServer=new QTcpServer(this);

 connect(tcpServer,SIGNAL(newConnection()),this,SLOT(acceptConnection()));//接收新用户

// connect(this,SIGNAL(userNumChange()),this,SLOT(sendUserList()));//发送客户端在线用户列表

}

TcpServer::~TcpServer()

{

 delete ui;

}

void TcpServer::receiveData()//接收到消息

{

 QTcpSocket *tempTcp=static_cast<QTcpSocket*>(sender());

 QByteArray dat1 = tempTcp->readAll();

 QString data = QString::fromLocal8Bit(dat1);

 qDebug()<<data;

 QStringList list=data.split("#");

 bool ret=0;

 if(list[0]=="a"){ //a代表注册

 ret=checkSignUp(list[1],list[2]);

 qDebug()<<ret<<11;

 QString sendData=list[0];

 if(ret)

 sendData ="#" list[1] "#true";

 else

 sendData ="#" list[1] "#false";

 QByteArray datasend = sendData.toLocal8Bit();

 tempTcp->write(datasend);

 }

 else if(list[0]=="b") //b代表登录

 {

 ret=checkSignIn(list[1],list[2]);

 qDebug()<<ret<<22;

 if (ret)

 {

 userMessage.insert(tempTcp,list[1]);//添加到用户列表

 sendUserList();

 connect(tempTcp,SIGNAL(disconnected()),this,SLOT(removeUserFormList()));//退出登录

 }

 }

 else if(list[0]=="c") //群聊

 {

 QMap<QTcpSocket*,QString>::iterator it=userMessage.begin();

 QString message="c#" list[1] "#" list[2];

 while(it!=userMessage.end())

 {

 QTcpSocket *tcp=it.key();

 if(tcp!=tempTcp){

 QByteArray datasend = message.toLocal8Bit();

 tcp->write(datasend);

 }

  it;

 }

 return;

 }

 else if(list[0]=="d")//私聊

 {

 //userMessage[list[2]]->write(list[1] "#" list[3]);

 QMap<QTcpSocket*,QString>::iterator it=userMessage.begin();

 QTcpSocket *tcp=NULL;

 while(it!=userMessage.end())

 {

 if(it.value()==list[2])

 {

 tcp=it.key();

 break;

 }

  it;

 }

 if(tcp==NULL)

 return;

 QString mes="e#" list[1] "#" list[2] "#" list[3];

 QByteArray datasend = mes.toLocal8Bit();

 tcp->write(datasend);

 return;

 }

 else if(list[0]=="e")

 {

 emit sendUserList();

 return;

 }else if(list[0]=="f"){

 removeUserFormList();

 return;

 }

 else

 return;

}

void TcpServer::on_startBtn_clicked()//开启服务

{

 ui->startBtn->setEnabled(false);//避免再次点击

 if(!tcpServer->listen(QHostAddress::Any,8888))

 {

 qDebug()<<tcpServer->errorString();

 close();

 return;

 }

}

void TcpServer::acceptConnection()//接收新用户

{

 QTcpSocket *tcp=tcpServer->nextPendingConnection();

 QString ip=tcp->peerAddress().toString();

 qDebug()<<"accept:"<<ip;

 connect(tcp,SIGNAL(readyRead()),this,SLOT(receiveData()));

}

bool TcpServer::checkSignIn(QString name,QString passward)//登录

{

 MySql *mysql=new MySql();

 bool ret=mysql->loguser(name,passward);

 if(ret)

 {

 ui->listWidget->addItem(name);

 }

 return ret;

}

bool TcpServer::checkSignUp(QString name, QString passward)//注册

{

 MySql *mysql=new MySql();

 bool ret=mysql->signup(name,passward);

 return ret;

}

void TcpServer::removeUserFormList()//从用户列表中删除

{

 QTcpSocket* socket = static_cast<QTcpSocket*>(sender());

 QString name=userMessage[socket];

 QList<QListWidgetItem*> list;

 list=ui->listWidget->findItems(name,Qt::MatchCaseSensitive);

 QListWidgetItem *sel=list[0];

 int r=ui->listWidget->row(sel);

 QListWidgetItem *item=ui->listWidget->takeItem(r);

 ui->listWidget->removeItemWidget(item);

 delete item;

 userMessage.remove(socket);

 emit userNumChange();

}

void TcpServer::sendUserList()//发送给客户端在线用户列表

{

 QString message="d";

 qDebug()<<message;

 QMap<QTcpSocket*,QString>::iterator it=userMessage.begin();

 while(it!=userMessage.end())

 {

 message ="#";

 qDebug()<<33<<it.value();

 message =it.value();

  it;

 }

 qDebug()<<1;

 if(message=="d")

 return;

 qDebug()<<2;

 it=userMessage.begin();

 while(it!=userMessage.end())

 {

 qDebug()<<message;

 QByteArray datasend = message.toLocal8Bit();

 it.key()->write(datasend);

  it;

 }

}