red5(二) 防止盗链
public boolean appConnect(IConnection conn, Object[] params) { if (conn instanceof IServiceCapableConnection) { //调用客户端代码 IServiceCapableConnection sc = (IServiceCapableConnection) conn; sc.invoke("clientMethod", new Object[]{"One", 1},this); } return super.appConnect(conn, params); }
?其中的clientMethod是客户端方法名称，new Object[]{"One", 1}是任意参数，this为必选
并书写接收客户端返回参数的方法
public void resultReceived(IPendingServiceCall arg0) { String host = arg0.getResult().toString(); String allowHost = “http://localhost:28080/redxserver”; boolean allow = false; if(host.indexOf( allowHost)>0){ allow = true; } if(!allow ){//获取当前的链接IConnection current = Red5.getConnectionLocal();current.close(); System.out.println("关闭连接"); }else { System.out.println("不关闭连接"); }}?在播放器as内书写方法
var client1:Object=new Object();client1.clientMethod=this.clientMethod;_connection.client =client1;
?
private function clientMethod(str:String,num:Number):String{ var str:String = ExternalInterface.call("window.top.location.href"); return str;}还要修改BaseRTMPHandler.java中的方法，防止as方法出错了，仍然可以播放。
具体如下?
protected void handlePendingCallResult(RTMPConnection conn, Notify invoke) {final IServiceCall call = invoke.getCall();final IPendingServiceCall pendingCall = conn.retrievePendingCall(invoke.getInvokeId());if (pendingCall != null) {// The client sent a response to a previously made call.Object[] args = call.getArguments();if ((args != null) && (args.length > 0)) {// TODO: can a client return multiple results?pendingCall.setResult(args[0]);}Set<IPendingServiceCallback> callbacks = pendingCall.getCallbacks();if (!callbacks.isEmpty()) {HashSet<IPendingServiceCallback> tmp = new HashSet<IPendingServiceCallback>();tmp.addAll(callbacks);for (IPendingServiceCallback callback : tmp) {try {callback.resultReceived(pendingCall);} catch (Exception e) {log.error("Error while executing callback {} {}", callback, e);//关闭连接，添加下面两行即可conn.close();break;}}}}}?
?
通过以上方法即可实现防止盗链
已经优化了，请看下一篇文章 red5(三) 防止盗链
?