.NET网络编程技术原理与开发实例

１｜ｌ　’“　“　　’　『Ｉ『　１　＿’　Ｉｌ　

实用第一　智．ｔ彗ｌ２ｊ￣，密集　

　ｒＰ　…　

．

ＮＥＴ网络编程技术原理与开发实例　

明延堂　

摘　要：简述了，ＮＥＴ架构的基本网络编程原理，详细介绍了一个即时消息通信系统的完整的构建　

过程。可以从中获得一些面向对象编程封装网络功能、编写自定义网络通信协议、多线程网络监　

听技术、自定义网络消息的流转等Ｃ≠≠网络开发经验。　

关键词：套接字；网络流；即时通信　

１　基本原理　

扼要地介绍．ＮＥＴ架构中关于套接字、网络编码等底层网　

络编程技术原理。将通过完整的Ｃ样实例演示如何利用这些技　

术进行底层网络编程。　

端成功连接后，就可以使用Ｓｅｎｄ、Ｒｅｃｅｉｖｅ等方法进行数据传　

输。当使用完Ｓｏｃｋｅｔ之后，可以使用ＳｈｕｔＤｏｗｎ方法使之失效　

或用Ｃｌｏｓｅ方法关闭Ｓｏｃｋｅｔ。　

Ｓｏｃｋｅｔ类的基本构造函数包含３个参数类型：ＡｄｄｒｅｓｓＦａｍｉｌｙ、　

ＳｏｃｋｅｔＴｙｐｅ及ＰｒｏｔｏｃｏｌＴｙｐｅ。ＡｄｄｒｅｓｓＦａｍｉｌｙ枚举用于设置Ｓｏｃｋｅｔ　

实例使用的地址类型．最常用的是ＩｎｔｅｒＮｅｔｗｏｒｋ和　

ＩｎｔｅｒｎｅｔｗｏｒｋＶ６，前者代表ＩＰｖ４地址，后者代表ＩＰｖ６地址。　

１．１　套接字　

套接字是网络通信的基石，是支持ＴＣＰｆｌＰ协议的网络通　

信的基本操作单元。可以将Ｓｏｃｋｅｔ看作不同主机间的进程进行　

ＳｏｃｋｅｔＴｙｐｅ枚举定义了Ｓｏｃｋｅｔ实例的类型，最常用的是Ｄｇｒａｍ　

和Ｓｔｒｅａｍ．前者用于ＵＤＰ协议ｆ数据报格式、非连接性、不可　

双向通信的端点，它构成了单个主机内及整个网络问的编程界　

面。Ｓｏｃｋｅｔ存在于通信域ｆ为了处理一般的线程通过Ｓｏｃｋｅｔ通　

信而引入的一种抽象概念）中。Ｓｏｃｋｅｔ通常和同一个域中的　

Ｓｏｃｋｅｔ交换数据。当然，数据交换也可以穿越域的界限，但需　

要执行某种特定的解释程序。各种进程在这个域中相互之间利　

靠数据传输１，后者用于ＴＣＰ协议（可靠的双向的有保证的连　

接、不保证消息边界、与一个对等终端连接１。ＰｒｏｔｏｃｏｌＴｙｐｅ枚　

举规定了Ｓｏｃｋｅｔ实例所使用的协议，最常用的是ＴＣＰ和ＵＤＰ。　

Ｓｏｃｋｅｔ实际上是平台无关的，它支持多种地址集、多种Ｓｏｃｋｅｔ　

Ｈｊ　Ｉｎｔｅｒａｃｔ协议簇来进行通信。　

Ｓｏｃｋｅｔ有两种不同的类型：流Ｓｏｃｋｅｔ和数据报Ｓｏｃｋｅｔ　应　

类型、多种传输层协议。一般网络编程中，最常用的是基于　

ＩｎｔｅｒＮｅｔｗｏｒｋ地址集中的Ｄｇｒａｍ类型的ＵＤＰ协议方式和Ｓｔｒｅａｍ　

用程序一般在同一类型Ｓｏｃｋｅｔ之间进行通信。当然，只要底层　

的通信协议允许，不同类型的Ｓｏｃｋｅｔ之间也可以通信。　

要通过互联网进行通信，至少需要一对Ｓｏｃｋｅｔ，一个运行　

于客户端（Ｃｌｉｅｎｔ　Ｓｏｃｋｅｔ１，另一个运行于服务器端（Ｓｅｒｖｅｒ　

类型的ＴＣＰ协议方式。　

１．２　网络编程　

Ｓｏｃｋｅｔ不仅有阻塞与非阻塞之分．还允许同步或异步方　

式进行操作。　

Ｃｌｉｅｎｔ）。根据连接启动的方式以及本地Ｓｏｃｋｅｔ要连接的目标，　

Ｓｏｃｋｅｔ之间的连接过程可以分为３个步骤：　

所谓同步方式，就是发送方发送数据分组之后，无需等待　

接收方响应。就接着发送下一个数据分组。异步方式是指当发　

送方发送一个数据分组之后，一直等待接收方响应后，才接着　

发送下一个数据分组。　

同步Ｓｏｃｋｅｔ是指在客户端或服务器上执行连接、发送、接　

收等操作时．服务器或客户端将会暂停工作。这种编程方式简　

（１）服务器监听：Ｓｅｒｖｅｒ　Ｓｏｃｋｅｔ处于等待连接的状态，实　

时监控网络状态，并不定位于具体的客户端　

（２）客户端请求：Ｃｌｉｅｎｔ　Ｓｏｃｋｅｔ发起连接请求，要连接的　

目标是Ｓｅｒｖｅｒ　Ｓｏｃｋｅｔ。为此，它首先需要描述目标Ｓｏｃｋｅｔ（网　

络地址及端［＿＝１号）　

（３）连接确认，是指当Ｓｅｒｖｅｒ　Ｓｏｃｋｅｔ监听到Ｃｌｉｅｎｔ　Ｓｏｃｋｅｔ　

单，适用于简单网络程序。但在高频度的网络操作应用中，就　

需要使用异步通信机制。对于服务器端，在同步操作过程中，　

』、，一个Ｓｏｃｋｅｔ处于Ｌｉｓｔｅｎ状态时．它可以调用Ａｃｃｅｐｔ方法来接　

的连接请求，它就启动一个新的线程，将自身属性发送到客户　

端。客户端一旦确认此属性，Ｓｏｃｋｅｔ连接就可以建立。　

．

收远程客户端的连接请求，而在连接请求到来之前，它一直运　

行在等待状态。当连接请求到来之后，该方法会返回一个与客　

户端相连接的Ｓｏｃｋｅｔ。显然，这种模式降低了网络的负载压　

力。因为服务器程序有一个同步Ｓｏｃｋｅｔ在侦听时，程序就处　

ＮＥＴ架构提供了一个功能强大的套接字接口：Ｓｏｃｋｅｔ．用　

于创建一个受控版本的网络传输服务。在Ｓｏｃｋｅｔ创建之后，就　

可以将其与一个地址及端口绑定起来。通过Ｃｏｎｎｅｃｔ方法与终　

５６　电　品与雏　

Ｎ盯ＷＯＲＫ＆Ｃ０硼啊Ｕ＿ｌＣ盯ｉＯＮ”　…　…　…　……　…　－　…　－…　一…　ｕ　…　－　”………　…　

于暂停状态，无法再建立一个同步的Ｓｏｃｋｅｔ侦听或进行其他　

操作。对于网络操作负荷较大的程序，此时就需要异步Ｓｏｃｋｅｔ　

操作。　

异步Ｓｏｃｋｅｔ可以在侦听的同时进行其他操作。对于服务器　

端的异步Ｓｏｃｋｅｔ来说．它需要一个方法开始接受网络连接请　

求；一个回调函数用于处理连接请求并从网络中接收数据；一　

个回调函数用于终止接收数据。异步Ｓｏｃｋｅｔ使用ＢｅｇｉｎＡｃｃｅｐｔ　

方法接收新的连接请求。它有两个参数：一个是ＡｓｙｎｃＣａｌｌｂａｃｋ　

类型的委托。一个是ｏｂｊｅｃｔ类型的传送状态信息。当一个新的　

连接请求到来时．ＢｅｇｉｎＡｃｃｅｐｔ方法中的回调函数就会被调用，　

负责获取连接的Ｓｏｃｋｅｔ实例，并把它交给处理请求的线程。异　

步Ｓｏｃｋｅｔ使用系统线程池来处理连接，一个线程负责处理连　

接．另一个线程负责接收连接，还有一个线程用于数据传输。　

线程之间可以使用Ｓｙｓｔｅｍ．Ｔｈｒｅａｄｉｎｇ．ＭａｎｕａｌＲｅｓｅｔＥｖｅｎｔ来终止主　

线程或在运行时通知主线程。　

阻塞套接字是指调用此Ｓｏｃｋｅｔ对象执行网络操作时．直　

到调用成功才返回，否则此对象就一直阻塞此操作上。而非阻　

塞套接字是指在调用此Ｓｃｏｋｅｔ对象执行网络操作时，不管是否　

执行成功．都立即返回　比如，调用ＳｔｒｅａｍＲｅａｄｅｒ类的　

ＲｅａｄＬｉｎｅ方法读取网络缓冲区中的数据，对于阻塞方式，如果　

调用的时候数据没有到达，则此方法一直挂在调用状态，直到　

成功读取数据，此函数才返回；对于非阻塞方式，不管数据是　

否到达，都立即返回，而不会一直挂在此函数调用上。　

在Ｗｉｎｄｏｗｓ网络通信软件开发技术中，异步非阻塞套接　

字，比如常见的Ｃ／Ｓ软件结构就是这种类型。在Ｃ＃网络编程　

中，并不需要深入理解同步、异步、阻塞和非阻塞的原理和机　

制．因为．ＮＥＴ架构已经将它们完美地封装了起来。　

１．３　网络流　

在网络通信中，流是～个用于传输数据的对象。数据传输　

有两个方向：ｏ１如果数据从外部源传输到应用程序中，则为　

读取流；ｏ２如果数据从应用程序传输到外部源中，即为写人　

流。其中，外部源可以是文件、网络、管道或内存区域。流对　

外部数据源不做任何假设。通常．应尽可能地使用一个独立的　

对象来传输数据，这样可以将数据传输过程和数据源分离，更　

容易切换数据源。　

对于这些流的操作，．ＮＥＴ框架提供了基类Ｓｙｓｔｅｍ．ＩＯ．　

ＭｅｍｏｒｙＳｔｒｅａｍ读写内存数据：基类Ｓｙｓｔｅｍ．Ｎｅｔ．Ｓｏｃｋｅｔｓ．Ｎｅｔｗｏｒｋ　

Ｓｔｒｅａｍ处理网络数据：管道数据的读写没有相应的流基类，需　

要开发人员编写一个继承自Ｓｙｓｔｅｍ．ＩＯ．Ｓｔｒｅａｍ的自定义类。　

在．ＮＥＴ网络编程中ＮｅｔｗｏｒｋＳｔｒｅａｍ是经常用到的类，它实　

