AI 助理
备案控制台
开发者社区 开发与运维 文章 正文

基于Kurento的WebRTC移动视频群聊技术方案

2018-05-23 3002
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介：

 说在前面的话：视频实时群聊天有三种架构：

       Mesh架构：终端之间互相连接，没有中心服务器，产生的问题，每个终端都要连接n-1个终端，每个终端的编码和网络压力都很大。群聊人数N不可能太大。

       Router架构：终端之间引入中心服务器，学名MCU(Multi Point Control Unit),每个终端的视频流都发布到MCU服务器上，然后服务器负责编码发布多视频流的工作，减轻客户端的压力。

       Mix架构：在Router架构基础上，多个视频流在服务器端被合为一个视频流，减轻网络压力。

       下面讲我们的选择，在MCU方面有licode、kurento等解决方案。kurento在视频群聊领域有专门的kurento Room解决方案，官方还提供一个kurento room server的样例实现。

       首先可以考虑不是一个Kurento Room Demo作为搭建方案原型的MCU组件。

       Room Demo的部署可见:http://doc-kurento-room.readthedocs.io/en/stable/demo_deployment.html

      其中碰到一些Maven编译问题：


Unable to initialise extensions Component descriptor role: 'com.jcraft.jsch.UIKeyboardInteractive', implementation: 'org.apache.maven.wagon.providers.ssh.jsch.interactive.PrompterUIKeyboardInteractive', role hint: 'default' has a hint, but there are other implementations that don't


      Maven的安装版本需要时3.0以上

      还有碰到找不到bower命令行问题。bower是node.js下面的一个包管理工具，安装node.js以后用npm安装即可

      最后按照部署指南网页中的命令启动服务器即可。

      Demo服务器有两部分，一部分是Demo Web服务器，二是把官方的kurento room server也集成到了这个demo中。不用再架设独立的kurento room server

      说说Android段的实施：再说一个公司：http://www.nubomedia.eu/，这家公司提供实时媒体通信开源云服务，核心组件可能是kurento media server，它的官网和kurento官网用一个模板，about里面显示两家组织有联系，kurento官方提供的Java Client因为底层API原因在Android上不肯用，这个nubomedia组织提供了一个kurento android client的实现，同时还提供了一个kurento room client的实现以及room使用案例：https://github.com/nubomedia-vtt/nubo-test,这家公司对其开发的开源方案管理非常及时，早晨提个接口的issue，下午已经commit了代码修改。

       这个案例虽然支持room沟通，但视频沟通是基于room发布订阅机制做的双人聊天。略改一下代码应该就可以实现多人聊天不过这家组织提供的两个client实现和官方的接口高度相似。主要改的是PeerVideoActivity这个类，下面我share一个基本走通多端通信的这个类的代码，供大家参考：


package fi.vtt.nubotest;  
  
import android.app.ListActivity;  
import android.content.SharedPreferences;  
import android.graphics.PixelFormat;  
import android.opengl.GLSurfaceView;  
import android.os.Bundle;  
import android.os.Handler;  
import android.util.Log;  
import android.view.Menu;  
import android.view.MenuItem;  
import android.view.View;  
import android.view.WindowManager;  
import android.widget.TextView;  
import android.widget.Toast;  
  
import org.webrtc.IceCandidate;  
import org.webrtc.MediaStream;  
import org.webrtc.PeerConnection;  
import org.webrtc.RendererCommon;  
import org.webrtc.SessionDescription;  
import org.webrtc.VideoRenderer;  
import org.webrtc.VideoRendererGui;  
  
import java.util.Map;  
  
import fi.vtt.nubomedia.kurentoroomclientandroid.RoomError;  
import fi.vtt.nubomedia.kurentoroomclientandroid.RoomListener;  
import fi.vtt.nubomedia.kurentoroomclientandroid.RoomNotification;  
import fi.vtt.nubomedia.kurentoroomclientandroid.RoomResponse;  
import fi.vtt.nubomedia.webrtcpeerandroid.NBMMediaConfiguration;  
import fi.vtt.nubomedia.webrtcpeerandroid.NBMPeerConnection;  
import fi.vtt.nubomedia.webrtcpeerandroid.NBMWebRTCPeer;  
  
