按键盘上方向键 ← 或 → 可快速上下翻页，按键盘上的 Enter 键可回到本书目录页，按键盘上方向键 ↑ 可回到本页顶部！
————未阅读完？加入书签已便下次继续阅读！
它）。fflush（）用于对输出缓冲区进行刷新。
如果名字不在列表中，就用fseek（）移到列表末尾，并用 fprintf（）将名字“打印”到列表末尾。随后，用
printf（）指出名字已成功加入列表（同样需要刷新标准输出），无限循环返回，继续等候一个新名字的进
入。
记住一般不能先在自己的计算机上编译此程序，再把编译好的内容上载到 Web 服务器，因为那台机器使用的
可能是不同类的处理器和操作系统。例如，我的Web 服务器安装的是 Intel 的CPU，但操作系统是Linux，所
以必须先下载源码，再用远程命令（通过telnet）指挥Linux 自带的C 编译器，令其在服务器端编译好程
序。
2。 Java 程序
这个程序先启动上述的 C 程序，再建立必要的连接，以便同它“交谈”。随后，它创建一个数据报套接字，
用它“监视”或者“侦听”来自程序片的数据报包。
//： NameCollector。java
// Extracts email names from datagrams and stores
// them inside a file； using Java 1。02。
import java。*；
import java。io。*；
import java。util。*；
public class NameCollector ｛
final static int COLLECTOR_PORT = 8080；
final static int BUFFER_SIZE = 1000；
byte＇＇ buf = new byte＇BUFFER_SIZE＇；
DatagramPacket dp =
new DatagramPacket（buf； buf。length）；
// Can listen & send on the same socket：
DatagramSocket socket；
Process listmgr；
PrintStream nameList；
DataInputStream addResult；
public NameCollector（） ｛
try ｛
listmgr =
Runtime。getRuntime（）。exec（〃listmgr。exe〃）；
nameList = new PrintStream（
554
…………………………………………………………Page 556……………………………………………………………
new BufferedOutputStream（
listmgr。getOutputStream（）））；
addResult = new DataInputStream（
new BufferedInputStream（
listmgr。getInputStream（）））；
｝ catch（IOException e） ｛
System。err。println（
〃Cannot start listmgr。exe〃）；
System。exit（1）；
｝
try ｛
socket =
new DatagramSocket（COLLECTOR_PORT）；
System。out。println（
〃NameCollector Server started〃）；
while（true） ｛
// Block until a datagram appears：
socket。receive（dp）；
String rcvd = new String（dp。getData（）；
0； 0； dp。getLength（））；
// Send to listmgr。exe standard input：
nameList。println（rcvd。trim（））；
nameList。flush（）；
byte＇＇ resultBuf = new byte＇BUFFER_SIZE＇；
int byteCount =
addResult。read（resultBuf）；
if（byteCount ！= …1） ｛
String result =
new String（resultBuf； 0）。trim（）；
// Extract the address and port from
// the received datagram to find out
// where to send the reply：
InetAddress senderAddress =
dp。getAddress（）；
int senderPort = dp。getPort（）；
byte＇＇ echoBuf = new byte＇BUFFER_SIZE＇；
result。getBytes（
0； byteCount； echoBuf； 0）；
DatagramPacket echo =
new DatagramPacket（
echoBuf； echoBuf。length；
senderAddress； senderPort）；
socket。send（echo）；
｝
else
System。out。println（
〃Unexpected lack of result from 〃 ＋
〃listmgr。exe〃）；
｝
｝ catch（SocketException e） ｛
System。err。println（〃Can't open socket〃）；
555
…………………………………………………………Page 557……………………………………………………………
System。exit（1）；
｝ catch（IOException e） ｛
System。err。println（〃munication error〃）；
e。printStackTrace（）；
｝
｝
public static void main（String＇＇ args） ｛
new NameCollector（）；
｝
｝ ///：~
NameCollector 中的第一个定义应该是大家所熟悉的：选定端口，创建一个数据报包，然后创建指向一个
DatagramSocket 的句柄。接下来的三个定义负责与C 程序的连接：一个 Process 对象是 C 程序由 Java 程序
启动之后返回的，而且那个Process 对象产生了 InputStream 和OutputStream，分别代表 C 程序的标准输出
和标准输入。和Java IO 一样，它们理所当然地需要“封装”起来，所以我们最后得到的是一个
PrintStream 和 DataInputStream。
这个程序的所有工作都是在构建器内进行的。为启动C 程序，需要取得当前的 Runtime 对象。我们用它调用
exec（），再由后者返回Process 对象。在Process 对象中，大家可看到通过一简单的调用即可生成数据流：
getOutputStream（）和 getInputStream（）。从这个时候开始，我们需要考虑的全部事情就是将数据传给数据
流nameList ，并从addResult 中取得结果。
和往常一样，我们将DatagramSocket 同一个端口连接到一起。在无限while 循环中，程序会调用
receive（）——除非一个数据报到来，否则receive（）会一起处于“堵塞”状态。数据报出现以后，它的内容
会提取到String rcvd 里。我们首先将该字串两头的空格剔除（trim），再将其发给C 程序。如下所示：
nameList。println（rcvd。trim（））；
之所以能这样编码，是因为Java 的exec（）允许我们访问任何可执行模块，只要它能从标准输入中读，并能
向标准输出中写。还有另一些方式可与非Java 代码“交谈”，这将在附录A 中讨论。
从C 程序中捕获结果就显得稍微麻烦一些。我们必须调用 read（），并提供一个缓冲区，以便保存结果。
read（）的返回值是来自C 程序的字节数。若这个值为…1，意味着某个地方出现了问题。否则，我们就将
resultBuf （结果缓冲区）转换成一个字串，然后同样清除多余的空格。随后，这个字串会象往常一样进入一
个DatagramPacket，并传回当初发出请求的那个同样的地址。注意发送方的地址也是我们接收到的
DatagramPacket 的一部分。
记住尽管C 程序必须在 Web 服务器上编译，但 Java 程序的编译场所可以是任意的。这是由于不管使用的是什
么硬件平台和操作系统，编译得到的字节码都是一样的。就就是Java 的“跨平台”兼容能力。
15。5。2 NameSender 程序片
正如早先指出的那样，程序片必须用Java 1。0 编写，使其能与绝大多数的浏览器适应。也正是由于这个原
因，我们产生的类数量应尽可能地少。所以我们在这儿不考虑使用前面设计好的Dgram 类，而将数据报的所
有维护工作都转到代码行中进行。此外，程序片要用一个线程监视由服务器传回的响应信息，而