现了标准的流机制。它主要提供了以下功能：ｏ１一组统一的　

读写网络数据的ＡＰＩ；ｏ２兼容其他．ＮＥＴ流，便于移植；ｏ３　

数据实时处理．避免应用程序被动等待数据。ＮｅｔｗｏｒｋＳｔｒｅａｍ　

的操作源是网络，所以它不支持随机访问。它的ＣａｎＳｅｅｋ属性　

值永远是Ｆａｌｓｅ。读取Ｐｏｓｉｔｉｏｎ属性或调用Ｓｅｅｋ方法会返回一　

个ＮｏｔＳｕｐｐ０ｒｔｅｄＥｘｃｅｐｔｉ０ｎ异常。　

对于更高层的操作，例如基于ＨＴＦＰ协议的操作．可以不　

使用Ｓｏｃｋｅｔ来构建ＮｅｔｗｏｒｋＳｔｒｅａｍ对象。例如，在基于浏览器　

的网络应用中．可以使用ＷｅｂＲｅｑｕｅｓｔ对象实例中的ＧｅｔＲｅｑｕｅｓｔ　

Ｓｔｒｅａｍ发送数据报文头部并返回相应的流对象，然后就可以调　

用ＢｅｇｉｎＷｒｉｔｅ、Ｗｒｉｔｅ、ＥｎｄＷｒｉｔｅ方法进行数据发送：可以使用　

ＷｅｂＲｅｓｐｏｎｓｅ对象实例的ＧｅｔＲｅｓｐｏｎｓｅＳｔｒｅａｍ方法获取网络流，　

然后调用ＢｅｇｉｎＲｅａｄ、Ｒｅａｄ、ＥｎｄＲｅａｄ接收数据。　

除了使用Ｒｅａｄ、Ｗｒｉｔｅ方法，还可以使用ＳｔｒｅａｍＲｅａｄｅｒ、　

ＳｔｒｅａｍＷｒｉｔｅｒ等方法进行数据读写。这些对象包含了流数据的　

编码和解码等内容，操作更方便。　

１．４　ＩＰ地址与ＤＮＳ解析　

Ｓｙｓｔｅｍ．Ｎｅｔ空间提供了一些与网络基本操作息息相关的类。　

比较重要的是ＩＰＡｄｄｒｅｓｓ、Ｄｎｓ、ＩＰＨｏｓｔＥｎｔｒｙ、ＩＰＥｎｄＥｎｔｒｙ。　

ＩＰＡｄｄｒｅｓｓ类是一个描述ＩＰ地址的类。它的静态方法Ｐａｒｓｅ　

及ＴｒｙＰａｒｓｅ可以将一个ＩＰ地址字符串实例化为一个ＩＰＡｄｄｒｅｓｓ　

对象。Ｄｎｓ类是一个提供有关域名解析操作的静态类。它将从　

网络域名系统中获取ＩＰ地址、主机名以及域名的对应关系，　

并将这些信息保存在一个ＩＰＨｏｓｔＥｎｔｒｙ对象中。ＩＰＨｏｓｔＥｎｔｒｙ的　

主要属性成员有ＡｄｄｒｅｓｓＬｉｓｔ、Ａｌｉａｓｅｓ和ＨｏｓｔＮａｍｅ分别保存主　

机的ＩＰ地址、别名和域名。ＩＰＥｎｄＰｏｉｎｔ类表示一个连接端点，　

即ＩＰ地址加上端口号构成的一个绑定。　

１．５网络编码与解码　

由于使用多种编程语言开发的应用程序及多种支撑平台在　

网络这个混合体上运行，并且网络中有多种编码方法：ＡＳＣＩＩ、　

Ｕｎｉｃｏｄｅ、Ｕ　ｒＦ７、ｕＴＦ８、Ｂｉｇ—Ｅｎｄｉａｎ等，因此网络编程中经常　

要遇到编码、解码的操作。这种现状需要一种将系统内码转换　

成网络编码的机制，以便应用程序能够准确地读写数据。．ＮＥＴ　

架构的Ｓｙｓｔｅｍ．Ｔｅｘｔ．Ｅｎｃｏｄｉｎｇ类提供这种功能。　

Ｅｎｃｏｄｉｎｇ类提供了字符串、Ｕｎｉｃｏｄｅ字符集和相应编码的　

字节数组之间的转换（转换的数据必须连续）。事实上，应用程　

序一般使用Ｅｎｃｏｄｅｒ和Ｄｅｃｏｄｅｒ来进行转换。Ｅｎｃｏｄｉｎｇ类包含　

常用编码的实例。开发者还可以在Ｅｎｃｏｄｅｒ和Ｄｅｃｏｄｅｒ的基础　

上编写自定义的编码和解码类来处理大量的数据转换工作。　

２基于ＴＣＰ的Ｃ／Ｓ结构实时通信系统的实现　

２．１　系统分析　

即时通信系统的总体目标是为企业用户提供一个简单便　

利、低成本的即时通信工具。通过与相关人员进行充分沟通，　

确定本系统至少需要具备客户端与服务器端两个通信模块。各　

（１）客户端：客户端是聊天用户使用的主要工具，它提供　

如下功能。　

个模块的功能特性如下：

ＮＥＴＷＯＲＫ＆ＣＤ啊啊Ⅱ一ＩＩ　盯ＩＯＮ　

ＰｒｉｓｍＣｏｎｎｅｃｔｉｏｎ直接派生自Ｃｏｍｐｏｎｅｎｔ类。限于篇幅，下　

面从几个侧面介绍该组件的具体实现。　

２．３．１．１开启到服务器端的连接　

要开肩新的连接．只需要设置ＰｒｉｓｍＣｏｎｎｅｃｔｉｏｎ组件的　

Ａｃｔｉｖｅ属性为Ｔｒｕｅ即可激活它，并触发一系列事件。在Ａｃｔｉｖｅ　

内部定义中．它首先创建一个ＴｃｐＣｌｉｅｎｔ实例，并连接到由　

Ｈｏｓｔ和Ｐｏｒｔ指定的对象，进而将该ＴｃｐＣｌｉｅｎｔ实例作为参数构　

建一个新的ＰｒｉｓｍＮｅｔｗｏｒｋＳｔｒｅａｍ类。该属性还开启了一个单独　

的后台线程。下面的代码定义了Ａｃｔｉｖｅ属性：　

ｐｕｂｌｉｃ　ｂｏｏｌ　Ａｃｔｉｖｅ　

｛　

ｇｅｔ｛ｒｅｔｕｒｎ＿ａｃｔｉｖｅ；）　

ｓｅｔ　

｛　

ｉｆ（

＿

ａｃｔｉｖｅ！＝ｖａｌｕｅ）　

ｆ　

ｉｆ《ｖａｌｕｅ）　

（　

＿

ｃｌｉｅｎｔＳｏｃｋｅｔ＝ｎｅｗ　ＴｃｐＣｌｉｅｎｔ０；　

一

ｃｌｉｅｎｔＳｏｃｋｅｔ．Ｃｏｎｎｅｃｔ（Ｈｏｓｔ，Ｐｏｒｔ）；　

＿

ａｃｔｉｖｅ＝ｔｒｕｅ；　

一

ｓｔｒｅａｍ＝ｎｅｗ　ＰｒｉｓｍＮｅｔｗｏｒｋＳｔｒｅａｍ（＿ｃｌｉｅｎｔＳｏｃｋｅｔ）；　

一

ｒｅａｄｅｒＴｈｒｅａｄ＝ｎｅｗ　Ｔｈｒｅａｄ（ＥｘｅｃｕｔｅＲｅａｄｅｒＴｈｒｅａｄ）；　

一

ｒｅａｄｅｒＴｈｒｅａｄ．ＩｓＢａｃｋｇｒｏｕｎｄ＝ｔｒｕｅ；　

——

ｒｅａｄｅｒＴｈｒｅａｄ．Ｓｔａｒｔ（）；　

）　

ｅｌｓｅ　

｛　

ｔｒｖ　

｛　

——

ｓｔｒｅａｍ．Ｃｌｏｓｅ（）；　

）　

ｃａｔｃｈ　

（】　

ａｃｔｉｖｅ＝ｖａｌｕｅ；

Ｉｏｇｇｅｄｌｎ＝ｆａｌｓｅ；　

一

．ｆ（Ｄｉｓｃｏｎｎｅｃｔｅｄ！＝ｎｕｌ１）　

ＤｉｓｃＯｎｎｅｃｔｅｄ“ｈｉｓ，ｎｅｗ　ＥｖｅｎｔＡｒｇｓ０）；　

）　

）　

）　

）　

２．３．１．２后台线程读取通信命令　

Ａｖｔｉｖｅ中的后台线程执行ＥｘｅｃｕｔｅＲｅａｄｅｒＴｈｒｅａｄ方法来侦　

听来自ＮｅｔｗｏｒｋＳｔｒｅａｍ中的数据，并对命令进行解析。下面的　

代码实现了该核心方法：　

ｐｒｉｖａｔｅ　ｖｏｉｄ　ＥｘｅｃｕｔｅＲｅａｄｅｒＴｈｒｅａｄ（）　

｛　

Ｌｉｓｔ＜ｓｔｒｉｎｇ＞ｔｏｋｅｎＬｉｓｔ＝ｎｅｗ　Ｌｉｓｔ＜ｓｔｒｉｎｇ＞０；　

ｓｔｒｉｎｇ　ｃｏｍｍａｎｄ；　

ｓｔｎｎｇ　ｓ：　

ＰｒｉｓｍＵｓｅｒ　ｕｓｅｒ；　

ｗｈｉｌｅ（Ａｃｔｉｖｅ）　

｛　

ｔｒＶ　

（　

ｃｏｍｍａｎｄ＝

一

ｓｔｒｅａｍ．ＲｅａｄＴｏｋｅｎｓ（ｔｏｋｅｎＬｉｓｔ）　

）　

ｃａｔｃｈ　

｛　

Ａｃｔｉｖｅ＝ｆａｌｓｅ；ｂｒｅａｋ；　

）　

ｓｗｉｔｃｈ（ｃｏｍｍａｎｄ）　

｛　

ｃａｓｅ”ＰＩ　ＮＧ”：　

ＷｒｉｔｅＴｏｋｅｎｓ（　ＰＩＮＧ“）　

ｂｒｅａｋ；　

ｃａｓｅ“ＬＯＧＩＮＥＲＲＯＲ“：　

ｉｆ（ＬｏｇｉｎＥｒｒｏｒ　ｌ＝ｎｕｌ１）　

ＬｏｇｉｎＥｒｒｏｒ（ｔｈｉｓ，ｎｅｗ　ＭｅｓｓａｇｅＥｖｅｎｔＡｒｇｓ（ｔｏｋｅｎＬｉｓｔ【０】））：　

ｂｒｅａｋ；　

ｃａｓｅ“ＬＯＧｌＮＯＫ”：　

一

ｕｓｅｒ＝ｎｅｗ　Ｐｒｉｓｍ　Ｕｓｅｒ０；　

ｓｔｒｉｎｇ　Ｔｏｋｅｎ＝ｔｏｋｅｎＬｉｓｔ［０］；　

