首页 诗词 字典 板报 句子 名言 友答 励志 学校 网站地图
当前位置: 首页 > 计算机考试 > 等级考试 > 复习指导 >

Flex和java的socket通信(2)

2009-02-21 
单向通信

    目的:客户端向服务端发消息,服务端将消息显示在屏幕上,不给客户端发送任何数据。
  服务器将反复进行一下过程。
  1 等待客户机连接请求
  2 连接客户机
  3 在断开客户机连接之前,接收字符串
  4 断开客户机连接
  5 返回至第一步
  获取与客户机连接的套接字的输入流,过程如下。
  Socket socket=server.accept(); //返回与客户机连接的套接字
  InputStream is=socket.getInputStream();//获取套接字的InputStream
  InputStreamReader isr=new InputStreamReader(is);
  BufferedReader reader= new BufferedReader(isr); //字符串流
  服务端代码:Server2.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();
  }
  }
  ====================
  客户端代码:Client2.mxml
  ===========================================
  <?xml version="1.0" encoding="utf-8"?>
  <mx:Application xmlns:mx="http://www.adobe.com/2006/mxml" layout="absolute" fontSize="12" creationComplete="initApp()">
  <mx:Script>
  <![CDATA[
  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+="连接已建立 n";
  }
  internal function funClose(event:Event):void
  {
  myText.text+="连接已关闭 n";
  }
  internal function sendMessage(msg:String):void//发送数据对应按钮click事件
  {
  var message:ByteArray=new ByteArray();//新建一个ByteArray存放数据
  //写入数据,writeUTFBytes方法,以utf-8格式传数据避免中文乱码
  message.writeUTFBytes(msg +"rn");
  socket.writeBytes(message);  //写入Socket的缓冲区
  socket.flush();//调用flush方法发送信息
  myText.text+=msg+"rn";//在客户端屏幕上输出发送的内容
  myInput.text="";//清空发言框
  }
  ]]>
  </mx:Script>
  <mx:TextArea x="10" y="10" width="703" height="263" id="myText"/>
  <mx:TextInput x="10" y="297" width="605" id="myInput"/>
  <mx:Button x="648" y="297" label="发送" id="myBtn" click="sendMessage(myInput.text)"/>
  </mx:Application>
  =====================
  知识点在(一)中已经讲过,就不重复了。
  服务端
  客户端
  有个疑问,在关闭swf的网页后,服务器屏幕会不停的输出:
  客户机:null
  客户机:null
  客户机:null
  客户机:null
  客户机:null
  不知道问题出在哪里,望知道的兄弟告知。

 

3COME考试频道为您精心整理,希望对您有所帮助,更多信息在http://www.reader8.com/exam/

热点排行