为什么我可以接收广播，但不能与我的应用程序中的特定套接字通信？

问题描述 投票：0回答：1

首先是一些有关我的设置的信息我有一台S8手机，我根据谷歌的AR-Devkit演示运行这个应用程序。

  public void closeSocket(DatagramSocket socket) {

    if (socket != null && socket.isConnected() ) {
        while (!socket.isConnected()) {
            socket.disconnect();
            try {
                Thread.sleep(SpringAR.TIME_OUT_IN_BROADCAST);
            } catch (InterruptedException e) {
                Log.d(SpringAR.protocollDebugLogPrefix, " Socket Closing interrupted");
                e.printStackTrace();
            }
        }
    }

    if (socket != null && !socket.isClosed()) {
        socket.close();
        while (!socket.isClosed()) {
            try {
                Thread.sleep(SpringAR.TIME_OUT_IN_BROADCAST);
            } catch (InterruptedException e) {
                Log.d(SpringAR.protocollDebugLogPrefix, " Socket Closing interrupted");
                e.printStackTrace();
            }
        }
    }
}

public DatagramSocket createSocket(InetAddress ipAddress, int port) {
    try {
        DatagramSocket socket = new DatagramSocket(null);
        InetSocketAddress address = new InetSocketAddress(ipAddress, port);
        socket.setReuseAddress(true);
        socket.bind(address);

        return socket;

    } catch (IOException e) {
        e.printStackTrace();
    }
    return null;
}

public DatagramSocket getBroadcastListenerSocket() throws IOException {

    InetSocketAddress anyAdress = new InetSocketAddress(InetAddress.getByName("0.0.0.0"), 9000);
    DatagramSocket socket = new DatagramSocket(null);
    socket.setSoTimeout(30);
    socket.setReuseAddress(true);
    socket.bind(anyAdress);
    return socket;
}

public DatagramSocket getBroadcastSenderSocket(DatagramSocket oldSocket) {

    DatagramSocket socket = null;
    try {
        ARDeviceAddress = InetAddress.getByName(comonUtils.getIPAddress(true));
        socket = getSocket(oldSocket, ARDeviceAddress, SpringAR.UDP_SERVER_PORT, null);
        socket.setBroadcast(true);
        socket.setSoTimeout(SpringAR.TIME_OF_FRAME_IN_MS);
    } catch (IOException e) {
        e.printStackTrace();
    }

    return socket;
}