——

ｕｓｅｒ．ＦｒｏｍＳｔｒｉｎｇ（ｒｅｆ　Ｔｏｋｅｎ）；　

一

Ｉｏｇｇｅｄｌｎ＝ｔｒｕｅ；　

ｉｆ（ＬｏｇｉｎＯＫ！＝ｎｕｌ１）　

ＬｏｇｉｎＯＫ（ｔｈｉｓ，ｎｅｗ　ＥｖｅｎｔＡｒｇｓ０）；　

．ｆ（ＲｏｏｍＡｄｄｅｄ！：ｎｕｌ１）　

｛　

ｓｔｒｉｎｇ　Ｒｏｏｍｓ＝ｔｏｋｅｎＬｉｓｔ［１】：　

ｗｈｉｌｅ（Ｒｏｏｍｓ！＝””）　

｛　

Ｓ＝Ｔｏｋｅｎｉｚｅｒ．ＧｅｔＴｏｋｅｎ（ｒｅｆ　Ｒｏｏｍｓ）；　

ＲｏｏｍＡｄｄｅｄ（ｔｈｉｓ，ｎｅｗ　ＲｏｏｍＮａｍｅＥｖｅｎｔＡｒｇｓ（ｓ））；　

）　

）　

ｂｒｅａｋ；　

ｃａｓｅ‘‘ＥＲＲＯＲ　‘　：

ｉｆ（Ｐ　ｒｉｓｍＥｒｒＯｒ！＝ｎｕｌ１）　

ＰｒｊｓｍＥｒｒ０ｒ（ｔｈｉｓ，ｎｅｗ　ＭｅｓｓａｇｅＥｖｅｎｔＡｒｇｓ（ｔｏｋｅｎＬｉｓｔ［Ｏ］））；　

ｂｒｅａｋ；　

ｃａｓｅ　ＪＯＩＮＲＯＯＭ　：　

—　

ｕｓｅｒＬｉｓｔ。Ｃｌｅａｒ（）；　

～

ｒｏｏｍＮａｍｅ＝ｔｏｋｅｎＬｉｓｔ［０］；　

ｉｆ（ＪｏｉｎｅｄＲｏｏｍ　ｌ＝ｎｕｌ１）　

ＪｏｉｎｅｄＲｏｏｍ（ｔｈｉｓ，ｎｅｗ　ＲｏｏｍＮａｍｅＥｖｅｎｔＡｒｇｓ（＿ｒｏｏｍＮａｍｅ））　

ｓｔｒｉｎｇ　ＵｓｅｒＳｔｒｉｎｇ＝ｔｏｋｅｎＬｉｓｔ［１】：　

ｗｈｉｌｅ（ＵｓｅｒＳｔｒｉｎｇ！＝“　）　

｛　

Ｓ＝Ｔｏｋｅｎｉｚｅｒ．ＧｅｔＴｏｋｅｎ（ｒｅｆ　ＵｓｅｒＳｔｒｉｎｇ）；　

ｕｓｅｒ＝ｎｅｗ　ＰｒｉｓｍＵｓｅｒ０；　

－确器　５９—　

实用第一智慧密集　

ｕｓｅｒ．Ｆｒ０ｍＳ　ｎｇ（ｒｅｆ　ｓ）：　

．ｆ（ｕｓｅｒ．ＵｓｅｒＮａｍｅ＝：ＴｈｉｓＵｓｅｒ．ＵｓｅｒＮａｍｅ）　

｛　

Ｓ＝ｕｓｅｒ．ＴｏＳｔｒｉｎｇ０；　

ＴｈｉｓＵｓｅｒ．ＦｒｏｍＳｔｒｉｎｇ（ｒｅｆ　ｓ）：　

ｕｓｅｒ＝ＴｈｉｓＵｓｅｒ；　

）　

——

ｕｓｅｒＬｉｓｔ．Ａｄｄ（ｕｓｅｒ）；　

＿ｆ（ＵｓｅｒＡｄｄｅｄＴｏＲｏｏｍ！＝ｎｕｌ１）　

ＵｓｅｒＡｄｄｅｄＴｏＲｏｏｍ（ｔｈｉｓ，ｎｅｗ　ＰｒｉｓｍＵｓｅｒＥｖｅｎｔＡｒｇｓ（ｕｓｅｒ））；　

｝　

ｂｒｅａｋ；　

ｃａｓｅ‘‘ＥＮＴＥＲＲＯＯＭ”：　

Ｓ＝ｔｏｋｅｎＬｉｓｔ［０］；　

ｕｓｅｒ＝ｎｅｗ　ＰｒｉｓｍＵｓｅｒＯ；　

ｕｓｅｒ．ＦｒｏｍＳｔ　ｇ（ｒｅｆ　ｓ）：　

——

ｕｓｅｒＬｉｓｔ．Ａｄｄ（ｕｓｅｒ）；　

．ｆ（ＵｓｅｒＡｄｄｅｄＴｏＲｏｏｍ！＝ｎｕｌ１）　

ＵｓｅｒＡｄｄｅｄＴｏＲｏｏｍ（ｔｈｉｓ，Ｎｅｗ　ＰｒｉｓｍＵｓｅｒＥｖｅｎｔＡｒｇｓ（ｕｓｅｒ））；　

ｂｒｅａｋ；　

ｃａｓｅ”ＬＥＡＶＥＲＯＯＭ“：　

ｕｓｅｒ：ＦｉｎｄＵｓｅｒ（ｔｏｋｅｎＬｉｓｔ｛Ｏ１）：　

ｉｆ（ｕｓｅｒ！＝ｎｕｌ１）　

｛　

．ｆ（ＵｓｅｒＬｅｆｔＲｏｏｍ！＝ｎｕｌ１）　

ＵｓｅｒＬｅｆｔＲｏｏｍ（ｔｈｉｓ，ｎｅｗ　ＰｒｉｓｍＵｓｅｒＥｖｅｎｔＡｒｇｓ（ｕｓｅｒ））　

—

ｕｓｅｒＬｉｓｔ　Ｒｅｍｏｖｅ（ｕｓｅｒ）；　

）　

ｂｒｅａｋ；　

ｃａｓｅ“ＲＯＯＭＣＯＵＮＴＣＨＡＮＧＥ“：　

ｉｆ（ＲｏｏｍＣｏｕｎｔＣｈａｎｇｅｄ！＝ｎｕｌ１）　

｛　

ｓｔｒｉｎｇ　ｒｏｏｍＮａｍｅ＝ｔｏｋｅｎＬｉｓｔ［０］；　

ｉｎｔ　ｃｏｕｎｔ＝Ｉｎｔ３２．Ｐａｒｓｅ｛ｔｏｋｅｎＬｉｓｔ【１】）：　

ＲｏｏｍＣｏｕｎｔＣｈａｎｇｅｄ（ｔｈｉｓ，ｎｅｗ　ＲｏｏｍＣｏｕｎｔＥｖｅｎｔＡｒｇｓ　

《ｒｏｏｍＮａｍｅ．ｃｏｕｎｔ））；　

｝　

ｂｒｅａｋ；　

ｃａｓｅ”ＳＴＡＲ丁”：　

ｉｆ（ＳｔａｒｔＳｉｇｎａ　ｒ！＝ｎｕｌ１）　

ＳｔａｒｔＳｉｇｎａｌ（ｔｈｉｓ，ｎｅｗ　ＥｖｅｎｔＡｒｇｓ０）；　

ｂｒｅａｋ；　

ｃａｓｅ”ＲＯＯＭＲＥＭＯＶＥＤ”：　

ｉｆ（ＲｏｏｍＲｅｍｏｖｅｄ！＝ｎｕＩ『）　

ＲｏｏｍＲｅｍｏｖｅｄ（ｔｈｉｓ，ｎｅｗ　ＲｏｏｍＮａｍｅＥｖｅｎｔＡｒｇｓ　

ｌｔＯｋｅｎＬｉｓｔ【０　

ｂｒｅａｋ；　

ｃａｓｅ”ＲＯＯＭＡＤＤＥＤ“：　

ｉｆ（ＲｏｏｍＡｄｄｅｄ！＝ｎｕｌ１）　

ＲｏｏｍＡｄｄｅｄ（ｔｈｉｓ，ｎｅｗ　ＲｏｏｍＮａｍｅＥｖｅｎｔＡｒｇｓ（ｔｏｋｅｎＬｉｓｔ［０］））；　

ｂｒｅａｋ；　

ｃａｓｅ“ＣＨＡＴ“：　

ｕｓｅｒ＝ＦｉｎｄＵｓｅｒ（ｔｏｋｅｎＬｉｓｔ【０】）：　

ｉｆ（ｕｓｅｒ！＝ｎｕｌ１）　

ｉｆ（ＣｈａｔＭｅｓｓａｇｅＲｅｃｅｉｖｅｄ！＝ｎｕｌ１）　

ＣｈａｔＭｅｓｓａｇｅＲｅｃｅｉｖｅｄ（ｔｈｉｓ．　

ｎｅｗ　ＰｒｉｓｍＵｓｅｒＭｅｓｓａｇｅＥｖｅｎｔＡｒｇｓ（ｕｓｅｒ，ｔｏｋｅｎＬｉｓｔ［１】））＝　

ｂｒｅａｋ；　

ｃａｓｅ“ＤＡ－『＿Ａ“：　

ｕｓｅｒ＝ＦｉｎｄＵｓｅｒ（ｔｏｋｅｎＬｉｓｔ［０】）：　

ｉｆ（ｕｓｅｒ！＝ｎｕｌ１）　

ｉｆ（ＤａｔａＭｅｓｓａｇｅＲｅｃｅｉｖｅｄ！：ｎｕｌ１）　

ＤａｔａＭｅｓｓａｇｅＲｅｃｅｉｖｅｄ（ｔｈｉｓ，　

ｎｅｗ　ＰｒｉｓｍＵｓｅｒＭｅｓｓａｇｅＥｖｅｎｔＡｒｇｓ（ｕｓｅｒ，ｔｏｋｅｎＬｉｓｔ［１】））＝　

ｂｒｅａｋ；　

ｃａｓｅ”ＵＳＥＲＩＮＦＯＣＨＡＮＧＥ”：　

Ｓ＝ｔｏｋｅｎＬｉｓｔ［０］；　

ｕｓｅｒ：ｎｅｗ　ＰｒｉｓｍＵｓｅｒ０；　

ｕｓｅｒ．ＦｒＯｍＳｔ　ｇ（ｒｅｆ　ｓ）：　

ＰｒｉｓｍＵｓｅｒ　ｍａｔｃｈｉｎｇＵｓｅｒ＝ＦｉｎｄＵｓｅｒ（ｕｓｅｒ．ＵｓｅｒＮａｍｅ）；　

ｉｆ（ｍａｔｃｈｉｎｇＵｓｅｒ！＝ｎｕｌ１）　

｛　

Ｓ＝ｔｏｋｅｎＬｉｓｔ［０］；　

ｍａｔｃｈｉｎｇＵｓｅｒ．ＦｒＯｍＳ　ｎｇ（ｒｅｆ　ｓ）；　

