欢迎访问我的GitHub
https://github.com/zq2599/blog_demos
内容：所有原创文章分类汇总及配套源码，涉及Java、Docker、Kubernetes、DevOPS等；
本篇概览本文是《Kurento实战》的第四篇，前面的文章中，咱们先部署KMS再启动官方demo，还把Kurento的重要概念都分类学习过，接下来要开始应用开发了；
本文的主要内容是分析官方的kurento-hello-world项目，了解Kurento应用开发的基本流程和知识点，本文使用的代码是官方发布的6.15.0版本，地址：https://github.com/Kurento/kurento-tutorial-java/archive/6.15.0.zip
阅读代码时，如果能从整体上将划分清楚功能模块，再有针对性的逐个攻破细节，将会更高效的学习和理解源码，接下来咱们就按照Kurento官方的标准套路去拆分并逐个攻破；
如何划分功能模块按照不同的职责划分，整个代码被拆分为三部分：
WebSocket相关：WebSocket相关的通用处理，例如连接建立、关闭、异常的回调，业务逻辑的分发等；
WebRTC信令相关：ICE、SDP相关的处理；
业务逻辑：如果说1和2代表的是WebRTC的通用处理，那么剩下的就是如何使用Kurento来实现业务需求了，这部分的主要内容是业务应用使用Kurento官方client和KMS交互，控制KMS为端侧提供服务，交互方式如下图：
按照上述方式将代码做好拆分，划定边界，不论是阅读官方demo还是自己开发应用，都能条理清晰的应对，接下来一起学习官方的hello-world源码，看看一个完整的Kurento应用是如何开发出来的
WebSocket相关最简单的逻辑应该是通用的WebSocket处理了，咱们先看这部分，复杂的稍后再说，Handler类中和WebSockert相关的逻辑如下：
继承自TextWebSocketHandler(只处理text类型的数据，对于二进制数据直接关闭会话)；
重写afterConnectionEstablished：WebSocket连接建立的回调，只打了一行日志；
重写handleTransportError：WebSocket发生异常时候的回调，仅关闭WebSocketSession；
重写afterConnectionClosed：不论WebSocket是正常关闭还是发生异常，此方法都会执行，逻辑也很简单，就是调用stop方法，这个方法是用来释放KMS资源的，有好几处都会调用，我们留到稍后和其他处理KMS的地方一起讲；
WebSockert部分最重要的代码是handleTextMessage方法，里面是收到前端数据时的处理逻辑：先把数据转为JsonObject对象，此对象的messageId字段有四种值，每一种id及其对应的处理方法如下表格所示：
messageId 处理方法 说明PROCESS_SDP_OFFER handleProcessSdpOffer 收到前端SDPOffer数据后的处理逻辑
ADD_ICE_CANDIDATE handleAddIceCandidate 收到前端ICE数据后的处理逻辑
STOP handleStop HashMap删除用户数据，再远程调用MediaPipeline.release
ERROR handleError HashMap删除用户数据，再远程调用MediaPipeline.release
并不是所有的应用都需要重写上诉全部代码，还是以实际需求出发决定是否要重写，以kurento-one2one-call项目为例，只重写了handleTextMessage和afterConnectionClosed，其他的使用父类的即可，如下图：
7. 还有一个发送消息到浏览器侧的sendMessage方法，以及发送错误信息的sendError方法； 信令相关
kurento-hello-world应用的功能是和KMS实现实时音视频通信，因此WebRTC标准的信令处理是必不可少的，可惜Kurento官方并没有对信令处理做太多封装（也可能是信令和不同的业务处理逻辑都不一样，导致不好抽象），结果就是一堆信令处理的代码散落在业务代码中；
就算业务和信令的处理代码同时出现在Handler类中，只要熟悉WebRTC的信令处理流程，也很容易读懂代码，下图结合了WebRTC标准的信令处理流程，对前端和服务端的代码串联在一起就行分析，左边是浏览器上执行的js代码，右边是服务端，这些代码都用红色箭头标识了处于WebRTC信令处理流程的具体位置，至此，整个流程都清晰的展现出来：