使用Socket、Java开发一个CS架构的多人聊天室

1、今天我们来制作 Flash 聊天室，学习使用 Socket 类，用 Java 作后台，开发一个 C / S 架构的多人聊天程序。首先，设计用户界面。一、界面设计界面的元件全部使用 Flash CS3 自带的组件： 首先，放入 TextInput 组件（实例名 input_txt），作为用户输入； 再放入 Button 组件（实例名 submit_btn），用于提交输入的信息； 最后放入 TextArea 组件（实例名 output_txt），显示聊天信息。二、组件参数初始化 由于客户端代码不是很多，我们这次就写在动作帧上：/ * 组件参数初始化 *submit_btn.label = 发送消息

2、;output_txt.editable = false;/ 设置各组件中字体的大小input_txt.setStyle(textFormat, new TextFormat(null, 15);output_txt.setStyle(textFormat, new TextFormat(null, 15);submit_btn.setStyle(textFormat, new TextFormat(null, 15, null, true);/ 当按下回车或点击 submit_btn 按钮后调用事件处理函数submit_btn.addEventListener(MouseEvent.CLIC

3、K, sendMessage);addEventListener(KeyboardEvent.KEY_DOWN, onKeyDown);/ 事件处理函数function onKeyDown(evt:KeyboardEvent):void if (evt.keyCode = Keyboard.ENTER) sendMessage(null); function sendMessage(evt:Event):void / 测试：将 input_txt 的内容输出到 output_txt 中 output_txt.appendText(input_txt.text + n); / 清空 input_

4、txt，并设置焦点到 input_txt input_txt.text = ; stage.focus = input_txt;三、编写客户端 Socket1. 首先，Socket 连接非常简单： var socket:Socket = new Socket(); socket.connect(, 8888);其中 connect() 方法中的两个参数分别为是主机名和端口号（端口号尽量用 1024 以上）。好了，这样就连接上了。接下来是读写的问题。2. 向服务器端写入字符串：我们在 sendMessage() 方法中进行写入操作，注意写出的字串必需以回车（n）结束：funct

5、ion sendMessage(evt:Event):void var bytes:ByteArray = new ByteArray(); bytes.writeUTFBytes(input_txt.text + n); socket.writeBytes(bytes); socket.flush(); / 清空 input_txt，并设置焦点到 input_txt input_txt.text = ; stage.focus = input_txt;3. 读取服务器端写回的字符串：最后将服务器发回的字符串输出到 output_txt 文本域中：/ 当客户端 socket 收到数据后会调用

6、readMessage() 函数socket.addEventListener(ProgressEvent.SOCKET_DATA, readMessage);function readMessage(evt:ProgressEvent):void output_txt.appendText(socket.readUTF() + n);四、Flash 客户端全部脚本/ * 组件参数初始化 *submit_btn.label = 发送消息;output_txt.editable = false;input_txt.setStyle(textFormat, new TextFormat(null,

7、 15);output_txt.setStyle(textFormat, new TextFormat(null, 15);submit_btn.setStyle(textFormat, new TextFormat(null, 15, null, true);submit_btn.addEventListener(MouseEvent.CLICK, sendMessage);addEventListener(KeyboardEvent.KEY_DOWN, onKeyDown);function onKeyDown(evt:KeyboardEvent):void if (evt.keyCode

8、 = Keyboard.ENTER) sendMessage(null); function sendMessage(evt:Event):void var bytes:ByteArray = new ByteArray(); bytes.writeUTFBytes(input_txt.text + n); socket.writeBytes(bytes); socket.flush(); input_txt.text = ; stage.focus = input_txt;/ * 客户端 Socket *var socket:Socket = new Socket();socket.conn

9、ect(, 8888);socket.addEventListener(ProgressEvent.SOCKET_DATA, readMessage);function readMessage(evt:ProgressEvent):void output_txt.appendText(socket.readUTF() + n);五、编写 Java 服务器端 Socket 最后，我们需要编写 Java 后台服务器端的代码。 首先，创建一个 ServerSocket 作为Socket 服务器。当有客户端连接后通过 accept() 方法即可得到客户端的 Socket：Server

10、Socket socketServer = new ServerSocket(8888);System.out.println(服务器已启动，等待客户端连接);/ accept() 方法是阻塞式的，当有客户端连接成功后才继续执行Socket socket = socketServer.accept();System.out.println(客户端连接成功);然后得到与客户端的输入流和输出流（输入流是客户端连接到服务器的管道，输出流则是服务器到客户端的管道）：/ 获得输入流和输出流，输入流为 BufferedReader 类型，输出流为 DataOutputStream 类型BufferedRe

11、ader reader =new BufferedReader(new InputStreamReader(socket.getInputStream(), UTF-8);DataOutputStream writer = new DataOutputStream(socket.getOutputStream(); 拿到输入输出流以后，就可以通过输入流（InputStream）读取 Flash 客户端发来的字符串，通过输出流（OutputStream）向 Flash 客户端写字符串：while (true) / readLine() 方法也是阻塞式的，当客户端有消息发来就读取，否则就一直等待

12、String msg = reader.readLine(); / 当客户端发送的字符串为 null 时，说明客户端已经关闭，此时退出循环 if (msg = null) System.out.println(客户端已离开); break; / 将读入的信息加工后再写回客户端 writer.writeUTF(写回客户端的 + msg);以上是ServerSocket 与 AS 3 Socket 通信的基本原理。在实际应用中，会有多个客户端连接这个ServerSocket，因此要创建一个多线程的 Socket 服务器。 下面简述一下多线程 Socket 服务器原理：当socketServer.a

13、ccept() 之后就需要实例化一个线程对象，在该对象中持有 socketServer.accept() 返回的 Socket 对象，然后让线程跑起来执行读写操作。如果再来一个客户端就再跑一个线程，同样执行读写操作。同时，用一个 List 容器来管理这些对象。 最终服务器端的代码如下：import java.io.BufferedReader;import java.io.DataOutputStream;import java.io.IOException;import java.io.InputStreamReader;import java.io.UnsupportedEncodingE

14、xception;import .ServerSocket;import .Socket;import java.util.ArrayList;import java.util.Iterator;import java.util.List;public class FlashScoket private List clientList = new ArrayList(); public static void main(String args) new FlashScoket().runSocket(); private void runSocket() try

15、 ServerSocket socketServer = new ServerSocket(8888); System.out.println(服务器已启动，等待客户端连接); while (true) / accept() 方法是阻塞式的，当有客户端连接成功后才继续执行 Socket socket = socketServer.accept(); System.out.println(客户端连接成功); / 实例化一个 Client 对象，并启动该线程 Client client = new Client(socket); clientList.add(client); client.sta

16、rt(); catch (IOException e) e.printStackTrace(); class Client extends Thread private Socket socket; private BufferedReader reader; private DataOutputStream writer; private Client(Socket socket) this.socket = socket; try / 获得输入流和输出流，输入流为 BufferedReader 类型，输出流为 DataOutputStream 类型 reader = new Buffere

17、dReader(new InputStreamReader(socket.getInputStream(), UTF-8); writer = new DataOutputStream(socket.getOutputStream(); catch (UnsupportedEncodingException e) e.printStackTrace(); catch (IOException e) e.printStackTrace(); Override public void run() try while (true) / readLine() 方法也是阻塞式的，当客户端有消息发来就读取

18、，否则就一直等待 String msg = reader.readLine(); / 当客户端发送的字符串为 null 时，说明客户端已经关闭，此时退出循环 if (msg = null) clientList.remove(this); System.out.println(客户端已离开); break; / 将读入的内容写给每个客户端 for (Iterator it = clientList.iterator(); it.hasNext();) Client client = it.next(); client.getWriter().writeUTF(msg); catch (IOEx

19、ception e) e.printStackTrace(); finally / 关闭 socket 及相关资源 try if (reader != null) reader.close(); catch (IOException e) e.printStackTrace(); finally try if (writer != null) writer.close(); catch (IOException e) e.printStackTrace(); finally try if (socket != null) socket.close(); catch (IOException e) e.printStackTrace(); public DataOutputStream getWriter() return writer; 六、补充技术1. 如何测试？* 首先要编译FlashScoket javac FlashScoket* 然后启动FlashScoket java FlashScoket* 最后将 Flash 发布为 exe 文件格式，同时开启多个即可。2. 自动跟踪到最后一行：当收到新的消息时自动滚动到最后一行，在 re