．ｆ（ＵｓｅｒＩｎｆｏＣｈａｎｇｅｄ！：ｎｕｌ１）　

ＵｓｅｒＩｎｆＯＣｈａｎｇｅｄ　（ｔｈｉｓ，ｎｅｗ　ＰｒｉｓｍＵｓｅｒＥｖｅｎｔＡｒｇｓ　

（ｍａｔｃｈｉｎｇＵｓｅｒ））：　

）　

ｂｒｅａｋ；　

ｃａｓｅ“ＳＥＲＶＥＲＳＴＡＴＳ“：　

ｊｆ｛ＳｅｒｖｅｒＳｔａｔｓＲｅｃｅｉｖｅｄ！＝ｎｕｌ１）　

（　

ｓｔｒｉｎｇ　ＳｔａｔＳｔｒｉｎｇ＝ｔｏｋｅｎＬｉｓｔ［Ｏ］；　

ＰｒｉｓｍＳｅｒｖｅｒＳｔａｔｓ　ｓｔａｔｓ＝ｎｅｗ　ＰｒｉｓｍＳｅｒｖｅｒＳｔａｔｓ（ｒｅｆ　

ＳｔａｔＳｔｒｉｎｇ）；　

ＳｅｒｖｅｒＳｔａｔｓＲｅｃｅｉｖｅｄ　Ｉｔｈｉｓ，ｎｅｗ　ＰｒｉｓｍＳｅｒｖｅｒＳｔａｔｓＥｖｅｎｔＡｒｇｓ　

（ｓｔａｔｓ））；　

）　

ｂｒｅａｋ；　

ｃａｓｅ”ＡＤＭＩＮＭＳＧ”：　

ｉｆ（ＡｄｍｉｎＭｅｓｓａｇｅＲｅｃｅｉｖｅｄ！＝ｎｕｌｌ１　

ＡｄｍｉｎＭｅｓｓａｇｅＲｅｃｅｉｖｅｄ（ｔｈｉｓ，ｎｅｗ　

ＭｅｓｓａｇｅＥＶｅｎｔＡｒｇｓ（ｔｏｋｅｎＬｉｓｔ１０】））：　

ｂｒｅａｋ；　

ｃａｓｅ“ＣＵＳＴＯＭ”：　

ｉｆ（ＣｕｓｔｏｍＣｏｍｍａｎｄＲｅｃｅｉｖｅｄ！：ｎｕｌ『）　

ＣｕｓｔｏｍＣｏｍｍａｎｄＲｅｃｅｉｖｅｄ（ｔｈｉｓ，　

ｎｅｗ　ＣｕｓｔｏｍＣｏｍｍａｎｄＥｖｅｎｔＡｒｇｓ｛ｔｏｋｅｎＬｉｓｔ　

【０】，ｔｏｋｅｎＬｉｓｔ［１　

ｂｒｅａｋ；　

ｃａｓｅ“ＬＡＴＥＮＣＹ“：　

ｓｔｒｉｎｇ　ｕｓｅｒＮａｍｅ＝ｔｏｋｅｎＬｉｓｔ［０］；　

ｉｎｔ　ｌａｔｅｎｃｙ：Ｉｎｔ３２．Ｐａｒｓｅ（ｔｏｋｅｎＬｉｓｔ［１　１）：　

Ｉｏｃｋ（ｕｓｅｒＬｉｓｔ）　

……．

ＮＥＴＷＯＲＫ＆ｅ０啊ＭＵＮＩＯ盯ＩＯＮ　

ｆｏｒｅａｃｈ（ＰｒｉｓｍＵｓｅｒ　Ｕ　ｉｎ　ｕｓｅｒＬｉｓｔ）　

ｊｆ　ｆＵ．ＵｓｅｒＮａｍｅ＝＝ｕｓｅｒＮａｍｅ）　

｛　

ｕ．ＬａｔｅｎｃｙＭＳ＝ｌａｔｅｎｃｙ；　

；ｆ　ｆＵｓｅｒＬａｔｅｎｃｙＵｐｄａｔｅｄ！＝ｎｕｌ１）　

ＵｓｅｒＬａｔｅｎｃｙＵｐｄａｔｅｄ（ｔｈｉｓ．ｎｅｗ　

ＰｒｉｓｍＵｓｅｒＥｖｅｎｔＡｒｇｓ（ｕ））：　

ｂｒｅａｋ；　

）　

ｂｒｅａｋ；　

）　

Ｔｈｒｅａｄ．Ｓｌｅｅｐ（１　Ｏ）：　

｝　

）　

２．３．１．３客户端基于服务器不同命令的处理事件　

ＥｘｅｃｕｔｅＲｅａｄｅｒＴｈｒｅａｄ方法将会触发多种事件，允许客户端　

根据接收到的命令执行不同的事件。这些事件允许客户端应用程　

序进行用户界面的信息更新。下面的代码定义了各种事件句柄：　

ｐｕｂｌｉｃ　ｅｖｅｎｔ　ＥｖｅｎｔＨａｎｄｌｅｒ＜ＥｖｅｎｔＡｒｇｓ＞Ｄｉｓｃｏｎｎｅｃｔｅｄ；　

ｐｕｂｌｉｃ　ｅｖｅｎｔ　ＥｖｅｎｔＨａｎｄｌｅｒ＜ＥｖｅｎｔＡｒｇｓ＞ＬｏｇｉｎＯＫ；　

ｐｕｂｌｉｃ　ｅｖｅｎｔ　ＥｖｅｎｔＨａｎｄｌｅｒ＜ＭｅｓｓａｇｅＥｖｅｎｔＡｒｇｓ＞ＬｏｇｉｎＥｒｒｏｒ；　

ｐｕｂｌｉｃ　ｅｖｅｎｔ　ＥｖｅｎｔＨａｎｄｌｅｒ＜ＭｅｓｓａｇｅＥｖｅｎｔＡｒｇｓ＞ＰｒｉｓｍＥｒｒＯｒ：　

ｐｕｂｌｉｃ　ｅｖｅｎｔ　ＥｖｅｎｔＨａｎｄｌｅｒ＜ＰｒｉｓｍＵｓｅｒＥｖｅｎｔＡｒｇｓ　＞　

ＵｓｅｒＡｄｄｅｄＴｏＲｏｏｍ；　

ｐｕｂｌｉｃ　ｅｖｅｎｔ　ＥｖｅｎｔＨａｎｄｌｅｒ＜ＰｒｉｓｍＵｓｅｒＥｖｅｎｔＡｒｇｓ　＞　

ＵｓｅｒＬｅｆｔＲｏｏｍ；　

ｐｕｂｌｉｃ　ｅｖｅｎｔ　ＥｖｅｎｔＨａｎｄ　Ｊｅｒ＜ＲｏｏｍＮａｍｅＥｖｅｎｔＡｒｇｓ　＞　

ＪｏｉｎｅｄＲｏｏｍ；　

ｐｕｂｌｉｃ　ｅｖｅｎｔ　ＥｖｅｎｔＨａｎｄＩｅｒ＜ＥｖｅｎｔＡｒｇｓ＞ＳｔａｒｔＳｉｇｎａｌ；　

ｐｕｂｌｉｃ　ｅｖｅｎｔ　ＥｖｅｎｔＨａｎｄｌｅｒ＜ＲｏｏｍＮａｍｅＥｖｅｎｔＡｒｇｓ＞　

ＲｏｏｍＲｅｍｏｖｅｄ；　

ｐｕｂｌｉｃ　ｅｖｅｎｔ　ＥｖｅｎｔＨａｎｄｌｅｒ＜ＲｏｏｍＮａｍｅＥｖｅｎｔＡｒｇｓ＞　

ＲｏｏｍＡｄｄｅｄ；　

ｐｕｂｌｉｃ　ｅｖｅｎｔ　ＥｖｅｎｔＨａｎｄｌｅｒ＜ＰｒｉｓｍＵｓｅｒＭｅｓｓａｇｅＥｖｅｎｔＡｒｇｓ＞　

ＣｈａｔＭｅｓｓａｇｅＲｅｃｅｉｖｅｄ；　

ｐｕｂｌｉｃ　ｅｖｅｎｔ　ＥｖｅｎｔＨａｎｄｌｅｒ＜ＰｒｉｓｍＵｓｅｒＭｅｓｓａｇｅＥｖｅｎｔＡｒｇｓ＞　

ＤａｔａＭｅｓｓａｇｅＲｅｃｅｉｖｅｄ；　

ｐｕｂｌｉｃ　ｅｖｅｎｔ　ＥｖｅｎｔＨａｎｄｌｅｒ＜ＰｒｉｓｍＵｓｅｒＥｖｅｎｔＡｒｇｓ　＞　

ＵｓｅｒｌｎｆｏＣｈａｎｇｅｄ；　

ｐｕｂｌｉｃ　ｅｖｅｎｔ　ＥｖｅｎｔＨａｎｄｌｅｒ＜ＰｒｉｓｍＳｅｒｖｅｒＳｔａｔｓＥｖｅｎｔＡｒｇｓ＞　

ＳｅｒｖｅｒＳｔａｔｓＲｅｃｅｉｖｅｄ；　

ｐｕｂｌｉｃ　ｅｖｅｎｔ　ＥｖｅｎｔＨａｎｄｌｅｒ＜ＭｅｓｓａｇｅＥｖｅｎｔＡｒｇｓ　＞　

ＡｄｍｉｎＭｅｓｓａｑｅＲｅｃｅｉｖｅｄ：　

ｐｕｂｌｉｃ　ｅｖｅｎｔ　ＥｖｅｎｔＨａｎｄｌｅｒ＜ＣｕｓｔｏｍＣｏｍｍａｎｄＥｖｅｎｔＡｒｇｓ＞　

ＣｕｓｔｏｍＣｏｍｍａｎｄＲｅｃｅｉｖｅｄ；　

ｐｕｂｌｉｃ　ｅｖｅｎｔ　ＥｖｅｎｔＨａｎｄｌｅｒ＜ＰｒｉｓｍＵｓｅｒＥｖｅｎｔＡｒｇｓ　＞　

ＵｓｅｒＬａｔｅｎｃｙＵｐｄａｔｅｄ：　

ｐｕｂｌｉｃ　ｅｖｅｎｔ　ＥｖｅｎｔＨａｎｄｌｅｒ＜ＲｏｏｍＣｏｕｎｔＥｖｅｎｔＡｒｇｓ　＞　

ＲｏｏｍＣｏｕｎｔＣｈａｎｇｅｄ；　

２．３．１．４向客户端发送指令　

除了从服务器端读取数据外，ＰｒｉｓｍＣｏｎｎｅｃｔｉｏｎ类也定义了　

向服务器发送指令的若干方法。这种命令收发遵循一定的规　

范。客户端（ＰｒｉｓｍＣｏｎｎｅｃｔｉｏｎ组件）和服务器端组件　

ｆＰｒｉｓｍＳｅｒｖｅｒ组件）都使用一个ＰｒｉｓｍＮｅｔｗｏｒｋＳｔｒｅａｍ类对象来管　

