examples/Server.hx


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

package examples;

import haxe.io.Bytes;
import sys.FileSystem;
import unix.UnixSocket;

class Server {
	static function main() {
	    var server = new UnixSocket("haxe.sock");

	    server.init();
	    server.bind();
	    server.listen(5);

        while (true) {
            trace('Waiting for clients to connect...');
    	    var client = server.accept();
    	    trace('Accepted connection from client with fd ${client.fileDescriptor}');
    	    var receivedData = client.readBytes("Ping".length).toString();
    	    trace('$receivedData');
    	    client.writeBytes(Bytes.ofString("Pong"));
    	    client.close();
	    }

	    if (FileSystem.exists("haxe.sock")) {
	        FileSystem.deleteFile("haxe.sock");
        }
	}
}