android java udp广播用于局域网搜索扫描设备。

news2024/11/17 3:38:09

        DatagramSocket socket = new DatagramSocket();
            //设置接收等待时长
            socket.setSoTimeout(LanCommConfig.RECEIVE_TIME_OUT);
            byte[] sendData = new byte[1024];
            //使用广播形式（目标地址设为255.255.255.255）的udp数据包
            DatagramPacket sendPacket = new DatagramPacket(sendData, sendData.length, InetAddress.getByName("255.255.255.255"), Const.DEVICE_BROADCAST_PORT);
            byte[] hostAddress = Utils.getLocalIPAddress();
            byte[]  b="啦啦啦啦啦啦啦啦啦噢噢噢噢噢噢噢噢".getBytes();
            byte[] broadcastData = packBroadcastData(hostAddress, b);
            sendPacket.setData(broadcastData);
            //发送udp数据包
            socket.send(sendPacket);
            Log.v(TAG, Utils.getDeviceIp() + Const.SEND_SYMBOL + "局域网广播 成功");


    /**
     * 协议规范
     * #(1) + packageType(1) +  ip(4) + dataLength(4) + [data]
     *
     * @param bytes
     * @param hostAddress
     * @return
     */
        private int type = Const.PACKET_TYPE_BROADCAST;
    private byte[] packBroadcastData(byte[] hostAddress, byte[] bytes) {
        //        Trace.d(TAG, "packBroadcastData() ：" + Arrays.toString(hostAddress));
        //        Trace.d(TAG, "packBroadcastData() : " + Arrays.toString(bytes));
        byte[] lengthBytes = ConvertUtils.intToByteArray(bytes.length);
        byte[] data = new byte[2 + hostAddress.length + bytes.length + lengthBytes.length];
        data[0] = Const.PACKET_PREFIX;
        data[1] = (byte) type;
        //        Trace.d(TAG, "packBroadcastData() : " + Arrays.toString(lengthBytes));
        System.arraycopy(hostAddress, 0, data, 2, hostAddress.length);
        System.arraycopy(lengthBytes, 0, data, 2 + hostAddress.length, lengthBytes.length);
        if (bytes != null && bytes.length != 0) {
            System.arraycopy(bytes, 0, data, 2 + hostAddress.length + lengthBytes.length, bytes.length);
        }
        Log.v(TAG, Utils.getDeviceIp() + Const.SEND_SYMBOL + "局域网广播 package data:\r\n" + Arrays.toString(data));
        return data;
    }

把自身的ip地址发送过去。

package com.fighter.lancomm.utils;

import java.net.Inet4Address;
import java.net.InetAddress;
import java.net.NetworkInterface;
import java.net.SocketException;
import java.net.UnknownHostException;
import java.util.Enumeration;

/**
 * @author sts
 * @date 2020/1/15
 */
public class Utils {

    /**
     * 获取内网IP地址
     *
     * @return
     * @throws SocketException
     */
    public static byte[] getLocalIPAddress() throws SocketException {
        for (Enumeration<NetworkInterface> en = NetworkInterface.getNetworkInterfaces(); en.hasMoreElements(); ) {
            NetworkInterface intf = en.nextElement();
            for (Enumeration<InetAddress> enumIpAddr = intf.getInetAddresses(); enumIpAddr.hasMoreElements(); ) {
                InetAddress inetAddress = enumIpAddr.nextElement();
                if (!inetAddress.isLoopbackAddress() && (inetAddress instanceof Inet4Address)) {
                    return inetAddress.getAddress();
                }
            }
        }
        return new byte[4];
    }

    public static String ipbyteToString(byte[] ip) throws UnknownHostException {
        return InetAddress.getByAddress(ip).getHostAddress();
    }

    public static String getDeviceIp() {
        try {
            byte[] localIPAddress = getLocalIPAddress();
            return Utils.ipbyteToString(localIPAddress);
        } catch (SocketException e) {
            e.printStackTrace();
        } catch (UnknownHostException e) {
            e.printStackTrace();
        }
        return "";
    }
}