本地最新代码:同步所有修改及新增模块

2026-08-11 13:34:15 +08:00
parent 2b86d14f56
commit 916ac6bda3
172 changed files with 13896 additions and 1774 deletions
--- a/ruoyi-admin/src/main/java/com/ruoyi/Dzp/MyUdpSocket.java
+++ b/ruoyi-admin/src/main/java/com/ruoyi/Dzp/MyUdpSocket.java
@@ -0,0 +1,93 @@
+package com.ruoyi.Dzp;
+
+import java.io.IOException;
+import java.net.InetSocketAddress;
+import java.nio.ByteBuffer;
+import java.nio.channels.DatagramChannel;
+import java.nio.channels.SelectionKey;
+import java.nio.channels.Selector;
+import java.util.Set;
+
+public class MyUdpSocket {
+    private DatagramChannel channel;
+    private Selector selector;
+    private final int MAX_SIZE = 1280;
+    private static int client_port;
+    private static String client_ip;
+    ByteBuffer receive_buffer = ByteBuffer.allocate(MAX_SIZE);
+
+    public MyUdpSocket(int port) throws IOException {
+        channel = DatagramChannel.open();
+        selector = Selector.open();
+        try {
+            //<2F><><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ͨ<EFBFBD><CDA8>Ϊ<EFBFBD><CEAA><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ģʽ
+            channel.configureBlocking(false);
+            //<2F><>ȡ<EFBFBD><C8A1><EFBFBD>׽<EFBFBD><D7BD><EFBFBD>ͨ<EFBFBD><CDA8><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>׽<EFBFBD><D7BD>֣<EFBFBD><D6A3><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>׽<EFBFBD><D7BD>ְ󶨵<D6B0><F3B6A8B5><EFBFBD><EFBFBD><EFBFBD>ָ<EFBFBD><D6B8><EFBFBD>˿<EFBFBD>
+            channel.socket().bind(new InetSocketAddress(port));
+            //Ϊͨ<CEAA><CDA8>ѡ<EFBFBD><D1A1><EFBFBD><EFBFBD>ע<EFBFBD><D7A2>ͨ<EFBFBD><CDA8><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ָ<EFBFBD><D6B8><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ѡ<EFBFBD><D1A1><EFBFBD><EFBFBD><EFBFBD>
+            channel.register(selector, SelectionKey.OP_READ);
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+
+    public final void send(String ip, int port, byte[] buffer, int size) throws IOException {
+        InetSocketAddress client = new InetSocketAddress(ip, port);
+        channel.send(ByteBuffer.wrap(buffer, 0, size), client);  //<2F><>EchoClient<6E>ظ<EFBFBD>һ<EFBFBD><D2BB><EFBFBD><EFBFBD><EFBFBD>ݱ<EFBFBD>
+    }
+
+    public final void close() throws IOException {
+        selector.close();
+        channel.close();
+    }
+
+    public final int get_client_port() {
+        return client_port;
+    }
+
+    public final String get_client_ip() {
+        return client_ip;
+    }
+
+    public final void get_receive_buffer(byte[] buffer) {
+        receive_buffer.get(buffer);
+    }
+
+    public final int receive() {
+        try {
+            receive_buffer.clear();
+            if (selector.select(10) != 0) {
+                Set<SelectionKey> readyKeys = selector.selectedKeys();
+                for (SelectionKey key : readyKeys) {
+                    readyKeys.remove(key);
+                    if (key.isReadable()) {
+                        DatagramChannel dc = (DatagramChannel) key.channel();
+                        InetSocketAddress client = (InetSocketAddress) dc.receive(receive_buffer); //<2F><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>һ<EFBFBD><D2BB>Client<6E><74><EFBFBD><EFBFBD><EFBFBD>ݱ<EFBFBD>
+                        if (client != null) {
+                            client_ip = client.getAddress().getHostAddress();
+                            client_port = client.getPort();
+                            //System.out.println(client_ip+":"+client_port+" size="+receive_buffer.position());
+                            key.interestOps(SelectionKey.OP_READ);
+                            return receive_buffer.position();
+                        } else {
+                            return 0;
+                        }
+                    } else {
+                        return 0;
+                    }
+                }
+            }
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+        return 0;
+    }
+
+    public final void get_receive_packet(byte[] packet, int size) {
+        int i;
+        for (i = 0; i < size; i++) {
+            packet[i] = receive_buffer.array()[i];
+        }
+    }
+
+}