flex与java之间socket通信的教程2

二）单向通信

目的：客户端向服务端发消息，服务端将消息显示在屏幕上，不给客户端发送任何数据。

服务器将反复进行一下过程。
１　等待客户机连接请求
２　连接客户机
３　在断开客户机连接之前，接收字符串
４　断开客户机连接
５　返回至第一步

获取与客户机连接的套接字的输入流，过程如下。

Socket socket=server.accept();  //返回与客户机连接的套接字
InputStream is=socket.getInputStream();　　//获取套接字的InputStream
InputStreamReader isr=new InputStreamReader(is);
BufferedReader reader= new BufferedReader(isr);  //字符串流

服务端代码：Server２.java
＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝
import java.net.*;
import java.io.*;
public class Server2 {
private BufferedReader reader;　//负责输入
private ServerSocket server;　　 //服务器套接字
private Socket socket;　　　　　 //套接字
        public Server2(){}　　//缺省构造函数
        void startServer()　　//启动服务器
        {
                try
                {
                        server=new ServerSocket(8888);　　　 //创建服务器套接字
                        System.out.println("服务器套接字建立完毕");
                        while(true)
                        {
                        　　System.out.println("等待客户机");
                        　　socket=server.accept();　//若客户机提出连接请求，与socket连接
                        　　System.out.println("完成与客户机的连接");
                        　　//获取socket输入流，“utf-8”这个编码设置是为了更好显示中文
reader=new BufferedReader(new　InputStreamReader(socket.getInputStream(),"UTF-8"));                                                               
getMessage();//读取来自客户机的数据，并输出至画面上
                        }
                }catch(Exception e)
                {
                        System.out.println(e);
                }
        }
        void getMessage()　　//读取来自套接字的信息
        {
                try
                {
                        while(true)　　　 //循环
                        {
                                System.out.println("客户机："+reader.readLine());
                        }
                }catch(Exception e){}
                finally{
                        System.out.println("客户机中断连接");
                        try
                        {
                                if(reader!=null) reader.close();　//关闭套接字的输入流
                                if(socket!=null) socket.close();　　//关闭套接字
                                reader=null;
                                socket=null;
                        }catch(Exception e){}
                }
        }
        public  static void main(String[] args)
        {
                Server2 server=new Server2();
                server.startServer();
        }

}
＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝


客户端代码：Client２.mxml
==================================================================================



                        import flash.net.Socket;　//导入类包
                import flash.utils.ByteArray;　　//ByteArray用来在读取数据的时候使用
                private var socket:Socket=new Socket();　//定义Socket
                //初始化程序
                internal function initApp():void
                {
                        socket.connect("127.0.0.1",8888); //连接服务器
                        socket.addEventListener(Event.CONNECT,funConnect); //监听是否连接
                        socket.addEventListener(Event.CLOSE,funClose); //监听连接关闭
                }
                internal function funConnect(event:Event):void
                {
                        myText.text+="连接已建立 ";
                }
                internal function funClose(event:Event):void
                {
                        myText.text+="连接已关闭 ";
                }
                internal function sendMessage(msg:String):void//发送数据对应按钮click事件
                {
                        var message:ByteArray=new ByteArray();//新建一个ByteArray存放数据
                        //写入数据，writeUTFBytes方法，以utf-8格式传数据避免中文乱码
message.writeUTFBytes(msg +" ");       
socket.writeBytes(message);　 //写入Socket的缓冲区
                        socket.flush();　　//调用flush方法发送信息
                        myText.text+=msg+" ";　　//在客户端屏幕上输出发送的内容
                        myInput.text="";　　//清空发言框
                }
        ]]>

       
       
       
       

＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