使用JAVA编写网络通信程序

等
java.io: 基于流模型的输入/输出包。该包用统一的流模型实现了各种格式的输入/输出，包括文件系统、网络和设备的输入/输出等
java.net: 网络包。该包支持TCP/IP协议，其中提供了socket、URL和WWW的编程接口
java.awt: 抽象窗口工具集。其中实现了可以跨平台的图形用户界面组件，包括窗口、菜单、滚动条和对话框等
java.applet: 支持applet程序设计的基本包
(6) 安全性
用于网络、分布环境下的Java必须要防止病毒的入侵，Java不支持指针，一切对内存的访问都必须通过对象的实例变量来实现，这样就防止了程序员使用欺骗手段访问对象的私有成员，同时也避免了指针操作中容易产生的错误。
4  JAVA工具
(1) JDK
1)      Java编译器
Java编译器将Java源代码文件编译成可执行的Java字节码。Java源代码文件的扩展名为 .java，Java编译器把这种扩展名的文件编译成扩展名为.class的文件。源文件中的每个类在编译后都将产生一个class文件，这意味一个Java源代码文件可能编译生成多个class文件。
2)      Java解释器
Java解释器对编译生成的字节码格式的可执行程序的运行提供支持，它是运行非图形Java程序的命令行工具。
3)      Appletviewer
它是Java Applet的简单测试工具，可使用它来测试Java Applet程序，而不需要WWW浏览器的支持。
(2) Visual J++
Visual J++ 集成了可视化界面设计、交互式调试、代码编辑、联机帮助信息和介绍如何快速掌握该开发环境的实用向导等多项功能，同时具有能充分利用Active X和COM新技术的优势。利用Visual J++可创建交互性很强的Internet应用程序，是难得的Java 开发系统。

5  客户机/服务器通信的实现：
(1) Application 同 Applet 的通信
两端通过Socket机制进行连接：
1)      客户端的编程流程:
      打开Socket，新建一个套接字；
      为套接字建立一个输入和输出流；
      根据服务器协议从套接字读入或向套接字写入；
      清除套接字和输入/输出流；
2)服务器端的编程流程:
      打开Server Socket,创建一个服务器型套接字和一个普通套接字，服务器型套接字在指定端口为客户端请求的Socket 服务；
      使用ServerSocket类的accept()方法使服务器型套接字处于监听状态并把监听结果返回给普通套接字；
      为该普通套接字创建输入和输出流；
      从输入和输出流中读入或写入字节流，进行相应的处理，并将结果返回给客户端；
      在客户端和服务器工作结束后关闭所有的对象,如服务器型的套接字,普通套接字,输入和输出流。
正是由于Java系统具有基于Socket的灵活通信机制，因而其应用程序能自由地打开和访问网络上的对象，就象在本地文件系统中一样。
(2) Applet之间的通信：
Applet之间的通信使用Applet Context类的getApplet()方法。
<applet  code=applet1.class  width=200  height=200  name=first>
只要在程序中加入 
Applet  oneapplet=getAppletContext().getApplet(“first”);便可使用name为first的Applet中的方法了。
在该课题中大量使用了该种通信方法，因为专门同服务器端通信的 Applet中包含接收信息方法和发送信息方法，所有客户端的Applet都要使用负责通信的Applet中的方法，所以客户端的Applet同负责通信的Applet必须进行通信。

6 程序
//服务器端程序S.java 负责与客户端通信
import java.io.*;
import java.net.*;
import java.lang.*;
import T2;

class ThreadEchoHandler extends Thread   //创建线程
{
     T2 theT2=new T2();
    
     Socket  incoming;
     int counter;
 
     ThreadEchoHandler(Socket i,int c)
     {  incoming=i;
        counter=c;  }

     public void run()
     {
           try
           {
           DataInputStream  in=new DataInputStream(incoming.getInputStream());
             DataOutputStream out=new DataOutputStream(incoming.getOutputStream());
             System.out.println ("hello");     
             boolean done=false;

                 while(!done)
                 {   String aa="";
                       String str=in.readUTF();     //从客户端得到字符串

                            
                           //在此加入各自的服务程序
                
                             System.out.println (str);
                    theT2.pass(str);  //解码
                             theT2.tongji();   //修改监控库中的信息

                           aa=theT2.guan();   //操纵数据库
                             System.out.println ("string z is:"+aa);

                    if(aa.compareTo("null")!=0 ) 
                                      //若是查询数据库，返回查询后的结果
                             {                   //若不是查询数据库，不向客户端输出信息
                               out.writeUTF(aa);
                               out.flush();  }
                 }//while

                 incoming.close();    //线程关闭
          
           }//try

           catch(IOException e)
           {System.out.println(e);}
     }//end run
}

//----------------------------------------
class S
{ 
     public static void main(String[] args)
     {     
                 int i=1;
           try
           {
                 ServerSocket s=new ServerSocket(1111);
                 for(;;)
                 {
                       Socket  incoming=s.accept();
                       System.out.println("connect:  "+i);
                       new ThreadEchoHandler(incoming,i).start();
                       i++;
                 }
           }
           catch(Exception e)
           { System.out.println(e); }
     }     
}

//客户端通信

上一页  [1] [2] [3]  下一页