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

（四）一个简单的聊天室

目的：做一个简单的聊天室，用来实现消息广播。

(66.89 KB)

2008-2-2 20:52

服务端代码：Server5.java

1. import java.net.*;
2. import java.io.*;
3. import java.util.*;
4. public class Server5 {
6.         private ServerSocket server;
7.         private BManager bMan=new BManager();//消息广播者
8.         public Server5(){}  //构造函数
9.         void startServer()  //启动服务器
10.         {
11.                 try{
12.                         server=new ServerSocket(8888); //创建服务器套接字
13.                         System.out.println("服务器套接字建立完毕");
14.                         while(true)
15.                         {
16.                                 Socket socket=server.accept();//若客户机提请求，socket连接
17.                                 new Chat_Thread(socket).start();//启动线程
18.                                 bMan.add(socket);//添加套接字
19.                                 bMan.sendClientInfo();//使用套接字输出当前聊天人数
20.                         }
21.                 }catch(Exception e){
22.                         System.out.println(e);
23.                 }
24.         }
25.         public static void main(String[] args) {
26.                 Server5 server=new Server5();
27.                 server.startServer();
28.         }
29.         class Chat_Thread extends Thread  //与客户机进行通信的线程累
30.         {
31.                 Socket socket; //套接字引用变量
32.                 private BufferedReader reader;//引用套接字输入流；
33.                 private PrintWriter writer;//引用套接字输出流；
34.                 Chat_Thread(Socket socket)//构造函数
35.                 {
36.                         this.socket=socket;
37.                 }
38.                 public void run()
39.                 {
40.                         
41.                         try
42.                         {
43.                                 reader=new BufferedReader(new InputStreamReader(socket.getInputStream(),"utf8"));
44.                                 writer=new PrintWriter(socket.getOutputStream(),true);
45.                                 String msg;
46.                                 //从输出流获取信息
47.                                 while((msg=reader.readLine())!=null)
48.                                 {
49.                                         System.out.println(msg);
50.                                         //向所有客户机传送信息
51.                                         bMan.sendToAll(msg);
52.                                 }
53.                         }catch(Exception e)
54.                         {
55.                                 
56.                         }finally
57.                         {
58.                                 try {//从消息广播者立标中删除socket
59.                                         bMan.remove(socket);
60.                                         if(reader !=null) reader.close();
61.                                         if(writer !=null) writer.close();
62.                                         if(socket !=null) socket.close();
63.                                         reader=null;
64.                                         writer=null;
65.                                         socket=null;
66.                                         System.out.println("客户机离开");
67.                                         //向所有客户机传送当前连接数
68.                                         bMan.sendClientInfo();
69.                                 } catch (Exception e) {}
70.                         }
71.                         
72.                 }
73.         }
74. }
76. //消息广播者类，继承Vector类
77. class BManager extends Vector
78. {
79.         BManager (){}//构造函数
80.         void add(Socket sock)
81.         {
82.                 super.add(sock);//添加套接字
83.         }
84.         void remove(Socket sock)
85.         {
86.                 super.remove(sock);//删除套接字
87.         }
88.    //向所有客户机传送消息，同步化方法。
89.         synchronized void sendToAll(String msg)
90.         {
91.                 PrintWriter writer=null; //输出流
92.                 Socket sock;  //套接字
93.                 for(int i=0;i                {
94.                         sock=(Socket)elementAt(i);//获取第i个套接字
95.                         try
96.                         {        //获取第i个套接字输出流
97.                                 writer=new PrintWriter(sock.getOutputStream(),true);
98.                         }catch(Exception ie){}
99. //使用第i各套接字输出流，输出消息
100.                         if(writer!=null) writer.println(msg);
101.                 }
102.         }
104.         //向所有客户机发送当前聊天人数
105.         synchronized void sendClientInfo()
106.         {
107.                 String info="当前聊天人数："+size();
108.                 System.out.println(info);
109.                 sendToAll(info);
110.         }
111. }

复制代码

知识点：

消息广播者类名为Bmanager，他继承了Vector类

 

class Bmanager extends Vector

 

{

 

        Bmanager(){}

 

void add(Socket socket)

 

{

 

        //添加套接字

 

}

 

void remove(Socket socket)

 

{

 

        //删除套接字

 

}

 

synchronized void sendToAll(String msg)

 

{‘

 

        //使用套接字的输出流，输出消息

 

}

 

synchronized void sendClientInfo()

 

{

 

        //使用套接字的输出流，输出当前聊天人数

 

}

 

}

客户端代码：Client5.mxml

4.                         import flash.net.Socket; //导入类包
5.                 import flash.utils.ByteArray;//ByteArray在读取数据时使用
6.                 private var socket:Socket=new Socket();//定义socket
7.                 internal function initApp():void
8.                 {
9.                         socket.connect("127.0.0.1",8888);//执行连接
10.                         //监听连接成功事件
11.                         socket.addEventListener(Event.CONNECT,funConnect);
12.                         //监听关闭事件
13.                         socket.addEventListener(Event.CLOSE,funClose);
14.                         //监听服务器新信息
15.                         socket.addEventListener(ProgressEvent.SOCKET_DATA,funSocket);
16.                 }
17.                 internal function funConnect(event:Event):void
18.                 {
19.                         myText.text+="连接已建立 ";
20.                 }
21.                 internal function funClose(event:Event):void
22.                 {
23.                         myText.text+="连接已关闭 ";
24.                 }
25.                 internal function sendMessage(msg:String):void //发送数据到服务器
26.                 {
27.                         //新建一个ByteArray来存放数据
28.                         var message:ByteArray=new ByteArray();
29.                         //写入数据，使用writeUTFBytes以utf8格式传数据，避免中文乱码
30.                         message.writeUTFBytes(msg+" ");
31.                         //写入socket的缓冲区
32.                         socket.writeBytes(message);
33. //调用flush方法发送信息
34.                         socket.flush();
35.                         //清空消息框
36.                         myInput.text="";
37.                 }
38.                 //接受服务器信息
39.                 internal function funSocket(event:ProgressEvent):void
40.                 {
41.                         var msg:String="";
42.                 //循环读取数据，socket的bytesAvailable对象存放了服务器传来的所有数据
43.                         while(socket.bytesAvailable)
44.                         {
45.                                 //强制使用utf8格式，避免中文乱码
46.                                 msg+=socket.readMultiByte(socket.bytesAvailable,"utf8");
47.                                 //使用换行符号把信息切开
48.                                 var arr:Array=msg.split(' ');
49.                                 for(var i:int=0;i                                {
50.                                         if(arr[i].length>1)
51.                                         {
52.                                                 //正则表达式，回车符
53.                                                 var myPattern:RegExp=/ /;
54.                                                 //删除回车符
55.                                                 arr[i]=arr[i].replace(myPattern,'');
56.                                                 //在聊天框中输出
57.                                                 myText.text+=arr[i]+" ";
58.                                         }
59.                                 }
60.                                 myText.verticalScrollPosition = myText.maxVerticalScrollPosition;//滚动到最下面
61.                         }
62.                                 
63.                 }
64.         ]]>
66.         
67.         
68.         
69.         
70.