import fi.vtt.nubotest.util.Constants;  
  
/** 
 * Activity for receiving the video stream of a peer 
 * (based on PeerVideoActivity of Pubnub's video chat tutorial example. 
 */  
public class PeerVideoActivity extends ListActivity implements NBMWebRTCPeer.Observer, RoomListener {  
    private static final String TAG = "PeerVideoActivity";  
  
    private NBMMediaConfiguration peerConnectionParameters;  
    private NBMWebRTCPeer nbmWebRTCPeer;  
  
    private SessionDescription localSdp;  
    private SessionDescription remoteSdp;  
    private String PaticipantID;  
  
    private VideoRenderer.Callbacks localRender;  
    private VideoRenderer.Callbacks remoteRender;  
    private GLSurfaceView videoView;  
  
    private SharedPreferences mSharedPreferences;  
  
    private int publishVideoRequestId;  
    private int sendIceCandidateRequestId;  
  
    private TextView mCallStatus;  
  
    private String  username, calluser;  
    private boolean backPressed = false;  
    private Thread  backPressedThread = null;  
  
    private static final int LOCAL_X_CONNECTED = 72;  
    private static final int LOCAL_Y_CONNECTED = 72;  
    private static final int LOCAL_WIDTH_CONNECTED = 25;  
    private static final int LOCAL_HEIGHT_CONNECTED = 25;  
    // Remote video screen position  
    private static final int REMOTE_X = 0;  
    private static  int REMOTE_Y = 0;  
    private static final int REMOTE_WIDTH = 25;  
    private static final int REMOTE_HEIGHT = 25;  
  
    private Handler mHandler;  
    private CallState callState;  
  
    private enum CallState{  
        IDLE, PUBLISHING, PUBLISHED, WAITING_REMOTE_USER, RECEIVING_REMOTE_USER,PATICIPANT_JOINED,RECEIVING_PATICIPANT,  
    }  
  
    @Override  
    public void onCreate(Bundle savedInstanceState) {  
        super.onCreate(savedInstanceState);  
        callState = CallState.IDLE;  
  
        setContentView(R.layout.activity_video_chat);  
        getWindow().addFlags(WindowManager.LayoutParams.FLAG_KEEP_SCREEN_ON);  
        mHandler = new Handler();  
        Bundle extras = getIntent().getExtras();  
        if (extras == null || !extras.containsKey(Constants.USER_NAME)) {  
            ;  
            Toast.makeText(this, "Need to pass username to PeerVideoActivity in intent extras (Constants.USER_NAME).",  
                    Toast.LENGTH_SHORT).show();  
            finish();  
            return;  
        }  
        this.username      = extras.getString(Constants.USER_NAME, "");  
        Log.i(TAG, "username: " + username);  
  
        if (extras.containsKey(Constants.CALL_USER)) {  
            this.calluser      = extras.getString(Constants.CALL_USER, "");  
            Log.i(TAG, "callUser: " + calluser);  
        }  
  
        this.mCallStatus   = (TextView) findViewById(R.id.call_status);  
        TextView prompt   = (TextView) findViewById(R.id.receive_prompt);  
        prompt.setText("Receive from " + calluser);  
  
        this.videoView = (GLSurfaceView) findViewById(R.id.gl_surface);  
        // Set up the List View for chatting  
        RendererCommon.ScalingType scalingType = RendererCommon.ScalingType.SCALE_ASPECT_FILL;  
        VideoRendererGui.setView(videoView, null);  
  
  
        localRender = VideoRendererGui.create(  LOCAL_X_CONNECTED, LOCAL_Y_CONNECTED,  
                LOCAL_WIDTH_CONNECTED, LOCAL_HEIGHT_CONNECTED,  
                scalingType, true);  
        NBMMediaConfiguration.NBMVideoFormat receiverVideoFormat = new NBMMediaConfiguration.NBMVideoFormat(352, 288, PixelFormat.RGB_888, 20);  
        peerConnectionParameters = new NBMMediaConfiguration(   NBMMediaConfiguration.NBMRendererType.OPENGLES,  
                NBMMediaConfiguration.NBMAudioCodec.OPUS, 0,  
                NBMMediaConfiguration.NBMVideoCodec.VP8, 0,  
                receiverVideoFormat,  
                NBMMediaConfiguration.NBMCameraPosition.FRONT);  
        nbmWebRTCPeer = new NBMWebRTCPeer(peerConnectionParameters, this, localRender, this);  
        nbmWebRTCPeer.initialize();  
        Log.i(TAG, "PeerVideoActivity initialized");  
        mHandler.postDelayed(publishDelayed, 4000);  
  
        MainActivity.getKurentoRoomAPIInstance().addObserver(this);  
  
  
  
        callState = CallState.PUBLISHING;  
        mCallStatus.setText("Publishing...");  
  
    }  
  
