Блог

Я создал два разных класса java, для клиента и для сервера, с методами отправки и получения в каждом. В соответствии с задачей я должен был установить соединение сервер-клиент через DatagramPacket и соединение клиент-сервер через DatagramChannel . Последний отлично работает, но у меня проблемы с датаграммами-они отправляются с сервера и никогда не поступают на клиент. Что случилось?

 public class TransferClient implements Serializable{
    private static final long serialVersionUID = 26L;
    public TransferClient() {

    }

    public void send(Command com) throws IOException {
        SocketAddress socketAddressChannel = new InetSocketAddress("localhost", 1);
        DatagramChannel datagramChannel=DatagramChannel.open();
        ByteBuffer bb;
        datagramChannel.connect(socketAddressChannel);
        ByteArrayOutputStream baos = new ByteArrayOutputStream();
        ObjectOutputStream oos = new ObjectOutputStream(baos);
        oos.writeObject(com);
        oos.flush();
        bb=ByteBuffer.wrap(baos.toByteArray(),0, baos.size());
        datagramChannel.send(bb,socketAddressChannel);
        baos.close();
        oos.close();
    }

    public Command receive() throws IOException, ClassNotFoundException {
        SocketAddress address = new InetSocketAddress(2029);
        DatagramSocket s = new DatagramSocket();
        DatagramPacket inputPacket = new DatagramPacket(new byte[1024],1024, address);
        s.receive(inputPacket);
        ByteArrayInputStream bais = new ByteArrayInputStream(inputPacket.getData());
        ObjectInputStream ois = new ObjectInputStream(bais);
        return (Command) ois.readObject();
    }
}

public class TransferServer {
    public TransferServer(){

    }

    public void send(Command com) throws IOException {
        ByteArrayOutputStream baos = new ByteArrayOutputStream();
        ObjectOutputStream oos = new ObjectOutputStream(baos);
        byte[] buffer;
        oos.writeObject(com);
        oos.flush();
        buffer=baos.toByteArray();
        SocketAddress address = new InetSocketAddress("localhost",2029);
        DatagramSocket s = new DatagramSocket();
        DatagramPacket outputPacket = new DatagramPacket(buffer,buffer.length,address);
        s.send(outputPacket);
    }


    public Command receive() throws IOException, ClassNotFoundException {
            SocketAddress socketAddressChannel = new InetSocketAddress("localhost", 1);
            DatagramChannel datagramChannel = DatagramChannel.open();
            datagramChannel.bind(socketAddressChannel);
            ByteBuffer bb = ByteBuffer.allocate(1024);
            datagramChannel.receive(bb);
            ByteArrayInputStream bais = new ByteArrayInputStream(bb.array());
            ObjectInputStream ois = new ObjectInputStream(bais);
            Command command;
            System.out.println(ois.available());
            command =(Command) ois.readObject();
            datagramChannel.close();
            ois.close();
            bais.close();
            return command;
    }
}
 

Вам необходимо указать порт, к которому вы будете привязаны DatagramSocket , чтобы получать свои данные. В противном случае он будет привязан к первому доступному порту, найденному на вашем компьютере.

И вам не нужно SocketAddress здесь, но вам нужно учитывать фактическую длину полученного пакета.

См.Документацию java.net. DatagramSocket

В receive() методе вашего TransferClient класса:

 public Command receive() throws IOException, ClassNotFoundException {

    DatagramSocket s = new DatagramSocket(2029); //Add your port Here

    DatagramPacket inputPacket = new DatagramPacket(new byte[1024],1024);
    s.receive(inputPacket);
    ByteArrayInputStream bais = new ByteArrayInputStream(inputPacket.getData(), 0, packet.getLength());
    ObjectInputStream ois = new ObjectInputStream(bais);
    return (Command) ois.readObject();
}