如何使相同的程序像服务器和客户端一样工作（使用java中的套接字）

Question

如何在java中使用相同的程序发送和接收数据？更糟糕的是，我需要在同一时间同时进行这两项操作。

Answer 1

您需要一个行为良好的队列，例如两个Thread之间的BlockingQueue。

public class TwoThreads { 
    static final String FINISHED = "Finished"; 
    public static void main(String[] args) throws InterruptedException { 
    // The queue 
    final BlockingQueue<String> q = new ArrayBlockingQueue<String>(10); 
    // The sending thread. 
    new Thread() { 
     @Override 
     public void run() { 
     String message = "Now is the time for all good men to come to he aid of the party."; 
     try { 
      // Send each word. 
      for (String word : message.split(" ")) { 
      q.put(word); 
      } 
      // Then the terminator. 
      q.put(FINISHED); 
     } catch (InterruptedException ex) { 
      Thread.currentThread().interrupt(); 
     } 
     } 
     { start();} 
    }; 
    // The receiving thread. 
    new Thread() { 
     @Override 
     public void run() { 
     try { 
      String word; 
      // Read each word until finished is detected. 
      while ((word = q.take()) != FINISHED) { 
      System.out.println(word); 
      } 
     } catch (InterruptedException ex) { 
      Thread.currentThread().interrupt(); 
     } 
     } 
     { start();} 
    }; 
    } 
}