我试图用java实现一个套接字的侦听器 DataSocket ，所以我创建了一个新的listener类 ExecutorService 在自己的线索上运行。在同一个类中，我想创建另一个方法，该方法也将通过同一个套接字将消息发送到同一个地址（因为该服务器也在等待我的答案）。
由于某种原因，套接字一直处于关闭状态，我得到了一个异常。
我用w while 循环等待消息，当我得到响应时，我使用回调发送一个答案。
这是实现：这是侦听器类：

public class MessageListener implements IMessageTransport {

    private final static int TIMEOUT_MILLIS = 300;
    private final int port = 12000;
    private InetAddress address;

    private DatagramSocket socket;

    private Executor executor;

    public MessageListener(String address, Executor executor) {
        this.executor = executor;

        try {
            this.address = InetAddress.getByName(address);
            socket = new DatagramSocket(null);
            SocketAddress sockaddr = new InetSocketAddress(this.address, port);
            socket.bind(sockaddr);
            socket.setSoTimeout(TIMEOUT_MILLIS);
        } catch (SocketException | UnknownHostException e) {
            e.printStackTrace(); // todo - handle exception
        }
    }

    public void start(final MessageTransportCallback callback) {
        executor.execute(new Runnable() {
            @Override
            public void run() {
                System.out.println("heresa");
                listen(callback);
            }
        });
    }

    public void send(byte[] message) {
        executor.execute(new Runnable() {
            @Override
            public void run() {
                System.out.println("heresa");
                sendMessage(message);
            }
        });
    }

    private void sendMessage(byte[] message) {
        System.out.println("Sending message: " + bytesToHex(message));
        try {
            DatagramPacket request = new DatagramPacket(message, message.length, this.address, this.port);
            socket.send(request);
        } catch (SocketTimeoutException e1) {
            System.out.println("timeout");
        } catch (IOException e) {
            e.printStackTrace(); // todo - handle exception
        }
    }

    private void listen(final MessageTransportCallback callback) {
        DatagramPacket reply;
        System.out.println("here");

        while (true) {
            try {
                byte[] data = new byte[2048];
                reply = new DatagramPacket(data, data.length);
                socket.receive(reply);
                if (reply.getLength() != 0) {
                    System.out.println("Read bytes: " + bytesToHex(reply.getData()));
                    callback.onComplete(Arrays.copyOfRange(reply.getData(), 0, reply.getLength()));
                }
            } catch (SocketTimeoutException e1) {
//                System.out.println("timeout?");
            } catch (IOException e) {
                e.printStackTrace(); // todo - handle exception
            }
        }
    }
}

这就是我发送信息和启动侦听器的方式：

final ExecutorService executorService = Executors.newFixedThreadPool(5);
MessageListener messageListener = new MessageListener(address, executorService);
messageListener.start(new MessageTransportCallback() {
    @Override
    public void onComplete(byte[] response) {
        System.out.println(response);
    }
});
messageListener.send(bytemessage);

虽然我得到一个绑定套接字错误：

java.net.BindException: Cannot assign requested address: Cannot bind
    at java.base/java.net.DualStackPlainDatagramSocketImpl.socketBind(Native Method)
    at java.base/java.net.DualStackPlainDatagramSocketImpl.bind0(DualStackPlainDatagramSocketImpl.java:84)
    at java.base/java.net.AbstractPlainDatagramSocketImpl.bind(AbstractPlainDatagramSocketImpl.java:117)
    at java.base/java.net.DatagramSocket.bind(DatagramSocket.java:395)
    at main.MessageListener.<init>(MessageListener.java:33)
    at main.Main.main(Main.java:194)

但奇怪的是，如果我像这样向套接字发送消息，它就会工作：

DatagramPacket request = new DatagramPacket(message, message.length, this.address, this.port);
socket.send(request);

这意味着套接字不会以这种方式返回绑定错误，但是，我不能像这样侦听套接字，我只能在发送消息之后才收到消息。。。
以及我为什么得到 bind 错误？如何创建一个具有侦听新消息的线程和发送消息的线程的套接字？