webRTC多人视频会议室（修正）

基于webRTC和websocket简单实现多人视频会议功能,前端纯JS代码,后台JAVA代码,主要实现功能暂未考虑效率,测试4人视频会议延迟极低可控制在200毫秒內

package com.scbd.bdpl.controller.multimedia;

import java.io.IOException;
import java.util.Collection;
import java.util.HashMap;
import java.util.Map;
import java.util.Set;

import javax.websocket.OnClose;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.server.PathParam;
import javax.websocket.server.ServerEndpoint;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONobject;

/**
 * websocket服务
 * @author Ivan
 *
 */

@ServerEndpoint（“/websocket/{username}“）
public class SocketServer {
	private static Map userOnlineMap = new HashMap（）;

	//连接时
	@OnOpen
	public void open（Session session@PathParam（“username“）String username） {
		for （String onlineUsername : userOnlineMap.keySet（）） {
			if（onlineUsername.equals（username）） {//用户已存在
				System.out.println（“用户已存在或用户名重复“）;
				return;
			}
		}
		//转发给其他人上线消息
		JSONobject json=new JSONobject（）;
		json.put（“type“ “userConnection“）;
		json.put（“data“ username）;
		forwardMessageExceptMe（session json.toString（））;
		System.out.println（username + “open“）;
		userOnlineMap.put（usernamesession）;//添加用户进入在线列表
	}

	//收到消息
	@OnMessage
	public void OnMessage（String message Session session@PathParam（“username“）String username） {
		//获得消息并转为JSON
		JSONobject json=JSON.parseobject（message）;
		String type=（String） json.get（“type“）;
		
		//判断消息
		switch （type） {
		//查询在线用户
		case “getOnlineUserName“:
			replyOnlineUserName（session）;
			break;
		//转发消息给sendTo
		default:
			String sendBy=（String） json.get（“sendBy“）;
			String sendTo=（String） json.get（“sendTo“）;
			if（sendBy!=null&&sendTo!=null） {
				forwardMessage（userOnlineMap.get（sendTo） message）;
			}
			break;
		}

	}

	@OnClose
	public void close（Session session@PathParam（“username“）String username） {
		System.out.println（username + “close“）;
		try {
			userOnlineMap.remove（username session）;
			session.close（）;
			//转发给其他人下线消息
			JSONobject json=new JSONobject（）;
			json.put（“type“ “userClose“）;
			json.put（“data“ username）;
			forwardMessageExceptMe（session json.toString（））;
		} catch （IOException e） {
			//			e.printStackTrace（）;
		}
	}

	//回复在线用户
	private void replyOnlineUserName（Session session） {
		Set OnlineUserNames=userOnlineMap.keySet（）;
		JSONobject json=new JSONobject（）;
		json.put（“type“ “userOnlineList“）;
		json.put（“data“ OnlineUserNames）;
		forwardMessage（sessionjson.toString（））;
	}

	//转发消息特定目标
	private void forwardMessage（Session sessionString message） {
		try {
			session.getBasicRemote（）.sendText（message）;
		} catch （IOException e） {
			//			e.printStackTrace（）;
		}
	}
	//转发消息给所有人
	private void forwardMessage（Collection sessionsString message） {
			for （Session session : sessions） {
				forwardMessage（sessionmessage）;
			}
	}
	//转发消息给除自己以外的所有人
	private void forwardMessageExceptMe（Session sessionString message） {
		for （Session sessions : userOnlineMap.values（）） {
			if（!sessions.equals（session）

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----

     文件     535212  2018-08-06 16:45  webRTC多人视频会议室\fastjson-1.2.41.jar

     文件      84349  2018-09-12 17:25  webRTC多人视频会议室\jquery-2.1.4.min.js

     文件       3287  2018-10-29 16:05  webRTC多人视频会议室\SocketServer.java

     文件        856  2018-10-29 16:28  webRTC多人视频会议室\video.html

     文件       6322  2018-10-29 16:08  webRTC多人视频会议室\video.js

     文件        194  2018-11-12 16:22  webRTC多人视频会议室\说明.txt

     目录          0  2018-11-12 16:20  webRTC多人视频会议室

----------- ---------  ---------- -----  ----

               630220                    7