下载地址：http://www.gxcode.top/code

项目说明

 springboot+webscoekt+webrtc
项目通过前端webrtc采集麦克风声音，通过websocket发送后台，然后处理成g711-alaw字节数据发生给广播UDP并播放。
后台处理项目使用线程池(5个线程)接受webrtc数据并处理g711-alaw字节数组放到Map容器中，在开一个线程实时获取Map容器中数据通过UDP发送。
项目采集采集麦克风数据稳定，个人已测试放心可用。

设置方法：

1、地址栏输入chrome://flags/, 搜索unsafely
2、enabled 并填入要授信的域名
3、按浏览器提示重启浏览器

使用说明：

1.WebRtcWSServer类onMessage接受webrtc.html采集客户数据-->>MyTask类下run()生成的,每一包数据存放D:\home\0 目录下

2.WebRtcWSServer类下把pcm存到一个文件中用于测试看采集的数据是否正确，D:\home\2 目录下
try {
    Path path = Paths.get(localUrl);
    byte[] fileBytes = Files.readAllBytes(path);
    FileWriteUt.byteWriteToPcm(fileBytes);
} catch (IOException e) {
    e.printStackTrace();
}

3.WebSocketUtilPro中获取每包pcm转gb711数据包，都存放到D:\home\2 目录下
public void run() {
    while(WebSocketUtilPro.mapBoolean.get("79")!=null && WebSocketUtilPro.mapBoolean.get("79")) {
        st = System.currentTimeMillis();
        if(mapBytes.get(drillDeviceId)!=null && mapBytes.get(drillDeviceId).size()>0){
            Map<Integer, Map<Long,byte[]>> sortMap = sortMapByKey(mapBytes.get(drillDeviceId));
            List<Integer> keysToRemove = new ArrayList<>();
            for (Integer key : sortMap.keySet()) {
                Map<Long,byte[]> bytes = sortMap.get(key);
                bytes = sortMapByKey1(bytes);
                for (Long aLong : bytes.keySet()) {
                    byte[] aByte = bytes.get(aLong);
                    //方式1：这里把录音文件保存本地 
                    FileWriteUt.byteWriteToG711(aByte); 
                    //方式; 2：把录音字节数据发送广播udp播放。
                }
                System.out.println(">>>>>>>>>>>>>第" + key +"包,数据发送完,耗时"+(System.currentTimeMillis()-st)+"ms" );
                keysToRemove.add(key);
            }
            // 删除需要删除的键
            for (Integer key : keysToRemove) { mapBytes.get(drillDeviceId).remove(key); }
        }
    }
}