WEBRTC多人视频通话

package com.acgist.manyrtc; import java.util.Collections; import java.util.HashMap; import java.util.Map; 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; @ServerEndpoint("/manyrtcwebsoketdemo.video/{uid}") public class WebSoketRTCTest { // 最大通话数量 private static final int MAX_COUNT = 20; private static final long MAX_TIME_OUT = 2 * 60 * 1000; // 用户和用户的对话映射 private static final Map<String, String> user_user = Collections.synchronizedMap(new HashMap<String, String>()); // 用户和websocket的session映射 private static final Map<String, Session> sessions = Collections.synchronizedMap(new HashMap<String, Session>()); /** * 打开websocket * @param session websocket的session * @param uid 打开用户的UID */ @OnOpen public void onOpen(Session session, @PathParam("uid")String uid) { session.setMaxIdleTimeout(MAX_TIME_OUT); System.out.println("onOpen======uid===============" + uid); sessions.put(uid, session); user_user.put(uid, "true"); } /** * websocket关闭 * @param session 关闭的session * @param uid 关闭的用户标识 */ @OnClose public void onClose(Session session, @PathParam("uid")String uid) { remove(session, uid); } /** * 收到消息 * @param message 消息内容 * @param session 发送消息的session * @param uid */ @OnMessage public void onMessage(String message, Session session, @PathParam("uid")String uid) { try { System.out.println("onMessage=====uid===============" + uid); System.out.println("原始的message消息是：" + message); String reviciver = message.substring(message.indexOf("}")+ 1); message = message.substring(0, message.indexOf("}")+1); if(message.indexOf("{") != -1) { message = message.replace("{", "{\"userid\":\""+ uid +"\",");//只会替换第一个大括号,吧自己的id发送给对方 } Session osession = sessions.get(reviciver); System.out.println("osession.isOpen():==========" + osession.isOpen()); System.out.println("修改后的数据： 我是"+uid +"==========发送消息给" + reviciver + "=====消息内容是" + message); if(osession.isOpen()){ osession.getAsyncRemote().sendText(new String(message.getBytes("utf-8"))); }else{ System.out.println(" 我是"+uid +"==========发送消息给" + reviciver + "=====但是" + reviciver + " 不在！"); this.nowaiting(osession); } /*for (Map.Entry<String, String> entry : user_user.entrySet()) { System.out.println("key = " + entry.getKey() + " and value = " + entry.getValue()); othersid = entry.getKey(); //有别人，并且别人不等于自己（要排除掉自己给自己发送消息）， if(othersid != null && !uid.equals(othersid) && WebSoketRTCTest.sessions.get(othersid) != null) { System.out.println("修改后的数据： 我是"+uid +"==========发送消息给" + othersid + "=====消息内容是" + message); Session osession = sessions.get(othersid); // 被呼叫的session System.out.println("osession.isOpen():==========" + osession.isOpen()); if(osession.isOpen()){ osession.getAsyncRemote().sendText(new String(message.getBytes("utf-8"))); }else{ System.out.println(" 我是"+uid +"==========发送消息给" + othersid + "=====但是" + othersid + " 不在！"); this.nowaiting(osession); } } } */ } catch (Exception e) { e.printStackTrace(); } } /** * 没有人在等待 * @param session 发送消息的session */ private void nowaiting(Session session) { session.getAsyncRemote().sendText("{\"type\" : \"nowaiting\"}"); } /** * 是否可以继续创建通话房间 * @return 可以：true；不可以false； */ public static boolean canCreate() { return sessions.size() <= MAX_COUNT; } /** * 判断是否可以加入 * @param oid 被申请对话的ID * @return 如果能加入返回：true；否则返回false； */ public static boolean canJoin(String oid) { return !(oid != null && user_user.containsKey(oid) && user_user.get(oid) != null); } /** * 添加视频对象 * @param uid 申请对话的ID * @param oid 被申请对话的ID * @return 是否是创建者：如果没有申请对话ID为创建者，否则为为加入者。创建者返回：true；加入者返回：false； */ public static boolean addUser(String user) { WebSoketRTCTest.user_user.put(user, "true"); return true; } /** * 移除聊天用户 * @param session 移除的session * @param uid 移除的UID */ private static void remove(Session session, String uid) { System.out.println("我进来移除了其他的id ,并且关闭了session====uid ==" + uid); /*String oid = user_user.get(uid); if(oid != null) user_user.put(oid, null); // 设置对方无人聊天 sessions.remove(uid); // 异常session user_user.remove(uid); // 移除自己 try { if(session != null && session.isOpen()) session.close(); // 关闭session } catch (IOException e) { e.printStackTrace(); }*/ } }