udp优化

src/main/java/org/redkale/net/AsyncNioUdpConnection.java

@@ -150,24 +150,30 @@ class AsyncNioUdpConnection extends AsyncNioConnection {
 
     @Override
     protected int implWrite(ByteBuffer src) throws IOException {
-        long now = System.currentTimeMillis();
+
-        //发送过频会丢包
         if (clientMode) {
+            long now = System.currentTimeMillis();
             if (this.writeTime + 1 > now) {
-                Utility.sleep(1);
+                Utility.sleep(1); //发送过频会丢包
                 this.writeTime = System.currentTimeMillis();
             } else {
                 this.writeTime = now;
             }
             return this.channel.send(src, remoteAddress);
         } else {
-            if (udpServerChannel.writeTime + 1 > now) {
+            udpServerChannel.writeLock.lock();
-                Utility.sleep(1);
+            try {
-                udpServerChannel.writeTime = System.currentTimeMillis();
+                long now = System.currentTimeMillis();
-            } else {
+                if (udpServerChannel.writeTime + 1 > now) {
-                udpServerChannel.writeTime = now;
+                    Utility.sleep(1); //发送过频会丢包
+                    udpServerChannel.writeTime = System.currentTimeMillis();
+                } else {
+                    udpServerChannel.writeTime = now;
+                }
+                return this.channel.send(src, remoteAddress);
+            } finally {
+                udpServerChannel.writeLock.unlock();
             }
-            return this.channel.send(src, remoteAddress);
         }
     }
 

src/main/java/org/redkale/net/AsyncNioUdpProtocolServer.java

@@ -12,6 +12,7 @@ import java.nio.channels.*;
 import java.util.Set;
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.atomic.LongAdder;
+import java.util.concurrent.locks.ReentrantLock;
 import java.util.function.*;
 import java.util.logging.Level;
 import org.redkale.boot.Application;
@@ -240,6 +241,8 @@ class AsyncNioUdpProtocolServer extends ProtocolServer {
 
         ByteBufferPool unsafeBufferPool;
 
+        final ReentrantLock writeLock = new ReentrantLock();
+
         volatile long writeTime;
 
         ConcurrentHashMap<SocketAddress, AsyncNioUdpConnection> connections = new ConcurrentHashMap<>();