AS3实例：使用 Socket 、Java ，开发一个 C / S 架构的多人聊天室

2024-05-04 18:58
文章标签 java 使用 开发 实例 架构 socket 聊天室 as3

本文主要是介绍AS3实例：使用 Socket 、Java ，开发一个 C / S 架构的多人聊天室，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

今天我们来制作 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_txtinput_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_txtinput_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();}}@Overridepublic 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  变量中，在写入时加进去：
  var userName:String = "FL 车在臣";
在  sendMessage() 中相应改为： 
  bytes.writeUTFBytes(userName + " : "  + input_txt.text + "\n");
 

6. 使用output_txt .htmlText  输出文字，那么相应的写入格式可以调整为： 
bytes.writeUTFBytes("<font color='#0000FF'>" +  userName + " : </font>" + input_txt.text + "\n");
 

这篇关于AS3实例：使用 Socket 、Java ，开发一个 C / S 架构的多人聊天室的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/959882。

相关文章

JVM 的类初始化机制

JVM 的类初始化机制

前言 当你在 Java 程序中new对象时，有没有考虑过 JVM 是如何把静态的字节码（byte code）转化为运行时对象的呢，这个问题看似简单，但清楚的同学相信也不会太多，这篇文章首先介绍 JVM 类初始化的机制，然后给出几个易出错的实例来分析，帮助大家更好理解这个知识点。 JVM 将字节码转化为运行时对象分为三个阶段，分别是：loading 、Linking、initialization
阅读更多...
Spring Security 基于表达式的权限控制

Spring Security 基于表达式的权限控制

前言 spring security 3.0已经可以使用spring el表达式来控制授权，允许在表达式中使用复杂的布尔逻辑来控制访问的权限。 常见的表达式 Spring Security可用表达式对象的基类是SecurityExpressionRoot。 表达式描述hasRole([role])用户拥有制定的角色时返回true （Spring security默认会带有ROLE_前缀）,去
阅读更多...
浅析Spring Security认证过程

浅析Spring Security认证过程

类图 为了方便理解Spring Security认证流程，特意画了如下的类图，包含相关的核心认证类 概述 核心验证器 AuthenticationManager 该对象提供了认证方法的入口，接收一个Authentiaton对象作为参数; public interface AuthenticationManager {Authentication authenticate(Authenti
阅读更多...
Spring Security--Architecture Overview

Spring Security--Architecture Overview

1 核心组件 这一节主要介绍一些在Spring Security中常见且核心的Java类，它们之间的依赖，构建起了整个框架。想要理解整个架构，最起码得对这些类眼熟。 1.1 SecurityContextHolder SecurityContextHolder用于存储安全上下文（security context）的信息。当前操作的用户是谁，该用户是否已经被认证，他拥有哪些角色权限…这些都被保
阅读更多...
Spring Security基于数据库验证流程详解

Spring Security基于数据库验证流程详解

Spring Security 校验流程图 相关解释说明（认真看哦） AbstractAuthenticationProcessingFilter 抽象类 /*** 调用 #requiresAuthentication(HttpServletRequest, HttpServletResponse) 决定是否需要进行验证操作。* 如果需要验证，则会调用 #attemptAuthentica
阅读更多...
Spring Security 从入门到进阶系列教程

Spring Security 从入门到进阶系列教程

Spring Security 入门系列 《保护 Web 应用的安全》 《Spring-Security-入门（一）：登录与退出》 《Spring-Security-入门（二）：基于数据库验证》 《Spring-Security-入门（三）：密码加密》 《Spring-Security-入门（四）：自定义-Filter》 《Spring-Security-入门（五）：在 Sprin
阅读更多...
Java架构师知识体认识

Java架构师知识体认识

源码分析 常用设计模式 Proxy代理模式Factory工厂模式Singleton单例模式Delegate委派模式Strategy策略模式Prototype原型模式Template模板模式 Spring5 beans 接口实例化代理Bean操作 Context Ioc容器设计原理及高级特性Aop设计原理Factorybean与Beanfactory Transaction 声明式事物
阅读更多...
mybatis的整体架构

mybatis的整体架构

mybatis的整体架构分为三层： 1.基础支持层 该层包括：数据源模块、事务管理模块、缓存模块、Binding模块、反射模块、类型转换模块、日志模块、资源加载模块、解析器模块 2.核心处理层 该层包括：配置解析、参数映射、SQL解析、SQL执行、结果集映射、插件 3.接口层 该层包括：SqlSession 基础支持层 该层保护mybatis的基础模块，它们为核心处理层提供了良好的支撑。
阅读更多...
百度/小米/滴滴/京东，中台架构比较

百度/小米/滴滴/京东，中台架构比较

小米中台建设实践 01 小米的三大中台建设：业务+数据+技术 业务中台--从业务说起 在中台建设中，需要规范化的服务接口、一致整合化的数据、容器化的技术组件以及弹性的基础设施。并结合业务情况，判定是否真的需要中台。 小米参考了业界优秀的案例包括移动中台、数据中台、业务中台、技术中台等，再结合其业务发展历程及业务现状，整理了中台架构的核心方法论，一是企业如何共享服务，二是如何为业务提供便利。
阅读更多...
这15个Vue指令，让你的项目开发爽到爆

这15个Vue指令，让你的项目开发爽到爆

1. V-Hotkey 仓库地址: github.com/Dafrok/v-ho… Demo: 戳这里 https://dafrok.github.io/v-hotkey 安装: npm install --save v-hotkey 这个指令可以给组件绑定一个或多个快捷键。你想要通过按下 Escape 键后隐藏某个组件，按住 Control 和回车键再显示它吗？小菜一碟： <template
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2