Client Server Separation?

[scurtyParticipant]

I’m trying to separate the client and server Methods from the “echoserver” banana into two separate apps to basically run the server side on one PC and the client on another and send data between these two apps

The problem is the server getting a memory access violation as soon as the client is accepted. Don’t know why…

network.monkey2

Monkey

Namespace Network 'Const HOST := "localhost" ' HOST ADDRESS [http://] [localhost] [127.0.0.1] 'Const PORT := 40122 Class NetServer Field HOST:String Field PORT:Int Method New(host:String, port:Int) Self.HOST = host Self.PORT = port 'Process() End Method Method Process:Void() ' Create the Server Socket Local SERVER := Socket.Listen( Self.HOST, Self.PORT ) If Not SERVER Print "Server: Failed to create server" ; Return ' On Failure... ' On Sucess... ' Initialize SERVER Configuration Print "Server | "+SERVER.Address+" | Is listening..." SERVER.SetOption( "SO_REUSEADDR",1 ) SERVER.SetOption( "TCP_NODELAY",1 ) Repeat ' Connection Loop ' Accept New Socket Connection Requests Local NEW_SOCKET := SERVER.Accept() If Not NEW_SOCKET Exit ' No Connection... ' Connection Found... Print "Server Accepted Client | "+NEW_SOCKET.PeerAddress Local STREAM := New SocketStream( NEW_SOCKET ) ' Read NEW_SOCKET Output STREAM New Fiber( Lambda() Repeat ' Extract Raw DATA Strings from STREAM Local DATA := STREAM.ReadSizedString() If Not DATA Exit ' Exit if Failure... STREAM.WriteSizedString( DATA ) Forever ' Done Reading DATA from STREAM STREAM.Close() End ) Forever ' Connection Loop Print "Server | Terminating..." SERVER.Close() End End Class Class NetClient Field HOST:String Field PORT:Int Method New(host:String, port:Int) Self.HOST = host Self.PORT = port 'Process() End Method Method Process() 'Fiber.Sleep( .5 ) ' Connect to Server on HOST and PORT Local CLIENT := Socket.Connect( Self.HOST, Self.PORT ) If Not CLIENT Print "Client | Couldn't Connect to Server!" ; Return ' Configure Client... Print "Client: "+CLIENT.Address+" | Connected to Server: "+CLIENT.PeerAddress CLIENT.SetOption( "TCP_NODELAY",1 ) ' Send Data to Server... Local STREAM := New SocketStream( CLIENT ) For Local i := 0 Until 100 STREAM.WriteSizedString( "This Message Number: " + i ) Print "Reply: " + STREAM.ReadSizedString() Next ' Client is Closing... Print "Client | Is Closing..." STREAM.Close() End End

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 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116

Namespace Network   'Const HOST := "localhost" ' HOST ADDRESS [http://] [localhost] [127.0.0.1] 'Const PORT := 40122   Class NetServer   Field HOST:String Field PORT:Int Method New(host:String, port:Int) Self.HOST = host Self.PORT = port 'Process() End Method   Method Process:Void() ' Create the Server Socket Local SERVER := Socket.Listen( Self.HOST, Self.PORT ) If Not SERVER Print "Server: Failed to create server" ; Return ' On Failure... ' On Sucess... ' Initialize SERVER Configuration Print "Server | "+SERVER.Address+" | Is listening..." SERVER.SetOption( "SO_REUSEADDR",1 ) SERVER.SetOption( "TCP_NODELAY",1 ) Repeat ' Connection Loop ' Accept New Socket Connection Requests Local NEW_SOCKET := SERVER.Accept() If Not NEW_SOCKET Exit ' No Connection... ' Connection Found... Print "Server Accepted Client | "+NEW_SOCKET.PeerAddress Local STREAM := New SocketStream( NEW_SOCKET ) ' Read NEW_SOCKET Output STREAM New Fiber( Lambda() Repeat ' Extract Raw DATA Strings from STREAM Local DATA := STREAM.ReadSizedString() If Not DATA Exit ' Exit if Failure... STREAM.WriteSizedString( DATA ) Forever ' Done Reading DATA from STREAM STREAM.Close() End ) Forever ' Connection Loop Print "Server | Terminating..." SERVER.Close() End End Class       Class NetClient   Field HOST:String Field PORT:Int Method New(host:String, port:Int) Self.HOST = host Self.PORT = port 'Process() End Method   Method Process() 'Fiber.Sleep( .5 ) ' Connect to Server on HOST and PORT Local CLIENT := Socket.Connect( Self.HOST, Self.PORT ) If Not CLIENT Print "Client | Couldn't Connect to Server!" ; Return ' Configure Client... Print "Client: "+CLIENT.Address+" | Connected to Server: "+CLIENT.PeerAddress CLIENT.SetOption( "TCP_NODELAY",1 ) ' Send Data to Server... Local STREAM := New SocketStream( CLIENT )   For Local i := 0 Until 100 STREAM.WriteSizedString( "This Message Number: " + i ) Print "Reply: " + STREAM.ReadSizedString() Next ' Client is Closing... Print "Client | Is Closing..." STREAM.Close() End End

 

server.monkey2

Monkey

#Import "<std>" #Import "network" Namespace APPLICATION_DEBUG Using std.. Using Network.. Global HOST := "localhost" Global PORT := 40122 Function Main:Void() Print "Loading Server..." Local N:NetServer = New NetServer(HOST, PORT) N.Process() End Function

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19

#Import "<std>" #Import "network"   Namespace APPLICATION_DEBUG   Using std.. Using Network..   Global HOST := "localhost" Global PORT := 40122   Function Main:Void()   Print "Loading Server..." Local N:NetServer = New NetServer(HOST, PORT) N.Process()   End Function

client.monkey2

Monkey

#Import "<std>" #Import "network" Namespace APPLICATION_DEBUG Using std.. Using Network.. Global HOST := "localhost" Global PORT := 40122 Function Main:Void() Print "Loading Client..." Local N:NetClient = New NetClient(HOST, PORT) N.Process() End Function

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20

#Import "<std>" #Import "network"   Namespace APPLICATION_DEBUG   Using std.. Using Network..   Global HOST := "localhost" Global PORT := 40122   Function Main:Void()   Print "Loading Client..." Local N:NetClient = New NetClient(HOST, PORT)   N.Process()   End Function

Any ideas?

[Mark SiblyKeymaster]

Not 100% sure what’s up (it’s not crashing here, but not working either…), but for starters you can only currently use fibers with mojo based apps. I plan to change this eventually but it’s a reasonably complex-ish job…

[scurtyParticipant]

Alrighty, not a problem. I’ll try and work around this for now.

[XaronParticipant]

I want to add a question here. So Fibers are threads, right? When I want to do just a command line server without that mojo stuff I could just do a plain and dirty approach without fibers and just a blocking loop? I’ve read somewhere a single thread solution could be even better than multithreading for networking…

 

@scurty: Have you got this working btw?

[scurtyParticipant]

I think Fibers are an alternative way of looking at Threads in abstraction, but ultimately I think they have the same inner workings for asynchronous programming…

Sorry for the late reply @xaron.
As Mark said you can only use Client/Server functionality using Mojo/MojoX. However, he might try and implement it down the road. For now, I would just emulate a Terminal using Mojo or MojoX… There is a “Console” View for Mojo X that is used in Ted2/Go that does almost the same thing as an output terminal; though I’m sure with some tweaking you could get a nicely polished command line with Monkey2 features and support.

[Author]

Posts