#include "websocket.h"
websocket::websocket()
{
m_socket = new QWebSocket;
}
void websocket::setUrl(QUrl url)
{
m_url = url;
}
void websocket::start(const QUrl& url)
{
m_socket->open(url);
}
void websocket::start(const QNetworkRequest &request)
{
initNetConfig();
m_socket->open(request);
}
void websocket::initSigSlots()
{
connect(m_socket,&QWebSocket::connected,[=](){on_connected();});
connect(m_socket,&QWebSocket::disconnected,[=](){on_disconnected();});
connect(m_socket,SIGNAL(error(QAbstractSocket::SocketError)),this,SLOT(on_error(QAbstractSocket::SocketError)));
connect(m_socket,SIGNAL(textFrameReceived(QString,bool)),this,SLOT(on_textFrameReceived(QString,bool)));
connect(m_socket,SIGNAL(textMessageReceived(QString)),this,SLOT(on_textMessageReceived(QString)));
}
//配置头部和加密证书
void websocket::initNetConfig()
{
initSigSlots();
m_request.setUrl(m_url);
m_request.setHeader(QNetworkRequest::UserAgentHeader, "surfBrowser/1.1.0.0");
QSslConfiguration conf = m_socket->sslConfiguration();
conf.setPeerVerifyMode(QSslSocket::VerifyNone);//不采用证书
// conf.setPeerVerifyMode(QSslSocket::VerifyPeer);//采用证书
conf.setProtocol(QSsl::TlsV1SslV3);
m_socket->setSslConfiguration(conf);
}
void websocket::sendMsg(const QString& msg)
{
qDebug() << msg;
m_socket->sendTextMessage(msg);
}
void websocket::on_connected()
{
qDebug()<<"webSocketMgr::on_connected";
}
void websocket::on_disconnected()
{
//m_socket->close();
qDebug()<<"webSocketMgr::on_disconnected";
on_timeout();
}
void websocket::on_error(QAbstractSocket::SocketError error)
{
qDebug()<<"webSocketMgr::on_error"<<error;
}
void websocket::on_textFrameReceived(const QString &frame, bool isLastFrame)
{
qDebug()<<"webSocketMgr::on_textFrameReceived"<<frame<<isLastFrame;
}
void websocket::on_textMessageReceived(const QString &message)
{
qDebug()<<"webSocketMgr::on_textMessageReceived"<<message;
}
void websocket::on_timeout()
{
qDebug()<<"webSocketMgr::on_timeout";
//ping服务端，通知其该客户端online
m_socket->ping("ping ping ping");
}
评论0