window下使用tcp传输视频(c++)

这篇具有很好参考价值的文章主要介绍了window下使用tcp传输视频(c++)。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。


参考链接:

tcp传输普通文本

网络编程:基于TCP的socket网络传输视频(C++, python)

由于项目要求,需要使用tcp完成视频的传输,udp其实也可以,但是udp不可靠,怕丢帧。
菜鸟一个,边缝边写,希望抛砖引玉,大家有意见可以评论区见。哈哈哈!
tcp相关内容不再赘述,本人也是半吊子,会用,远离之前学过,有点忘记了。干货开始:
vs完整工程文件(包括代码和可执行文件):
文件较大,建议csdn下载
csdn:0积分下载,无需梯子
github:需要梯子,文件超过100m了,只上传了源码

整体思路

  1. 对于视频文件读入之后按帧传输,每一帧传输之前使用opencv进行压缩(接收端接收到数据之后也需要解压缩)。
  2. 在传输压缩后的图像数据之前,先传输视频的总帧数和单帧压缩后数组的长度,从而帮助接收端进行解码。
  3. 服务器端和客户端都可实现收发操作。

环境配置

win10
opencv4.5.1
c++ 11
vs2019

废话不多说,直接上代码:

服务器端:

server.h

#pragma once
#include<iostream>
#include<winsock.h>
#include <string>
#pragma comment(lib,"ws2_32.lib")
#include "myopencv.h"
using namespace std;


class Server {
public:
	int m_port; //端口号
	//定义服务端套接字,接受请求套接字
	SOCKET m_server;
	SOCKET m_accept;
	VideoCapture m_cap;
	vector<Mat> m_file_in;
	vector<Mat> m_file_out;
	string m_send_buf;
	string m_recv_buf;

	bool initialization(const int& port, const VideoCapture& cap); // 初始化
	bool build_connect();
	bool send_data();
	bool receive_data();
	bool free_connect();
};

server.cpp

#include "server.h"
#define SIZE 100

bool Server::initialization(const int& port, const VideoCapture& cap) {
	m_port = port;
	m_cap = cap;

	// 初始化库(windows独有)
	//初始化套接字库
	WORD w_req = MAKEWORD(2, 2);//版本号
	WSADATA wsadata;
	int err;
	err = WSAStartup(w_req, &wsadata);
	if (err != 0) {
		cout << "初始化套接字库失败!" << endl;
		return false;
	}
	else {
		cout << "初始化套接字库成功!" << endl;
	}

	//检测版本号
	if (LOBYTE(wsadata.wVersion) != 2 || HIBYTE(wsadata.wHighVersion) != 2) {
		cout << "套接字库版本号不符!" << endl;
		WSACleanup();
		return false;
	}
	else {
		cout << "套接字库版本正确!" << endl;
	}

	return true;
}

bool Server::build_connect() {
	//服务端地址客户端地址
	SOCKADDR_IN server_addr;
	SOCKADDR_IN accept_addr;

	//填充服务端信息
	server_addr.sin_family = AF_INET;  // 用来定义那种地址族,AF_INET:IPV4
	server_addr.sin_addr.S_un.S_addr = htonl(INADDR_ANY);  // 保存ip地址,htonl将一个无符号长整型转换为TCP/IP协议网络的大端
	// INADDR_ANY表示一个服务器上的所有网卡
	server_addr.sin_port = htons(m_port);  // 端口号

	//创建套接字
	m_server = socket(AF_INET, SOCK_STREAM, 0);  // 使用tcp进行连接

	if (::bind(m_server, (SOCKADDR*)&server_addr, sizeof(SOCKADDR)) == SOCKET_ERROR) {
		cout << "套接字绑定失败!" << endl;
		WSACleanup();
		return false;
	}
	else {
		cout << "套接字绑定成功!" << endl;
	}

	//设置套接字为监听状态
	if (listen(m_server, SOMAXCONN) < 0) {
		cout << "设置监听状态失败!" << endl;
		WSACleanup();
		return false;
	}
	else {
		cout << "设置监听状态成功!" << endl;
	}
	cout << "服务端正在监听连接,请稍候...." << endl;
	//接受连接请求
	int len = sizeof(SOCKADDR);
	m_accept = accept(m_server, (SOCKADDR*)&accept_addr, &len);
	if (m_accept == SOCKET_ERROR) {
		cout << "连接失败!" << endl;
		WSACleanup();
		return false;
	}
	cout << "连接建立,准备接受数据" << endl;
	return true;
}

