| | |
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * 初始化参数
|
|---|
| | | *
|
|---|
| | | * @param ipAddress 本地监听端口
|
|---|
| | | * @param port 本地监听端口
|
|---|
| | | * @param socketOptions
|
|---|
| | |
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * 初始化参数
|
|---|
| | | *
|
|---|
| | | * @param ipAddress 本地监听IP地址
|
|---|
| | | * @param port 本地监听端口
|
|---|
| | | * @param options
|
|---|
| | |
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * 初始化参数
|
|---|
| | | *
|
|---|
| | | * @param port 本地监听端口
|
|---|
| | | * @param options
|
|---|
| | | * @return
|
|---|
| | |
|---|
| | | lock.acquire();
|
|---|
| | | if (TextUtils.isEmpty(ipAddress)) {
|
|---|
| | | mSocket = SocketPool.getInstance().getUdpSocket(new InetSocketAddress( port));
|
|---|
| | | }
|
|---|
| | | else{
|
|---|
| | | } else {
|
|---|
| | | mSocket = SocketPool.getInstance().getUdpSocket(new InetSocketAddress(Inet4Address.getByName(ipAddress), port));
|
|---|
| | | }
|
|---|
| | | mSocket.joinGroup(InetAddress.getByName(socketOptions.getGroupAddress()));
|
|---|
| | | //去掉 组地址（光伏app不同网段不允许） 2025年04月01日15:43:58
|
|---|
| | | // mSocket.joinGroup(InetAddress.getByName(socketOptions.getGroupAddress()));
|
|---|
| | | mSocket.setSoTimeout(socketOptions.getSoTimeOut());
|
|---|
| | | mSocket.setBroadcast(true);
|
|---|
| | | // mSocket.setReuseAddress(true);
|
|---|
| | |
|---|
| | | LinkPacket linkPacket=new LinkPacket(String.format(TopicConstant.NATIVE_BUSPRO_UP, receivePacket.getAddress().getHostAddress()), data);
|
|---|
| | | linkPacket.setNativeType(NativeType.BusPro);
|
|---|
| | | QueueUtils.getInstance().add(linkPacket);
|
|---|
| | | }
|
|---|
| | | else {
|
|---|
| | | } else {
|
|---|
| | | //link协议
|
|---|
| | | socketOptions.getHandleMessage().read(new Packet(data));
|
|---|
| | | }
|
|---|
