资源简介
基于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
相关资源
- java使用udp协议和硬件进行数据收发处
- 行为模式 Java实现 IDEA工程
- 基于Jsp+JavaBean的网上购书系统
- 石油大学java在线考试题
- java写的聊天室项目
- 数据结构-串的模式匹配算法Java实现
- 数据结构-二叉树Java实现
- java工信部考试题库
- java五子棋游戏(源码)
- trident-7.0.jar
- 一个java新闻标题爬虫
- 课设职工工资管理系统
- Java开发的记事本完整版源代码
- java课程设计(人事管理系统)283197
- Java多线程赛马游戏Java源码
- java连接MySQL的个人通讯录
- 《Java语言程序设计》-期末考试试题及
- Java课程设计大作业FlappyBird
- 使用javase的图形化界面编写的聊天室
- 百度翻译API调用案例
- 架构探险-从零开始写Java Web框架-全书
- 医院分诊管理系统
- 中兴软创java面试题
- 2018校招-中兴软创java面试题
- 企业通讯录项目 基于SSM下的JAVA项目
- Android通过JavaWeb实现用户登录(一)
- 双线程JAVA小程序
- java 正则匹配所有 {},并取出所有符合
- JavaWeb项目实战和从入门到精通第三版
- 传智javaEE35期就业班全套视频.txt
评论
共有 条评论