微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦！

【音视频】windows视音频设备热插拔集成5-2

分类：Windows作者：编程之家原文地址AI导航网

上一篇实现了windows的音视频设备热插拔功能，这一篇集成到SDK中。我的对外接口类是HCMDesktopRecorder，该篇主要讲如何集成热插拔功能，其他代码忽略。

1、开启并注册热插拔

int HCMDesktopRecorder::init(/* 忽略 */)
{
	/* 忽略 */
	
	// Create thread for detect device callback
	m_detectDeviceThread = std::thread(std::bind(&HCMDesktopRecorder::detectDeviceProcess, this));
	// Start detecting device
	DEVICE::DeviceDetector::GetInstance().startDetect();
	m_deviceDetectCbId = DEVICE::DeviceDetector::GetInstance().registerCallback(std::bind(&HCMDesktopRecorder::deviceDetectCb,
		this, std::placeholders::_1, std::placeholders::_2));
				
	/* 忽略 */
}

向DeviceDetector注册的回调，一旦收到设备变更通知就触发自己的函数detectDeviceProcess

void HCMDesktopRecorder::deviceDetectCb(DEVICE::DeviceDetectType type, DEVICE::DeviceDetectAction action)
{
	std::unique_lock<std::mutex> lock(m_detectDeviceMutex);
	m_detectDeviceInfoList.push_back({ type, action });
	m_detectDeviceFlag = true;
	m_detectDeviceCond.notify_all();
}

detectDeviceProcess的线程函数实现如下：

void HCMDesktopRecorder::detectDeviceProcess()
{
	while (m_inited) {
		std::unique_lock<std::mutex> lock(m_detectDeviceMutex);
		while (!m_detectDeviceFlag && m_inited) {
			m_detectDeviceCond.wait_for(lock, std::chrono::microseconds(1000));
		}

		while (!m_detectDeviceInfoList.empty()) {
			auto info = m_detectDeviceInfoList.front();
			m_detectDeviceInfoList.pop_front();
			handleAudioDevice(info.type, info.action);
			handleVideoDevice(info.type, info.action);
		}
		m_detectDeviceFlag = false;
	}
}

其中handleAudioDevice和handleVideoDevice实现有点长，如下。
如果发现当前使用的设备被拔掉了，那么先销毁内存，并找可用的新设备，如果找到了，则开启新设备并更新到muxer中，实现见replaceAudioCaptor和replaceVideoCaptor；如果监测到插入了新设备并且当前无相同类型设备在使用，那么同样创建新设备并更新到muxer，同样详见replaceAudioCaptor和replaceVideoCaptor

