V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
raiz
V2EX  ›  Android

一个 Android 使用 DatagramSocket 发送 UDP 的问题? https://stackoverflow.com/q/55533832/5105007

  •  
  •   raiz · 2019-04-07 21:32:33 +08:00 · 8088 次点击
    这是一个创建于 2065 天前的主题,其中的信息可能已经有所发展或是发生改变。

    https://stackoverflow.com/q/55533832/5105007

    class UdpSendActivity : AppCompatActivity() {
    
        override fun onCreate(savedInstanceState: Bundle?) {
            super.onCreate(savedInstanceState)
            setContentView(R.layout.activity_udp_send)
    
            Thread(::runTest1).start()
            Thread(::runTest2).start()
        }
    
    
        fun runTest1():Unit {
            val dstAddressList = List(50 ){
                Inet4Address.getByName("192.168.1.${10 + it}")
            }
    
            val srcSocket = DatagramSocket()
            val byteArray = ByteArray(500)
    
            val startMs = System.currentTimeMillis()
            for (dstAddress in dstAddressList) {
                val packet = DatagramPacket(byteArray, 0, byteArray.size, dstAddress, 55555)
    
                srcSocket.send(packet)
                srcSocket.send(packet)
                srcSocket.send(packet)
                srcSocket.send(packet)
    
            }
            val costMs = System.currentTimeMillis() - startMs
            Log.e("UdpSendActivity", "#A $costMs ms")
        }
    
        fun runTest2():Unit {
            val dstAddressList = List(50 ){
                Inet4Address.getByName("192.168.1.${10 + it}")
            }
    
    //        val srcSocket = DatagramSocket()
            val byteArray = ByteArray(500)
            val startMs = System.currentTimeMillis()
    
            for (dstAddress in dstAddressList) {
                val packet = DatagramPacket(byteArray, 0, byteArray.size, dstAddress, 55555)
                // the diffrent line
                val srcSocket = DatagramSocket()
                srcSocket.send(packet)
                srcSocket.send(packet)
                srcSocket.send(packet)
                srcSocket.send(packet)
            }
            val costMs = System.currentTimeMillis() - startMs
            Log.e("UdpSendActivity", "#B $costMs ms")
        }
    }
    

    log:

    E/UdpSendActivity: #B 23 ms
    E/UdpSendActivity: #A 1507 ms

    两个测试的区别在于使用一个 DatagramSocket 发送给所有的目的地址 还是 每个目的地址创建一个新的 DatagramSocket 来发送,日志显示前者速度非常慢。

    2 条回复    2019-04-08 15:46:26 +08:00
    inoizyz
        1
    inoizyz  
       2019-04-08 15:14:22 +08:00 via Android
    每次循环都使用一个新的 socket 那就不用管之前那个 socket 的状态,可以直接用吧?如果用旧的,那上一个包没发完会扔掉重新开始发当前的包吗,DatagramSocket.send 是同步的吧?
    raiz
        2
    raiz  
    OP
       2019-04-08 15:46:26 +08:00
    @inoizyz 同步方法来着,阻塞着
    关于   ·   帮助文档   ·   博客   ·   API   ·   FAQ   ·   实用小工具   ·   1031 人在线   最高记录 6679   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 19ms · UTC 18:35 · PVG 02:35 · LAX 10:35 · JFK 13:35
    Developed with CodeLauncher
    ♥ Do have faith in what you're doing.