Java在CS网络中的应用

1、java在c/s网络中的应用【简介】随着java语言的日益流彳亍，特别是java与internetweb的密切结合，使它在全球取得了 巨大的成功。java语言以其独立于平台、面向对象、分布式、多线索及完善的安全机制等特 色，成为现代信息系统建设中的良好的开发平台和运行环境。和internet上的许多环境一样，完整的java应用环境实际上也是一个客户机/服务器环境，更确 切地说是浏览器/服务器模型(即browser/server模型，简称web模型)。但与传统的客八机/服务器(c/s) 的二层结构不同，应用java的web模型是由三层结构组成的。传统的c/s结构通过消息传递机制， 由客户端发出请

2、求给服务器，服务器进行相应处理后经传递机制送回客户端。而在web模型中，服 务器一端被分解成两部分：一部分是应用服务器(web服务器)，另一部分是数据库服务器.针对分布式计算环境，java通过其网络类库提供了良好的支持。对数据分布，血va提供了一个 url(uniformresourcelocator)x'j.,利用此对象可打开并访问网络上的对彖，其访问方式与访问本地 文件系统几乎完全相同。对操作分布，java的客户机/服务器模式可以把运算从服务器分散到客户一 端(服务器负责提供查询结果，客户机负责组织结果的显示)，从而捉高整个系统的执行效率，增加 动态可扩充性。java网络类库是ja

3、va语言为适应internet环境而进行的扩展。另外，为适应internet 的不断发展，java还提供了动态扩充协议，以不断扩充jaw网络类库。java的网络类库支持多种intei-net协议，包括telneuftp和http(www),与此相对应的java 网络类库的子类库为：jj.ftpj.www.contentj.www.htmljava.nct.www.http这些子类库各自容纳了可用于处理internet协议的类和方法。其中，用于处理一些基本的 网络功能，包括远程登录(telnet)； .ftp用于处理ftp协议；.www.content用于处理www 页面内容；.www.html

4、和.wwvv.http则分别捉供了对html语言和http协议的支持。客户机/服务器在分布处理过程屮，使用基于连接的网络通信模式。该通信模式首先在客户 机和服务器z间定义一套通信协议，并创建一 socket类，利用这个类建立一条可靠的链接；然后， 客户机/服务器再在这条链接上可靠地传输数据。客户机发出请求，服务器监听來自客户机的请求， 并为客户机提供响应服务。这就是典型的“请求应答”模式。下面是客户机/服务器的一个典型运作过 程：1 服务器监听相应端口的输入；2. 客户机发出一个请求；3. 服务器接收到此请求；4. 服务器处理这个请求，并把结果返冋给客户机；5. 重复上述过程，直至完成一次会话

5、过程。按照以上过程，我们使用jaw语言编写一个分别针对服务器和客户机的应用程序(application)。 该程序在服务器上时，程序负责监听客户机请求，为每个客户机请求建立socket连接，从而为脅户 机提供服务。本程序提供的服务为：读取来自客户机的一行文本，反转该文木，并把它发回给客八机。通过该程序实例我们看到，使用java语言设计c/s程序时需要注意以卜-几点：(1) 、服务器应使用scrvcrsockct类來处理客户机的连接请求。当脅户机连接到服务器所监听的 端口时，scrvcrsockct将分配一新的socket对象。这个新的socket对象将连接到一些新端口，负责处 理与z相对应客八

6、机的通信。然后，服务器继续监听serversocket,处理新的客户机连接。socket和 serversocket是java网络类库提供的两个类。(2) 、服务器使用了多线程机制。server对象本身就是一个线程，它的nm()方法是一个无限循环, 用以监听來口客户机的连接。每当有一个新的客户机连接时，scrvcrsockct就会创建一个新的socket 类实例，同时服务器也将创建一新线程，即一个connection对象，以处理基于socket的通信。与客 八机的所有通信均由这个connection对象处理<>connection的构造函数将初始化基于socket对彖的通 信流，并

