背景

本文使用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.Finalcn.hutoolhutool-all5.5.7maven-compiler-plugin1.81.8maven-assembly-plugin3.0.0com.luck.im.ServerStartjar-with-dependenciesmake-assemblypackagesingle

 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