打印

[编程] Flash P2P 通信技巧 (AS-Java-AS)

众所周知Flash的功能比较强大,但是有两个功能到目前为止始终无法实现
1是swf的点对点连接
2是swf读写操作文件
别想了,靠Flash本身是不可能的,虽然有传说中的MMSave();等一些隐藏函数,但是毕竟这些未公开的函数了解的人并不多,用起来也不方便。
那么究竟有没有其他办法可以扶助实现呢?答案当然是肯定的。在这里我们需要请出当前最热的两门名副其实的编程语言C++/Java,靠他们来实现你要实现的功能吧。
在这里我用Java举例。

首先我们必须了解 AS如何让Java做事?对于双方来讲唯一应用性最高的途径就是Socket了。
AS1->XMLSocket->send()->Java.Socket->InputStream
AS2->XMLSocket->send()->Java.Socket->InputStream
AS3->Socket->writh()->flush()->Java.Socket->InputStream
as1&2只支持以字符串形式发送socket,而as3支持真正意义上的流,在这里为了兼容和教学简单,我均以字符串形式来实现相互间的通信。



1->AS与Java最基本的通信

1.1 简单Java服务器
首先我们来做最简单的单线程Java服务器
复制内容到剪贴板
代码:
import java.io.*;
import java.net.*;
public class Server extends ServerSocket{
    //服务端口号常量(as要求必须大于1024,小于65535)
    private static final int SERVER_PORT = 10086;
    //申明流的空间
    private Socket client;
    private BufferedReader in;
    private PrintWriter out;
    private String src;
    //构造函数
    public Server() throws IOException{
        super(SERVER_PORT);
        //监听连接,初始流在进来后读取前,和写入后发送前所存放的空间
        Socket socket = accept();
        in = new BufferedReader(new InputStreamReader(client.getInputStream()));
        out = new PrintWriter(client.getOutputStream(),true);
        //循环等待读取信息
        while(true){
            //读取行信息,注意是以换行符结束的
            src = in.readLine();
            //如果发送"close",就跳出循环(断开连接)
            if(src.equals("close")){
                break;
            }
            //在收到的信息前加是标识并发回(注意结尾加"\0",这是as的XMLSocket读入每条信息的条件.as3的Socket不需要)
            out.println("rev: "+src+"\0");
            //以上out.println("xx")相当于out.write("xx");out.flush();的执行效果
            System.out.println("msg is "+src)
        }
        //关闭连接
        close();
    }
        
    //入口函数...
    public static void main (String[] args) throws IOException{
        new Server();    
    }
}
这样一个Java的服务器就建好了,Java是同步的事件的驱动是等待的,这个AS是不同的,所以方法对与as区别还是比较大的,具体功能已经注释的非常清楚。至于具体Java的特性我不是专业的,为了对读者负责我就不做详细介绍了,有兴趣的朋友可以查阅Java相关书籍。
接下来呢就是AS的访问了:



1.2 AS1 与 Java 通信
Action Script 1
复制内容到剪贴板
代码:
var SERVER_PORT = 10086;
var SERVER_IP = "127.0.0.1";
var conn = new XMLSocket();
conn.connect(SERVER_IP,SERVER_PORT);
conn.onConnect = socketConnect;
conn.onData = socketData;
function socketConnect(success){
    trace("connect"+success);
    if(success){
        this.send("hello world\r");
    }
}
function socketData(src){
    trace(src);
}
接触了相对生疏的Java后现在回到AS,感觉就是爽,嘿嘿
前三行定义了三个变量,由于as1没有强制类型,所以千万别加上类型修饰符啊,反而会出错,请注意。
conn.connect(SERVER_IP,SERVER_PORT);连接到socket的服务器。
如果连接成功 Java中的 ServerSocket.accept();会返回一个对象,并向下执行。
as的连接成功呢则触发了socketConnect(success)的事件,并且把true的参数传如函数。当然连不到就是false了。
成功后就会发送一个"hello world\r"的字符串,"\r"是回车符,因为Java里我用的是readLine();所以需要看到行的结束。
当有数据进来的时候呢就会出发socketData函数了,这里把信息输出。
好了用as1的朋友到此已经成功与Java程序通讯了。