7、启动线程的运行。与客户机的通信以及服务的提供，均由connection对象处理。(3) 、客户机首先创建一 socket对象，用以与服务器通信。之后需创建两个对象：datalnputstrcam 和printstream,前者用以从socket的inputstream输入流屮读取数据，后者则用于往socket的 outputstream中写数据。最后，客户机程序从标准输入(如：控制台)中读取数据，并把这些数据写 到服务器，在从服务器读取应答消息，然后大这些应答消息写到到准输出。以下分别为服务器和客户机端的源程序清单。木程序在nt4.0网络环境(tcp/ip)下使用jdk1.1 调试通过。/se

8、rver.javaimportjava.io.*;.*;publicclassscrvcrcxtcndsthrcad publicfinalstaticintdefault_port=6543;protectdintport;protectdserversockrtlisten_socket;定义出错例穆：如果出现异常错误，退出程序。publicstaticvoidfail(exceptione,stringmsg)system.err.println(msg+m:"+e);systcm.cxit(l);/定义并启动服务器的socket例程，监听客户机的连接请求。publicserv

9、er(intport)if(port=0)port=default_port;this.port=port;trylisten_socket=newserversocket(port);caich(ioexceptione)fail(e, mexccptioncrcatingscrvcrsockcth); systcm.out.println(hscrvcr: listeningonportn+port); this.start();该线程一直循环执行，监听并接受客户机发岀的连接请求。对每一个连接，均产生一个连接 对象与z对应，通过socket通道进行通信。*/publicvoidrun()t

10、rywhile(true)socketci ie nt_sockct 二 listen_sockct.acccpt();conncctionc=ncwconncction(clicnt_sockct);catch(ioexceptione)fail(e/xceptionwhilelisteningforconnections1')启动服务器主程序publicstaticvoidmain(stringargs)in tport=0;if(args.lcngth=l)tryport=integer.parseint(args0); catch(numberformatexceptione)

11、port=0;ncwscrvcr(port);/endofthemain)/endofserverclass以卜定义了 connection类，它是用来处理与客户机的所有通信的线程。classconncctioncxtcndsthrcadprotectedsocketclient;protcctcddatalnputstrcamin;protectedprintstreamout;初始化通信流并启动线程publicc onn ection(socketclient_socket)clicnt=clicnt_sockct;try(in=newdatainputstream(client.geti

12、nputstream(); out=newprintstream(client.getoutputstream();catch(ioexccptionc)(tryclient.close();catch(ioexceptione2);system.err.printin(l,exceptionwhilegettingsocketstreram:,+e); return;)this.start;(/endofconnectionmethod服务例程：读出一行文木； 反转文本；返回文本。publicvoidrun()stringline;stringbuffcrrcvlinc;intlen;try

13、for(；;)/readalineline=i n.readline();if(line=null)break;/reversethelinelcn=linc.lcngth(); revline=newstringbuffer(len);for(inti=len-l ;i>=0;i)revline.insert(len-1 -i;line.charat(i);/writeoutthereverselineout.println(rcvlinc);catch(ioexceptione);finallytryclicnt.closc();catch(ioexceptione2);/endof

14、runmethod/endofconnectionclass/clienl.javaimportjava.io.*;.*;publicclassclientextendspublicstaticfinalintdefault_port=6543;/定义出错例程publicstaticfinalvoidusagc()(system.out.println(husage:javaclientm);system.exit(o);pub!icstaticvoidmain(stringargs)intport=default_port;sockets=null;/解析端口参数if(args.length

15、!=l)&&(args.length !=2)usage();if(args.length=l)port=default_port;elsetryport=lnteger.parselnt(args 1); catch(numberformaatexceptione)usage();try产生一个socket,通过指定的端口与主机通信。s=newsocket(args0,port);/产生用于发出和接收的文本字符流datainputstreamsin=newdatainputstream(s.getinputstream();printstreamsout=newdatal n

16、putstream(s.getinputstream();/从控制台读入字符流datainputstreamin=newdatalnputstrcam(systcm.in);返回连接的地址和端口system.out.println(mconnectedtom+s.getinetaddress()+l,:m+s.getport();stringline;for(;)显示提示符systcm.out.print(m>n);system.out.flush();/读入控制台输入的一行字符line=in.readline();if(l ine=n ull )break:/将接收的文木行送至服务器sout.println(line);从服务器接收一行字符line=sin.readline();/checkifconnectioniscloscd(i.c.foreof)if(line=null)sys