java - 数据报 channel 与线程一起工作

Question

我正在尝试设计一个系统，其中有发送方和接收方，双方都可以发送和接收数据包。我为每个发送方和接收方使用 2 个数据报 channel ，并在每一侧使用 2 个线程来处理该问题。

从发送者向接收者发送数据工作正常，但是当我在接收者端收到该数据时，我想发回确认，但我似乎无法在发送者端接收。我的逻辑看起来正确吗？

这是我的类(class)的详细信息:

线程类

Thread t = new Thread(new Sender())
Thread t1 = new Thread(new Receiver())
t.start()
t1.start();

发送者类别

Sender implements Runnable{
    //open  channel
    //connect to address
    //send over data in run method
}

Sender ACK class{
    //open channel
    //connect
    //retrieve and get data received (WAITS For incoming data but data has already been sent)
}

接收器类

Receiver implements Runnable{
   //open channel
   //bind
   //Print out data received
       //send ack
}

Receiver ACK class{
    //open channel
    //connect
    //send ack method
      //send out data
}

Answer 1

我认为您需要某种同步来确保您的接收者准备好接收消息。例如，您可以使用 CountDownLatch

在发送方中，您应该await()，接收方应该在闩锁对象上调用countDown()。尝试此操作以确保您的接收器在发送消息时已准备好接收消息。如果这没有帮助，请显示您的发件人和收件人代码。