背景

本文使用webtrc实现了一个简单的语音视频聊天室、支持多人音视频聊天、屏幕共享。

环境配置

音视频功能需要在有Https协议的域名下才能获取到设备信息，

测试环境搭建Https服务参考Windows下Nginx配置SSL实现Https访问（包含openssl证书生成）_殷长庆的博客-CSDN博客

正式环境可以申请一个免费的证书

复杂网络环境下需要自己搭建turnserver，网络上搜索大多是使用coturn来搭建turn服务

turn默认监听端口3478，可以使用webrtc.github.io测试服务是否可用

本文在局域网内测试，不必要部署turn，使用的谷歌的stun:stun.l.google.com:19302

webrtc参考文章

WebRTC技术简介 – 知乎 (zhihu.com)

实现

服务端

服务端使用netty构建一个websocket服务，用来完成为音视频传递ICE信息等工作。

maven配置

4.0.0com.luck.cccc-im1.0-SNAPSHOTcc-imhttp://maven.apache.org${env.JAVA_HOME}UTF-81.8io.nettynetty-all4.1.74.Final                    cn.hutool            hutool-all            5.5.7        maven-compiler-plugin1.81.8                    maven-assembly-plugin            3.0.0                                                                        com.luck.im.ServerStart                                                                        jar-with-dependencies                                                                            make-assembly                    package                                            single                                                        

JAVA代码

聊天室服务

package com.luck.im;import java.util.List;import io.netty.bootstrap.ServerBootstrap;import io.netty.channel.ChannelFuture;import io.netty.channel.ChannelHandlerContext;import io.netty.channel.ChannelInitializer;import io.netty.channel.ChannelPipeline;import io.netty.channel.EventLoopGroup;import io.netty.channel.nio.NioEventLoopGroup;import io.netty.channel.socket.SocketChannel;import io.netty.channel.socket.nio.NioServerSocketChannel;import io.netty.handler.codec.MessageToMessageCodec;import io.netty.handler.codec.http.HttpServerCodec;import io.netty.handler.codec.http.websocketx.TextWebSocketFrame;import io.netty.handler.codec.http.websocketx.WebSocketServerProtocolHandler;public class ChatSocket {private static EventLoopGroup bossGroup = new NioEventLoopGroup();private static EventLoopGroup workerGroup = new NioEventLoopGroup();private static ChannelFuture channelFuture;/** * 启动服务代理 *  * @throws Exception */public static void startServer() throws Exception {try {ServerBootstrap b = new ServerBootstrap();b.group(bossGroup, workerGroup).channel(NioServerSocketChannel.class).childHandler(new ChannelInitializer() {@Overridepublic void initChannel(SocketChannel ch) throws Exception {ChannelPipeline pipeline = ch.pipeline();pipeline.addLast(new HttpServerCodec());pipeline.addLast(new WebSocketServerProtocolHandler("/myim", null, true, Integer.MAX_VALUE, false));pipeline.addLast(new MessageToMessageCodec() {@Overrideprotected void decode(ChannelHandlerContext ctx, TextWebSocketFrame frame,List