Обнаружение сетевых служб Неправильный IP-адрес разрешен

Question

Я хочу подключить несколько устройств Android через обнаружение сетевых служб. Я хочу использовать звездную топологию. Таким образом, устройство должно обнаруживать, а другие - регистрировать службу, которая должна быть обнаружена обнаружителем. Для этого я взял NSD Chat (https://github.com/gauravcanon/NsdChat) NsdHelper и изменил его лишь немного, поэтому после разрешения службы, которая устанавливает соединение, вызывается обратный вызов. Это работает в основном, если я использую три устройства. два рекламодателя и один первооткрыватель. Службы получают разрешение и соединение. Если я получу дополнительного третьего рекламодателя, это приведет к сбою в 80% всех попыток. Причина в том, что serviceInfo, который передается в функции onServiceResolved в ResolveListener, содержит IP-адрес разрешающего телефона, а не рекламного. Порт правильный и имя сервиса тоже. Это такое странное поведение, я не знаю, как отладить это. Я использую Bonjour браузер, чтобы увидеть все зарегистрированные сервисы, и регистрация всех сервисов в порядке. Вся информация о сервисе, содержащая правильный IP-адрес и порт. Я также попробовал чистый процесс обнаружения без установления связи. Та же ошибка. Иногда IP-адрес распознавателя находится в serviceinfo. Это может также произойти при первом открытии и втором, но, скорее всего, при третьем. Я опубликую свой код NsdHelper ниже. Я сделал некоторые правки прямо сейчас, потому что я попытался снова запустить процесс обнаружения после разрешения, так что есть больше различий в чате NSD, но ошибка сохраняется. Кто-то использует реализацию NSD Android через NSDManager с несколькими устройствами? Это работает для вас? Что ты делаешь по-другому? Эта тема связана там, у кого-то были такие же проблемы ( Android, NSD / DNS-SD: ненадежное обнаружение NsdManager и разрешение IP ). Я не могу представить, что эта ошибка все еще вещь 3 года назад?

Я благодарен за каждый намек!

    class NsdHelper(private var mContext: Context, private val createClient: (InetAddress, Int)->Unit, val mHandler: Handler) {
internal var mNsdManager: NsdManager = mContext.getSystemService(Context.NSD_SERVICE) as NsdManager
internal lateinit var mResolveListener: NsdManager.ResolveListener
private var mDiscoveryListener: NsdManager.DiscoveryListener? = null
private var mRegistrationListener: NsdManager.RegistrationListener? = null
var mServiceName = "Wizard"
var chosenServiceInfo: NsdServiceInfo? = null
    internal set
val mServices = mutableListOf<NsdServiceInfo>()

fun initializeNsd() {
    stopDiscovery()
    tearDown()
    initializeResolveListener()
}


fun reset(){
    initializeResolveListener()
    discoverServices()
}

fun initializeDiscoveryListener() {
    mDiscoveryListener = object : NsdManager.DiscoveryListener {
        override fun onDiscoveryStarted(regType: String) {
            Log.d(TAG, "Service discovery started")
        }

        override fun onServiceFound(service: NsdServiceInfo) {
            Log.d(TAG, "Service discovery success$service")
            when {
                service.serviceType != SERVICE_TYPE -> Log.d(TAG, "Unknown Service Type: " + service.serviceType)
                service.serviceName == mServiceName -> Log.d(TAG, "Same machine: $mServiceName")
                service.serviceName.contains("Verzauberte") -> {
                    if (mServices.none { it.serviceName == service.serviceName })
                    mNsdManager.resolveService(service, mResolveListener)
                }
            }
        }

        override fun onServiceLost(service: NsdServiceInfo) {
            Log.e(TAG, "service lost$service")
        }

        override fun onDiscoveryStopped(serviceType: String) {
            Log.i(TAG, "Discovery stopped: $serviceType")
        }

        override fun onStartDiscoveryFailed(serviceType: String, errorCode: Int) {
            Log.e(TAG, "Discovery failed: Error code:$errorCode")
        }

        override fun onStopDiscoveryFailed(serviceType: String, errorCode: Int) {
            Log.e(TAG, "Discovery failed: Error code:$errorCode")
        }
    }
}

fun initializeResolveListener() {
    mResolveListener = object : NsdManager.ResolveListener {
        override fun onResolveFailed(serviceInfo: NsdServiceInfo, errorCode: Int) {
            Log.e(TAG, "Resolve failed$errorCode")
        }

        override fun onServiceResolved(serviceInfo: NsdServiceInfo) {
            Log.e(TAG, "Resolve Succeeded. $serviceInfo")
            if (serviceInfo.serviceName == mServiceName) {
                Log.d(TAG, "Same IP.")
                return
            }
            chosenServiceInfo = serviceInfo
            mHandler.post(Runnable {
                createClient(
                    serviceInfo.host,
                    serviceInfo.port
                )
            })
            mServices.add(serviceInfo)
            reset()
        }
    }
}

fun initializeRegistrationListener() {
    mRegistrationListener = object : NsdManager.RegistrationListener {
        override fun onServiceRegistered(NsdServiceInfo: NsdServiceInfo) {
            mServiceName = NsdServiceInfo.serviceName
            Log.d(TAG, "Service registered: $mServiceName")
        }

        override fun onRegistrationFailed(arg0: NsdServiceInfo, arg1: Int) {
            Log.d(TAG, "Service registration failed: $arg1")
        }

        override fun onServiceUnregistered(arg0: NsdServiceInfo) {
            Log.d(TAG, "Service unregistered: " + arg0.serviceName)
        }

        override fun onUnregistrationFailed(serviceInfo: NsdServiceInfo, errorCode: Int) {
            Log.d(TAG, "Service unregistration failed: $errorCode")
        }
    }
}

fun registerService(port: Int) {
    tearDown()  // Cancel any previous registration request
    initializeRegistrationListener()
    val serviceInfo = NsdServiceInfo().apply {
        serviceType = SERVICE_TYPE
        serviceName = "Verzauberte[$port]"
        setPort(port)
    }
    mNsdManager.registerService(
        serviceInfo, NsdManager.PROTOCOL_DNS_SD, mRegistrationListener
    )
}

fun discoverServices() {
    stopDiscovery()  // Cancel any existing discovery request
    initializeDiscoveryListener()
    Log.d(this.toString(), "Start discovering")
    mNsdManager.discoverServices(
        SERVICE_TYPE, NsdManager.PROTOCOL_DNS_SD, mDiscoveryListener
    )
}

fun stopDiscovery() {
    if (mDiscoveryListener != null) {
        try {
            mNsdManager.stopServiceDiscovery(mDiscoveryListener)
        } finally {
        }
        mDiscoveryListener = null
    }
}

fun tearDown() {
    if (mRegistrationListener != null) {
        try {
            mNsdManager.unregisterService(mRegistrationListener)
        } finally {
        }
        mRegistrationListener = null
    }
}



companion object {
    val SERVICE_TYPE = "_votinginteractions._tcp."
    val TAG = "NsdHelper"
}

}