1.3 AS2 与 Java 通信
Action Script 2
复制内容到剪贴板
代码:
var SERVER_PORT:Number = 10086;
var SERVER_IP:String = "127.0.0.1";
var conn:XMLSocket = new XMLSocket();
conn.connect(SERVER_IP,SERVER_PORT);
conn.onConnect = socketConnect;
conn.onData = socketData;
function socketConnect(success:Boolean){
    trace("connect"+success);
    if(success){
        this.send("hello world\r");
    }
}
function socketData(src:String){
    trace(src);
}
以上是fla版,和as1唯一的区别就是有类型定义,这样做无论是时间执行效率还是空间执行效率都会有明显提高。
接下去看看真正的Action Script 2代码,将以下代码保存成Socket.as文件,和fla文件放在一起。
复制内容到剪贴板
代码:
class Socket extends XMLSocket{
    public function Socket(){
        super();
    }
    public function onConnect(success:Boolean){
        trace("connect"+success);
        if (success){
            this.send("hello world\r");
        }
    }
    public function onData(src:String){
        trace(src);
    }
}
fla里在帧上写
复制内容到剪贴板
代码:
var SERVER_PORT:Number = 10086;
var SERVER_IP:String = "127.0.0.1";
var conn:Socket = new Socket();
conn.connect(SERVER_IP,SERVER_PORT);
这才是真正的as2,当然你可以更好的修改Socket,让他符合Server的要求,比如在类里加上一个常量,并写入符合Server要求的方法。
复制内容到剪贴板
代码:
public var msg:String = "";
public function write(src){
    msg += src;
}
public function flush(){
    this.send(msg+"\r");
    msg = "";
}
这样在fla里发送的方式就改为
复制内容到剪贴板
代码:
conn.write("hello world");
conn.flush();
这样是不是又规范又符合Java的要求了呢?我只是举是一个简单例子,你可以按要求自己再修改。



1。4 AS3 与 Java 通信
Action Script 3
最后是传说中的as3了,这里我们用Socket中的writeUTFBytes();来写字符串。首先来看fla版的
复制内容到剪贴板
代码:
var SERVER_PORT:Number = 10086;
var SERVER_IP:String = "127.0.0.1";
var conn:Socket = new Socket(SERVER_IP,SERVER_PORT);
conn.addEventListener("connect",socketConnect);
conn.addEventListener("socketData",socketData);
function socketConnect(event:Event){
    event.target.writeUTFBytes("hello world");
    event.target.writeByte(10);
    event.target.flush();
}
function socketData(event:ProgressEvent){
    trace(event.target.readUTFBytes(event.target.bytesAvailable));
}
看看这个fla版本的是不是在代码上思路更加清晰呢?所有事件已经全部改为监听的方式,并且所有事件将把事件作为参数传入函数。
bytesAvailable为字节长度,而readUTFBytes的参数是从当前指向的位置读取到参数位置,这样写就是读完。
在as2里,如果在事件触发的函数里写this指向的是触发事件的实例,而as3永远指向所在类的实力,触发事件的实例被记录在传入事件参数的target对象中。
as3更加注重的是oop,在fla里已经体现出来了。接下来就来看看DocmentClass的方法
复制内容到剪贴板
代码:
package{class Run{
    private var SERVER_PORT:Number = 10086;
    private var SERVER_IP:String = "127.0.0.1";
    public function Run(){
        //在这里写代码并在flash里设置该类为文档类,和直接写上帧上其实没有区别,入口函数
        new ClientSocket(SERVER_IP,SERVER_PORT);
    }
}}
当然还有一个ClientSocket.as的文件放这个socket客户端类
复制内容到剪贴板
代码:
package {
    import flash.net.Socket;
    import flash.events.ProgressEvent;
    import flash.events.Event;
    import flash.events.IOErrorEvent;
    public class ClientSocket extends Socket {
        public function ClientSocket(ip:String,port:uint) {
            super(ip,port);
            addEventListener("cennect",socketConnect);
            addEventListener("socketData",socketData);
            addEventListener("ioError",ioError);
        }
        public function send(src:String) {
            writeUTFBytes(src);
            writeByte(10);
            flush();
        }
        private function socketConnect(event:Event) {
            send("hello world");
        }
        private function socketData(event:ProgressEvent) {
            trace(readUTFBytes(bytesAvailable));
        }
        private function ioError(event:IOErrorEvent) {
            trace("connect error");
        }
    }
}
入口函数创建了一个客户端的对象,而具体的类的内部构造如上代码所示:
首先创建父类构造函数,再为自己添加监听,当连接时执行socketConnect();发送字符串,注意writeByte(10)是换行符。
在as3的socket类里还有其他的事件,这里因为教学原因所以没有过多的举例,相关可以查阅socket的帮助
close  在服务器关闭套接字连接时调度。
connect  在建立网络连接后调度。(这个监听在教程里已经实现)
deactivate  Flash Player 失去操作系统焦点并变为非活动状态时调度。
ioError  在出现输入/输出错误并导致发送或加载操作失败时调度。(以前是在onConnect传入false,而这里是直接引发ioError事件,更规范)
securityError  若对 Socket.connect() 的调用尝试连接到调用方安全沙箱外部的服务器或端口号低于 1024 的端口,则进行调度。
socketData  在套接字接收到数据后调度。 (这个监听在教程里已经实现)



