- 浏览: 309498 次
- 性别:
- 来自: 南昌
文章分类
最新评论
-
秋风扫落叶:
不错,学习了。shadow文件中记录的格式是什么?
/etc/passwd & /etc/shadow 详解 -
key232323:
重拾jstl——写得很好。我收藏下。
JSTL标签用法 -
zxl10059:
不错,非常简明扼要
Hibernate分页 -
Batmankwok:
很好,所见略同,
自定义组件MXML和as两种实现的方式和区别 -
Dxx23:
摘话回帖!
通过response对象的sendRedirec ...
response.sendRedirect方式的转向与RequestDispatcher的forward方法的比较
今天我们来制作 Flash 聊天室,学习使用 Socket 类,用 Java 作后台,开发一个 C / S 架构的多人聊天程序。首先,设计用户界面。
一、界面设计
界面的元件全部使用 Flash CS3 自带的组件:
首先,放入 TextInput 组件(实例名 input_txt),作为用户输入;
再放入 Button 组件(实例名 submit_btn),用于提交输入的信息;
最后放入 TextArea 组件(实例名 output_txt),显示聊天信息。
二、组件参数初始化
由于客户端代码不是很多,我们这次就写在动作帧上:
// ************ 组件参数初始化 ************
submit_btn.label = "发送消息";
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.CLICK, 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_txt,并设置焦点到 input_txt
input_txt.text = "";
stage.focus = input_txt;
}
三、编写客户端 Socket
1. 首先,Socket 连接非常简单:
var socket:Socket = new Socket();
socket.connect("127.0.0.1", 8888);
其中 connect() 方法中的两个参数分别为是主机名和端口号(端口号尽量用 1024 以上)。好了,这样就连接上了。接下来是读写的问题。
2. 向服务器端写入字符串:我们在 sendMessage() 方法中进行写入操作,注意写出的字串必需以回车(\n)结束:
function 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 收到数据后会调用 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, 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 == 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.connect("127.0.0.1", 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:
ServerSocket socketServer = new ServerSocket(8888);
System.out.println("服务器已启动,等待客户端连接");
// accept() 方法是阻塞式的,当有客户端连接成功后才继续执行
Socket socket = socketServer.accept();
System.out.println("客户端连接成功");
然后得到与客户端的输入流和输出流(输入流是客户端连接到服务器的管道,输出流则是服务器到客户端的管道):
// 获得输入流和输出流,输入流为 BufferedReader 类型,输出流为 DataOutputStream 类型
BufferedReader reader =
new BufferedReader(new InputStreamReader(socket.getInputStream(), "UTF-8"));
DataOutputStream writer = new DataOutputStream(socket.getOutputStream());
拿到输入输出流以后,就可以通过输入流(InputStream)读取 Flash 客户端发来的字符串,通过输出流(OutputStream)向 Flash 客户端写字符串:
while (true) {
// readLine() 方法也是阻塞式的,当客户端有消息发来就读取,否则就一直等待
String msg = reader.readLine();
// 当客户端发送的字符串为 null 时,说明客户端已经关闭,此时退出循环
if (msg == null) {
System.out.println("客户端已离开");
break;
}
// 将读入的信息加工后再写回客户端
writer.writeUTF("写回客户端的" + msg);
}
以上是ServerSocket 与 AS 3 Socket 通信的基本原理。在实际应用中,会有多个客户端连接这个ServerSocket,因此要创建一个多线程的 Socket 服务器。
下面简述一下多线程 Socket 服务器原理:当socketServer.accept() 之后就需要实例化一个线程对象,在该对象中持有socketServer.accept() 返回的 Socket 对象,然后让线程跑起来执行读写操作。如果再来一个客户端就再跑一个线程,同样执行读写操作。同时,用一个 List 容器来管理这些对象。
最终服务器端的代码如下:
import java.io.BufferedReader;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.UnsupportedEncodingException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
public class FlashScoket {
private List<Client> clientList = new ArrayList<Client>();
public static void main(String[] args) {
new FlashScoket().runSocket();
}
private void runSocket() {
try {
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.start();
}
} 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 BufferedReader(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() 方法也是阻塞式的,当客户端有消息发来就读取,否则就一直等待
String msg = reader.readLine();
// 当客户端发送的字符串为 null 时,说明客户端已经关闭,此时退出循环
if (msg == null) {
clientList.remove(this);
System.out.println("客户端已离开");
break;
}
// 将读入的内容写给每个客户端
for (Iterator<Client> it = clientList.iterator(); it.hasNext();) {
Client client = it.next();
client.getWriter().writeUTF(msg);
}
}
} catch (IOException 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. 自动跟踪到最后一行:当收到新的消息时自动滚动到最后一行,在 readMessage() 方法中加入:
output_txt.verticalScrollBar.scrollPosition = output_txt.verticalScrollBar.maxScrollPosition;
3. 当出现输入/输出错误并导致发送或加载操作失败时提示用户,加入对IO_ERROR 的侦听:
socket.addEventListener(IOErrorEvent.IO_ERROR, socketIOError);
function socketIOError(evt:IOErrorEvent):void {
output_txt.appendText("服务器端尚未开启,请稍后再试\n");
}
4. 在sendMessage() 中加入对空字符串的验证,如果为空则 return:
if (input_txt.text == "") {
return;
}
5. 在消息前面显示用户名:大家可以制作一个登录页面,输入用户名,假设已将输入的用户名存放在 userName 变量中,在写入时加进去:
发表评论
-
web.xml tomcat 和jetty 区别
2010-09-07 09:31 2189因为使用GWT,所以测试的时候是在jetty上运行的,但是最后 ... -
单元测试之实践四 Action的测试
2010-08-30 10:14 874Action的测试是比较辛苦的。因为它依赖与其他的环境(比如t ... -
单元测试之实践三 Service的测试
2010-08-30 10:13 995测试Service,因为Service依赖的Dao, 所以只需 ... -
单元测试之实践二,关于DAO的测试
2010-08-30 10:12 972前阵子发表过 我的第一个真正意义上的测试 。里面对于测试S ... -
Mockito特点
2010-08-30 10:02 11121. 只能使用jdk1.5以上,因为它的方便是用jdk1.5的 ... -
HttpUnit进行Web测试
2010-08-30 00:06 1714简介:HttpUnit是基于JUnit ... -
关于单元测试的一些看法
2010-08-28 14:26 929从参加工作以来,参加 ... -
Eclipse IDE下 Cactus + Jetty 对 Servlet 的测试
2010-08-28 13:09 1576在开发J2EE Web项目时,测试过程常涉及到代码与Web C ... -
用cactus,jetty实现对servlet类进行单元测试三(完)
2010-08-28 11:39 1134OK,可以开始写测试类了,代码为: pa ... -
用cactus,jetty实现对servlet类进行单元测试二
2010-08-28 11:37 1380按照官网的定义,我们就可以用MILY: 'Arial','sa ... -
用cactus,jetty实现对servlet类进行单元测试一
2010-08-28 11:35 1409JUnit是名声大燥了,想必只要学过JAVA的人都知道世上有个 ... -
相关测试工具下载
2010-08-26 17:21 1472相关测试工具下载 HP-Mercury软件测试工具下载,随时 ... -
单元测试实践小结
2010-08-26 16:40 634在系统开发过程种使用单元测试,会带来很多的的好处,最明显为: ... -
软件测试杂录
2010-08-26 14:41 1118比较杂,有空再整理一 ... -
J2EE单元测试
2010-08-26 11:06 1080一、测试原则 Java ... -
利用httpunit测试servlet
2010-08-26 10:33 2037传统的Java WEB应用中,核心技术莫过于Servlet类与 ... -
使用 EasyMock 更轻松地进行测试
2010-08-25 14:40 1016测试驱动开发是软件开发的重要部分。如果代码不进行测试,就是不可 ... -
Cactus工作原理
2010-08-24 09:52 1019Cactus 是Jakarta的子项目 ... -
Cactus实例讲解
2010-08-23 17:08 931Cactus简介 . 简介 Cactus实现了对JUni ... -
flex和java的通信
2010-08-17 15:35 739一、准备: 服务端:J ...
相关推荐
一个flash聊天室一个flash聊天室一个flash聊天室一个flash聊天室一个flash聊天室一个flash聊天室
【Flash聊天室源码】是一个基于C#编程语言开发的小型聊天室项目,它为初学者提供了一个良好的学习平台,可以深入理解网络通信和实时交互的实现方式。在这个项目中,我们可以学到以下几个重要的IT知识点: 1. **C#...
Flash聊天室源码 功能介绍: flash聊天室,实现了无刷新聊天,界面美观。 同时支持一对一聊天。还有一个普通聊天室,输入 用户名称就可以聊天 注意: 请从ChatRoom.html页面进入 开发环境为Visual Studio ...
flash聊天室只有一个swf文件,喜欢的兄弟可以下载玩玩
【PHP+Flash 聊天室 源码】是一个基于PHP编程语言和Adobe Flash技术构建的实时在线交流平台。这个源码包提供了完整的聊天室功能实现,包括前端的用户界面设计、动态数据交换以及后端的数据处理。下面将详细阐述PHP和...
一个在线的flash聊天室 一个在线的flash聊天室 一个在线的flash聊天室
Flash聊天室源码是基于Adobe Flash技术构建的实时通信平台的源代码,它允许用户通过互联网进行音频、视频以及文字交流。在Web2.0时代,Flash因其良好的跨平台性和实时交互性,常被用于创建在线聊天室。下面将详细...
【标题】"Flash聊天室"指的是使用Adobe Flash技术构建的在线聊天平台。在Web早期,Flash因其交互性和多媒体功能而广泛应用于创建动态网页元素,包括实时聊天应用。这些聊天室允许用户通过网络进行实时文本、音频甚至...
【首页Flash聊天室(Flash + PHP + XML)】是一种经典的在线实时交流系统,结合了Adobe Flash的交互性、PHP的服务器端处理能力和XML的数据交换功能。这个系统允许用户在网站的首页上进行实时的文本聊天,提升了用户...
【一流网络Flash聊天室】是一款基于ASP技术和Flash动画构建的在线聊天平台,旨在提供一个实时互动的交流环境。ASP(Active Server Pages)是微软开发的一种服务器端脚本语言,它允许开发者在网页上动态生成内容,与...
在Flash聊天室中,消息通常以JSON或AMF(Action Message Format)格式编码,这两种格式都是轻量级且易于解析的数据交换格式,适合在网络上传输。 6. **安全性与隐私保护**: 由于HTTP协议的明文传输特性,基于...
在IT领域,Flash聊天室是一种基于Adobe Flash技术构建的在线实时交流平台,它允许用户通过互联网进行文字、语音甚至视频的沟通。这个“Flash+ASP简单聊天室”学习素材提供了了解和构建此类应用的基础知识。 Flash是...
【标题】:“Flash聊天室代码”是一套用于创建互动式在线聊天平台的源代码,它基于Adobe Flash技术,提供了一种动态且富媒体的用户体验。这个项目可能包含了基本的聊天功能,如用户输入消息、实时显示聊天记录以及...
【标题】:“Flash聊天室”是指使用Adobe Flash技术构建的在线聊天平台,它结合了ASP(Active Server Pages)脚本语言来实现服务器端交互。在Web早期,Flash因其丰富的动画效果和互动性,在创建动态用户体验方面非常...
《基于Flex的Flash聊天室实现详解》 在Web开发领域,构建实时互动的聊天室是一项常见的需求,而基于Adobe Flex的Flash技术曾是实现此类应用的主流选择之一。本文将深入探讨如何使用Flex来创建一个功能完备的Flash...
《构建Flash Chat v1.2:深入探索Flash聊天室开发技术》 在互联网技术日新月异的时代,交互式应用成为提升用户体验的关键因素之一。"Develooping Flash Chat v1.2"是一款基于Flash技术的聊天室应用程序,旨在提供...
软件名称:Flash聊天室 开发平台:Flash 8 + JAVA 采用框架:Blue框架 开发者:弃天笑 时间:2007年2月15号 简单实在……实现了公聊,私聊,以及表情的一些基本功能
flash聊天室插件for discuz 6.0插件.rar
《深入解析Develooping Flash Chat v1.2:构建Flash聊天室的源码剖析》 在信息技术领域,源码是软件开发的核心,它揭示了程序背后的逻辑与设计思路。当我们谈论“商业编程-源码-Develooping Flash Chat v1.2”时,...