qtcpsocket 客户端_qtcpsocket接收结构体数据

qtcpsocket 客户端_qtcpsocket接收结构体数据实现tcp客户端通信并支持keepAlive探测包#pragmaonce#include<QObject>#include<QTcpSocket>/***********************************************作者:wujianhua*时间:2021/02/25*类介绍:sockettcp客户端通信类************************************************/classT.

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE使用 1年只要46元 售后保障 童叟无欺

实现tcp客户端通信并支持keepAlive探测包 

#pragma once

#include <QObject>
#include <QTcpSocket>
/**********************************************
* 作者:wujianhua
* 时间:2021/02/25
* 类介绍:socket tcp客户端通信类
*
***********************************************/
class TcpClient : public QObject
{
	Q_OBJECT

public:
	TcpClient(QObject *parent);
	~TcpClient();
	
	/**********************************************
	* 作者:wujianhua
	* 时间:2021/02/25
	* 函数:连接服务器
	* 参数:
	*	ip:服务器地址
	*	port:服务器端口
	*	timeout:超时时间
	* 返回:
	*	连接成功返回true,失败返回false
	***********************************************/
	bool connect(const QString ip, int port, int timeout = 3000);

	/**********************************************
	* 作者:wujianhua
	* 时间:2021/02/25
	* 函数:断开服务器连接
	* 参数:
	*	无
	* 返回:
	*	无
	***********************************************/
	void disconnect();
	
	/**********************************************
	* 作者:wujianhua
	* 时间:2021/02/25
	* 函数:是否连接
	* 参数:
	*	无
	* 返回:
	*	返回true为连接状态,false为断开状态
	***********************************************/
	bool isOnline();
	
	/**********************************************
	* 作者:wujianhua
	* 时间:2021/02/25
	* 函数:发送数据
	* 参数:
	*	dat:数据对象
	* 返回:
	*	发送成功返回对应发的字节数,-1设备未连接
	***********************************************/
	int send(QByteArray dat);
	
	/**********************************************
	* 作者:wujianhua
	* 时间:2021/02/25
	* 函数:接收设备发送过来的数据
	* 参数:
	*	buf:接收设备发送的数据缓存
	*	timeout:超时时间
	* 返回:
	*	返回接收到的数据字节数,-1设备未连接
	***********************************************/
	int recv(QByteArray &buf, int timeout = 10*1000);

	/**********************************************
	* 作者:wujianhua
	* 时间:2021/03/02
	* 函数:设置心跳保活机制
	* 参数:
	*	keepIdle:没有数据交互后发送心跳探测包 单位秒
	*	keepInterval:探测包间隔时间 单位秒
	*	keepCount:探测重试次数
	* 返回:
	*	无
	***********************************************/
	void setKeepAlive(int keepIdle = 2, int keepInterval = 1, int keepCount = 3);

private slots:
	void slot_connected();
	void slot_readData();
	void slot_disconnected();
	void slot_stateChange(QAbstractSocket::SocketState state);
private:
	QTcpSocket *_tcp = nullptr;
	QString _ip;
	int _port;
	bool _online = false;
	QByteArray _readbuf;
};
#include "TcpClient.h"
#include <QSettings>
#include <QDebug>


#ifdef Q_OS_WIN
#include <WinSock2.h>
#include <WS2tcpip.h>
#include <ws2ipdef.h>
#include <mstcpip.h>
#include <winsock.h>
#pragma comment(lib, "Ws2_32.lib")

#endif // Q_OS_WIN

#ifdef Q_OS_LINUX
#include <sys/socket.h>
#include <sys/types.h>
#include <sys/ioctl.h>
#include <errno.h>
#include <netinet/tcp.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <fcntl.h>
#endif // Q_OS_LINUX


TcpClient::TcpClient(QObject *parent)
	: QObject(parent){
	_tcp = new QTcpSocket(this);
	QObject::connect(_tcp, &QAbstractSocket::connected, this, &TcpClient::slot_connected);
	QObject::connect(_tcp, &QIODevice::readyRead, this, &TcpClient::slot_readData);
	QObject::connect(_tcp, &QAbstractSocket::disconnected, this, &TcpClient::slot_disconnected);
	QObject::connect(_tcp, &QAbstractSocket::stateChanged, this, &TcpClient::slot_stateChange);
}

TcpClient::~TcpClient() {
	disconnect();
	delete _tcp;
	_tcp = nullptr;
}

bool TcpClient::connect(const QString ip, int port, int timeout /*= 3000*/){
	disconnect();
	_tcp->abort();
	_ip = ip;
	_port = port;
	_tcp->connectToHost(_ip, _port);
	_tcp->waitForConnected(timeout);
	if (_online) {
		setKeepAlive();
	}
	return _online;
}