理从连接的Ｓｏｃｋｅｔ读取和写入数据。ＰｒｉｓｍＮｅｔｗｏｒｋＳｔｒｅａｍ负责　

从底层的Ｓｏｃｋｅｔ读取和写入原始字节，ＰｒｉｓｍＳｅｒｖｅｒ使用一个基　

于文本的传输协议在多个客户端之间传递格式化的消息。下面　

的代码实现ＰｒｉｓｍＣｏｎｎｅｅｔｉｏｎ对象调用ＷｒｉｔｅＴｏｋｅｎｓ向服务器端　

发送各种指令：　

ｐｕｂｌｉｃ　ｖｏｉｄ　Ｌｏｇｉｎ（ｓｔｒｉｎｇ　ｕｓｅｒＮａｍｅ，ｓｔｒｉｎｇ　ｐａｓｓｗｏｒｄ）　

（　

ＷｒｉｔｅＴｏｋｅｎｓ　（　“ＬＯＧＩＮ“，　ｕｓｅｒＮａｍｅ，ｐａｓｓｗｏｒｄ，　

ＳｕｂｊｅｃｔＮａｍｅ）：　

｝　

ｐｕｂｌｉｃ　ｖｏｉｄ　ＬｏｇｉｎＮｅｗ（ＰｒｉｓｍＵｓｅｒ　ｎｅｗＵｓｅｒ）　

（　

ＷｒｉｔｅＴｏｋｅｎｓ　（”ＬＯＧｆＮＮＥＷ“，　ｎｅｗＵｓｅｒ．ＴｏＳｔｒｉｎｇ（），　

ＳｕｂｊｅｃｔＮａｍｅ）；　

）　

ｐｕｂｌｉｃ　ｖｏｉｄ　ＥｎｔｅｒＲｏｏｍ（ｓｔｒｉｎｇ　ｒｏｏｍＮａｍｅ）　

（　

ＷｒｉｔｅＴｏｋｅｎｓ（“ＪＯＩＮＲ０ＯＭ“．ｒｏｏｍＮａｍｅ）；　

）　

ｐｕｂｌｉｃ　ｖｏｉｄ　ＣｒｅａｔｅＲｏｏｍ（ｓｔｒｉｎｇ　ｒｏｏｍＮａｍｅ，ｉｎｔ　ｍａｘＵｓｅｒｓ）　

｛　

ＷｎｔｅＴｏｋｅｎｓ（　ＣＲＥＡＴＥＲＯＯＭ“，ｒｏｏｍＮａｍｅ，ｍａｘＵｓｅｒｓ）；　

｝　

ｐｕｂｌｉｃ　ｖｏｉｄ　ＳｅｎｄＣｈａｔ（ｓｔｒｉｎｇ　ｃｈａｔＴｅｘｔ）　

｛　

ＷｒｉｔｅＴｏｋｅｎｓ（”ＣＨＡＴ¨　ｃｈａｔＴｅｘｔ）；　

Ｊ　

ｐｕｂｌｉｃ　ｖｏｉｄ　ＳｅｎｄＤａｔａ（ｓ　ｎｇ　ｄａｔａＴｅｘｔ）　

｛　

ＷｒｉｔｅＴｏｋｅｎｓ（”ＤＡＴＡ“，ｄａｔａＴｅｘｔ）；　

｝　

ｐｕｂｌｉｃ　ｖｏｉｄ　ＳａｖｅＵｓｅｒｌｎｆｏ（ＰｒｉｓｍＵｓｅｒ　ｕｓｅｒ）　

｛　

ＷｒｉｔｅＴｏｋｅｎｓ（”ＳＡＶＥＵＳＥＲ“．ｕｓｅｒ．ＴｏＳｔｒｉｎｇ０）；　

）　

ｐｕｂｌｉｃ　ｖｏｉｄ　ＳｅｒｖｅｒＳｔａｔｓ（）　

（　

ＷｒｉｔｅＴｏｋｅｎｓ（“ＳＥＲＶＥＲＳＴＡＴＳ”）：　

）　

ｐｕｂｌｉｃ　ｖｏｉｄ　ＣｕｓｔｏｍＣｏｍｍａｎｄ（ｓｔｒｉｎｇ　ＣｏｍｍａｎｄＮａｍｅ，ｓｔｒｉｎｇ　

Ｐａｒａｍｓ）　

｛　

ＷｒｉｔｅＴｏｋｅｎｓ（“ＣＵＳＴＯＭ“，ＣｏｍｍａｎｄＮａｍｅ，Ｐａｒａｍｓ）；　

｝　

ｐｒｉｖａｔｅ　ｖｏｉｄ　ＷｒｉｔｅＴｏｋｅｎｓ（ｐａｒａｍｓ　ｏｂｊｅｃｔ［】ｔｏｋｅｎｓ）　

｛　

ｉｆ（ＡｃｔｉｖｅＪ　

｛　

蕾嫡扭２：匠０圬１３与．囊１９　６１　

…　』　ｆ　ＥＩ　Ｉｉｔ　…　．　一　，Ｊ　ｍｉ　Ｊ　　Ｉ・　一ｆＩ＿１４　Ｊ＿’　Ｊ　　‘ｔｉ　ｎ　

实用第一　智慧密集　

．　。　，　…　．．　，．　…，…　．．　…．　…　．　……　…　　．

ｔｒＶ　

｛　

一

ｓｔｒｅａｍ．ＷｒｉｔｅＴ０ｋｅｎｓ（ｔ０ｋｅｎｓ）：　

｝　

ｃａｔｃｈ　

｛　

Ａｃｔｉｖｅ＝ｆａｌｓｅ；　

｝　

）　

）　

２．３．２使用ＰｒｉｓｍＳｅｒｖｅｒ组件封装服务器端操作　

与ＰｒｉｓｍＣｏｎｎｅｃｔｉｏｎ封装客户端功能相对应。ＰｒｉｓｍＳｅｒｖｅｒ组　

件封装了服务器端的功能。它是即时通信服务器应用程序的基　

础，封装了多线程环境中的服务器端Ｓｏｃｋｅｔ、管理各种连接、　

处理消息传递。　

ＰｒｉｓｍＳｅｒｖｅｒ组件提供了很多的属性来控制服务器的行为。　

１）Ｐｏｒｔ：指定服务器用于侦听连接的端口号。　

２）ＬｏｂｂｙＮａｍｅ：新的客户端将被添加到默认的聊天室。　

３）ＰｒｏｈｉｂｉｔＳａｍｅＩＰ：值为Ｔｒｕｅ时，阻止来自相同ＩＰ的多　

个连接。　

４）ＰｒｏｈｉｂｉｔＳａｍｅＵｓｅｒｎａｍｅ：值为Ｔｒｕｅ时，阻止来自相同用　

户名称的多次登录。　

５）Ｐｉｎｇｌｎｔｅｒｖａｌ：控制服务器测试客户端连接的时间间隔。　

６）Ｉｍｐｌｅｍｅｎｔａｔｉｏｎ：必须设置为派生自抽象基类ＰｒｉｓｍＳｅｒｖ　

ｅｒＩｍｐｌｅｍｅｎｔａｔｉｏｎ类的实例。　

ＰｒｉｓｍＳｅｒｖｅｒ组件也提供了一些方法，允许管理员控制客　

户端与服务器的交互行为。　

ＰｒｉｓｍＳｅｒｖｅｒ组件直接派生自Ｃｏｍｐｏｎｅｎｔ类。下面从几个　

侧面介绍它的具体实现。　

２．３－２．１激活服务器　

ＰｒｉｓｍＳｅｒｖｅｒ也定义了一个Ａｃｔｉｖｅ属性。当Ａｃｔｉｖｅ属性被　

设置为ｔｕｒｅ时。将首先判断其Ｉｍｐｌｅｍｅｎｔａｔｉｏｎ属性是否被设置　

成一个派生自ＰｒｉｓｍＳｅｒｖｅｒｌｍｐｌｅｍｅｎｔａｔｉｏｎ的实例。该实例提供　

了一个接口用于用户管理．允许服务器使用一个本地文件、数　

据库或其他存储机制来保存用户注册信息。在该属性定义中，　

还创建了一个新的ＴｃｐＬｉｓｔｅｎｅｒ实例，用以侦听客户连接．接　

受请求．然后创建Ｓｏｃｋｅｔ类或ＴｃｐＣｌｉｅｎｔ类的实例与客户端进　

行通信。如果Ａｃｔｉｖｅ属性设为ｆａｌｓｅ，则停止ＴｃｐＬｉｓｔｅｎｅｒ的侦　

听，并关闭所有的客户端请求。下面的代码定义了ＰｒｉｓｍＳｅｒｖｅｒ　

类的Ａｃｔｉｖｅ属性：　

ｐｕｂｌｉｃ　ｂｏｏｌ　Ａｃｔｉｖｅ　

｛　

ｇｅｔ　

｛　

ｒｅｔｕｒｎ

—

ａｃｔｉｖｅ；　

）　

６２　ｒ　涵２０　１幢３．醢１９岛

与雄訇　蛾　

ｓｅｔ　

｛　。。　

ｉｆ（＿ａｃｔｉｖｅ！＝ｖａｌｕｅ）　

｛　

ｉｆ（ｖａｌｕｅ）　

｛　

ｉｆ（Ｉｍｐｌｅｍｅｎｔａｔｉｏｎ＝＝ｎｕｌ１）　

ｔｈｒｏｗ　ｎｅｗ　ＰｒｉｓｍＳｅｒｖｅｒＥｘｃｅｐｔｉｏｎ（”不能激活服务器！”）　

一

ｌｉｓｔｅｎｅｒ＝ｎｅｗ　ＴｃｐＬｉｓｔｅｎｅｒ（ＩＰＡｄｄｒｅｓｓ．Ａｎｙ，Ｐｏｒｔ）；　

——

ｌｉｓｔｅｎｅｒ．Ｓｔａｒｔ（）；　

＿

ａｃｔｉｖａｔｅｄ：ＤａｔｅＴｉｍｅ．Ｎｏｗ；　

一

ｌｉｓｔｅｎＴｈｒｅａｄ：ｎｅｗ　Ｔｈｒｅａｄ（ＥｘｅｃｕｔｅＬｉｓｔｅｎｅｒＴｈｒｅａｄ）；　

一

ｌｉｓｔｅｎＴｈｒｅａｄ．ＩｓＢａｃｋｇｒｏｕｎｄ＝ｔｒｕｅ；　

—　

１ｉｓｔｅｎＴｈｒｅａｄ．Ｓｔａｒｔ（）；　

一

ａｃｔｉｖｅ＝ｔｒｕｅ；　

）　

ｅｌｓｅ　

｛　

一

ａｃｔｉｖｅ：ｆａｌｓｅ；　

—　

１ｉｓｔｅｎｅｒ．Ｓｔｏｐ（）；　

ｆｏｒ（ｉｎｔ　ｉ＝Ｇｕｅｓｔｓ．Ｃｏｕｎｔ一１：ｉ＞＝０：ｉ一一）　

