java - 在 Android 中同时使用 Datagramsocket 发送和接收 - 只是发送？

Question

我在一个线程中使用 DatagramSocket 接收数据，在另一个线程中使用 DatagramSocket 将数据发送到 PC (Java)。但它只是每 1 秒发送一次数据但不接收。 但是当我在发送代码后将接收代码放在同一个线程中时......它有效...... 但我想每隔一秒发送一次数据，同时等待任何数据......

编辑:我发现问题是我无法在两个不同的线程中打开一个端口。现在我的问题是，如何每 1 秒取消一次 DatagramSocket.Receive() 并发送我的数据并再次返回接收？

public class MainActivity extends ActionBarActivity {

TextView status;
GPSTracker gps;
boolean started = false;
boolean waitting = false;
String mess = "Waiting ...";

@Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_main);
    status = (TextView) findViewById(R.id.status);

    gps = new GPSTracker(MainActivity.this);

    Timer time = new Timer(); // Instantiate Timer Object
    ScheduledTask st = new ScheduledTask(); 
    time.schedule(st, 0, 1000); // Create Repetitively task for every 1 secs
}

public class SendThread implements Runnable {
    private DatagramSocket mySocket;

    public void run() {
        try {
            InetAddress receiverHost = InetAddress.getByName("192.168.0.1");
            int receiverPort = Integer.parseInt("8080");
            String message = "Lat:0-Long:0";
            if (gps.canGetLocation()) {
                double latitude = gps.getLatitude();
                double longitude = gps.getLongitude();
                message = "Lat:" + latitude + "-Long:" + longitude;
            } else {
                gps.showSettingsAlert();
            }
            mySocket = new DatagramSocket();
            byte[] sendBuffer = message.getBytes();
            DatagramPacket packet = new DatagramPacket(sendBuffer,
                    sendBuffer.length, receiverHost, receiverPort);
            mySocket.send(packet);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

public class RecieveThread implements Runnable {
    public void run() {
        try {
            Log.i("1", "1");
            DatagramSocket mySocket = new DatagramSocket(8080);
            waitting = true;
            // to receive a message
            int MESSAGE_LEN = 60;
            byte[] recvBuffer = new byte[MESSAGE_LEN];
            DatagramPacket datagram = new DatagramPacket(recvBuffer,
                    MESSAGE_LEN);
            Log.i("2", "2");
            mySocket.receive(datagram);
            Log.i("Recieved", "Recieved");
            String recvdString = new String(recvBuffer);
            mess = recvdString;
            runOnUiThread(new Runnable() {
                @Override
                public void run() {
                    status.setText(mess);
                }
            });
            mySocket.close();
            waitting = false;
        } catch (Exception e) {
            waitting = false;
            e.printStackTrace();
        }
    }
}

public class ScheduledTask extends TimerTask {
    public void run() {
        if (!waitting) {
            Thread rThread = new Thread(new RecieveThread());
            rThread.start();
        }
        Thread sThread = new Thread(new SendThread());
        sThread.start();
    }
}
}

Answer 1

我找到了答案: 我使用了两个不同的套接字，一个用于通过端口发送数据，另一个用于从同一端口接收数据。 (两个不同的线程) 但第一个应该连接到那个端口，第二个应该绑定(bind)到那个端口。 一切正常。