bool Server::send_data() {
	Mat frame;
	vector<uchar> data_encode;
	std::vector<int> params;  // 压缩参数
	params.resize(3, 0);
	params[0] = IMWRITE_JPEG_QUALITY; // 无损压缩
	params[1] = 100;
	char frames_cnt[10] = { 0, };
	_itoa_s(int(m_cap.get(CAP_PROP_FRAME_COUNT)), frames_cnt, 10);
	send(m_accept, frames_cnt, 10, 0);
	cout << "开始发送" << endl;
	int j = 0;
	while (m_cap.read(frame)) {

		m_file_in.push_back(frame.clone());
		imencode(".jpg", frame, data_encode, params);  // 对图像进行压缩
		int len_encoder = data_encode.size();

		_itoa_s(len_encoder, frames_cnt, 10);
		send(m_accept, frames_cnt, 10, 0);

		_itoa_s(SIZE, frames_cnt, 10);
		send(m_accept, frames_cnt, 10, 0);
		// 发送
		char send_char[SIZE] = { 0, };
		int index = 0;
		bool flag = false;
		for (int i = 0; i < len_encoder / SIZE + 1; ++i) {
			for (int k = 0; k < SIZE; ++k) {
				if (index >= data_encode.size()) {
					flag = true;
					break;
				}
				send_char[k] = data_encode[index++];
			}
			send(m_accept, send_char, SIZE, 0);
		}

		//m_send_buf = to_string(j + 1);
		//send(m_server, m_send_buf.c_str(), strlen(frames_cnt.c_str()), 0);
		//waitKey(25);
		//imshow("input", frame);
		data_encode.clear();
		++j;
		cout << j << endl;  // 发送端一直在发送
	}
	cout << "发送完成";
	return true;
}

bool Server::receive_data() {
	Mat frame;
	vector<uchar> data_decode;
	std::vector<int> params;  // 压缩参数
	char recv_char[100];

	params.resize(3, 0);
	params[0] = IMWRITE_JPEG_QUALITY; // 无损压缩
	params[1] = 100;

	char frams_cnt[10] = { 0, };
	recv(m_accept, frams_cnt, 10, 0);
	// 解析总帧数
	int count = atoi(frams_cnt);
	for (unsigned int i = 0; i < count; ++i) {
		recv(m_accept, frams_cnt, 10, 0);
		// 解析总帧数
		int cnt = atoi(frams_cnt);
		recv(m_accept, frams_cnt, 10, 0);
		int size = atoi(frams_cnt);

		data_decode.resize(cnt);
		int index = 0;
		bool flag = true;
		for (int i = 0; i < cnt / size + 1; ++i) {
			recv(m_accept, recv_char, size, 0);
			for (int k = 0; k < size; ++k) {
				if (index >= cnt) {
					flag = true;
					break;
				}
				data_decode[index++] = recv_char[k];
			}
		}

		//data_decode.pop_back();
		frame = imdecode(data_decode, IMREAD_COLOR);
		m_file_out.push_back(frame.clone());
		//waitKey(25);
		//imshow("s", frame);
		//char recv_buf[50];
		//recv(m_accept, recv_char, 50, 0);
		//cout << "客户端信息:" << recv_buf << endl;
		data_decode.clear();
	}
	cout << "接受完成";
	return true;
}

bool Server::free_connect() {
	m_cap.release();
	//关闭套接字
	closesocket(m_server);
	closesocket(m_accept);
	//释放DLL资源
	WSACleanup();
	return true;
}
客户端

client.h

#pragma once
#include<iostream>
#include<winsock.h>
#include <string>
#pragma comment(lib,"ws2_32.lib")
#include "myopencv.h"
using namespace std;


class Server {
public:
	int m_port; //端口号
	string m_ip; //服务端ip地址
	//定义服务端套接字,接受请求套接字
	SOCKET m_server;
	VideoCapture m_cap;
	vector<Mat> m_file_in;
	vector<Mat> m_file_out;
	//定义发送缓冲区和接受缓冲区
	string m_send_buf;
	string m_recv_buf;

	bool initialization(const int& port, const string& ip, const VideoCapture& cap); // 初始化
	bool build_connect();
	bool send_data();
	bool receive_data();
	bool free_connect();
};

client.cpp文章来源地址https://www.toymoban.com/news/detail-423173.html

#include "client.h"
#define SIZE 100
bool Server::initialization(const int& port, const string& ip, const VideoCapture& cap) {
	m_port = port;
	m_cap = cap;
	m_ip = ip;
	// 初始化库(windows独有)
	//初始化套接字库
	WORD w_req = MAKEWORD(2, 2);//版本号
	WSADATA wsadata;
	int err;
	err = WSAStartup(w_req, &wsadata);
	if (err != 0) {
		cout << "初始化套接字库失败!" << endl;
		return false;
	}
	else {
		cout << "初始化套接字库成功!" << endl;
	}

	//检测版本号
	if (LOBYTE(wsadata.wVersion) != 2 || HIBYTE(wsadata.wHighVersion) != 2) {
		cout << "套接字库版本号不符!" << endl;
		WSACleanup();
		return false;
	}
	else {
		cout << "套接字库版本正确!" << endl;
	}

	return true;
}

