Now the code is cleaner, and we can configure the server a bit

.gitignore

@@ -0,0 +1 @@
+/target

.idea/.gitignore

@@ -0,0 +1,8 @@
+# Default ignored files
+/shelf/
+/workspace.xml
+# Editor-based HTTP Client requests
+/httpRequests/
+# Datasource local storage ignored files
+/dataSources/
+/dataSources.local.xml

.idea/modules.xml

@@ -0,0 +1,8 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="ProjectModuleManager">
+    <modules>
+      <module fileurl="file://$PROJECT_DIR$/.idea/socket_server.iml" filepath="$PROJECT_DIR$/.idea/socket_server.iml" />
+    </modules>
+  </component>
+</project>

.idea/socket_server.iml

@@ -0,0 +1,11 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<module type="EMPTY_MODULE" version="4">
+  <component name="NewModuleRootManager">
+    <content url="file://$MODULE_DIR$">
+      <sourceFolder url="file://$MODULE_DIR$/src" isTestSource="false" />
+      <excludeFolder url="file://$MODULE_DIR$/target" />
+    </content>
+    <orderEntry type="inheritedJdk" />
+    <orderEntry type="sourceFolder" forTests="false" />
+  </component>
+</module>

.idea/vcs.xml

@@ -0,0 +1,6 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="VcsDirectoryMappings">
+    <mapping directory="" vcs="Git" />
+  </component>
+</project>

Cargo.lock

@@ -0,0 +1,7 @@
+# This file is automatically @generated by Cargo.
+# It is not intended for manual editing.
+version = 3
+
+[[package]]
+name = "socket_server"
+version = "0.1.0"

Cargo.toml

@@ -0,0 +1,8 @@
+[package]
+name = "socket_server"
+version = "0.1.0"
+edition = "2021"
+
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+
+[dependencies]

src/main.rs

@@ -0,0 +1,31 @@
+use std::net::UdpSocket;
+use std::io::stdin;
+
+fn main() {
+    let server_address: String = get_server_address();
+    listen(server_address);
+}
+
+fn get_server_address() -> String {
+    println!("Enter server address (format xxx.xxx.xxx.xxx:port)");
+    let mut server_address = String::new();
+    stdin().read_line(&mut server_address).expect("Reading the server address from input");
+    server_address = String::from(server_address.trim());
+    return server_address;
+}
+
+fn listen(server_address: String) {
+    println!("listening on {}", server_address);
+    loop {
+        let mut message: String = String::new();
+        let mut buf: [u8; 1024] = [0; 1024];
+        let socket: UdpSocket = UdpSocket::bind(server_address.clone()).expect("Error while binding the socket.");
+        let (num_bytes, src_addr) = socket.recv_from(&mut buf).expect("Error while receiving message");
+        message.push_str(std::str::from_utf8(&buf[..num_bytes]).expect("Invalid UTF-8 data"));
+        println!("{}:{}", src_addr.to_string(), message);
+
+        if message.trim() == "!STOP" {
+            return;
+        }
+    }
+}