SSDP协议_mpp协议

SSDP协议_mpp协议privatevoidsendDatagramPacket(finalStringip){newThread(newRunnable(){@Overridepublicvoidrun(){try{MulticastSocketmu

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE稳定放心使用

 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();



    }
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请联系我们举报,一经查实,本站将立刻删除。

发布者:全栈程序员-站长,转载请注明出处:https://javaforall.net/184160.html原文链接:https://javaforall.net

(0)
全栈程序员-站长的头像全栈程序员-站长


相关推荐

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

关注全栈程序员社区公众号