    private Runnable publishDelayed = new Runnable() {  
        @Override  
        public void run() {  
            nbmWebRTCPeer.generateOffer("derp", true);  
        }  
    };  
  
    @Override  
    public boolean onCreateOptionsMenu(Menu menu) {  
        // Inflate the menu; this adds items to the action bar if it is present.  
        getMenuInflater().inflate(R.menu.menu_video_chat, menu);  
        return true;  
    }  
  
    @Override  
    public boolean onOptionsItemSelected(MenuItem item) {  
        // Handle action bar item clicks here. The action bar will  
        // automatically handle clicks on the Home/Up button, so long  
        // as you specify a parent activity in AndroidManifest.xml.  
        int id = item.getItemId();  
  
        //noinspection SimplifiableIfStatement  
        if (id == R.id.action_settings) {  
            return true;  
        }  
  
        return super.onOptionsItemSelected(item);  
    }  
  
    @Override  
    protected void onStart() {  
        super.onStart();  
  
    }  
  
    @Override  
    protected void onPause() {  
        nbmWebRTCPeer.stopLocalMedia();  
        super.onPause();  
    }  
  
    @Override  
    protected void onResume() {  
        super.onResume();  
        nbmWebRTCPeer.startLocalMedia();  
    }  
  
    @Override  
    protected void onStop() {  
        endCall();  
        super.onStop();  
    }  
  
    @Override  
    protected void onDestroy() {  
        super.onDestroy();  
    }  
  
    @Override  
    public void onBackPressed() {  
        // If back button has not been pressed in a while then trigger thread and toast notification  
        if (!this.backPressed){  
            this.backPressed = true;  
            Toast.makeText(this,"Press back again to end.",Toast.LENGTH_SHORT).show();  
            this.backPressedThread = new Thread(new Runnable() {  
                @Override  
                public void run() {  
                    try {  
                        Thread.sleep(5000);  
                        backPressed = false;  
                    } catch (InterruptedException e){ Log.d("VCA-oBP","Successfully interrupted"); }  
                }  
            });  
            this.backPressedThread.start();  
        }  
        // If button pressed the second time then call super back pressed  
        // (eventually calls onDestroy)  
        else {  
            if (this.backPressedThread != null)  
                this.backPressedThread.interrupt();  
            super.onBackPressed();  
        }  
    }  
  
    public void hangup(View view) {  
        finish();  
    }  
  
    public void receiveFromRemote(View view){  
        Log.e(TAG,"--->receiveFromRemote");  
        if (callState == CallState.PUBLISHED){  
            callState = CallState.WAITING_REMOTE_USER;  
            nbmWebRTCPeer.generateOffer("remote", false);  
            runOnUiThread(new Runnable() {  
                @Override  
                public void run() {  
                    mCallStatus.setText("Waiting remote stream...");  
                }  
            });  
        }  
    }  
  
    /** 
     * Terminates the current call and ends activity 
     */  
    private void endCall() {  
        callState = CallState.IDLE;  
        try  
        {  
            if (nbmWebRTCPeer != null) {  
                nbmWebRTCPeer.close();  
                nbmWebRTCPeer = null;  
            }  
        }  
        catch (Exception e){e.printStackTrace();}  
    }  
  
