Проблема с связью Java UDP с многопоточностью - PullRequest
Новая
       12

Проблема с связью Java UDP с многопоточностью

0 голосов
/ 23 ноября 2018

Сейчас я изучаю сетевое программирование на языке Java, и я написал программу, которая 30 раз отправляет текущее время на сервер, и сервер создаст новый поток для анализа полученного пакета UDP и выдаст обратную связь клиенту, если сервер получит UDP.пакет.

Вопрос в том, что после запуска моего кода Сервер может получить пакет UDP и создать новый поток, но кажется, что DatagramSocket и DatagramPacket не передаются потоку.Отсюда поток не может дать отзыв клиенту, и клиент будет ждать все время после отправки первого пакета UDP.

Мой код здесь:

Сервер 

public class MulUDPServer {
public static void main(String[] args) {
    DatagramSocket socket = null; 
    DatagramPacket receivedPacket; 
    final int PORT = 10010; 
    byte[] b = new byte[1024];
    receivedPacket = new DatagramPacket(b, b.length);
    try {
        socket = new DatagramSocket(PORT);
        System.out.println("Server start!");
        while (true) {
            // receive the packet from server
            socket.receive(receivedPacket);
            // to check if Server get the packet
            System.out.println(new String(receivedPacket.getData(), 0, receivedPacket.getLength()));
            // start the thread to handle the packet we have got
            Thread thread = new Thread(new LogicThread(socket, receivedPacket));
            thread.start();
        }
    } catch (Exception e) {
        e.printStackTrace();
    } finally {
        try {
            // close the connection
            socket.close();
        } catch (Exception e) {
        }
    }
}

Thread 

public class LogicThread implements Runnable {

DatagramSocket socket = null;
DatagramPacket receivedPacket = null;

public LogicThread(DatagramSocket socket, DatagramPacket receivedPacket) {
    this.socket = socket;
    this.receivedPacket = receivedPacket;
}

public void run() {
    try {
        // to test if a thread have been set up
        System.out.println("a thread have been set up");
        byte[] data = receivedPacket.getData();
        int len = receivedPacket.getLength();
        // get the client IP
        InetAddress clientAddress = receivedPacket.getAddress();
        // get the client port
        int clientPort = receivedPacket.getPort();
        // print the info about received packet
        System.out.println("Client's IP：" + clientAddress.getHostAddress());
        System.out.println("Client's port：" + clientPort);
        System.out.println("The info：" + new String(data, 0, len));
        // feedback to Client
        byte[] b = "OK".getBytes();
        DatagramPacket sendPacket = new DatagramPacket(b, b.length, clientAddress, clientPort);
        // send
        socket.send(sendPacket);
    } catch (Exception e) {
        e.printStackTrace();
    }
}
}

Клиент 

public class MulUDPClient {
public static void main(String[] args) {
        DatagramSocket socket = null; 
        DatagramPacket sendPacket; 
        DatagramPacket receivedPacket; 
        String serverHost = "localhost"; 
        int serverPort = 10010; 
        try {
            socket = new DatagramSocket();
            InetAddress address = InetAddress.getByName(serverHost);
            byte[] b = new byte[1024];
            receivedPacket = new DatagramPacket(b, b.length);
            System.out.println("Client ready!");
            for (int i = 0; i < 30; i++) {
                // get the current time
                Date d = new Date(); 
                String content = d.toString(); 
                byte[] data = content.getBytes();
                sendPacket = new DatagramPacket(data, data.length, address, serverPort);
                socket.send(sendPacket);
                System.out.println("already send time");
                Thread.sleep(10);

                // receive packet from Server
                socket.receive(receivedPacket);
                byte[] response = receivedPacket.getData();
                int len = receivedPacket.getLength();
                String s = new String(response, 0, len);
                System.out.println("the feedback from Server：" + s);
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                // close the connection
                socket.close();
            } catch (Exception e) {
            }
        }
    }
}

** Результат ** после запуска Сервера и Клиента отдельно в двух терминалах:

Сервер 

Server start!
Fri Nov 23 14:52:02 CST 2018
a thread have been set up

Клиент 

Client ready!
already send time

Из результатов, которые мы можем узнать, Клиент отправил пакет UDP, а Сервер правильно его проанализировал и создал поток.Затем программа ждет ...

Это озадачивает меня несколько дней, Может кто-нибудь помочь мне решить ее?:).Спасибо!

Редактировать

Клиент

** НЕ МОЖЕТ ** работать 

for (int i = 0; i < 30; i++) {
    Thread writerWorker = new WriterWorker(socket);
    writerWorker.start();
    Thread readerWorker = new ReaderWorker(socket);
    readerWorker.start();
}

** МОЖЕТ ** работать 

for (int i = 0; i < 30; i++) {
    Date d = new Date(); 
    String content = d.toString(); 
    byte[] data = content.getBytes();
    sendPacket = new DatagramPacket(data, data.length, address, serverPort);
    socket.send(sendPacket);
    Thread.sleep(10);
    Thread readerWorker = new ReaderWorker(socket);
    readerWorker.start();
}

WriterWorker 

public class WriterWorker extends Thread {
    DatagramSocket socket;
    String serverHost = "localhost";
    int serverPort = 10000;
    DatagramPacket sendPacket;

    public WriterWorker(DatagramSocket socket) {
        this.socket = socket;
    }

    @Override
    public void run() {
        try {
            InetAddress address = InetAddress.getByName(serverHost);
            Date d = new Date();
            String content = d.toString();
            byte[] data = content.getBytes();
            sendPacket = new DatagramPacket(data, data.length, address, serverPort);
            socket.send(sendPacket);
            System.out.println("already send time");

        } catch (Exception e) {
            // TODO: handle exception
        }
    }
}

Ответы [ 2 ]

0 голосов
/ 23 ноября 2018

в вашей логике есть недостаток, когда вы делаете socket.receive(receivedPacket);, это позволит работнику ждать, пока некоторые пакеты дейтаграмм не поступят ...

правильный способ обработки асинхронной связи через сокеты будетследующий (здесь пример для клиентской части) 

socket = new DatagramSocket();
Thread readerWorker = new ReaderWorker(socket);
readerWorker.start();

Thread writerWorker = new WriterWorker(socket);
writerWorker.start();

таким образом вы бы разделили чтение и запись в разные потоки, а метод блокировки socket.receive(...) не остановил бы ваш поток записи ...

каждый работник будет реализовывать свой собственный рабочий цикл

цикл записи: 

while(true){
    if (sendPacket!= null){
        socket.send(sendPacket);
    }
    Thread.sleep(10);
}

цикл чтения: 

while(true){
    socket.receive(receivedPacket);
    handlePacket(receivedPacket);
}

ПРИМЕЧАНИЕ:

этот код былнаписано совершенно не в своем уме, я не проверял правильный синтаксис

0 голосов
/ 23 ноября 2018

удалить "Thread.sleep (10)" в клиенте

...