Java使用WebSocket和WebRTC视频通话

新版的Chrome浏览器，加强了安全性，所以要使用https，同时也有很多修改，这个例子已经过时，不能使用。

可以参考新的文章：WebRTC续集

这两天终于是抽了时间把WebRTC搞定了，去年就想弄的，但是确实没时间，而且那时候JavaEE的WebSocket还没有规范，网上也都是用的Tomcat自己的WebSocket实现的，或者还使用了一些ajax辅助，JavaEE7中有了WebSocket的规范，Tomcat也支持，所以最近也是写了出来。

首先WebRTC，这个可以百度一下，大概就是一个音频和视频通讯技术，可以跨平台，只要能用浏览器的基本都可以使用，当然要你的浏览器支持。
但是这东西好像是有规范，但是各个浏览器实现方式有些不一样，我这里主要使用的是Chrome做的例子。

DEMO地址在：http://www.acgist.com/demo/video

如果很长时间没有加载出来，对不起，很可能是你上不了Google。

使用到的javascript都在页面上面都有，注释也差不多写了，我这里也不贴出来了。
还有就是引用了Google的js库channel.js，不过还是下载下来放到本地服务器吧，因为很多地方访问google.com很吃力啊。
最开始就是这个js没有加载完郁闷了很久，还一直以为是代码写错了。

进入页面的时候，注意初始化页面js中的一个参数：initiator：
如果是创建人这个参数设为false；
如果是加入的时候这个设置为true，这时候才会发起视频通话的请求。

这里我主要贴一下服务端的代码，其实服务端代码很简单，就是收到用户的请求，发送给另外一个用户就可以了，这里处理的其实是用户WebRTC的一些信息，并不是去传输视频，如下：

import java.io.IOException;
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("/acgist.video/{uid}")
public class AcgistVideo {

	// 最大通话数量
	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>());
	
	@OnOpen
	public void onOpen(Session session, @PathParam("uid")String uid) {
		session.setMaxIdleTimeout(MAX_TIME_OUT);
		sessions.put(uid, session);
	}

	@OnClose
	public void onClose(Session session, @PathParam("uid")String uid) {
		remove(session, uid);
	}

	@OnMessage
	public void onMessage(String message, Session session, @PathParam("uid")String uid) {
		try {
			if(uid != null && user_user.get(uid) != null && AcgistVideo.sessions.get(user_user.get(uid)) != null) {
				Session osession = sessions.get(user_user.get(uid)); // 被呼叫的session
				if(osession.isOpen()) {
					osession.getAsyncRemote().sendText(new String(message.getBytes("utf-8")));
				} else {
					this.nowaiting(osession);
				}
			} else {
				this.nowaiting(session);
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
	
	private void nowaiting(Session session) {
		session.getAsyncRemote().sendText("{\"type\" : \"nowaiting\"}");
	}

	// 判断是否可以继续创建
	public static boolean canCreate() {
		return sessions.size() <= MAX_COUNT;
	}

	// 是否可以进入房间
	public static boolean canJoin(String oid) {
		return !(oid != null && user_user.containsKey(oid) && user_user.get(oid) != null);
	}
	
	// 添加用户
	public static boolean addUser(String uid, String oid) {
		if(oid != null && !oid.isEmpty()) {
			AcgistVideo.user_user.put(uid, oid);
			AcgistVideo.user_user.put(oid, uid);
			return false;
		} else {
			AcgistVideo.user_user.put(uid, null);
			return true;
		}
	}

	// 删除用户
	private static void remove(Session session, String 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();
		}
	}

}

上面最主要的就是onMessage方法，其他很多都是一些辅助方法。

注意这个需要使用到JavaEE7的新内容，所以服务器请使用Tomcat8。

例子下载：http://pan.baidu.com/s/1mgFkXHe
参考文章：http://blog.csdn.net/leecho571/article/details/8146525
国外网站（功能比较多）：https://talky.io/

下面是截图（不要吐槽看不清楚啊，是上传那里压缩图片写的不好）：

WebRTC视频通话

注：有时候会断开连接，大概是STUN服务器连接不上吧。