bool Server::build_connect() {
	//服务端地址客户端地址
	SOCKADDR_IN server_addr;
	SOCKADDR_IN accept_addr;

	//填充服务端信息
	server_addr.sin_family = AF_INET;  // 用来定义那种地址族,AF_INET:IPV4
	server_addr.sin_addr.S_un.S_addr = inet_addr(m_ip.c_str());  // 保存ip地址,htonl将一个无符号长整型转换为TCP/IP协议网络的大端
	// INADDR_ANY表示一个服务器上的所有网卡
	server_addr.sin_port = htons(m_port);  // 端口号

	//创建套接字
	m_server = socket(AF_INET, SOCK_STREAM, 0);
	if (connect(m_server, (SOCKADDR*)&server_addr, sizeof(SOCKADDR)) == SOCKET_ERROR) {
		cout << "服务器连接失败!" << endl;
		WSACleanup();
		return false;
	}
	else {
		cout << "服务器连接成功!" << endl;
	}

	return true;
}

bool Server::send_data() {
	Mat frame;
	vector<uchar> data_encode;
	std::vector<int> params;  // 压缩参数
	params.resize(3, 0);
	params[0] = IMWRITE_JPEG_QUALITY; // 无损压缩
	params[1] = 100;
	char frames_cnt[10] = { 0, };
	_itoa_s(int(m_cap.get(CAP_PROP_FRAME_COUNT)), frames_cnt, 10);
	send(m_server, frames_cnt, 10, 0);
	cout << "开始发送" << endl;
	int j = 0;
	while (m_cap.read(frame)) {

		m_file_in.push_back(frame.clone());
		imencode(".jpg", frame, data_encode, params);  // 对图像进行压缩
		int len_encoder = data_encode.size();

		_itoa_s(len_encoder, frames_cnt, 10);
		send(m_server, frames_cnt, 10, 0);

		_itoa_s(SIZE, frames_cnt, 10);
		send(m_server, frames_cnt, 10, 0);
		// 发送
		char send_char[SIZE] = { 0, };
		int index = 0;
		bool flag = false;
		for (int i = 0; i < len_encoder / SIZE + 1; ++i) {
			for (int k = 0; k < SIZE; ++k) {
				if (index >= data_encode.size()) {
					flag = true;
					break;
				}
				send_char[k] = data_encode[index++];
			}
			send(m_server, send_char, SIZE, 0);
		}

		//m_send_buf = to_string(j + 1);
		//send(m_server, m_send_buf.c_str(), strlen(frames_cnt.c_str()), 0);
		//waitKey(25);
		//imshow("input", frame);
		data_encode.clear();
		++j;
		cout << j << endl;  // 发送端一直在发送
	}
	cout << "发送完成";
	return true;
}

bool Server::receive_data() {
	Mat frame;
	vector<uchar> data_decode;
	std::vector<int> params;  // 压缩参数
	char recv_char[100];

	params.resize(3, 0);
	params[0] = IMWRITE_JPEG_QUALITY; // 无损压缩
	params[1] = 100;

	char frams_cnt[10] = { 0, };
	recv(m_server, frams_cnt, 10, 0);
	// 解析总帧数
	int count = atoi(frams_cnt);
	for (unsigned int i = 0; i < count; ++i) {
		recv(m_server, frams_cnt, 10, 0);
		// 解析总帧数
		int cnt = atoi(frams_cnt);
		recv(m_server, frams_cnt, 10, 0);
		int size = atoi(frams_cnt);

		data_decode.resize(cnt);
		int index = 0;
		bool flag = true;
		for (int i = 0; i < cnt / size + 1; ++i) {
			recv(m_server, recv_char, size, 0);
			for (int k = 0; k < size; ++k) {
				if (index >= cnt) {
					flag = true;
					break;
				}
				data_decode[index++] = recv_char[k];
			}
		}

		//data_decode.pop_back();
		frame = imdecode(data_decode, IMREAD_COLOR);
		m_file_out.push_back(frame.clone());
		//waitKey(25);
		//imshow("s", frame);
		//char recv_buf[50];
		//recv(m_accept, recv_char, 50, 0);
		//cout << "客户端信息:" << recv_buf << endl;
		data_decode.clear();
	}
	cout << "接受完成";
	return true;
}

bool Server::free_connect() {
	m_cap.release();
	//关闭套接字
	closesocket(m_server);
	//释放DLL资源
	WSACleanup();
	return true;
}

