Flex和java的socket通信

高傲的活着 发表于 2011-12-22 08:54

<DIV>一个简单的聊天室</DIV>
<DIV> </DIV>
<DIV>服务端：</DIV>
<DIV>开发工具:</DIV>
<DIV>eclipse3.6+jdk1.6 　　</DIV>
<DIV>客户端：</DIV>
<DIV>开发工具：Flash Builder4　　</DIV>
<DIV>目的：做一个简单的聊天室，用来实现消息广播。</DIV>
服务端代码(Server.java)
<DIV id=codeText class=codeText>
<OL style="PADDING-BOTTOM: 5px; MARGIN: 0px 1px 0px 0px; PADDING-LEFT: 0px; PADDING-RIGHT: 0px; PADDING-TOP: 5px" class=dp-css>
<LI>import java.net.*; </LI>
<LI>import java.io.*; </LI>
<LI>import java.util.*; </LI>
<LI>public class Server { </LI>
<LI>    private ServerSocket server; </LI>
<LI>    private BManager bMan=new BManager(); //消息广播者 </LI>
<LI> </LI>
<LI>    public Server(){} //构造函数 </LI>
<LI>    void startServer(){ //启动服务器 </LI>
<LI>        try{ </LI>
<LI>            server=new ServerSocket(8888); //创建服务器套接字 </LI>
<LI>            System.out.println("服务器套接字建立完毕！"); </LI>
<LI>            while(true){ </LI>
<LI>                Socket socket=server.accept(); //若客户机提出请求，socket连接 </LI>
<LI>                new Chat_Thread(socket).start(); //启动线程 </LI>
<LI>                bMan.add(socket); //添加套接字 </LI>
<LI>                bMan.sendClientInfo(); //使用套接字输出当前聊天人数 </LI>
<LI>            } </LI>
<LI>        }catch(Exception e){ </LI>
<LI>            System.out.println(e); </LI>
<LI>        } </LI>
<LI>    } </LI>
<LI> </LI>
<LI>    public static void main(String[] args) { </LI>
<LI>        Server server=new Server(); </LI>
<LI>        server.startServer(); </LI>
<LI>    } </LI>
<LI>} </LI>
<LI> </LI>
<LI>class Chat_Thread extends Thread{ //与客户机进行通信的线程类 </LI>
<LI>    Socket socket; //套接字引用变量 </LI>
<LI>    BManager bMan=new BManager(); </LI>
<LI>    private BufferedReader reader; //引用套接字输入流 </LI>
<LI>    private PrintWriter writer; //引用套接字输出流 </LI>
<LI> </LI>
<LI>    Chat_Thread(Socket socket){ </LI>
<LI>        this.socket=socket; </LI>
<LI>    } </LI>
<LI> </LI>
<LI>    public void run(){ </LI>
<LI>        try{ </LI>
<LI>            reader=new BufferedReader(new InputStreamReader(socket.getInputStream(),"utf8")); </LI>
<LI>            writer=new PrintWriter(socket.getOutputStream(),true); </LI>
<LI>            String msg = null; </LI>
<LI>            //从输出流获取消息 </LI>
<LI>            while((reader.readLine())!=null) </LI>
<LI>            { </LI>
<LI>                System.out.println(msg); </LI>
<LI>                bMan.sendToAll(msg); </LI>
<LI>            } </LI>
<LI>        } </LI>
<LI>        catch(Exception e){ </LI>
<LI>            System.out.println(e); </LI>
<LI>        }finally{ </LI>
<LI>            try{ </LI>
<LI>                //从消息广播者中删除socket </LI>
<LI>                bMan.remove(socket); </LI>
<LI>                if(reader !=null) reader.close(); </LI>
<LI>                if(writer !=null) writer.close(); </LI>
<LI>                if(socket !=null) socket.close(); </LI>
<LI>                reader=null; </LI>
<LI>                writer=null; </LI>
<LI>                socket=null; </LI>
<LI>                System.out.println("客户机离开"); </LI>
<LI>                //向所有客户机传送当前连接数 </LI>
<LI>                bMan.sendClientInfo(); </LI>
<LI>            } catch (Exception e) {} </LI>
<LI>        } </LI>
<LI>    } </LI>
<LI>} </LI>
<LI> </LI>
<LI>//消息广播者类，继承Vector类 </LI>
<LI>class BManager extends Vector{ </LI>
<LI> </LI>
<LI>    BManager(){} //构造函数 </LI>
<LI>    void add(Socket socket){ </LI>
<LI>        super.add(socket); //添加套接字 </LI>
<LI>    } </LI>
<LI> </LI>
<LI>    void remove(Socket socket){ </LI>
<LI>        super.remove(socket); //删除套接字 </LI>
<LI>    } </LI>
<LI> </LI>
<LI>    //向所有客户机传送消息，同步化方法 </LI>
<LI>    synchronized void sendToAll(String msg){ </LI>
<LI>        PrintWriter writer=null; //输出流 </LI>
<LI>        Socket socket; //套接字 </LI>
<LI> </LI>
<LI>        for(int i=0;i<size();i++){ //执行循环 </LI>
<LI>            socket=(Socket)elementAt(i); //获取第i个套接字 </LI>
<LI>            try{ </LI>
<LI>                //获取第i个套接字输出流 </LI>
<LI>                writer=new PrintWriter(socket.getOutputStream(),true); </LI>
<LI>            }catch(Exception e){ </LI>
<LI>                //使用第i个套接字输出流，输出消息 </LI>
<LI>                if(writer!=null) </LI>
<LI>                    writer.println(msg); </LI>
<LI>            } </LI>
<LI>        } </LI>
<LI>    } </LI>
<LI>    //向所有客户机发送当前聊天人数 </LI>
<LI>    synchronized void sendClientInfo(){ </LI>
<LI>        String info="当前聊天人数："+size(); </LI>
<LI>        System.out.println(info); </LI>
<LI>    } </LI>
<LI>}</LI></OL></DIV>
客户端代码:FlexClient.mxml
<DIV id=codeText class=codeText>
<OL style="PADDING-BOTTOM: 5px; MARGIN: 0px 1px 0px 0px; PADDING-LEFT: 0px; PADDING-RIGHT: 0px; PADDING-TOP: 5px" class=dp-css>
<LI><?xml version="1.0" encoding="utf-8"?> </LI>
<LI><s:Application xmlns:fx="http://ns.adobe.com/mxml/2009" </LI>
<LI>             xmlns:s="library://ns.adobe.com/flex/spark" </LI>
<LI>             xmlns:mx="library://ns.adobe.com/flex/mx" minWidth="955" minHeight="600" creationComplete="initApp()"> </LI>
<LI>    <fx:Declarations> </LI>
<LI>         </LI>
<LI>    </fx:Declarations> </LI>
<LI>     </LI>
<LI>    <fx:Script> </LI>
<LI>        <![CDATA[ </LI>
<LI>             </LI>
<LI>            import flash.net.Socket; </LI>
<LI>            import flash.utils.ByteArray; //ByteArray在读取数据时使用 </LI>
<LI>            private var socket:Socket=new Socket(); //定义socket </LI>
<LI>             </LI>
<LI>            internal function initApp():void </LI>
<LI>            { </LI>
<LI>                socket.connect("127.0.0.1",8888); //执行连接 </LI>
<LI>                //监听连接成功事件 </LI>
<LI>                socket.addEventListener(Event.CONNECT,funConnect); </LI>
<LI>                //监听关闭事件 </LI>
<LI>                socket.addEventListener(Event.CLOSE,funClose); </LI>
<LI>                //监听服务器新消息 </LI>
<LI>                socket.addEventListener(ProgressEvent.SOCKET_DATA,funSocket); </LI>
<LI>            } </LI>
<LI>             </LI>
<LI>             </LI>
<LI>            internal function funConnect(event:Event):void{ </LI>
<LI>                myText.text="连接已建立..."; </LI>
<LI>                 </LI>
<LI>            } </LI>
<LI>             </LI>
<LI>            internal function funClose(event:Event):void{ </LI>
<LI>                myText.text="连接已关闭..."; </LI>
<LI>            } </LI>
<LI>             </LI>
<LI>             </LI>
<LI>            internal function sendMessage(msg:String):void{ //发送数据到服务器 </LI>
<LI>                //新建一个ByteArray来存放数据 </LI>
<LI>                var message: ByteArray=new ByteArray(); </LI>
<LI>                //写入数据，使用writeUTFBytes以utf8格式传数据，避免中文乱码 </LI>
<LI>                message.writeUTFBytes(msg+"n"); </LI>
<LI>                //写入socket的缓冲区 </LI>
<LI>                socket.writeBytes(message); </LI>
<LI>                //调用flush方法发送信息 </LI>
<LI>                socket.flush(); </LI>
<LI>                //清空消息框 </LI>
<LI>                myInput.text=""; </LI>
<LI>                 </LI>
<LI>            } </LI>
<LI>            //接受服务器信息 </LI>
<LI>            internal function funSocket(event:ProgressEvent):void{ </LI>
<LI>                var msg:String=""; </LI>
<LI>                //循环读取数据，socket的bytesAvailable对象存放了服务器传来的所有数据 </LI>
<LI>                while(socket.bytesAvailable) </LI>
<LI>                { </LI>
<LI>                    //强制使用utf8格式，避免中文乱码 </LI>
<LI>                    msg+=socket.readMultiByte(socket.bytesAvailable,"utf8"); </LI>
<LI>                    //使用n换行符号把信息切开 </LI>
<LI>                    var arr:Array=msg.split('n'); </LI>
<LI>                     </LI>
<LI>                    for(var i:int=0;i<arr.length;i++){ </LI>
<LI>                        //正则表达式，回车符 </LI>
<LI>                        var myPattern:RegExp=/r/; </LI>
<LI>                        //删除回车符 </LI>
<LI>                        arr[i]=arr[i].replace(myPattern,''); </LI>
<LI>                        //在聊天框中输出 </LI>
<LI>                        myText.text+=arr[i]+'n'; </LI>
<LI>                    } </LI>
<LI>                     </LI>
<LI>                } </LI>
<LI>                myText.verticalScrollPosition=myText.maxVerticalScrollPosition; //滚动到最下面 </LI>
<LI>            } </LI>
<LI>             </LI>
<LI>        ]]> </LI>
<LI>    </fx:Script> </LI>
<LI>    <mx:TextArea x="10" y="48" width="334" height="250" id="myText"/> </LI>
<LI>    <s:TextInput x="10" y="18" width="334" id="myName" text="名字"/> </LI>
<LI>    <s:TextInput x="10" y="297" width="261" height="20" id="myInput"/> </LI>
<LI>    <s:Button x="270" y="296" label="发送" width="74" id="myBtn" click="sendMessage(myName.text+':'+myInput.text)"/> </LI>
<LI></s:Application></LI></OL></DIV>
参考资料
<a href="http://www.114study.com/template/datum/datumdetail.aspx?ddid=422060" target="_blank">http://www.114study.com/template/datum/datumdetail.aspx?ddid=422060</A>

页: [1]

Chinaunix's Archiver

Flex和java的socket通信