www.pudn.com > ServerClient.rar > ServerClient.java

import java.io.*; 
import java.net.*; 
 
public class ServerClient 
{ 
 
  public ServerClient(int port) 
  { 
    Server server=new Server(port); 
    server.start(); 
    Client client=new Client(port); 
    client.start(); 
  } 
 
  public static void main(String[] args) 
  { 
    new ServerClient(7777); 
  } 
} 
 
//服务器线程 
class Server extends Thread 
{ 
  //使用端口号 
  int port; 
  ServerSocket server; 
  Socket socket; 
  //服务器输出流 
  DataOutputStream outStream=null; 
  //服务器输入流 
  DataInputStream inStream=null; 
 
  public Server(int port) 
  { 
    try 
    { 
      this.port=port; 
      server=new ServerSocket(port); 
    } 
    catch(Exception e) 
    { 
      System.out.println(e.toString()); 
    } 
  } 
 
  public void run() 
  { 
    try 
    { 
      //监听用户连接 
      socket=server.accept(); 
      outStream=new DataOutputStream(socket.getOutputStream()); 
      inStream=new DataInputStream(socket.getInputStream()); 
      //服务器准备好，可以进行通讯 
      System.out.println("server is ok,please continue!"); 
      while(true) 
      { 
        //读取从客户端发送的信息 
        String str=inStream.readUTF(); 
        System.out.println("The server receive String:"+str); 
        //将信息重新向客户端发送 
        outStream.writeUTF(str); 
      } 
    } 
    catch(Exception e) 
    { 
      System.out.println(e.toString()); 
    } 
  } 
} 
 
class Client extends Thread 
{ 
  //指定通讯端口  
  int port; 
  Socket socket; 
  DataInputStream inStream=null; 
  DataOutputStream outStream=null; 
 
  public Client(int port) 
  { 
    try 
    { 
      this.port=port; 
      //建立同本地机子的socket连接 
      socket=new Socket(InetAddress.getLocalHost(),port); 
      inStream=new DataInputStream(socket.getInputStream()); 
      outStream=new DataOutputStream(socket.getOutputStream()); 
      //客户端准备好，可以进行通讯 
      System.out.println("client is ok,please continue!"); 
    } 
    catch(Exception e) 
    { 
      System.out.println(e.toString()); 
    } 
  } 
  public void run() 
  { 
    try 
    { 
      while(true) 
      { 
        byte[] b=new byte[1024]; 
        String str=""; 
        //从键盘读取字符串 
        int m=System.in.read(b); 
        str=new String(b,0,0,m-1); 
        //向服务器发送信息 
        outStream.writeUTF(str); 
        //从服务器读取信息 
        str=inStream.readUTF(); 
        System.out.println("The client receive String:"+str); 
      } 
    } 
    catch(Exception e) 
    { 
      System.out.println(e.toString()); 
    } 
  } 
}