Ｇｕｅｓｔｓ［ｉ］．Ｓｔｒｅａｍ．Ｃｌｏｓｅ（）；　

Ｇｕｅｓｔｓ．Ｃｌｅａｒ（）；　

）　

）　

｝　

）　

２．３．２．２后台线程获取客户端连接　

当ＰｒｉｓｍＳｅｒｖｅｒ激活后．后台线程将执行ＥｘｅｃｕｔｅＬｉｓｔｅｎｅｒ　

Ｔｈｒｅａｄ方法，循环获取客户端连接，直到ＰｒｉｓｍＳｅｒｖｅｒ的Ａｃｔｉｖｅ　

属性值变为ｆａｌｓｅ为止。期间ＰｒｉｓｍＳｅｒｖｅｒ会在一定的时间间隔　

内检查客户端的连接状态。如果没有任何响应，则从用户列表　

中移除客户。在该方法中调用了一个线程方法ＥｘｅｃｕｔｅＣｌｉｅｎｔＳｏｃ　

ｋｅｔＴｈｒｅａｄ．它接受一个ＰｒｉｓｍＵｓｅｒ实例参数，表示与服务器端　

进行通信的客户。该方法读取来自客户端的各种Ｐｒｉｓｍ协议命　

令，然后进行相应的处理。下面的代码实现了ＥｘｅｃｕｔｅＬｉｓｔｅｎｃｒ　

Ｔｈｒｅａｄ方法：　

ｐｒｉｖａｔｅ　ｖｏｉｄ　ＥｘｅｃｕｔｅＬｉｓｔｅｎｅｒＴｈｒｅａｄ（）　

｛　

ｉｎｔＣｙｃｌｅｓ＝０：　

ｗｈｉｌｅ（Ａｃｔｉｖｅ）　

｛　

ｗｈｉｌｅ（＿ｌｉｓｔｅｎｅｒ．Ｐｅｎｄｉｎｇ（））　

ｆ　

ＴｃｐＣｌｉｅｎｔ　ｃｌｉｅｎｔＳｏｃｋｅｔ；　

ｃｌｉｅｎｔＳｏｃｋｅｔ＝

一

ｌｉｓｔｅｎｅｒ．ＡｃｃｅｐｔＴｃｐＣｌｉｅｎｔＯ；　

ＰｒｉｓｍＮｅｔｗｏｒｋＳｔｒｅａｍ　ｐｎｓ＝ｎｅｗ　ＰｒｉｓｍＮｅｔｗｏｒｋＳｔｒｅａｍ　

（ｃ¨ｅｎｔＳ０ｃｋｅｔ）：　

ＰｒｉｓｍＧｕｅｓｔ　ｎｅｗＧｕｅｓｔ＝ｎｅｗ　ＰｒｉｓｍＧｕｅｓｔ（ｔｈｉｓ，ｐｎｓ，　

ｃ　ＪｉｅｎｔＳＯｃｋｅｔ）：　

ｉｆ（ＰｒｏｈｉｂｉｔＳａｍｅｌＰ）　

｛　

ｌｏｃｋ（一ｇｕｅｓｔＬｉｓｔ）　

ｆ　

ｆｏｒｅａｃｈ（ＰｒｉｓｍＧｕｅｓｔ　ｇｕｅｓｔ　ｉｎ　Ｇｕｅｓｔｓ）　

ｉｆ（ｇｕｅｓｔ．ＩＰＡｄｄｒｅｓｓ．ＴｏＳｔｒｉｎｇ　０＝＝　

ｎｅｗＧｕｅｓｔ．ＩＰＡｄｄｒｅｓｓ．ＴｏＳｔｒｉｎｇ０）　

｛　

ｉｆ（ＧｕｅｓｔＤｉｓｃｏｎｎｅｃｔｅｄＳａｍｅｌＰ！＝ｎｕｌ１）　

ＧｕｅｓｔＤｉｓｃｏｎｎｅｃｔｅｄＳａｍｅｌＰ（ｔｈｉｓ．　

ｎｅｗ　ＰｒｉｓｍＧｕｅｓｔＥｖｅｎｔＡｒｇｓ（ｎｅｗＧｕｅｓｔ））；　

ｎｅｗＧｕｅｓｔ．ＷｒｉｔｅＴｏｋｅｎｓ（”ＥＲＲＯＲ　，“统一　

ｌＰ不能发起多个连接！“）：　

ｐｎｓ　Ｃｌｏｓｅ（）；　

ｂｒｅａｋ；　

）　

）　

）　

ｉｆ（ｎｅｗＧｕｅｓｔ．Ｓｔｒｅａｍ．ＷａｓＣＩｏｓｅｄ）　

ｃｏｎｔｉｎｕｅ；　

ｌｏｃｋ（一ｇｕｅｓｔＬｉｓｔ）　

｛　

ｇｕｅｓｔＬｉｓｔ．Ａｄｄ（ｎｅｗＧｕｅｓｔ）；　

ｃＯｎｎｅｃｔ　Ｏｎｓ＋＋：　

ｉｆ（＿ｇｕｅｓｔＬｉｓｔ．Ｃｏｕｎｔ＞一ｍａｘＧｕｅｓｔＣ０ｕｎｔ）　

一

ｎ１ａｘＧｕｅｓｔＣＯｕｎｔ＝

一

ｇｕｅｓｔＬｉｓｔ．Ｃｏｕｎｔ；　

）　

ｊｆ（ＧｕｅｓｔＣＯｎｎｅｃｔｅｄ！：ｎｕｌ１）　

ＧｕｅｓｔＣＯｎｎｅｃｔｅｄ（ｔｈｉｓ，ｎｅｗ　ＰｒｉｓｍＧｕｅｓｔＥｖｅｎｔＡｒｇｓ　

（ｎｅｗＧｕｅｓｔ））；　

Ｔｈｒｅａｄ　ｔｈｒｄＣｌｉｅｎｔ＝ｎｅｗ　Ｔｈｒｅａｄ（ＥｘｅｃｕｔｅＣＩｉｅｎｔＳＯｃｋｅｔ　

Ｔｈｒｅａｄ）；　

ｔｈｒｄＣｌｉｅｎｔ．ＩｓＢａｃｋｇｒｏｕｎｄ＝ｔｒｕｅ；　

ｔｈｒｄＣｌｉｅｎｔ．Ｓｔａｒｔ（ｎｅｗＧｕｅｓｔ）；　

｝　

Ｔｈｒｅａｄ．Ｓｌｅｅｐ（１　Ｏ）：　

Ｃｙｃｌｅｓ＋＋；　

ｉｆ（Ｃｙｃｌｅｓ＞＝

ｐｉｎｇＣｙｃｌｅｓ）　

｛　

ｉｆ（Ｐｉｎｇｉｎｇ！＝ｎｕｌ１）　

Ｐｉｎｇｉｎｇ（ｔｈｉｓ，ｎｅｗ　ＥｖｅｎｔＡｒｇｓ０）；　

Ｃｙｃｌｅｓ：Ｏ：　

ｌｏｃｋ（一ｇｕｅｓｔＬｉｓｔ）　

｛　

ｆｏｒ《ｉｎｔ　ｉ＝Ｇｕｅｓｔｓ．Ｃｏｕｎｔ一１：ｉ＞：Ｏ：ｉ一一）　

ｆ　

ＰｒｉｓｍＧｕｅｓｔ　ｇ＝Ｇｕｅｓｔｓ［ｉ］；　

ｉｆ（ｇ．ＷａｉｔｉｎｇＦｏｒＰｉｎｇ）　

ＲｅｍｏｖｅＧｕｅｓｔ（ｇ）；　

ｅｌｓｅ　

ｇ．Ｐｉｎｇ（）；　

）　

）　

）　

｝　

｝　

２．３．３使用ＰｒｉｓｍＮｅｔｗｏｒｋＳｔｒｅａｍ组件封装网络流操作　

本实时通信系统使用ＴＣＰ协议保持应用的连通性。　

ＰｒｉｓｍＮｅｔｗｏｒｋＳｔｒｅａｍ类封装了ＮｅｔｗｏｒｋＳｔｒｅａｍ类，并实现了一些　

自定义的方法，从网络流中读写数据。ＰｒｉｓｍＮｅｔｗｏｒｋＳｔｒｅａｍ类　

还定义了一些属性用于信息统计。　

２．３．３．１网络流的初始化　

为了初始化网络流对象，需要在ＰｒｉｓｍＮｅｔｗｏｒｋＳｔｒｅａｍ类的　

构造甬数中传递一个ＴｃｐＣｌｉｅｎｔ实例，然后从该实例中获取　

ＮｅｔｗｏｒｋＳｔｒｅａｍ对象实例进行操作。下面的代码实现网络流的　

初始化：　

ｐｕｂｌｉｃ　ＰｒｉｓｍＮｅｔｗｏｒｋＳｔｒｅａｍ（ＴｃｐＣｌｉｅｎｔ　ｃｌｉｅｎｔ）　

（　

一

ｃｌｉｅｎｔ＝ｃｌｉｅｎｔ；　

ｓｔｒｅａｍ＝ｃｌｉｅｎｔ．ＧｅｔＳｔｒｅａｍ０；　

｝　

２．３．３．２读写Ｐｒｉｓｍ协议命令及消息　

ＰｒｉｓｍＮｅｔｗｏｒｋＳｔｒｅａｍ类采用两个方法ＲｅａｄＴｏｋｅｎｓ和　

ＷｒｉｔｅＴｏｋｅｎｓ用于读写指定的Ｐｒｉｓｍ协议命令。ＷｒｉｔｅＴｏｋｅｎｓ方　

法首先调用Ｔｏｋｅｎｉｚｅｒ类的Ｔｏｋｅｎｉｚｅ方法，将多个参数合并为　

Ｅｌ１分隔标记组成的字符串，然后调用ＷｒｉｔｅＳｔｒｉｎｇ方法写入到网　

络流中。ＲｅａｄＴｏｋｅｎｓ则执行相反的过程，对来自网络流的字符　

串进行分解，并返回命令字符串。ＲｅａｄＴｏｋｅｎｓ和ＷｒｉｔｅＴｏｋｅｎｓ　

是ＰｒｉｓｍＮｅｔｗｏｒｋＳｔｒｅａｍ类的核心方法，它们的实现由另外两个　

核心方法ＲｅａｄＳｔｒｉｎｇ和ＷｒｉｔｅＳｔｒｉｎｇ方法支撑。下面的代码实现　

了这些方法：　

ｐｕｂｌｉｃ　ｖｏｉｄ　ＷｒｉｔｅＴｅｋｅｎｓ（ｐａｒａｍｓ　ｏｂｊｅｃｔ［】ｔｏｋｅｎｓ）　

｛　

ｓｔｒｉｎｇ　Ｓ＝Ｔｏｋｅｎｉｚｅｒ．ＴＯｋｅｎｉｚｅ《ｔｏｋｅｎｓ）　

ＷｒｉｔｅＳｔｒｉｎｇ（ｓ）；　

）　