2 Java多线程服务器
基本的通信做到以后就是修改代码增加功能了,这里我们必须让Java能支持多个线程的连接,这才是服务器呀。
复制内容到剪贴板
代码:
import java.io.*;
import java.net.*;
public class Server extends ServerSocket{
    //服务端口号常量(as要求必须大于1024,小于65535)
    private static final int SERVER_PORT = 10086;
    //构造函数
    public Server() throws IOException{
        super(SERVER_PORT);
        //监听新连接,为每个连接分配一个线程,将新的连接传入独立线程
        Socket socket = accept();
        new SocketThread(socket);
    }
    //入口函数...
    public static void main (String[] args) throws IOException{
        new Server();    
    }
    //建一个类,该类属于独立的线程,他的每个实例都会在独立的线程里运行
    class SocketThread extends Thread{
        
        //申明流的空间在独立线程里了,因为他属于传送时所需,主线程只是监听有没有新连接
        private Socket client;
        private BufferedReader in;
        private PrintWriter out;
        private String src;
            
        //构造函数
        public SocketThread(Socket socket) throws IOException{
            //初始客户端的连接为该线程传入的连接
            client = socket;
            //初始流在进来后读取前,和写入后发送前所存放的空间
            in = new BufferedReader(new InputStreamReader(client.getInputStream()));
            out = new PrintWriter(client.getOutputStream(),true);
            //准备工作完毕,启动该线程
            start();
        }
        public void run(){try {
            //循环等待读取信息
            while(true){
                //读取行信息,注意是以换行符结束的
                src = in.readLine();
                //如果发送"close",就跳出循环(断开连接)
                if(src.equals("close")){
                    break;
                }
                //在收到的信息前加是标识并发回(注意结尾加"\0",这是as的XMLSocket读入每条信息的条件.as3的Socket不需要)
                out.println("rev: "+src+"\0");
                //以上out.println("xx")相当于out.write("xx");out.flush();的执行效果
                System.out.println("msg is "+src)
            }
            //关闭连接
            close();
        }catch(IOException e){
        }catch(NullPointerException e){
            System.out.println("client closed");
        }}
    }
}
修改后的Java主线程监听是否有新的连接,如果有就把这个连接分配到新的线程,让他去监听消息,而自己继续监听连接,这样的思路是不是很清晰呢?
仔细看看其实不是很难,大部分的代码都和前面的一样,只是循环监听信息的代码被放到的独立的线程里面。
关于多线程和一些Java的技术问题,为了对大家负责,我依然谨慎言语,以免误导大家。
现在你可以启动多个as对Java进行连接,并且他们之间互不干扰。一个线程对应一个连接,底层的工作非常透明,管理非常容易。



