Initial commit

JavaUDSServer/pom.xml

@@ -0,0 +1,17 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>se.rutdev.proxmig</groupId>
+    <artifactId>JavaUDSServer</artifactId>
+    <version>1.0-SNAPSHOT</version>
+
+    <properties>
+        <maven.compiler.source>23</maven.compiler.source>
+        <maven.compiler.target>23</maven.compiler.target>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+    </properties>
+
+</project>

JavaUDSServer/src/main/java/nu/zoom/checked/server/Main.java

@@ -0,0 +1,49 @@
+package nu.zoom.checked.server;
+
+import java.io.IOException;
+import java.net.StandardProtocolFamily;
+import java.net.UnixDomainSocketAddress;
+import java.nio.ByteBuffer;
+import java.nio.channels.ServerSocketChannel;
+import java.nio.charset.StandardCharsets;
+import java.nio.file.Files;
+import java.nio.file.Path;
+
+public class Main {
+    public static void main(String[] args) throws IOException {
+        new Main().run();
+    }
+
+    private void run() throws IOException {
+        var path = Path.of("/tmp").resolve("udsserver.sock") ;
+        Files.deleteIfExists(path);
+        var socketAddress = UnixDomainSocketAddress.of(path);
+        ServerSocketChannel serverChannel = ServerSocketChannel
+                .open(StandardProtocolFamily.UNIX);
+        serverChannel.bind(socketAddress);
+
+        boolean keepRunning = true;
+        while (keepRunning) {
+            try (var clientChannel = serverChannel.accept()) {
+                if (clientChannel != null) {
+                    var buffer = ByteBuffer.allocate(500);
+                    clientChannel.read(buffer);
+                    buffer.flip();
+                    var length = Byte.toUnsignedInt(buffer.get());
+                    if (length < 400 && length > 0) {
+                        var rawMessage = new byte[length];
+                        buffer.get(rawMessage);
+                        var message = new String(rawMessage, StandardCharsets.UTF_8);
+                        System.out.println(message);
+                        if (message.startsWith("q")) {
+                            keepRunning = false;
+                        }
+                    }
+                }
+            }
+        }
+
+        serverChannel.close();
+        Files.deleteIfExists(path);
+    }
+}