ｐｕｂｌｉｃ　ｓｔｒｉｎｇ　ＲｅａｄＴｏｋｅｎｓ（Ｌｊｓｔ＜ｓｔ　ｎｇ＞ｓｔｒｉｎｇＬｉｓｔ）　

｛　

ｓｔｒｉｎｇ　ＣｏｍｍａｎｄＳｔｒｉｎｇ＝““：　

ｓｔｒｉｎｇＬｉｓｔ．Ｃｌｅａｒ（）；　

ｓｔｒｉｎｇ　Ｓ＝ＲｅａｄＳｔｒｉｎｇＯ；　

ｉｆ（ｓ．Ｌｅｎｇｔｈ＞０）　

ＣｏｍｍａｎｄＳｔｒｉｎｇ＝Ｔｏｋｅｎｉｚｅｒ．ＧｅｔＴｏｋｅｎ（ｒｅｆ　Ｓ）　

ｗｈｉｌｅ（ｓ．Ｌｅｎｇｔｈ＞０）　

ｓｔｒｉｎｇＬｉｓｔ．Ａｄｄ（Ｔｏｋｅｎｉｚｅｒ．ＧｅｔＴｏｋｅｎ（ｒｅｆ　ｓ））：　

ｒｅｔｕｒｎ　ＣｏｍｍａｎｄＳｔｒｉｎｇ；　

｝　

ｐｒｉｖａｔｅ　ｓｔｒｉｎｇ　ＲｅａｄＳｔｒｉｎｇ（）　

｛　

ｓｔｒｉｎｇ　ＲｅｔｕｒｎＳｔｒｉｎｇ＝“”：　

脑螭　

器　６３　

实用第　一　智　慧密集　

ｉｎｔ　Ｐｏｓ；　

ｉｎｔ　ＢｙｔｅｓＲｅａｄ；　

ｄｏ　

｛　

ｉｆ（一ｄｅｓｉｒｅｄＭｅｓｓａｇｅｌｅｎｇｔｈ＞０）　

｛　

ｆ（一ｉｎｃｏｍｉｎｇＭｅｓｓａｇｅ．Ｌｅｎｇｔｈ＞＝一ｄｅｓｉｒｅｄＭｅｓｓａｇｅｌｅｎｇｔｈ）　

｛　

ＲｅｔｕｒｎＳｔｒｉｎｇ：

一

ｉｎｃｏｍｉｎｇＭｅｓｓａｇｅ．Ｓｕｂｓｔｒｉｎｇ　

（０，一ｄｅｓｉｒｅｄＭｅｓｓａｇｅｌｅｎｇｔｈ）；　

一

ｉｎｃｏｍｉｎｇＭｅｓｓａｇｅ＝

一

ｉｎｃｏｍｉｎｇＭｅｓｓａｇｅ．Ｓｕｂｓｔｒｉｎｇ　

（＿ｄｅｓｉｒｅｄＭｅｓｓａｇｅｌｅｎｇｔｈ，一ｉｎｃｏｍｉｎｇＭｅｓｓａｇｅ．Ｌｅｎｇｔｈ一　

＿ｄｅｓｉｒｅｄＭｅｓｓａｇｅｌｅｎｇｔｈ）；　

＿ｄｅｓｉｒｅｄＭｅｓｓａｇｅｌｅｎｇｔｈ：０：　

）　

ｅｌｓｅ　

｛　

ＢｙｔｅｓＲｅａｄ＝

一

ｓｔｒｅａｍ．Ｒｅａｄ（一ｂｕｆｆｅｒ，０，ＢｕｆｆｅｒＳｉｚｅ）；　

ｉｆ《ＢｙｔｅｓＲｅａｄ＝＝０）　

Ｔｈｒｅａｄ．Ｓｌｅｅｐ（１　Ｏ）：　

ｅｌｓｅ　

—

ｉｎｃｏｍｉｎｇＭｅｓｓａｇｅ＝

一

ｉｎｃｏｍｉｎｇＭｅｓｓａｇｅ＋　

Ｅｎｃｏｄｉｎｇ．Ｄｅｆａｕｌｔ．ＧｅｔＳｔｒｉｎｇ（——ｂｕｆｆｅｒ，０，ＢｙｔｅｓＲｅａｄ）；　

）　

）　

ｅｌｓｅ　

（　

Ｐｏｓ：

ｉｎｃｏｍｉｎｇＭｅｓｓａｇｅ．ＩｎｄｅｘＯｆ（　ｌ　）：　

ｉｆ（Ｐｏｓ＞０）　

（　

一

ｄｅｓｉｒｅｄＭｅｓｓａｇｅｌｅｎｇｔｈ＝Ｉｎｔ３２．Ｐａｒｓｅ　

（

ｉｎｃｏｍｉｎｇＭｅｓｓａｇｅ．Ｓｕｂｓｔｒｉｎｇ（Ｏ，Ｐｏｓ））：　

一

ｉｎｃｏｍｉｎｇＭｅｓｓａｇｅ＝

ｉｎｃｏｍｉｎｇＭｅｓｓａｇｅ．Ｓｕｂｓｔｒｉｎｇ　

（Ｐｏｓ＋１，一ｉｎｃｏｍｉｎｇＭｅｓｓａｇｅ．Ｌｅｎｇｔｈ—Ｐｏｓ一１）　

）　

ｅｌｓｅ　

｛　

ＢｙｔｅｓＲｅａｄ＝

一

ｓｔｒｅａｍ．Ｒｅａｄ（一ｂｕｆｆｅｒ，０，ＢｕｆｆｅｒＳｉｚｅ）；　

ｉｆ（ＢｙｔｅｓＲｅａｄ＝＝０）　

Ｔｈｒｅａｄ．Ｓｌｅｅｐ（１　Ｏ）：　

ｅｌｓｅ　

—

ｉｎｃｏｍｉｎｇＭｅｓｓａｇｅ＝

一

ｉｎｃｏｍｉｎｇＭｅｓｓａｇｅ＋　

Ｅｎｃｏｄｉｎｇ　Ｄｅｆａｕｌｔ．ＧｅｔＳｔｒｉｎｇ（——ｂｕｆｆｅｒ，０，ＢｙｔｅｓＲｅａｄ）；　

）　

）　

）ｗｈｉｌｅ《ＲｅｔｕｒｎＳｔｒｉｎｇ＝：““＆＆一ｓｔｒｅａｍ．ＣａｎＲｅａｄ＆＆　

一

ｃｌｏｓｅｄ）；　

一

ｂｙｔｅｓＲｅａｄ＋＝ＲｅｔｕｒｎＳｔｒｉｎｇ．Ｌｅｎｇｔｈ；　

ｔｏｔａｌＢｙｔｅｓＲｅａｄ＋：ＲｅｔｕｒｎＳｔｒｉｎｇ．Ｌｅｎｇｔｈ；　

＿

ｒｅｔｕｒｎ　ＲｅｔｕｒｎＳｔｒｉｎｇ；　

｝　

ｐｒｉｖａｔｅ　ｖｏｉｄ　ＷｒｉｔｅＳｔｒｉｎｇ（ｓｔｒｉｎｇ　Ｓ）　

（　

ｉｆ（一ｓｔｒｅａｍ．ＣａｎＷｒｉｔｅ）　

｛　

Ｓ＝ｓ．Ｌｅｎｇｔｈ＋“ｌ¨＋ｓ：　

ｂｙｔｅ［】ｏｕｔｐｕｔＢｙｔｅｓ＝Ｅｎｃｏｄｉｎｇ．Ｄｅｆａｕｌｔ．ＧｅｔＢｙｔｅｓ（ｓ）；　

——

ｓｔｒｅａｍ．Ｗｒｉｔｅ（ｏｕｔｐｕｔＢｙｔｅｓ，０，ｏｕｔｐｕｔＢｙｔｅｓ．Ｌｅｎｇｔｈ）；　

ｂｙｔｅｓＷｒｉｔｔｅｎ＋＝ｏｕｔｐｕｔＢｙｔｅｓ．Ｌｅｎｇｔｈ；　

一

ｔｏｔａｌＢｙｔｅｓＷｒｉｔｔｅｎ＋＝ｏｕｔｐｕｔＢｙｔｅｓ．Ｌｅｎｇｔｈ；　

＿

｝　

）　

２．３．４使用ＰｒｉｓｍＳｅｒｖｅｒｌｍｐｌｅｍｅｎｔａｔｉｏｎ组件管理用户信息　

ＰｆｉｓｍＳｅｒｖｅｒ具有一个Ｉｍｐｌｅｍｅｎｔａｔｉｏｎ属性。在激活ＰｆｉｓｍＳｅ　

ｌｗｅｒ之前．必须为该属性赋值一个派生自ＰｒｉｓｍＳｅｒｖｅｒｌｍｐｌｅｍｅｎ　

ｔａｔｉｏｎ类的实例。ＰｒｉｓｍＳｅｒｖｅｒＩｍｐｌｅｍｅｎｔａｔｉｏｎ类提供了大量管理　

用户的框架方法．派生类将重写这些方法实现自定义的管理形　

式，比如，可以派生一个ＰｆｉｓｍＳｅｒｖｅｒＳｑｌＩｍｐｌｅｍｅｎｔａｔｉｏｎ组件，　

将用户信息存储到ＳＱＬ　Ｓｅｒｖｅｒ数据库中；或者派生一个　

ＰｒｉｓｍＳｅｒｖｅｒＸｍｌｌｍｐｌｍｅｎｔａｔｉｏｎ组件．将用户信息存储到ＸＭＬ文　

件中。　

除了构造函数，ＰｒｉｓｍＳｅｒｖｅｒｌｍｐｌｅｍｅｎｔａｔｉｏｎ中的方法都是虚　

方法，派生类通过重载这些方法实现自定义的用户管理功能。　

默认情况下．只要用户名和密码不为空，都允许通过验证。类　

库中实现了一个派生自￣ｒｉｓｍＳｅｒｖｅｒｌｍｐｌｅｍｅｎｔａｔｉｏｎ的ＰｒｉｓｍＳｅｒｖｅｒ　

ＦｉｌｅＩｍｐｌｅｍｅｎｔａｔｉｏｎ类。该组件会创建一个名为Ｕｓｅｒｓ的文件夹，　

用于在文件系统中保存用户信息。它主要使用Ｓｙｓｔｅｍ．１０空间　

下与文件操作相关的类来操作文件。下面的代码读写文件数据　

库验证用户名和密码：　

ｐｕｂｌｉｃ　ｏｖｅｒｒｉｄｅ　ｂｏｏｌ　ＣｈｅｃｋＵｓｅｒＮａｍｅ｛ｓｔｒｉｎｇ　ｕｓｅｒＮａｍｅ，ｒｅｆ　

ｓｔｒｉｎｇ　ｍｓｇ）　

｛　

ｉｆ《！ｂａｓｅ　ＣｈｅｃｋＵｓｅｒＮａｍｅ（ｕｓｅｒＮａｍｅ，ｒｅｆ　ｍｓｇ））　

ｒｅｔｕｒｎ　ｆａｌｓｅ；　

ｉｆ（ＵｓｅｒＥｘｉｓｔｓ（ｕｓｅｒＮａｍｅ））　