3 AS 通过Java数据转发实现P2P通信
谈到这里,其实要实现这步就非常容易了,原理上只要将本来Java收到后返回的信息,发到别人这里去,就可以了。原理如下所示
flash_1 -> Java -> flash_2
flash_2 -> Java -> flash_3
flash_3 -> Java -> flash_1
这样任何两个flash之间都能通过java转发了,现在只有一个问题,就是Java怎么知道我的信息要发给谁?其实很简单我们在每个连接连入的时候发送一条注册信息,让Java知道我的名字,而别人只要在字符串前加上我的名字就可以了。
那么在Java里 我们需要两个功能
1个是增加和删除自己的标识
2是识别字符串中哪些是名字,哪些是信息
这里我们用到方法是<空格>
"r s1";这样的一条信息过去,Java服务器要处理为该连接添加一个标识s1,而在这以后任何客户端只要发送
"s1 Hello";就会把"Hello"这个字符串发送给标识为s1的客户端,这样两个flash之间就完全实现了数据互通
"u s1";当离开的时候可以用这个代码来删除s1的标识符
为了简单和安全,我们可以暂设为标识必须是两位,以字母开头,这样的组合已经超过千种,绝对够用了。
这样只要判断空个所出现的位置即可,如果是第二位就是注册或卸载标识,如果是第三位就是字符转发了,如果都没有,那就是错误信息。
把上面的Run里的out.println("rev: "+src+"\0");改成以下信息就可以判断信息是注册还是卸载了
复制内容到剪贴板
代码:
//屏蔽所有长度小于4的信息,不做处理.
if(line.length()<4){
    out.write("error: length<4");
    out.flush();
    line = in.readLine();
    continue;
}
//命令字符
if (line.charAt(1)==' '){
    //相应客户端命令请求
    name = line.substring(2);
    switch (line.charAt(0)) {
    case 'r':
        //注册客户端
        if (!registered && name.length()==2){
            //为自己加一个ID
            Server.clientID.put(name,client);
            registered = true;
            //返回注册成功
            out.write("registeration successed");
            out.flush();
        }
        break;
    case 'u':
        //删除客户端
        Server.clientID.remove(name);
        registered = false;
        break;
    }
}else if (line.charAt(2)==' '){
    //这里是转发代码;
}
当然这里用的一些API在前面还要声明过。在线程类里增加两条申明
复制内容到剪贴板
代码:
private String name;
private boolean registered;
构造函数里
复制内容到剪贴板
代码:
registered = false;
当然最重要的是还要在Server的主线程里声明一个放ID的容器
复制内容到剪贴板
代码:
public static HashMap clientID = new HashMap();
这样每个连接都有自己的ID了

现在要做的是在转发了,在上面的转发代码的地方写
复制内容到剪贴板
代码:
send(line.substring(0,2),line.substring(3));
当然send函数还没有定义呢,现在定义
复制内容到剪贴板
代码:
public boolean send(String id, String src) throws IOException {
    //读取标识的地址
    Socket socket = (Socket)Server.clientID.get(id);
    if (socket != null){
        out = new PrintWriter(socket.getOutputStream(), true);
        out.write(src);
        out.flush();
        return true;
    }else{
        return false;    
    }
}
这里我加入了判断id是否存在,当不存在就没有任何操作,并且将操作结果成功与否返回,在send的时候就可以分类成功或不成功分别做什么了。


马上来开两个AS吧,用到我们刚才第一章节里自己封装的as2,把加载成功的地方改成send("r c1\r");和send("r c2\r");
Action Script 2
复制内容到剪贴板
代码:
//file1
var SERVER_PORT:Number = 10086;
var SERVER_IP:String = "127.0.0.1";
conn:Socket = new Socket();
conn.connect(SERVER_IP,SERVER_PORT);
conn.onConnect = function (success:Boolean){
    if (success){
        write("r c1");
        flush();
    }
}
//file2
var SERVER_PORT:Number = 10086;
var SERVER_IP:String = "127.0.0.1";
conn:Socket = new Socket();
conn.connect(SERVER_IP,SERVER_PORT);
conn.onConnect = function (success:Boolean){
    if (success){
        write("c2 hello");
        flush();
    }
}
依次运行file1,file2看看,file2运行的时候是不是成功收到了一个hello呢?嘿嘿。
这样做虽然底层还是没有实现P2P,但是效果已经达到,如果还是觉得不够理想,那么可以每个客户端都绑定一个Java的ServerSocket,负责收信息,并转发给同绑定Flash,这样虽然没有实现swf的p2p,但是在底层已经p2p了。