    @Override  
    public void onLocalSdpOfferGenerated(final SessionDescription sessionDescription, NBMPeerConnection nbmPeerConnection) {  
        Log.e(TAG,"--->onLocalSdpOfferGenerated");  
        if (callState == CallState.PUBLISHING || callState == CallState.PUBLISHED) {  
            localSdp = sessionDescription;  
            Log.e(TAG,"--->onLocalSdpOfferGenerated:publish");  
            runOnUiThread(new Runnable() {  
                @Override  
                public void run() {  
                    if (MainActivity.getKurentoRoomAPIInstance() != null) {  
                        Log.d(TAG, "Sending " + sessionDescription.type);  
                        publishVideoRequestId = ++Constants.id;  
  
//                    String sender = calluser + "_webcam";  
//                    MainActivity.getKurentoRoomAPIInstance().sendReceiveVideoFrom(sender, localSdp.description, publishVideoRequestId);  
  
                        MainActivity.getKurentoRoomAPIInstance().sendPublishVideo(localSdp.description, false, publishVideoRequestId);  
                    }  
                }  
            });  
        } else { // Asking for remote user video  
            Log.e(TAG,"--->onLocalSdpOfferGenerated:remote");  
            remoteSdp = sessionDescription;  
//            nbmWebRTCPeer.selectCameraPosition(NBMMediaConfiguration.NBMCameraPosition.BACK);  
            runOnUiThread(new Runnable() {  
                @Override  
                public void run() {  
                    if (MainActivity.getKurentoRoomAPIInstance() != null) {  
                        Log.e(TAG, "Sending--> " +calluser+ sessionDescription.type);  
                        publishVideoRequestId = ++Constants.id;  
  
                        String sender = calluser + "_webcam";  
                        MainActivity.getKurentoRoomAPIInstance().sendReceiveVideoFrom(sender, remoteSdp.description, publishVideoRequestId);  
                    }  
                }  
            });  
        }  
    }  
  
    @Override  
    public void onLocalSdpAnswerGenerated(SessionDescription sessionDescription, NBMPeerConnection nbmPeerConnection) {  
    }  
  
    @Override  
    public void onIceCandidate(IceCandidate iceCandidate, NBMPeerConnection nbmPeerConnection) {  
        Log.e(TAG,"--->onIceCandidate");  
        sendIceCandidateRequestId = ++Constants.id;  
        if (callState == CallState.PUBLISHING || callState == CallState.PUBLISHED){  
            Log.e(TAG,"--->onIceCandidate:publish");  
            MainActivity.getKurentoRoomAPIInstance().sendOnIceCandidate(this.username, iceCandidate.sdp,  
                    iceCandidate.sdpMid, Integer.toString(iceCandidate.sdpMLineIndex), sendIceCandidateRequestId);  
        } else{  
            Log.e(TAG,"--->onIceCandidate:"+this.calluser);  
            MainActivity.getKurentoRoomAPIInstance().sendOnIceCandidate(this.calluser, iceCandidate.sdp,  
                    iceCandidate.sdpMid, Integer.toString(iceCandidate.sdpMLineIndex), sendIceCandidateRequestId);  
        }  
    }  
  
    @Override  
    public void onIceStatusChanged(PeerConnection.IceConnectionState iceConnectionState, NBMPeerConnection nbmPeerConnection) {  
        Log.i(TAG, "onIceStatusChanged");  
    }  
  
    @Override  
    public void onRemoteStreamAdded(MediaStream mediaStream, NBMPeerConnection nbmPeerConnection) {  
        if (callState == CallState.PUBLISHING || callState == CallState.PUBLISHED) {  
            Log.e(TAG, "-->onRemoteStreamAdded-->no");  
            return;  
  
  
        }  
        Log.e(TAG, "-->onRemoteStreamAdded");  
        RendererCommon.ScalingType scalingType = RendererCommon.ScalingType.SCALE_ASPECT_FILL;  
        remoteRender = VideoRendererGui.create( REMOTE_X, REMOTE_Y,  
                REMOTE_WIDTH, REMOTE_HEIGHT,  
                scalingType, false);  
        REMOTE_Y = REMOTE_Y+25;  
        nbmWebRTCPeer.attachRendererToRemoteStream(remoteRender, mediaStream);  
        runOnUiThread(new Runnable() {  
            @Override  
            public void run() {  
                mCallStatus.setText("");  
            }  
        });  
    }  
  
