Skip to content

A-ZHANG1/RtcWinDemo

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

13 Commits
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

2020-11-10: 增加了国内可用的STUN服务器,提高了连通率 修改IceTransportsType,去除本机IP选项

作业说明

目标

  1. 实现多人通话功能
  2. 实现多人聊天功能

多人通话功能

demo中关键函数理解

首先对多人通话中涉及的部分关键函数进行分析:

  • void CRtcWinDemoDlg::AddTrack(webrtc::VideoTrackInterface* track, bool is_local)是实现加流的关键函数。它首先对待加入的track进行检查,如果其类型为kVideoKind且该track未曾加入,则加入该流,并调用HWND AllocateWindow(bool is_local, std::string track_id)为其分配对应的窗口。
  • HWND AllocateWindow(bool is_local, std::string track_id)是为流分配窗口的函数。它首先预分配一个窗口,然后检测该窗口是否已被其他流占用,如果未被占用,则窗口分配成功,否则分配失败,返回NULL

本地流rtc_manager.cpp中的CreateLocalMediaStream() 函数触发receiver_->AddTrack(video_track_, true);传入的true参数代表is_local = true,即该流为本地流。

远程流rtc_manager.cpp中的PeerConnectionObserver()函数触发receiver_->AddTrack(video_track, false);传入的false参数代表is_local = false,即该流为远程流。

多人通话实现思路

窗口加入流

RtcWinDemoDlg.cpp初始代码中,AllocateWindow()已实现了为本地流和第一个远程流的加流和分配窗口操作:为本地流分配第一个窗口,远程流分配第二个窗口。参考第一个远程流的相关操作,增加额外的远程流,即可实现多人通话功能。主要修改函数为AllocateWindow(),对于远程流,依次检查窗口二、三、四的占用情况,如果未被占用,则分配成功,并标记为已被占用,否则检查下一个窗口。修改后的该函数如下

HWND CRtcWinDemoDlg::AllocateWindow(bool is_local, std::string track_id) {
	CWnd* pWnd = NULL;
	if (is_local) {
		pWnd = GetDlgItem(IDC_LOCAL_WIN);
	} else {
		if (!win1Used) {
			pWnd = GetDlgItem(IDC_REMOTE_WIN_1);
			win1Used = true;
		}
		else if (!win2Used) {
			pWnd = GetDlgItem(IDC_REMOTE_WIN_2);
			win2Used = true;
		}
		else if (!win3Used) {
			pWnd = GetDlgItem(IDC_REMOTE_WIN_3);
			win3Used = true;
		}
		
		if (pWnd) {
			auto it = map_of_video_renders_.begin();
			while (it != map_of_video_renders_.end()) {
				if (it->second->GetWindow() == pWnd->GetSafeHwnd()) {
					return NULL;
				}
				it++;
			}
		}
	}
	return pWnd ? pWnd->GetSafeHwnd() : NULL;
}
窗口退出流

添加SetWinUsed(HWND window)函数,该函数将输入的这个window的标记设为未被占用。

void CRtcWinDemoDlg::SetWinUsed(HWND window) {
	CWnd* pWnd = NULL;
	pWnd = GetDlgItem(IDC_REMOTE_WIN_1);

	if (window == pWnd->GetSafeHwnd()) {
		win1Used = false;
	}
	else {
		pWnd = GetDlgItem(IDC_REMOTE_WIN_2);
		if (window == pWnd->GetSafeHwnd()) {
			win2Used = false;
		}
		else {
			pWnd = GetDlgItem(IDC_REMOTE_WIN_3);
			if (window == pWnd->GetSafeHwnd()) {
				win3Used = false;
			}
		}
	}
}

RemoveTrack函数中进行调用SetWinUsed,修改后的该函数如下

void CRtcWinDemoDlg::RemoveTrack(webrtc::VideoTrackInterface* track) {
	if (track && track->kind() == webrtc::MediaStreamTrackInterface::kVideoKind) {
		std::string track_id = track->id();
		auto it = map_of_video_renders_.find(track_id);
		if (it != map_of_video_renders_.end()) 
			SetWinUsed(map_of_video_renders_[track_id]->GetWindow()); {
			it->second->SetTrack(nullptr);
			map_of_video_renders_.erase(it);
		}
	}
}

多人聊天功能

根据demo中的onReceiveMessage函数可以看到response消息类和其他消息类的接收处理,其中其他消息类中可以看到有一个method为broadcast的消息处理函数,根据该函数就可以设计发信息的json内容格式,由于是主动信息,将notification改为request即可。从输入框获取信息,并在最后需要将输入框进行清空处理。

void CRtcWinDemoDlg::OnBnClickedBtnSend()
{
	CString strMessage, strRoomId, strUserName;
	m_editRoomId.GetWindowText(strRoomId);
	m_editUserId.GetWindowText(strUserName);
	m_editMessage.GetWindowText(strMessage);

	if (strMessage.IsEmpty()) {
		AfxMessageBox(_T("Invalid Message"));
		return;
	}

	room_id_ = CStringToStdString(strRoomId);
	user_name_ = CStringToStdString(strUserName);

	cJSON* root_json = cJSON_CreateObject();

	cJSON_AddItemToObject(root_json, "request", cJSON_CreateBool(true));
	cJSON_AddItemToObject(root_json, "id", 			cJSON_CreateNumber(AllocateSession(kWebSocketRequestJoinRoom, user_id_)));
	cJSON_AddItemToObject(root_json, "method", cJSON_CreateString("broadcast"));

	cJSON* data_json = cJSON_CreateObject();
	cJSON_AddItemToObject(root_json, "data", data_json);
	cJSON_AddItemToObject(data_json, "rid", cJSON_CreateString(room_id_.c_str()));
	cJSON_AddItemToObject(data_json, "uid", cJSON_CreateString(user_id_.c_str()));

	cJSON* info_json = cJSON_CreateObject();
	cJSON_AddItemToObject(data_json, "info", info_json);
	cJSON_AddItemToObject(info_json, "msg", cJSON_CreateString(CStringToStdString(strMessage).c_str()));
	cJSON_AddItemToObject(info_json, "senderName", cJSON_CreateString(user_name_.c_str()));

	//这一步是把发送的信息显示到聊天内容会重复显示两次本机发出去的信息
	//OnChatMessage(root_json);

	char* request = cJSON_Print(root_json);
	cJSON_Delete(root_json);

	LogPrintf(request);
	if (websocket_ && request) {
		websocket_->sendMessage(std::make_shared<std::string>(request));
	}

	if (request) {
		cJSON_free(request);
		//清空输入框
		m_editMessage.SetWindowText(NULL);
	}

	//不需要改变按键状态
	//GetDlgItem(IDC_BTN_SEND)->EnableWindow(TRUE);
}

实现效果

About

No description, website, or topics provided.

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published