void HCMDesktopRecorder::handleAudioDevice(DEVICE::DeviceDetectType type, DEVICE::DeviceDetectAction action)
{
	DEVICE::AUdio_DEVICE defaultDevice = {};
	std::list<DEVICE::AUdio_DEVICE> devices;
	if (type == DEVICE::DeviceDetectType::DEVICE_DDETECT_TYPE_MIC) {
		DEVICE::AudioDevice::getMicDevices(devices);
		if (action == DEVICE::DeviceDetectAction::DEVICE_DDETECT_ACTION_REMOVE) {
			bool removed = true;
			for each (auto device in devices) {
				if (device.id == m_setting.mic.id) {
					removed = false;
					break;
				}
				if (device.isDefault) {
					defaultDevice = device;
				}
			}
			if (removed) {
				memset(m_setting.mic.id, 0, sizeof(m_setting.mic.id));
				if (m_micCaptor != nullptr) {
					m_filemuxer->replaceAudioCaptor(m_micCaptor, true, false);
					CAPTOR::destroyAudioCaptor(&m_micCaptor);
					m_micCaptor = nullptr;
				}
				if (!devices.empty()) {
					memcpy_s(m_setting.mic.id, sizeof(m_setting.mic.id), defaultDevice.id.c_str(), defaultDevice.id.size());
					memcpy_s(m_setting.mic.name, sizeof(m_setting.mic.name), defaultDevice.name.c_str(), defaultDevice.name.size());
					CAPTOR::createAudioCaptor((CAPTOR::AUdio_CAPTURE_TYPE)m_setting.amCaptorId, &m_micCaptor);
					m_micCaptor->init(true, m_setting.mic.id);
					m_filemuxer->replaceAudioCaptor(m_micCaptor, true, true);
				}
			}
		}
		else if (action == DEVICE::DeviceDetectAction::DEVICE_DDETECT_ACTION_ADD) {
			bool added = false;
			if (devices.size() > 0 && strlen(m_setting.mic.id) == 0) {
				for each (auto device in devices) {
					if (device.isDefault) {
						defaultDevice = device;
						added = true;
						break;
					}
				}
				if (added) {
					memcpy_s(m_setting.mic.id, sizeof(m_setting.mic.id), defaultDevice.id.c_str(), defaultDevice.id.size());
					memcpy_s(m_setting.mic.name, sizeof(m_setting.mic.name), defaultDevice.name.c_str(), defaultDevice.name.size());
					CAPTOR::createAudioCaptor((CAPTOR::AUdio_CAPTURE_TYPE)m_setting.amCaptorId, &m_micCaptor);
					m_micCaptor->init(true, m_setting.mic.id);
					m_filemuxer->replaceAudioCaptor(m_micCaptor, true, true);
				}
			}
		}
	}
	else if (type == DEVICE::DeviceDetectType::DEVICE_DDETECT_TYPE_SPEAKER) {
		DEVICE::AudioDevice::getSpeakerDevices(devices);
		if (action == DEVICE::DeviceDetectAction::DEVICE_DDETECT_ACTION_REMOVE) {
			bool removed = true;
			for each (auto device in devices) {
				if (device.id == m_setting.speaker.id) {
					removed = false;
					break;
				}
				if (device.isDefault) {
					defaultDevice = device;
				}
			}
			if (removed) {
				memset(m_setting.speaker.id, 0, sizeof(m_setting.speaker.id));
				if (m_speakerCaptor != nullptr) {
					m_filemuxer->replaceAudioCaptor(m_speakerCaptor, false, false);
					CAPTOR::destroyAudioCaptor(&m_speakerCaptor);
					m_speakerCaptor = nullptr;
				}
				if (!devices.empty()) {
					memcpy_s(m_setting.speaker.id, sizeof(m_setting.speaker.id), defaultDevice.id.c_str(), defaultDevice.id.size());
					memcpy_s(m_setting.speaker.name, sizeof(m_setting.speaker.name), defaultDevice.name.c_str(), defaultDevice.name.size());
					CAPTOR::createAudioCaptor((CAPTOR::AUdio_CAPTURE_TYPE)m_setting.asCaptorId, &m_speakerCaptor);
					m_speakerCaptor->init(false, m_setting.speaker.id);
					m_filemuxer->replaceAudioCaptor(m_speakerCaptor, false, true);
				}
			}
		}
		else if (action == DEVICE::DeviceDetectAction::DEVICE_DDETECT_ACTION_ADD) {
			bool added = false;
			if (devices.size() > 0 && strlen(m_setting.speaker.id) == 0) {
				for each (auto device in devices) {
					if (device.isDefault) {
						defaultDevice = device;
						added = true;
						break;
					}
				}
				if (added) {
					memcpy_s(m_setting.speaker.id, sizeof(m_setting.speaker.id), defaultDevice.id.c_str(), defaultDevice.id.size());
					memcpy_s(m_setting.speaker.name, sizeof(m_setting.speaker.name), defaultDevice.name.c_str(), defaultDevice.name.size());
					CAPTOR::createAudioCaptor((CAPTOR::AUdio_CAPTURE_TYPE)m_setting.asCaptorId, &m_speakerCaptor);
					m_speakerCaptor->init(false, m_setting.speaker.id);
					m_filemuxer->replaceAudioCaptor(m_speakerCaptor, false, true);
				}
			}
		}
	}

	if (m_callbacks.onDeviceChanged != nullptr) {
		m_callbacks.onDeviceChanged(type);
	}
}