    @Override  
    public void onRemoteStreamRemoved(MediaStream mediaStream, NBMPeerConnection nbmPeerConnection) {  
        Log.i(TAG, "onRemoteStreamRemoved");  
    }  
  
    @Override  
    public void onPeerConnectionError(String s) {  
        Log.e(TAG, "onPeerConnectionError:" + s);  
    }  
  
    @Override  
    public void onRoomResponse(RoomResponse response) {  
        Log.e(TAG, "-->OnRoomResponse:" + response);  
        if (Integer.valueOf(response.getId()) == publishVideoRequestId){  
            SessionDescription sd = new SessionDescription(SessionDescription.Type.ANSWER,  
                    response.getValue("sdpAnswer").get(0));  
            if (callState == CallState.PUBLISHING){  
                callState = CallState.PUBLISHED;  
                nbmWebRTCPeer.processAnswer(sd, "derp");  
            } else if (callState == CallState.WAITING_REMOTE_USER){  
                callState = CallState.RECEIVING_REMOTE_USER;  
                nbmWebRTCPeer.processAnswer(sd, "remote");  
            } else if (callState == CallState.PATICIPANT_JOINED){  
  
                callState = CallState.RECEIVING_PATICIPANT;  
                nbmWebRTCPeer.processAnswer(sd, this.PaticipantID);  
                //NOP  
            }  
        }  
    }  
  
    @Override  
    public void onRoomError(RoomError error) {  
        Log.e(TAG, "OnRoomError:" + error);  
    }  
  
    @Override  
    public void onRoomNotification(RoomNotification notification) {  
        Log.e(TAG, "OnRoomNotification--> (state=" + callState.toString() + "):" + notification);  
  
        if(notification.getMethod().equals("iceCandidate")) {  
            Map<String, Object> map = notification.getParams();  
  
            String sdpMid = map.get("sdpMid").toString();  
            int sdpMLineIndex = Integer.valueOf(map.get("sdpMLineIndex").toString());  
            String sdp = map.get("candidate").toString();  
  
            IceCandidate ic = new IceCandidate(sdpMid, sdpMLineIndex, sdp);  
            Log.e(TAG, "callState-->" + callState);  
            if (callState == CallState.PUBLISHING || callState == CallState.PUBLISHED) {  
                nbmWebRTCPeer.addRemoteIceCandidate(ic, "derp");  
            }else if(callState==CallState.PATICIPANT_JOINED ||  callState== CallState.RECEIVING_PATICIPANT){  
                nbmWebRTCPeer.addRemoteIceCandidate(ic,this.PaticipantID);  
            }else {  
                nbmWebRTCPeer.addRemoteIceCandidate(ic, "remote");  
            }  
        }  
        if(notification.getMethod().equals("participantPublished"))  
        {  
            Map<String, Object> map = notification.getParams();  
            final String user = map.get("id").toString();  
            this.calluser = user;  
            this.PaticipantID = "pt_"+this.calluser;  
  
            PeerVideoActivity.this.runOnUiThread(new Runnable() {  
                @Override  
                public void run() {  
                    callState = CallState.PATICIPANT_JOINED;  
                    nbmWebRTCPeer.generateOffer(PaticipantID, false);  
  
                }  
            });  
        }  
    }  
  
    @Override  
    public void onRoomConnected() {  
  
    }  
  
