SSDP协议_mpp协议

 private void sendDatagramPacket(final  String ip) {
        new Thread(new Runnable() {
            @Override
            public void run() {
                try {

                    MulticastSocket multicastSocket = new MulticastSocket();
                    InetAddress broadcaseAddress = InetAddress.getByName("239.255.255.250");
                    multicastSocket.joinGroup(broadcaseAddress);
                    while (true) {

                        DatagramPacket datagramPacket = new DatagramPacket(ip.getBytes(), ip.length(), broadcaseAddress, 1900);
                        datagramPacket.setAddress(broadcaseAddress);
                        datagramPacket.setPort(1900);
                        multicastSocket.send(datagramPacket);
                        try {
                            Thread.sleep(1000);
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
                } catch (IOException e) {
                    e.printStackTrace();
                }


            }
        }).start();

    }

 private void receiverDate() {

        new Thread(new Runnable() {
            @Override
            public void run() {
                MulticastSocket multicastSocket;
                try {
                    multicastSocket = new MulticastSocket(1900);
                    InetAddress address = InetAddress.getByName("239.255.255.250");
                    multicastSocket.joinGroup(address);
                    byte[] buf = new byte[1024];

                    while (true) {
                        DatagramPacket datagramPacket = new DatagramPacket(buf, buf.length);
                        multicastSocket.receive(datagramPacket); // 接收数据，同样会进入阻塞状态

                        byte[] message = new byte[datagramPacket.getLength()]; // 从buffer中截取收到的数据
                        Log.i(TAG, "receiverDate:getAddress "+datagramPacket.getAddress());
                        Log.i(TAG, "receiverDate:new String(message) "+new String(message));
                    }
                } catch (IOException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                } // 接收数据时需要指定监听的端口号

            }
        }).start();



    }