void HCMDesktopRecorder::handleVideoDevice(DEVICE::DeviceDetectType type, DEVICE::DeviceDetectAction action)
{
	DEVICE::VIDEO_DEVICE defaultDevice = {};
	std::list<DEVICE::VIDEO_DEVICE> devices;
	if (type == DEVICE::DeviceDetectType::DEVICE_DDETECT_TYPE_CAMERA) {
		DEVICE::VideoDevice::getCameraDevices(devices);
		if (action == DEVICE::DeviceDetectAction::DEVICE_DDETECT_ACTION_REMOVE) {
			bool removed = true;
			for each (auto device in devices) {
				if (device.id == m_setting.camera.id) {
					removed = false;
					break;
				}
				if (device.isDefault) {
					defaultDevice = device;
				}
			}
			if (removed) {
				memset(m_setting.camera.id, 0, sizeof(m_setting.camera.id));
				// Remove camera captor
				if (m_cameraCaptor != nullptr) {
					m_filemuxer->replaceVideoCaptor(m_cameraCaptor, true, false);
					CAPTOR::destroyVideoCaptor(&m_cameraCaptor);
					m_cameraCaptor = nullptr;
				}
				if (!devices.empty()) {
					memcpy_s(m_setting.camera.id, sizeof(m_setting.camera.id), defaultDevice.id.c_str(), defaultDevice.id.size());
					memcpy_s(m_setting.camera.name, sizeof(m_setting.camera.name), defaultDevice.name.c_str(), defaultDevice.name.size());
					// Create camera captor
					CAPTOR::createVideoCaptor((CAPTOR::VIDEO_CAPTURE_TYPE)m_setting.vcCaptorId, &m_cameraCaptor);
					m_cameraCaptor->init(m_setting.camera.id, m_setting.framerate);
					m_filemuxer->replaceVideoCaptor(m_cameraCaptor, true, true);
				}
			}
		}
		else if (action == DEVICE::DeviceDetectAction::DEVICE_DDETECT_ACTION_ADD) {
			bool added = false;
			if (devices.size() > 0 && strlen(m_setting.camera.id) == 0) {
				for each (auto device in devices) {
					if (device.isDefault) {
						defaultDevice = device;
						added = true;
						break;
					}
				}
				if (added) {
					memcpy_s(m_setting.camera.id, sizeof(m_setting.camera.id), defaultDevice.id.c_str(), defaultDevice.id.size());
					memcpy_s(m_setting.camera.name, sizeof(m_setting.camera.name), defaultDevice.name.c_str(), defaultDevice.name.size());
					// Create camera captor
					CAPTOR::createVideoCaptor((CAPTOR::VIDEO_CAPTURE_TYPE)m_setting.vcCaptorId, &m_cameraCaptor);
					m_cameraCaptor->init(m_setting.camera.id, m_setting.framerate);
					m_filemuxer->replaceVideoCaptor(m_cameraCaptor, true, true);
				}
			}
		}
	}
	else if (type == DEVICE::DeviceDetectType::DEVICE_DDETECT_TYPE_MONITOR) {}

	if (m_callbacks.onDeviceChanged != nullptr) {
		m_callbacks.onDeviceChanged(type);
	}
}

2、muxer类关于replaceAudioCaptor和replaceVideoCaptor的实现

Ffmpegmuxer实现详见《【音视频】保存同步的音视频文件-ffmpeg（九）》，这里只做热插拔实现的介绍。
replaceAudioCaptor的实现，详见代码。
amCaptor是麦克风采集器，asCaptor是扬声器采集器，aFilter是音频转码或混流过滤器