到了这里,关于window下使用tcp传输视频(c++)的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • 安卓 Windows 通过ts链接获取m3u8视频地址进行视频下载

    目录 环境: 解决思路及过程: .TS—— .m3u8 1.利用安卓视频缓存机制合成视频 1.1 找到鲨鱼浏览器目录 1.2 进入Android/data/com.zhijianzhuoyue.sharkbrowser/cashe 缓存目录  1.3 显示隐藏文件 1.4 进入可以看到两个随机生成的视频文件夹,进入一个即是对应视频播放缓存目录 1.4 再次进入得

    2024年02月11日
    浏览(54)
  • 将Windows系统上的音频、视频通过iTunes传输到iPhone上

    这个地方需要下载安装版的iTunes 下载地址: https://www.apple.com/itunes/download/win64 不要从Windows的APP Store中下载iTunes,不好使。 安装完成后,如果是导入一个文件夹中的资料,则点击 【文件】》【将文件夹添加到资料库】 在弹出的窗口中找到对应的音频文件,选中文件夹,会导

    2024年02月15日
    浏览(34)
  • 微信小程序使用weapp-qrcode.js生成二维码以及“扫普通链接二维码打开小程序”动态传递参数实现记录

    参考文章原文链接:微信小程序使用weapp-qrcode.js完成二维码的生成_fairy_404的博客-CSDN博客 首先给需要生成二维码的页面创建一个canvas 因为我这里实现的是弹窗展示二维码,所有就把 canvas移出页面,小伙伴们根据自己需求进行调整,weapp-qrcode.js内容参考链接中就有,我这里就

    2024年02月15日
    浏览(51)
  • 微信小程序使用weapp-qrcode.js生成二维码以及“扫普通链接二维码打开小程序”动态传递参数实现以及遇到问题记录

    参考文章原文链接:微信小程序使用weapp-qrcode.js完成二维码的生成_fairy_404的博客-CSDN博客 首先给需要生成二维码的页面创建一个canvas 因为我这里实现的是弹窗展示二维码,所有就把 canvas移出页面,小伙伴们根据自己需求进行调整,weapp-qrcode.js内容参考链接中就有,我这里就

    2024年02月01日
    浏览(53)
  • C++(20):普通函数的参数使用auto声明

    C++20进一步解放了对auto的使用,可以在函数的参数中使用auto,auto, auto 并且类型推导的规则与C++11中是一致的 C++(11):auto通过初始化类型推导变量类型_auto如何实现自动推导变量的类型-CSDN博客

    2024年01月22日
    浏览(33)
  • 微信小程序后台:解决微信扫普通链接地址无法跳转到体验版微信的问题,配置普通链接二维码规则解释和理解

    一、现象与原因 最近突然发现微信管理平台中,设置好的普通二维码连接跳转到体验版小程序的功能,没有区分体验版和生产版,全部到生产环境的小程序了。 这现象,跟我以前理解的可不一样,可能会出生产的事故,马上仔细研究了研究。 研究发现,“扫普通链接二维码

    2024年02月15日
    浏览(63)
  • 微信小程序-扫普通链接二维码打开小程序

    类似很多饭堂扫桌面二维码点餐都是用这种方式实现扫普通链接二维码打开小程序 一、小程序设置: 链接后面带参数: 首先要在小程序管理-开发管理-开发设置:扫普通链接二维码打开小程序 添加可访问的链接,此链接要求域名已备案,并且要下载校验文件,并根据说明文

    2024年02月14日
    浏览(39)
  • 国企普通员工如何才能成为公务员,这三种途径可供参考

    国企普通员工如何转变成公务员?作为国企普通员工,如果要成为国家公务员,其主要的路径有三个方面,一是符合国家公务员法规定的公务员招录条件要求的,可以报考国家公务员;二是在国有企业担任领导职务,符合公务员调任要求,可以通过调动的方式到机关担任公务

    2024年02月17日
    浏览(45)
  • 如何使用WinSCP通过固定公网TCP地址实现远程连接内网设备传输文件

    ​ Winscp 是一个支持 SSH( Secure SHell)的 可视化 SCP(Secure Copy)文件传输软件,它的主要功能是在本地与远程计算机间安全地复制文件,并且可以直接编辑文件。 ​ 可视化操作就是直接把文件 从本机拖入 ,打开文件 直接双击 即可。 软件特性 支持协议众多:SSH ,FTP、SFTP、FTPS、

    2024年04月16日
    浏览(68)
  • 在直播系统中使用SRT协议传输视频

    目录 1、简述 2、NDI、RTSP协议的优缺点 3、SRT协议简介 4、SRT协议链接地址URL格式

    2024年02月02日
    浏览(32)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包