    @Override  
    public void onRoomDisconnected() {  
  
    }  
}


      再就是android room demo中的MainActivity的添加cert的代码要去掉注释，让这段代码生效，就可以连通服务器了。

       在iOS的实施方面，上面这家公司也提供了一个工具包：https://github.com/nubomediaTI/Kurento-iOS ，工具包里面也有demo

       Web方面，最上面官方的哪个demo就足够参考了

       后记：很荣幸这篇博客获得了很多CSDN程序员的关注和询问，这只能证明我很荣幸有机会在去年的那个时间点(16年7月)在大家之前处理了一个后续大家都很关注的技术问题，而处理这个问题主要用到的服务器端room server项目和android端nubo test项目，官方在后续好像都做了一定的升级，反而是我自己搞完这个之后，因为产品设计的原因，后来再没有深入地去生产实施这个东西，甚至开发笔记本关于这个项目的源码项目好像都已经删除了，对于大家提出的问题，早期的我还能答一答，后面的我估计你们用到的源码和我用到的源码估计都不是一个版本了，再就是里面的代码细节也基本忘得差不多，在这儿我建议后续开发这个功能可以去深入阅读分析Kurento官方(https://github.com/Kurento）和欧洲媒体服务云服务商nubomedia官方（https://github.com/nubomedia-vtt）的代码示例和文档。我面给出的代码样例是基于nubomedia一对一视聊样例改的，官方原始代码样例在这段时间内都有了变更。在掌握大的基本WebRTC通信的原理的前提下，我觉得改新的代码估计也不会太难

       这个文章原发于CSDN，今天转过来试试云栖的博客系统，不过这个文章的确是我本人写的。


文章标签：
Android开发
Web App开发
Java
JavaScript
iOS开发
Maven
程序员
API
dengel
目录
相关文章
音视频牛哥
|
Web App开发 编解码 安全
音视频绕不开的话题之WebRTC
闲来无事，我们今天探讨下音视频绕不开的一个话题：WebRTC。WebRTC之于音视频行业，无异于FFMpeg，可以说WebRTC的开源，让音视频行业大跨步进入发展快车道。
音视频牛哥
188 0
游客3eenxn3lyh7ye
|
缓存 NoSQL 前端开发
浅析开发体育赛事直播系统的设计与实现
东莞梦幻网络科技的“体育赛事直播源码”主要是用于搭建类似于雷速体育和斗球体育等平台，该系统的出现能帮助快速搭建平台和降低开发成本。
游客3eenxn3lyh7ye
201 0
jsjsjjs
|
监控 网络协议 安全
即时通讯技即时通讯技术文集（第8期）：移动端弱网优化系列 [共14篇]
为了更好地分类阅读52im.net 总计1000多篇精编文章，我将在每周三推送新的一期技术文集，本次是第8 期。
jsjsjjs
193 0
即时通讯技即时通讯技术文集（第8期）：移动端弱网优化系列 [共14篇]
云豹kj的晨曦
|
消息中间件 运维 数据库
语音直播app开发，关于分布式系统的探索
语音直播app开发，关于分布式系统的探索
云豹kj的晨曦
133 0
lygcorey
|
缓存 API 网络安全
APICloud平台使用融云模块实现音视频通话实践经验总结分享
APICloud平台使用融云模块实现音视频通话实践经验总结分享
lygcorey
254 0
APICloud平台使用融云模块实现音视频通话实践经验总结分享
后端老鸟
|
Web App开发 编解码 JavaScript
互动直播之WebRTC服务开源技术选型
介绍了直播的基础知识，对比几种传输标得出WebRTC的优势，常见的WebRTC架构及开源方案。
后端老鸟
4338 0
互动直播之WebRTC服务开源技术选型
李瑞利9527
|
Web App开发 编解码 边缘计算
基于WebRTC的互动直播实践
互动直播已经逐渐成为直播的主要形式。映客直播资深音视频工程师叶峰峰在LiveVideoStackCon 2018大会的演讲中详细介绍了INKE自研连麦整体设计思路、如何基于WebRTC搭建互动直播SDK以及针对用户体验进行优化。本文由LiveVideoStack整理而成。
李瑞利9527
870 0
基于WebRTC的互动直播实践
yunbao111
直播平台搭建，系统开发和音视频技术方面该如何进行
面对直播平台搭建的热潮，入场者更多的是盲目的跟风入场，并没有做到对直播平台的初步了解就匆匆加入，这也导致了很多运营商在功能、平台搭建方面的要求显得有些无厘头。
yunbao111
477 0
直播平台搭建，系统开发和音视频技术方面该如何进行
云豹短视频嘉兴
|
Web App开发 编解码 负载均衡
一对一语音直播系统源码如何解决音视频直播技术难点
直播作为实时性和互动性要求较高的音视频应用场景，存在非常多的技术难点，就连一对一的直播模式也毫不例外。比如低延迟、流畅性、回声消除、国内外互通和海量并发等问题，都是开发过程中的难点。但是，在开发过程中如果具备了优质的一对一语音直播系统源码，那么这些难点可能都会得到一定的解决。
云豹短视频嘉兴
419 0
一对一语音直播系统源码如何解决音视频直播技术难点
千言万语乐此不疲
|
Web App开发 边缘计算 缓存
打造“零距离”互动直播间，低延时流媒体技术实践
如何提升直播过程中三个要素之间的互动，让主播与主播之间、主播与粉丝之间达到一致 的用户体验？优酷直播流媒体团队做了低延时流媒体技术的探索实践，实现了在用户体验不下 降的基础上，让主播与主播延时&lt;300ms,主播与粉丝延时&lt;600ms，解决了直播间各类互动问题。
千言万语乐此不疲
1196 0
打造“零距离”互动直播间，低延时流媒体技术实践

热门文章

最新文章

  • 1
    QSqlDatabase: QMYSQL driver not loaded 解决方案
  • 2
    这 12 个基于 AI 的 VSCode “杀手级” 生产力插件，了解一下？（一）
  • 3
    关于规则引擎的选型和疑惑思考
  • 4
    面试必问的4种单点登录的实现方式，你知道几个？
  • 5
    揭秘2017双11背后的网络－双11的网络产品和技术概览
  • 6
    我的NVIDIA开发者之旅——作为一名初学者，我是如何开启 NVIDIA Jetson Nano 开发的
  • 7
    FluentData-新型轻量级ORM 利用T4模板 批量生成多文件 实体和业务逻辑 代码
  • 8
    Hadoop-No.10之列簇
  • 9
    HDU 1213 How Many Tables
  • 10
    GitHub push文件失败时
  • 1
    js+jquery实现贪吃蛇经典小游戏
    29
  • 2
    ROS2：从初识到深入，探索机器人操作系统的进化之路
    31
  • 3
    《精准掌控时间：C++ 人工智能开发中的运行时间监测之道》
    26
  • 4
    《解锁 C++数据读写秘籍：赋能人工智能训练》
    28
  • 5
    git 常用命令
    108
  • 6
    学习Git的最佳实践有哪些？
    33
  • 7
    通义灵码开发者社区的重要性 —— 知识共享与学习
    33
  • 8
    Git 学习----基本概念
    28
  • 9
    java小工具util系列4：基础工具代码(Msg、PageResult、Response、常量、枚举)
    33
  • 10
    dllhost.exe进程占用CPU很高怎么解决?
    27

    • 相关课程

    更多
  • 开放语聊技术与应用
  • 大咖带你聊物联网
  • HaaS物联网云端一体低代码开发课程
  • 阿里小蜜中的机器阅读技术
  • 大数据分析之企业级网站流量运营分析系统开发实战（第四阶段）
  • 阿里巴巴智能语音交互技术与应用

    • 相关电子书

    更多
  • 海量消息的直播互动系统演进历程
  • ReactNative在京东无线端的实践
  • 直面音视频质量评估之痛——走进腾讯音视频质量体系

    • 相关实验场景

    更多
  • 【涂鸦即艺术】基于云应用开发平台CAP部署AI实时生图绘板
  • SAE 极速部署专属 AI 证件照神器
  • 奥运时刻！零代码生成奥运风格AI写真。
  • 阿里云IoT小程序应用开发和组件实践
  • 手把手教你用IoT设备监控家庭环境数据
  • 专属钉底座交付培训课程
    • 下一篇
    无影云桌面