public DatagramSocket getSocket(DatagramSocket oldSocket, InetAddress ipAddress, int port, InetAddress targetAddress) {

    if (oldSocket != null ) {
        closeSocket(oldSocket);
    }
    DatagramSocket socket = null;
    try {
        socket = createSocket(ipAddress, port);
        socket.setBroadcast(false);
        socket.setSoTimeout(SpringAR.TIME_OF_FRAME_IN_MS);
        if (targetAddress != null)
          socket.connect(targetAddress, port);

    } catch (SocketException e) {
        e.printStackTrace();
    }
    return socket;
}

 public class DatagramReciever extends Thread {

        private String datagramToSend = "";
        private boolean newDatagramToSend = false;
        private DatagramPacket snd_packet;

        DatagramSocket senderSocket = null;
        DatagramSocket listenerSocket = null;
        private DatagramSocket broadCastListenerSocket;

        //Buffer gettters and setters
        private int writeBuffer = 0;
        private SpringAR.comStates oldState;

        int getReadBuffer() {
            if (writeBuffer == 1) return 0;
            return 1;
        }

        void switchBuffer() {
            recieveByteIndex = 0;
            writeBuffer = getReadBuffer();
        }

        public String dbg_message = "";
        //Management Communication Headers

        public void kill() {
            closeSocket(senderSocket);
            closeSocket(listenerSocket);
            closeSocket(broadCastListenerSocket);
        }



        public void run() {

            try {

                initializeBroadcastConnection();

                while (true) {

                    //Recieving Datagramm
                    DatagramPacket rcv_packet = new DatagramPacket(rcv_message[writeBuffer], rcv_message[writeBuffer].length);
                    boolean NewMessageArrived = true;
                    try {
                        listenerSocket.receive(rcv_packet);
                    } catch (SocketTimeoutException e) {
                          NewMessageArrived = false;
                    }
                    //Watchdog
                    handleWatchDogTimer(State);

                    //TODO Delete String conversion
                    if (NewMessageArrived) {
                        dbg_message = new String(rcv_message[writeBuffer], 0, rcv_packet.getLength(), "US-ASCII");
                        Log.d(SpringAR.dataDebugLogPrefix, "" + rcv_packet.getAddress().getHostAddress() + ": " + dbg_message.trim() + " of " + rcv_packet.getLength() + "length ");
                    }

                    if (validatePackageSender(rcv_packet)) {
                        connectionStateMachine(rcv_message, rcv_packet);
                    }

                    //Sending Datagram
                    if (newDatagramToSend && hostIpAddress != null) {
                        //Log.d(SpringAR.protocollDebugLogPrefix, "Server sending: " + datagramToSend);
                        byte[] snd_message = datagramToSend.getBytes();

                        try {
                            snd_packet = packSendPackageByState(snd_message);
                            assert (snd_packet != null);
                            senderSocket.send(snd_packet);
                            newDatagramToSend = false;
                        } catch (IOException e1) {
                            e1.printStackTrace();
                            //causes     Caused by: android.system.ErrnoException: sendto failed: EINVAL (Invalid argument)
                            Log.e(SpringAR.protocollDebugLogPrefix, "Server Error in State: " + State.name());
                           break;
                        }

                    }

                }
            } catch (IOException e1) {
                e1.printStackTrace();
            }
        }

        private void initializeBroadcastConnection() throws IOException {
            ARDeviceAddress = InetAddress.getByName(comonUtils.getIPAddress(true));
            senderSocket = getSocket(null, ARDeviceAddress, SpringAR.UDP_SERVER_PORT, null);
            broadCastListenerSocket = getBroadcastListenerSocket();
            listenerSocket = broadCastListenerSocket;
            Log.d(SpringAR.protocollDebugLogPrefix, "initializeBroadcastConnection completed");
        }


        // handles management traffic like configurstion files
        private void connectionStateMachine(byte[][] payload, DatagramPacket rcv_packet) throws IOException {
            //Reset triggered by Host
            if (comonUtils.indexOf(payload[writeBuffer], SpringAR.recieveResetHeaderByte) != SpringAR.STRING_NOT_FOUND) {
                State = SpringAR.comStates.STATE_resetCommunication;
            }

            Log.d(SpringAR.protocollDebugLogPrefix, "ConnectionStateMachine: " + State.name());
            switch (State) {
                case STATE_resetCommunication: {
                    messageCounter = 0;
                    listenerSocket = broadCastListenerSocket;
                    hostIpAddress = comonUtils.getBroadcastAddress(context);
                    senderSocket = getBroadcastSenderSocket(senderSocket);
                    setSendToSpringMessage(SpringAR.sendResetHeader);
                    State = SpringAR.comStates.STATE_broadCastHeader;

                    return;
                }

                case STATE_broadCastHeader: {
                    if (comonUtils.indexOf(payload[writeBuffer], SpringAR.recieveHostReplyHeaderByte) != SpringAR.STRING_NOT_FOUND) {
                        Log.d(SpringAR.protocollDebugLogPrefix, " Host Reply Header recieved");
                        //Extract the hostIp
                        String hostIpAdressAsString = new String(payload[writeBuffer]);
                        hostIpAdressAsString = hostIpAdressAsString.replace(SpringAR.recieveHostReplyHeader, "").trim();
                        Log.d(SpringAR.dataDebugLogPrefix, hostIpAdressAsString);

                        hostIpAddress = InetAddress.getByName(hostIpAdressAsString);

                        //Set Connection from broadcast to target
                        ARDeviceAddress = InetAddress.getByName(comonUtils.getIPAddress(true));
                        Log.d(SpringAR.protocollDebugLogPrefix, " New Device Adress " + ARDeviceAddress);
                        senderSocket = getSocket(senderSocket, ARDeviceAddress, SpringAR.UDP_SERVER_PORT, hostIpAddress);
                        listenerSocket = senderSocket;
                        State = SpringAR.comStates.STATE_sendCFG;
                        return;
                    }


                    setSendToSpringMessage(SpringAR.sendBroadcasteHeader);

                    delayByMs(SpringAR.TIME_OUT_IN_BROADCAST);
                    return;
                }

                case STATE_sendCFG: {
                    if ( SpringAR.STRING_NOT_FOUND != comonUtils.indexOf(payload[writeBuffer], SpringAR.recieveCFGHeaderByte )) {

                        State = SpringAR.comStates.STATE_sendRecieveData;
                        return;
                    }

                    setSendToSpringMessage(SpringAR.formConfigurationMessage());
                    return;
                }

                case STATE_sendRecieveData: {
                    if ( SpringAR.STRING_NOT_FOUND != comonUtils.indexOf(payload[writeBuffer], SpringAR.recieveDataHeaderByte)) {
                        writeRecievedDataToBuffer(payload[writeBuffer], rcv_packet.getLength());
                    }
                    break;
                }
                default:
                    Log.d(SpringAR.protocollDebugLogPrefix, "Connection State Machine invalid state");

            }


}

https://github.com/PicassoCT/arcore-android-sdk/blob/6c9b48a3d520e039cd48bc2af7354ccdec857736/arcore-android-sdk/samples/hello_ar/app/src/main/java/com/google/ar/core/examples/app/common/tcpClient/Server.java

所有测试都在家庭WiFi设置中进行，其中具有主机应用程序的桌面直接连接到WiFi路由器。

到目前为止工作的是：设备可以广播它的存在。主机可以广播其配置。设备无法在主机上从IP与IP通信。双方都有固定的IP设置。

我可以使用主机应用程序与App PacketSender进行通信，并在其中排除故障。

我还构建了一个较小的调试循环，只能来回发送udp-packets，这也很有用。

感谢您的时间

Captured Packages-Showing Broadcast going from the ARDevice to the Host-Application and a direktional Answer by the HostApplication, that is never recieved on the ARDevice

java android udp broadcast
1个回答
1
投票

改变这一行：

socket.setSoTimeout(30);

至

socket.setSoTimeout(1000);

你有一个相当复杂的状态机进入这里，如果没有日志可以查看，很难分辨出正在发生的事情。我会像这样总结你的状态机：

  1. 广播配置消息
  2. 花30ms听取回复
  3. 如果没有收到响应，阻止SpringAR.TIME_OF_FRAME_IN_MS（不包含在你的代码中;我假设它是1000ms），然后循环回＃1
  4. 如果收到响应，则直接向对等方发送回复，然后转到＃2

＃4是没有发生的步骤。可能的原因（基于Wireshark转储）是ARDevice响应达到“主机”需要68ms。你只给了它30ms。它可能有很多原因需要很长时间，但这超出了你的问题的范围。

最新问题
© www.soinside.com 2019 - 2024. All rights reserved.