int Ffmpegmuxer::replaceAudioCaptor(CAPTOR::AudioCaptor* audioCaptor, bool isMic, bool add)
{
	/* 没有启动过audio流程，就不再启动（重启流程比较麻烦，就不做了，反正主要为了测试audio设备的热插拔） */
	if (m_audioStream == nullptr) {
		return ERROR_CODE_UNINITIALIZED;
	}

	int err = ERROR_CODE_OK;
	std::lock_guard<std::mutex> lock(m_mutex);
	if (add) {
		bool hasDevice = false;
		if ((m_audioStream->amCaptor != nullptr && isMic) || (m_audioStream->asCaptor != nullptr && !isMic)) {
			hasDevice = true;
		}
		if (!hasDevice) {
			if (m_audioStream->amCaptor == nullptr && isMic) {
				m_audioStream->amCaptor = audioCaptor;
			}
			else if (m_audioStream->asCaptor == nullptr && !isMic) {
				m_audioStream->asCaptor = audioCaptor;
			}
			/* 销毁filter */
			FILTER::destroyAudioFilter(&m_audioStream->aFilter);
			/* 重新创建filter */
			err = createAudioFilter(m_audioStream->amCaptor, m_audioStream->asCaptor);
			if (err == ERROR_CODE_OK) {
				/* 启动captor和filter */
				if (m_audioStream->amCaptor != nullptr) {
					m_audioStream->amCaptor->start();
				}
				if (m_audioStream->asCaptor != nullptr) {
					m_audioStream->asCaptor->start();
				}
				if (m_audioStream->aFilter != nullptr) {
					m_audioStream->aFilter->start();
				}
			}
		}
	}
	else {
		if (isMic && m_audioStream->amCaptor == audioCaptor) {
			err = m_audioStream->amCaptor->stop();
			m_audioStream->amCaptor = nullptr;
		}
		else if (!isMic && m_audioStream->asCaptor == audioCaptor) {
			err = m_audioStream->asCaptor->stop();
			m_audioStream->asCaptor = nullptr;
		}
	}
	return err;
}

replaceVideoCaptor实现，详见代码。
vmCaptor是显示器采集器，vcCaptor是摄像头采集器，vTranscoder是视频转码器，vFilter是视频混流过滤器

int Ffmpegmuxer::replaceVideoCaptor(CAPTOR::VideoCaptor* videoCaptor, bool isCamera, bool add)
{
	/* 没有启动过video流程，就不再启动（重启流程比较麻烦，就不做了，反正主要为了测试video设备的热插拔） */
	if (m_videoStream == nullptr) {
		return ERROR_CODE_UNINITIALIZED;
	}

	int err = ERROR_CODE_OK;
	std::lock_guard<std::mutex> lock(m_mutex);
	if (add) {
		bool hasDevice = false;
		if ((m_videoStream->vmCaptor != nullptr && !isCamera) || (m_videoStream->vcCaptor != nullptr && isCamera)) {
			hasDevice = true;
		}
		if (!hasDevice) {
			if (m_videoStream->vmCaptor == nullptr && !isCamera) {
				m_videoStream->vmCaptor = videoCaptor;
			}
			else if (m_videoStream->vcCaptor == nullptr && isCamera) {
				m_videoStream->vcCaptor = videoCaptor;
			}
			/* 销毁filter */
			TRANSCODER::destroyVideoTranscoder(&m_videoStream->vTranscoder);
			FILTER::destroyVideoFilter(&m_videoStream->vFilter);
			/* 重新创建filter */
			err = createVideoFilter(m_videoStream->vmCaptor, m_videoStream->vcCaptor);
			if (err == ERROR_CODE_OK) {
				/* 启动captor和filter */
				if (m_videoStream->vmCaptor != nullptr) {
					m_videoStream->vmCaptor->start();
				}
				if (m_videoStream->vcCaptor != nullptr) {
					m_videoStream->vcCaptor->start();
				}
				if (m_videoStream->vFilter != nullptr) {
					m_videoStream->vFilter->start();
				}
			}
		}
	}
	else {
		if (isCamera && m_videoStream->vcCaptor == videoCaptor) {
			err = m_videoStream->vcCaptor->stop();
			m_videoStream->vcCaptor = nullptr;
		}
		else if (!isCamera && m_videoStream->vmCaptor == videoCaptor) {
			err = m_videoStream->vmCaptor->stop();
			m_videoStream->vmCaptor = nullptr;
		}
	}
	return err;
}

3、停止热插拔监测

删除热插拔回调并停止监测

void HCMDesktopRecorder::release()
{
	/* 忽略 */

	DEVICE::DeviceDetector::GetInstance().removeCallback(m_deviceDetectCbId);
	DEVICE::DeviceDetector::GetInstance().stopDetect();
}

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