ｒｅｔｕｒｎ　ｔｒｕｅ；　

ｔｒｖ　

｛　

ｓｔｒｉｎｇ　ＵｓｅｒＦｉｌｅ＝ＧｅｔＵｓｅｒＦｉｌｅＮａｍｅ（ｕｓｅｒＮａｍｅ）；　

ＦｉｌｅＳｔｒｅａｍ　ｆｓ＝Ｆｉｌｅ　Ｃｒｅａｔｅ（Ｕｓｅｒ　ｅ）：　

ｆｓ．Ｃｌｏｓｅ（）；　

Ｆｉｌｅ．ＤｅＩｅｔｅ（Ｕｓｅｒ　ｅ）：　

ｒｅｔｕｒｎ　ｔｒｕｅ；　

）　

ｃａｔｃｈ　

｛　

ｍｓｇ＝”指定的用户名包含无效的字符Ｉ”　

ｒｅｔｕｒｎ　ｆａｌｓｅ；　

）　

（下转第７０页）　

　’…　‘　　。

实用第一　智慧密集　

…　……　…　．　　．……　．　．　…　…　…　

ｃｏｎｎｅｃｔｉｏｎ．ａｄｄＥｖｅｎｔＬｉｓｔｅｎｅｒ　ｆＳｅｃｕｒｉｔｙＥｒｒｏｒＥｖｅｎｔ．　

ｃｕｓｔｏｍＣｌｉｅｎｔ．ｏｎＭｅｔａＤａｔａ＝ｍｅｔａＤａｔａＨａｎｄｌｅｒ；　

ｓｔｒｅａｍ．ｃｌｉｅｎｔ＝ｃｕｓｔｏｍＣｌｉｅｎｔ；　

ＳＥＣＵＲＩ　ＥＲＲ０Ｒ，ｓｅｃｕｒｉｔｙ　ＥｒｒｏｒＨａｎｄｌｅｒ）；　

／／连接　

ｃｏｎｎｅｃｔｉｏｎ．ｃｏｎｎｅｃｔ（ｎｕｌ１）；　

ｖｉｄｅｏ＝ｎｅｗ　Ｖｉｄｅｏ（）；　

ｖｉｄｅｏ．ａｔｔａｃｈＮｅｔＳｔｒｅａｍ（ｓｔｒｅａｍ）；　

ｖｉｄｅｏ．ｘ＝ｆｌｖＡｔｔｒｉｂ．ｘｐｏｓ；　

ｖｉｄｅｏ．ｙ＝ｆｌｖＡｔｔｒｉｂ．ｙｐｏｓ；　

ｖｉｄｅｏ．ｗｉｄｔｈ＝ｆｌｖＡｔｔｒｉｂ．ｗ：　

网络的连接可能会出现多种情况，比如文件未找到等，可　

以根据这些信息进一步地操作：　

ｆｕｎｃｔｉｏｎ　ｎｅｔＳｔａｔｕｓＨａｎｄＩｅｒ（ｅｖｅｎｔ：ＮｅｔＳｔａｔｕｓＥｖｅｎｔ）：ｖｏｉｄ　

｛　

ｓｗｉｔｃｈ（ｅｖｅｎｔ．ｉｎｆｏ．ｃｏｄｅ）　

｛　

ｃａｓｅ。ＮｅｔＣＯｎｎｅｃｔｉＯｎ．Ｃｏｎｎｅｃｔ．Ｓｕｃｃｅｓｓ“：　

ｌ　

ｖｉｄｅｏ．ｈｅｉｇｈｔ＝ｆｌｖＡｔｔ　ｂ．ｈ：　

ｓｔｒｅａｍ．ｐｌａｙ（ｌｆｖＡｔｔｒｉｂ．ｓｒｃ）；　

∥添加视频信息到场景　

ｓｔ．ａｄｄＣｈ＿ｌｄ（ｖｉｄｅｏ）：　

∥连接成功，进行流媒体的下载并播放　

ｃｏｎｎｅｃｔＳｔｒｅａｍＯ；　

ｂｒｅａｋ；　

３　结语　

该程序用Ｆｌａｓｈ　ＣＳ３在Ｗｉｎｄｏｗｓ　ＸＰ　ＳＰ２上编译运行通过，　

ｄｅｆａｕｌｔ：　

ｂｒｅａｋ；　

能够很好地根据配置文件完成Ｆｌａｓｈ影片的定制，对于仅仅用　

于展示或者具有简单交互的情况下，完全可以只通过配置　

ＸＭＬ文件就可以完成　当然，更复杂的Ｆｌａｓｈ设计还需要在图　

形界面里面完成。　

）　

）　

ｐｒｉｖａｔｅ　ｆｕｎｃｔｉｏｎ　ｃｏｎｎｅｃｔＳｔｒｅａｍ０：ｖｏｉｄ　

｛　

／／建立流媒体连接　

ｓｔｒｅａｍ＝ｎｅｗ　ＮｅｔＳｔｒｅａｍ（ｃｏｎｎｅｃｔｉｏｎ）；ｓｔｒｅａｍ．ａｄｄＥｖｅｎｔ　

Ｌｉｓｔｅｎｅｒ　（ＮｅｔＳｔａｔｕｓＥｖｅｎｔ．ＮＥＴ—ＳＴＡＴＵＳ，　ｎｅｔＳｔａｔｕｓＨａｎｄｌｅｒ）：　

ｓｔｒｅａｍ．ａｄｄＥｖｅｎｔＬｉｓｔｅｎｅｒ（ＡｓｙｎｃＥｒｒｏｒＥｖｅｎｔ　ＡＳＹＮＣ—ＥＲＲＯＲ，　

ａｓｙｎｃＥｒｒ０ｒＨａｎｄｌｅｒ）；　

参考文献　

［１］Ａｄｏｂｅ．Ａｃｔｉｏｎ　Ｓｃｒｉｐｔ　３．０编程手册．　

［２】ｈｔｔｐ：／／ｗｗｗ．ａｄｏｂｅ．ｃｏｍ／ｄｅｖｎｅｔ／ａｃｔｉｏｎｓｃｒｉｐｔ／ｓａｍｐｌｅｓ．ｈｔｍｌ　

（收稿日期：２０１３—０８—１５）　

ｖａｒ　ｃｕｓｔｏｍＣｌｉｅｎｔ：Ｏｂｊｅｃｔ＝ｎｅｗ　Ｏｂｊｅｃｔ（）；　

（上接第６４页）　

）　

ｐｕｂｌｉｃ　ｏｖｅｒｒｉｄｅ　ｂｏｏｌ　ＩｓＰａｓｓｗｏｒｄＶａｌｉｄ（ｓｔｒｉｎｇ　ｕｓｅｒＮａｍｅ，ｓｔｒｉｎｇ　

ｐａｓｓｗｏｒｄ）　

｛　

ＰｒｉｓｍＵｓｅｒ　ＴｅｍｐＵｓｅｒ＝ｎｅｗ　ＰｒｉｓｍＵｓｅｒＯ；　

ＴｅｍｐＵｓｅｒ．ＵｓｅｒＮａｍｅ＝ｕｓｅｒＮａｍｅ；　

）　

ｐｕｂｌｉｃ　ｏｖｅｒｒｉｄｅ　ｖｏｉｄ　ＳａｖｅＳｅｔｔｉｎｇｓ（）　

｛　

ｓｔｒｉｎｇ　Ｓ＝Ｔｏｋｅｎｉｚｅｒ．Ｔｏｋｅｎｉｚｅ　

（Ｓｅｒｖｅｒ．Ｐｏｒｔ，Ｓｅｒｖｅｒ．ＰｒｏｈｉｂｉｔＳａｍｅＩＰ，Ｓｅｒｖｅｒ　

ＰｒｏｈｉｂｉｔＳａｍｅＵｓｅｒＮａｍｅ）；　

Ｆｉｌｅ．ＷｒｉｔｅＡＩＩＴｅｘｔ（一ｓｅｔｔｉｎｇｓＦｉｌｅ，ｓ）：　

）　

ＰｏｐｕｌａｔｅＵｓｅｒｌｎｆｏ（ＴｅｍｐＵｓｅｒ）；　

ｒｅｔｕｒｎ（ｐａｓｓｗｏｒｄ＝＝ＴｅｍｐＵｓｅｒ．Ｐａｓｓｗｏｒｄ）；　

）　

２．４客户端应用的实现　

写了　ＰｒｉｓｍＳｅｒｖｅｒＦｉｌｅｌｍｐｌｅｍｅｎｔａｔｉｏｎ类同时也重

客户端应用是一个ＷｉｎＦｏｒｍ应用程序，主要的功能都封装在　

核心类库中，只需添加引用即可。当用户打开客户端主窗体时，　

需要指定服务器信息．允许用户注册或登录．然后连接到通信服　

务器端进行通信。限于篇幅，具体的界面编程过程不再赘述。　

ＬｏａｄＳｅｔｔｉｎｇｓ和ＳａｖｅＳｅｔｔｉｎｇｓ方法．用于加载和保存服务器端的　

配置信息。下面的代码实现了配置信息的存取：　

ｐｕｂｌｉｃ　ｏｖｅｒｒｉｄｅ　ｖｏｉｄ　ＬｏａｄＳｅｔｔｉｎｇｓ（）　

｛　

２＿５服务器端应用的实现　

服务器端也是一个ＷｉｎＦｏｒｍ应用程序．它的主要功能也　

都封装在核心类库中．在用户界面上，只需要调用核心类库即　

ｉｆ（Ｆｉｌｅ．Ｅｘｉｓｔｓ（一ｓｅｔｔｉｎｇｓＦｉｌｅ））　

｛　

ｓｔｒｉｎｇ　Ｓ＝Ｆｉｌｅ．ＲｅａｄＡＩＩＴｅｘｔ（．＿ｓｅｔｔｉｎｇｓＦｉｌｅ）；　

Ｓｅｒｖｅｒ．Ｐｏｒｔ＝Ｔｏｋｅｎｉｚｅｒ．ＧｅｔＴｏｋｅｎＩｎｔ（ｒｅｆ　ｓ）：　

Ｓｅｒｖｅｒ．ＰｒｏｈｉｂｉｔＳａｍｅｌＰ＝Ｔｏｋｅｎｉｚｅｒ．ＧｅｔＴｏｋｅｎＢＯＯＩ《ｒｅｆ　ｓ）：　

Ｓｅｒｖｅｒ．ＰｒｏｈｉｂｉｔＳａｍｅＵｓｅｒＮａｍｅ＝Ｔｏｋｅｎｉｚｅｒ．ＧｅｔＴｏｋｅｎＢｏｏ１　

可。在服务器端可以停止即时通信服务（此时所有的客户端将　

无法进行正常的聊天行为）、查看聊天用户信息、连接信息以　

及聊天记录、向客户端发送管理信息、查看统计信息等。限于　

篇幅．具体的界面编程过程不再赘述。　

（收稿日期：２０１３—０５—０７）　

（ｒｅｆ　ｓ）：　

）　

：７ｏｉ！：ｉ　与鞋