我刚做的import java.net.*;
import java.io.*;class view extends Thread
{
BufferedReader br;
DataInputStream dis;
DataOutputStream dos;
public view(BufferedReader br,DataInputStream dis,DataOutputStream dos)
{
this.br=br;this.dis=dis;this.dos=dos;
}
public void run()
{
this.viewclient();
}
public void viewclient()
{
while(true)
{
try
{
String str = br.readLine(); if (str.equals("END")) break;
System.out.println("you: " + str);
}
catch (IOException e)
{
e.printStackTrace();
}
}
}
};
class chat extends Thread
{
BufferedReader br;
DataInputStream dis;
DataOutputStream dos;
chat(BufferedReader br,DataInputStream dis,DataOutputStream dos)
{
this.br=br;this.dis=dis;this.dos=dos;
}
public void run()  
{
this.viewclient();
}
public void viewclient()
{
while(true)
{
try
{
//String str=dis.readLine();
//dos.writeBytes(str);
int i=dis.read();
dos.write(i);
System.out.print((char)i);
}
catch (IOException e)
{
e.printStackTrace();
}
}
}
};
class chatserver 
{
//public static int clientnum; chatserver()
{
//clientnum++;
} public static void main(String[] args) throws IOException
{
ServerSocket ss=new ServerSocket(8080);
Socket s=ss.accept();
BufferedReader br=new BufferedReader(new InputStreamReader(s.getInputStream()));
DataInputStream dis=new DataInputStream(System.in);
DataOutputStream dos=new DataOutputStream(s.getOutputStream());
view v=new view(br,dis,dos);
v.start();
chat c=new chat(br,dis,dos);
c.start();
}
}
class chatclient
{
public static int clientnum; chatclient()
{
clientnum++;
} public static void main(String[] args) throws IOException
{
//BufferedReader br=new BufferedReader(new InputStreamReader(System.in));
//BufferedWriter bw=new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));

Socket s=new Socket("127.0.0.1",8080);
BufferedReader br=new BufferedReader(new InputStreamReader(s.getInputStream()));
DataInputStream dis=new DataInputStream(System.in);
DataOutputStream dos=new DataOutputStream(s.getOutputStream());
/*while(true)
{
dos.write(dis.read());

String str = br.readLine();
//br.flush();
if (str.equals("END")) break;
System.out.println("you: " + str);

}*/

view v=new view(br,dis,dos);//查看信息线程
v.start();
chat c=new chat(br,dis,dos);//发送信息线程
c.start();
}
};