相关推荐

Windows2012R2备用域控搭建
Windows2012R2备用域控搭建 前置操作 域控主域控的主dns：自己的ip备域控的主dns：自己的ip，备dns：主域控的ip 客户端主dns：主域控的ip，备dns：备域控的ip 一般说主和备，主要是指担任PDC放置的角色的这台DC，所有修改密码的操作必须由这台DC应答 除了修改密码、域管
主域控角色迁移和夺取（转载）
主域控角色迁移和夺取（转载） 转载自：http://yupeizhi.blog.51cto.com/3157367/1427978 操作系统版本：Windows2012R2 数据中心版 FSMO角色迁移 主域控没有挂的情况下使用FSMO角色迁移 FSMO角色迁移步骤，下面步骤在备用域控上执行 0、使
Windows2012R2 NTP时间同步
Windows2012R2 NTP时间同步 Windows2012R2里没有了internet时间，需要使用另外的方式去做时间同步 下面分两个情况 两个情况，两个情况都需要用修改组策略的方式来做 情况一 没有Windows域环境 集群中的每个服务器都要能上网，每个服务器都要执行下面的操作 开启 NT
Windows注册表操作基础代码
Windows注册表操作基础代码 Windows下对注册表进行操作使用的一段基础代码Reg.h:#pragmaonce#include&lt;assert.h&gt;#include&lt;windows.h&gt;classReg{HKEYhkey;public:voidopen(HKEYroot
黑客常用WinAPI函数整理
黑客常用WinAPI函数整理之前的博客写了很多关于Windows编程的内容，在Windows环境下的黑客必须熟练掌握底层API编程。为了使读者对黑客常用的Windows API有个更全面的了解以及方便日后使用API方法的查询，特将这些常用的API按照7大分类进行整理如下，希望对大家的学习有所帮助。一
一个简单的Windows Socket可复用框架
一个简单的Windows Socket可复用框架说起网络编程，无非是建立连接，发送数据，接收数据，关闭连接。曾经学习网络编程的时候用Java写了一些小的聊天程序，Java对网络接口函数的封装还是很简单实用的，但是在Windows下网络编程使用的Socket就显得稍微有点繁琐。这里介绍一个自己封装的一
Windows文件操作基础代码
Windows文件操作基础代码 Windows下对文件进行操作使用的一段基础代码File.h，首先是File类定义：#pragmaonce#include&lt;Windows.h&gt;#include&lt;assert.h&gt;classFile{HANDLEhFile;//文件句柄publ
Winpcap基础代码
Winpcap基础代码 使用Winpcap进行网络数据的截获和发送都需要的一段代码：#include&lt;PCAP.H&gt;#pragmacomment(lib,&quot;wpcap.lib&quot;)//#pragmacomment(lib,&quot;ws2_32.lib&quot;)#
使用vbs脚本进行批量编码转换
使用vbs脚本进行批量编码转换 最近需要使用SourceInsight查看分析在Linux系统下开发的项目代码，我们知道Linux系统中文本文件默认编码格式是UTF-8，而Windows中文系统中的默认编码格式是Gb2312。系统内的编码格式有所区别倒无伤大雅，关键的是SourceInsigh...
缓冲区溢出攻击
缓冲区溢出攻击缓冲区溢出（Buffer Overflow）是计算机安全领域内既经典而又古老的话题。随着计算机系统安全性的加强，传统的缓冲区溢出攻击方式可能变得不再奏效，相应的介绍缓冲区溢出原理的资料也变得“大众化”起来。其中看雪的《0day安全：软件漏洞分析技术》一书将缓冲区溢出攻击的原理阐述得简洁
苹果市值2025年有望达4万亿美元
pythonJavaScriptjavaHTMLreactjsC#AndroidCSSNode.jssqlrpython-3.xMysqLjQueryc++pandasFlutterangularIOSdjangolinuxswifttypescript路由器JSON路由器设置无线路由器h3c华三华三路由器设置华三路由器电脑软件教程arraysdocker软件图文教程Cvue.jslaravelspring-bootreact-native