如何使用 Kotlin 使用协程扫描本地 IP 地址

Question

我有一个应用程序可以扫描本地 IP 地址以连接到开放端口 8102。我已经能够获取正确的 IP 地址，但需要很长时间，因为每次轮询的超时时间为 200 毫秒。这是我成功达到的最低水平。

我想我的问题是有没有办法使用协程来分割工作并更快地获取地址？现在大约需要 3 秒，而我的目标地址仅为 192.168.0.21。

这是我的代码：

fun init() = GlobalScope.launch(Dispatchers.IO) {
            //Get local ip
            DatagramSocket().use { socket ->
                socket.connect(InetAddress.getByName("8.8.8.8"), 10002)
                ip = socket.getLocalAddress().getHostAddress().split(".") as MutableList<String>
            }
            //Go through local addresses to find receiver
            txtOutput.text = ip.toString()
            prefix = ip[0] + "." + ip[1] + "." + ip[2] + "."

            var i = 1
            do {
                try {
                    client = Socket()
                    client.connect(InetSocketAddress(prefix + i.toString(), 8102), 200)
                } catch (e: Exception) {
                    print(e.toString())
                    i++
                }
            } while (!(client.isConnected) or (i > 254))
            targetIP = prefix + i.toString()
            client = Socket()
            try{
            client.connect(InetSocketAddress(targetIP, 8102), 150)
                if(client.isConnected){
                client.keepAlive = true}}
            catch (e:IOException){
                cancel("Could not connect")
            }

Answer 1

理论上是可以的，但是需要测试一下

fun init() = GlobalScope.launch(Dispatchers.IO) {
    //Get local ip
    DatagramSocket().use { socket ->
        socket.connect(InetAddress.getByName("8.8.8.8"), 10002)
        ip = socket.getLocalAddress().getHostAddress().split(".") as MutableList<String>
    }
    //Go through local addresses to find receiver
    txtOutput.text = ip.toString()
    prefix = ip[0] + "." + ip[1] + "." + ip[2] + "."

//    var i = 1
//    do {
//        try {
//            client = Socket()
//            client.connect(InetSocketAddress(prefix + i.toString(), 8102), 200)
//        } catch (e: Exception) {
//            print(e.toString())
//            i++
//        }
//    } while (!(client.isConnected) or (i > 254))
    
    ///#########
    val answer= Channel<Int>()

    for (i in 0..254){
        launch {
            try { 
                client = Socket()
                client.connect(InetSocketAddress(prefix + i.toString(), 8102), 200)
                answer.send(i)
            }catch (e:Exception){ }

        }
    }
    val i=answer.receive()
    ///#########

    targetIP = prefix + i.toString()
    client = Socket()
    try {
        client.connect(InetSocketAddress(targetIP, 8102), 150)
        if (client.isConnected) {
            client.keepAlive = true
        }
    } catch (e: IOException) {
        cancel("Could not connect")
    }

}