交互

Question

A向B说：hello  B  
B收到后向A说：hello  A 
要代码！

Answer 1

public interface EventHanlder{
   public void handleEvent(String evt);
}public class A implements EventHanlder{
   public void handleEvent(String evt){
       System.out.println("Receive Event :" + evt);
   }
   public sayHello(){
       B b = new B();
       b.hello("Hello B");
   }
   public static void main(String args[]){
       A a = new A();
       a.sayHello();
   }
}
public class B{
   private EventHanlder a;
   public B(EventHanlder a){ this.a = a;}
   
   public void hello(String content){
      System.out.println("B Receive Event:" + content);
      if(null != a) a.handleEvent("Hello handler!");
   }
}
随手写的，没调过，意思就是使用回调

Answer 2

import java.io.*;
import java.net.*;
public class Server
{
  
ServerSocket server = null;
    Socket you = null;
public Server()
{
 try
 {
  server = new ServerSocket(2007);
  while(true)
  {
  you = server.accept();
  if(you != null)
  new Thread(new Services(you)).start();
  }
 }catch(Exception e){}

} public static void main(String args[])
 {      new Server();
 }
 
 }
 
 class Services implements Runnable
 {
  Socket you = null;
  String data = null;
  public Services(Socket you)
  {
  this.you = you;
  }
 
  public void run()
  {
  try
  {
  DataInputStream din = new DataInputStream(you.getInputStream());
  DataOutputStream dout = new DataOutputStream(you.getOutputStream());
  while(true)
  {
  data = din.readUTF();
 
  if(data.equals("exit"))
  {
     System.out.println(data);
     break;
     
   }
   
  dout.writeUTF("hello  B ");
  }
  dout.close();
  din.close();
  you.close();
  }catch(Exception e){}
 }
 }

Answer 3

import java.io.*;
import java.net.*;
public class Client
{
Socket you = null;
public Client()
{
 try
 {
  you = new Socket("localhost",2007);
  if(you != null)
  new Thread(new SendData(you)).start();
 }catch(Exception e){}

} public static void main(String args[])
 {      new Client();
 }
 
 }
 
 class SendData implements Runnable
 {
  Socket you = null;
  String data = null;
  public SendData(Socket you)
  {
  this.you = you;
  }
 
  public void run()
  {
  try
  {
  DataInputStream din = new DataInputStream(you.getInputStream());
  DataOutputStream dout = new DataOutputStream(you.getOutputStream());
            BufferedReader bin = new BufferedReader(new InputStreamReader(System.in));
            
  while(true)
  { 
     dout.writeUTF("hello  A");
     System.out.println(din.readUTF());
     data = bin.readLine();
     if(data.equals("exit"))
     {
        dout.writeUTF(data);
        break;
     }
 
  }
  dout.close();
  din.close();
  you.close();
  }catch(Exception e){}
 }
 }编译运行通过，参考下

Answer 4

import java.io.*;
import java.net.*;
public class Server
{
  
ServerSocket server = null;
    Socket you = null;
public Server()
{
 try
 {
  server = new ServerSocket(2007);
  while(true)
  {
  you = server.accept();
  if(you != null)
  new Thread(new Services(you)).start();
  }
 }catch(Exception e){}

} public static void main(String args[])
 {      new Server();
 }
 
 }
 
 class Services implements Runnable
 {
  Socket you = null;
  String data = null;
  public Services(Socket you)
  {
  this.you = you;
  }
 
  public void run()
  {
  try
  {
  DataInputStream din = new DataInputStream(you.getInputStream());
  DataOutputStream dout = new DataOutputStream(you.getOutputStream());
  while(true)
  {
  data = din.readUTF();
  System.out.println(data);
  if(data.equals("exit"))
  {
     System.out.println("客户退出！继续监听中...");
     break;
     
   }
   
  dout.writeUTF("hello  B ");
  }
  dout.close();
  din.close();
  you.close();
  }catch(Exception e){}
 }
 }
不好意思，忘记改了