void TcpClient::disconnect(){
	if (_online) {
		_tcp->disconnectFromHost();
	}
}

bool TcpClient::isOnline(){
	return _online;
}

int TcpClient::send(QByteArray dat){
	int size = -1;
	if (_online) {
		size = _tcp->write(dat);
		_tcp->flush();
	}
	return size;
}

int TcpClient::recv(QByteArray &buf, int timeout /* = 10*1000 */){
	int size = -1;
	if (_online) {
		_tcp->waitForReadyRead(timeout);
		size = _readbuf.size();
		buf = _readbuf;
	}
	return size;
}

void TcpClient::setKeepAlive(int keepIdle /* = 2 */, int keepInterval /* = 1 */, int keepCount /* = 3 */){
	//设置keepAlive心跳检测
	int fd = _tcp->socketDescriptor();
	int keepAlive = 1;		//开启keepAlive属性
	setsockopt(fd, SOL_SOCKET, SO_KEEPALIVE, (char*)&keepAlive, sizeof(keepAlive));
	setsockopt(fd, IPPROTO_TCP, TCP_KEEPALIVE, (char*)&keepIdle, sizeof(keepIdle));
	setsockopt(fd, IPPROTO_TCP, TCP_KEEPINTVL, (char*)&keepInterval, sizeof(keepInterval));
	setsockopt(fd, IPPROTO_TCP, TCP_KEEPCNT, (char*)&keepCount, sizeof(keepCount));
}

void TcpClient::slot_connected(){
	_online = true;
}

void TcpClient::slot_readData(){
	_readbuf = _tcp->readAll();
}

void TcpClient::slot_disconnected(){
	_online = false;
}

void TcpClient::slot_stateChange(QAbstractSocket::SocketState state){
	switch (state){
	case QAbstractSocket::UnconnectedState:
		_online = false;
		break;
	case QAbstractSocket::ConnectedState:
		_online = true;
		break;
	default:
		break;
	}
}

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/195651.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • jpa/springdata(1)jpa

    jpa/springdata(1)jpa

  • 2021全国大学生电子设计竞赛–电源–三相逆变(硬件)「建议收藏」

    2021全国大学生电子设计竞赛–电源–三相逆变(硬件)「建议收藏」废话不多说,直接上电路!三相逆变系统的框架如下::那么,降压电路不用多说,网上多得是1、下面说一下逆变驱动电路,也是通篇一律,这里贴上电路图,2、LC滤波器很多人会问我,LC如何选取,还有人在问,为啥我做出来之后发现电感在出声?答:第一个问题,网上可以搜得到,就是一个公式,以基波50HZ进行计算就行。第二个问题,有时候电感明明很大了,仍然出声音,其实那不是电感的问题,由于瓷片电容本身结构的问题,所以就睡导致在高频下的振荡出声,如果换成安规电容或者CBB就会…

  • redflag linux6.0 sp2桌面版,红旗Linux桌面版(Red Flag Linux)

    redflag linux6.0 sp2桌面版,红旗Linux桌面版(Red Flag Linux)第一次听说红旗Linux的“Favour”吗?现在的新名词太多,你作为第二个听说的人,一点也不落伍从09年起,针对Linux开源技术的发展特点,红旗Linux对个人版产品线做了重要调整,其中“Favour”版将尽可能把最新、最炫的DD呈现给关注开源技术的“红Fan家人”们,也希望获得更多爱好者对红旗Linux产品的关注、反馈和支持。红旗inWise操作系统V8.0是对系统软件包组件的升级和稳定性易…

  • vagrant系列三:vagrant搭建的php7环境

    vagrant系列三:vagrant搭建的php7环境

  • ubuntu20.04清华源_ubuntu20.04更换国内源

    ubuntu20.04清华源_ubuntu20.04更换国内源Ubuntu22.04的稳定版计划于2022年4月21日发布。开发工作已经在紧锣密鼓地进行,它将遵循如下发布时间表:2022年2月24日:功能冻结2022年3月17日:用户界面冻结2022年3月31日:测试版发布2022年4月14日:候选版本2022年4月21日:最终稳定版本Ubuntu22.04仍在积极开发中。您不应该在生产机器或主系统上使用它。如果你想在备用机器或虚拟机上测试它,你可以从Ubuntu的网站下载每日

  • 常见的js算法_javascript数据结构与算法

    常见的js算法_javascript数据结构与算法常见的几种js算法(一)快速排序算法1.1:先从数列中取出一个数作为“基准”。1.2:分区过程:将比这个“基准”大的数全放到“基准”的右边,小于或等于“基准”的数全放到“基准”的左边。1.3:再对左右区间重复第二步,直到各区间只有一个数。代码实现:varquickSort=function(arr){if(arr.length<=1){retur…

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号