[完毕...  答疑和下载 在11楼]
<1 AS与Java最基本的通信> .. OK
<2 Java多线程服务器> .. OK
<3 AS 通过Java数据转发实现P2P通信> .. OK
<4 将P2P方式用类封装资源免费下载> .. OK

[ 本帖最后由 hack86 于 2007-7-12 20:37 编辑 ]
本帖最近评分记录
Flash Game Development
Rich Internet Application
学习了```
君子动手不动口
题目应该错了,应该是Flash结合java实现Socket通讯。
要知道两个flash之间如果不依靠其它技术是无法实现相互的P2P通讯的,因为flash的socket只能是Socket Client
,不能是Socket Server(Listener)。
两个应用要实现Socket通讯就必须一个是监听端一个客户端的。
我看你怎么P2P
少些争论,多写教程

TOP

还在为头像烦恼?还在为不能关注好友动态烦忧?快来蓝色理想家园吧!
P其他服务器吧,P客户端纯FLASH不可能,能的话就神了

TOP

写的不错!
不过纯p2p是不行的,只能通过服务器转发!

TOP

以后AS3和JAVA相互配合的应用肯定会越来越多,越来越深入!

TOP

请问Socket socket = accept();
里面是什么机制实现监听的?
这个语法在main thread中应该只执行一次就完了,如何才能不能监听呢?

TOP

引用:
原帖由 jimohuoshan 于 2007-7-12 11:28 发表
以后AS3和JAVA相互配合的应用肯定会越来越多,越来越深入!
火山说的对,其实梦境已经早这么做了。

其实楼主讲的不错,java写的server就一个最简单普通的。但是已经把问题讲清楚了,很好,对于初学者有所了解就OK了。其实一个把as写的很好的人真的很难写一个好的server的。因为一个好的server在一台主流PC上1s能处理5K的连接,但恐怕除了专家很少有人能搞出来。

所以了,大家要成为AS专家(相信大部分都是专搞as的吧),而不是东搞搞,西搞搞。奉劝那些又想学这个又想学那个的同学们,成某一方面的专家即可,不用三心二意。。

欢迎大家讨论。

[ 本帖最后由 alvas 于 2007-7-12 13:49 编辑 ]
少些争论,多写教程

TOP

精品文章的标题是不是应该改改?

TOP



回8楼  Server是继承了ServerSocket的,所以accept();就是 ServerSocket.accept();
Java是同步的,执行到这里Java会等待,知道有连接才会继续执行下面的代码。
这里用一个while(true){ServerSocket.accept();}就可以持续监听了。每次收到连接执行下面,又循环到上面,继续等待。
要停止给一个条件 break; 就可以了。

回9楼 做为一个AS程序员,我觉得要做的就是学习AS的精粹和相关的东西,AS程序即使学习JavaAPI也是为自己的AS服务。做为一个程序员,其实没有不会的程序,之所以写不出来程序是因为不知道该语言的API,一个不会Java或C的程序员不是合格的程序员,但是这个会只是知道他的原理和基础,不包括API。
9楼说得非常对,不要想着什么都精通,专一门,别的该学的学,不该学的不要浪费时间,现在的作品都是团队合作的。质量远远比一个人开发的作品速度快,质量高。
而有些极端的人说那我只学AS,其他都不管,您觉得可以吗?程序是必须需要基础的。
建议所有AS的程序员去学习一下 国家计算机等级考试二级 或者 国家计算机技术与软件专业技术资格(水平)考试程序员 对AS是有帮助的。
比如你不学数据结构,你说你精通AS,可以啊,我说AS的对象全部存在一张哈希表里,您能听得懂吗?
比如你不学Java基础,我说类继承不继承构造函数,AS的类不可重载,只能用switch参数模拟,您能理解吗?
比如你不学C/C++基础,我说AS里除了简单类型uint,number,string等是值变量,其他全部是指针变量,您有何看法呢?
有些东西是必学的,必须扎实,这样才能更加充实AS的研究道路,要知道让一个没有接触过Flash的普通程序员去理解什么时间轴变量,什么MC对象也不是很容易的事。相反有些自己领域没有必要学的,就不要浪费自己的时间,事倍功半。

回10楼 改成什么??



回14楼 不会就不会,as程序员只要负责把socket的原理理解,发出去然后等着收,java端 是Java程序员的事,和你有什么关系?? 基础想学就学一下,我的注释很清楚,如果不想学 Java源码已经提供 你直接用就可以。


回15楼 我是一个标准的程序员 C/Java都必须会 但要说明的是 我的会是没有API的。会的只是基础、概念、特点这是所有程序员必须掌握的。

[ 本帖最后由 hack86 于 2007-7-12 14:19 编辑 ]
附件: 您所在的用户组无法下载或查看附件,您需要注册/登录后才能查看!
Flash Game Development
Rich Internet Application

TOP

为什么不用 FMS 做服务器呢?

TOP

引用:
原帖由 geniicheng 于 2007-7-12 13:52 发表
为什么不用 FMS 做服务器呢?
FMS可扩展性太差。。。而且很贵。。。还不如RED5有前途。
少些争论,多写教程

TOP

java 不会 怎么办
xhtml/css/Ajax/AS/php/mysql你才是程序员,你家全是程序员 -__-

TOP

引用:
原帖由 jevin 于 2007-7-12 14:12 发表
java 不会 怎么办
你要做as专家还是java专家?   了解一下java是很好的,自己学学吧,我是java转as的。
少些争论,多写教程

TOP

引用:
FMS可扩展性太差。。。而且很贵。。。还不如RED5有前途。
我今天下午才研究 FMS 的,好像进入状况很难啊,
这段时间我打算用 AIR 做个 聊天 程序
,你说的这个RED5是什么东东啊

TOP

引用:
原帖由 alvas 于 2007-7-12 14:13 发表


你要做as专家还是java专家?   了解一下java是很好的,自己学学吧,我是java转as的。
不是不会 是忘了 学AS的时候也几乎没用到JAVA的东西
看来如果真要用LZ说的东西 JAVA还是要捡回来
xhtml/css/Ajax/AS/php/mysql你才是程序员,你家全是程序员 -__-

TOP

居然还有忘这种说话? hoho      
如果真学过,我就不相信以上教程中我的Java代码会看不懂!如果懂做为AS程序员Java到这个程度已经够了!   
也没有会和不会这么一说。
Flash Game Development
Rich Internet Application

TOP

果然写出来东西了

呵呵 顶一下 回去再欣赏
承接FLASH动画、全FLASH网站、电视竞猜游戏等项目

TOP

swf2swf 的 P2P
复制内容到剪贴板
代码:
//  file1
var lc:LocalConnection = new LocalConnection();
_root.send.onPress = function ()
{
    _root.txt.text += _root.input.text + "\n";
    lc.send("_p1", "talk", _root.input.text);
    _root.input.text = "";
}
lc.talk = function ($str:String):Void
{
    _root.txt.text += $str + "\n";
}
lc.connect("_p2");
复制内容到剪贴板
代码:
//  file2
var lc:LocalConnection = new LocalConnection();
_root.send.onPress = function ()
{
    _root.txt.text += _root.input.text + "\n";
    lc.send("_p2", "talk", _root.input.text);
    _root.input.text = "";
}
lc.talk = function ($str:String):Void
{
    _root.txt.text += $str + "\n";
}
lc.connect("_p1");
[ 本帖最后由 abc12hjc 于 2007-7-12 16:20 编辑 ]

TOP

lc 可以在同一台机器上 实现p2p通信 可以把参数传到对方的swf中,让接受放执行lc对象下的函数。
Flash Game Development
Rich Internet Application

TOP

不错,hack86的进步越来越快了:)

TOP

Red5
访问RIAForge.org看看。
失去执着,将一无所有。
www.7yue.com

TOP

引用:
原帖由 hack86 于 2007-7-12 14:30 发表
居然还有忘这种说话? hoho      
如果真学过,我就不相信以上教程中我的Java代码会看不懂!如果懂做为AS程序员Java到这个程度已经够了!   
也没有会和不会这么一说。
昨天是没看就回了
其实JAVA和AS3很像 LZ解释写这么详细 想不懂就难啊
xhtml/css/Ajax/AS/php/mysql你才是程序员,你家全是程序员 -__-

TOP

JAVA像AS3? 哈哈  貌似Java出得早 哈哈
Flash Game Development
Rich Internet Application

TOP

原来还是p2s2p
建议楼主改下标题,容易引起误会的