server.java

网络服务器和客户端小程序 请多多指教 哈哈哈哈

//服务器端程序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); }
　} 
}

//客户端通信小应用程序 Echo.java

import java.io.*;
import java.net.*;
import java.awt.*;
import java.applet.*;

public class Echo extends Applet
{
　TextArea ta;
　Socket echoSocket;
　DataOutputStream os;
　DataInputStream is;
　String Line;

　public void init() 
　{ 
　　setBackground(Color.white);
　　ta=new TextArea(5,80);
　　ta.setEditable(false);
　　add(ta); 
　　try
　　{
　　　echoSocket=new Socket("10.102.4.41",1111);} //与服务器建立连接
　　　catch(IOException e)
　　　{System.out.println("error");}
　　}
　　public void st(String stri) //发送字符串的方法
　　{　
　　　try
　　　{
　　　　DataOutputStream os=new DataOutputStream(echoSocket.getOutputStream());
　　　　DataInputStream is=new DataInputStream(echoSocket.getInputStream()); 
　　　　os.writeUTF(""+ stri ); //向服务器输送string
　　　　os.flush();
　　　}
　　　catch(IOException e)
　　　{System.out.println(" error:"+e); } 
　　} 

　　public String st1() //接收字符串的方法
　　{
　　　String Line="";
　　　try
　　　{
　　　　DataOutputStream os=new DataOutputStream(echoSocket.getOutputStream());
　　　　DataInputStream is=new DataInputStream(echoSocket.getInputStream()); 
　　　　Line=is.readUTF(); //从服务器读来的信息
　　　　ta.appendText(""+Line); //在文本域中输出信息
　　　}
　　　catch(IOException e)
　　　{
　　　　System.out.println(" error:"+e);
　　　}
　　　return Line;
　　}
　}