Server question?

[EdzUpParticipant]

When looking at the echoserver.monkey2 file I see that the server doesnt have a stream is this an oversight?

I ask as in all networking sometimes messages need to be sent to the server but from this the server doesnt have any way to receive them. I tried attaching a SocketStream to a socket that is listening but all I get is spammed with:
socket_recv error! err=10057, msg=Unknown error, socket=1244, data=00e50184, size=4

Does anyone have a more concise networking example maybe a simple chat system as the echoserver.monkey file doesnt actually show client/server systems as it appears that the client just spams its stream with data and gets it back again which is the effect I am getting now.

[Mark SiblyKeymaster]

If you’re talking about TCP, a ‘listening’ server socket is not a stream – it is a ‘connection point’ for incoming connections (which are themselves streams). With TCP, you need to be connected before you can send/receive data so you can’t actually exchange any data with the ‘server’ which is there purely to establish the connections.

With UDP you can talk to the ‘server’ (a ‘server’ doesn’t actually do much/anything) but it is unreliable and packets can arrive out of order so it’s not as easy to use as TCP.

If you’re thinking about using something higher level, I was thinking about converting enet again which would be very easy to do. Would this be useful?

http://enet.bespin.org/

There is also raknet, which is much more complex and would likely take considerably longer to do fully:

http://www.jenkinssoftware.com/raknet/manual/Doxygen/

Both are very mature and well regarded.

If you want to keep using sockets, I recommend looking at some socket tutorials first, eg:

https://www.tutorialspoint.com/unix_sockets/

A lof of these use threads to handle multiple connections, but the basic ideas are the same with fibers. Google for more etc…

[EdzUpParticipant]

If ENet had Max like functionality and ipv6 I would be very interested in that, from what I can gather though it’s still only ipv4. There is a bodge patch to make it use ipv6 but it’s reliability is questionable.

If servers are just connection management then I will just reconfigure the code I have to make it work like that.

One thing that puzzled me is I had two clients connected but both were receiving what they sent through the stream which is why I wondered if it was actually connected or was just bouncing back. I will dig deeper and try to adjust the echoserver code to see if I can get a example of the issue.

[EdzUpParticipant]

OK after giving this a lot of thought (yes my head hurts after all that lol) a way around it would be to give the server it’s own client  (id0) this means basically the connection server will be able to send messages to clients etc.

It’s a nice theory and one I will now try to put into practice

[VoidwalkerParticipant]

I know it’s OT but that’s the way the AGK guys handle it. When creating a server there, you will have client ID 0 instantly as well on the server side.

[EdzUpParticipant]

Thanks Voidwalker at least I know it’s how some other systems do it :).

What I want to make is a easy to use robust network system for MX2 that way anything else will be easier when dealing with Internet/networking stuff.

[VoidwalkerParticipant]

I will give this a try as well and will share my results. Maybe we can create some simple server client app for the bananas folder.

[EdzUpParticipant]

Good idea, we could make a simple chat program that could work with multiple clients. At least that way it could replace the echoserver.monkey file giving a better example

[VoidwalkerParticipant]

Yep, definitely. But I would wait for 1.1.08 because Mark changed quite a lot under the hood. Will see that I pull the github stuff and compile it by myself but the last time I tried (last week) it could not compile all modules because there were some breaking changes.

[EdzUpParticipant]

OK will wait for 1.1.0.8

[SamFisherParticipant]

Little late, but here a little Chat Server/Client App for 1.1.07

Server.monkey2

Monkey

Namespace serverChatSample #import "<std>" #import "<mojo>" Using std.. Using mojo.. Const HOST:="localhost" 'Note: Use "" for 'public' host? Const PORT:=40122 Class ServerDemo Method New() New Fiber( Server ) End Method Server() Local server:=Socket.Listen( HOST,PORT ) If Not server Print "Server: Failed to create server" ; Return Print "Server @"+server.Address+" listening" server.SetOption( "SO_REUSEADDR",1 ) server.SetOption( "TCP_NODELAY",1 ) Repeat Local socket:=server.Accept() If Not socket Exit Print "Server accepted client @"+socket.PeerAddress Local stream:=New SocketStream( socket ) New Fiber( Lambda() Repeat Local line:=stream.ReadSizedString() Local command:String Local _var1:String If Not line Exit Print line+" from client @"+socket.PeerAddress If(line.Contains("/_join_ "))Then New Client(line.Replace("/_join_ ",""),socket,stream) line="" Endif if(line.Contains("/"))Then Local c:string[]=line.Split(" ") Print c.Length If(c.Length>1) command=c[0] _var1=c[1] Endif line="" Endif If(command) line="" Select command Case "/nick" line="***"+Client.ReturnUserName(socket)+" is now known as "+_var1 Client.ChangeUserName(socket, _var1) Default line="WRONG COMMAND" End Select Endif If(line) if(command) command="" _var1="" Else line=Client.ReturnUserName(socket)+": "+line Endif 'Sending to all For Local c:Client=Eachin Client.clientList c.clientSocketStream.WriteSizedString(line) Next Endif Forever stream.Close();Print "Stream Closed" End ) Forever Print "Server:Bye" server.Close() End End 'Client Class Class Client Field clientSocket :Socket Field clientName :String Field clientSocketStream :SocketStream Global clientList :List<Client> = New List<Client> Method New(name:String, socket:Socket, stream:SocketStream) Self.clientSocket=socket Self.clientName=name Self.clientSocketStream=stream clientList.AddLast(Self) End Function ReturnUserName:String(socket:Socket) For Local c:Client=Eachin Client.clientList if(c.clientSocket.PeerAddress=socket.PeerAddress)Then Return c.clientName Next Return "Anonymous" End Function ChangeUserName(socket:Socket, newName:String) For Local c:Client=Eachin Client.clientList if(c.clientSocket.PeerAddress=socket.PeerAddress)Then c.clientName=newName Next End End '--Main Function Main() New AppInstance New ServerDemo App.Run() 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 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153

Namespace serverChatSample   #import "<std>" #import "<mojo>"   Using std.. Using mojo..   Const HOST:="localhost" 'Note: Use "" for 'public' host? Const PORT:=40122   Class ServerDemo   Method New() New Fiber( Server ) End Method Server() Local server:=Socket.Listen( HOST,PORT ) If Not server Print "Server: Failed to create server" ; Return Print "Server @"+server.Address+" listening" server.SetOption( "SO_REUSEADDR",1 )   server.SetOption( "TCP_NODELAY",1 ) Repeat Local socket:=server.Accept() If Not socket Exit Print "Server accepted client @"+socket.PeerAddress Local stream:=New SocketStream( socket ) New Fiber( Lambda() Repeat Local line:=stream.ReadSizedString() Local command:String Local _var1:String If Not line Exit Print line+" from client @"+socket.PeerAddress If(line.Contains("/_join_ "))Then New Client(line.Replace("/_join_ ",""),socket,stream) line="" Endif if(line.Contains("/"))Then Local c:string[]=line.Split(" ") Print c.Length If(c.Length>1) command=c[0] _var1=c[1] Endif line="" Endif If(command) line="" Select command Case "/nick" line="***"+Client.ReturnUserName(socket)+" is now known as "+_var1 Client.ChangeUserName(socket, _var1) Default line="WRONG COMMAND" End Select Endif If(line) if(command) command="" _var1="" Else line=Client.ReturnUserName(socket)+": "+line Endif 'Sending to all For Local c:Client=Eachin Client.clientList c.clientSocketStream.WriteSizedString(line) Next Endif Forever stream.Close();Print "Stream Closed" End ) Forever Print "Server:Bye" server.Close() End   End   'Client Class Class Client   Field clientSocket :Socket Field clientName :String Field clientSocketStream :SocketStream Global clientList :List<Client> = New List<Client> Method New(name:String, socket:Socket, stream:SocketStream) Self.clientSocket=socket Self.clientName=name Self.clientSocketStream=stream clientList.AddLast(Self) End Function ReturnUserName:String(socket:Socket) For Local c:Client=Eachin Client.clientList if(c.clientSocket.PeerAddress=socket.PeerAddress)Then Return c.clientName Next Return "Anonymous" End Function ChangeUserName(socket:Socket, newName:String) For Local c:Client=Eachin Client.clientList if(c.clientSocket.PeerAddress=socket.PeerAddress)Then c.clientName=newName Next End End '--Main Function Main() New AppInstance New ServerDemo App.Run() End

Client.monkey2

Monkey

Namespace clientChatSample #Import "<std>" #Import "<mojo>" #Import "<mojox>" Using std.. Using mojo.. Using mojox.. Const HOST:="localhost" 'Note: Use "" for 'public' host? Const PORT:=40122 Class ClientDemo Extends Window Global sendLine :String Global firstrun :Bool Global mainView :DockingView Global chatView :TextView Global inputField :TextField Global sendButton :Button Global stream :SocketStream Global client :Socket Method New() Super.New( "Client Chat Sample", 800, 600, WindowFlags.Resizable ) '---- chatView=New TextView chatView.ReadOnly=True chatView.Text="Commands without quotes:~n'/exit' Terminate the Chat Client~n'/nick newUserName' Change the UserName~n" inputField=New TextField inputField.Text="user"+Millisecs()'Randome User Name sendButton=New Button("Send") '---- mainView=New DockingView mainView.AddView(chatView,"top","90%") mainView.AddView(inputField,"left","90%") mainView.AddView(sendButton,"right","10%") Local sendLineLambda:=Lambda() sendLine=inputField.Text inputField.Text="" 'chatline Commands Select sendLine Case "/exit" 'Terminate App App.Terminate() End Select If Not(firstrun) New Fiber( Client ) Endif End '---- sendButton.Clicked=Lambda() sendLineLambda() End '---- inputField.Entered=Lambda() sendLineLambda() End ContentView=mainView End Method Client() Local receiveLength:Int chatView.AppendText("Client: Try to connect to Server("+HOST+":"+PORT+")~n") Fiber.Sleep( .5 ) client=Socket.Connect( HOST,PORT ) If Not client 'Print "Client: Couldn't connect to server" chatView.AppendText("Client: Couldn't connect to server~n") Return Endif 'Print "Client @"+client.Address+" connected to server @"+client.PeerAddress chatView.AppendText("Connected to server @"+client.PeerAddress+"~n") client.SetOption( "TCP_NODELAY",1 ) stream=New SocketStream( client ) Repeat if(sendLine) If not(firstrun) stream.WriteSizedString("/_join_ "+sendLine) firstrun=True Else stream.WriteSizedString(sendLine) Endif sendLine="" Endif if(receiveLength<client.CanReceive) chatView.AppendText(stream.ReadSizedString()+"~n") receiveLength=client.CanReceive Endif Fiber.Sleep(.01) Forever Print "Client:Bye" stream.Close() End End '--Main Function Main() New AppInstance New ClientDemo App.Run() 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 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142

Namespace clientChatSample   #Import "<std>" #Import "<mojo>" #Import "<mojox>"   Using std.. Using mojo.. Using mojox..   Const HOST:="localhost" 'Note: Use "" for 'public' host? Const PORT:=40122     Class ClientDemo Extends Window Global sendLine :String Global firstrun :Bool Global mainView :DockingView Global chatView :TextView Global inputField :TextField Global sendButton :Button Global stream :SocketStream Global client :Socket Method New() Super.New( "Client Chat Sample", 800, 600, WindowFlags.Resizable ) '---- chatView=New TextView chatView.ReadOnly=True chatView.Text="Commands without quotes:~n'/exit' Terminate the Chat Client~n'/nick newUserName' Change the UserName~n" inputField=New TextField inputField.Text="user"+Millisecs()'Randome User Name sendButton=New Button("Send") '---- mainView=New DockingView mainView.AddView(chatView,"top","90%") mainView.AddView(inputField,"left","90%") mainView.AddView(sendButton,"right","10%") Local sendLineLambda:=Lambda() sendLine=inputField.Text inputField.Text="" 'chatline Commands Select sendLine Case "/exit" 'Terminate App App.Terminate() End Select If Not(firstrun) New Fiber( Client ) Endif End '---- sendButton.Clicked=Lambda() sendLineLambda() End '---- inputField.Entered=Lambda() sendLineLambda() End ContentView=mainView End   Method Client() Local receiveLength:Int   chatView.AppendText("Client: Try to connect to Server("+HOST+":"+PORT+")~n") Fiber.Sleep( .5 ) client=Socket.Connect( HOST,PORT ) If Not client 'Print "Client: Couldn't connect to server" chatView.AppendText("Client: Couldn't connect to server~n") Return Endif 'Print "Client @"+client.Address+" connected to server @"+client.PeerAddress chatView.AppendText("Connected to server @"+client.PeerAddress+"~n") client.SetOption( "TCP_NODELAY",1 ) stream=New SocketStream( client ) Repeat if(sendLine) If not(firstrun) stream.WriteSizedString("/_join_ "+sendLine) firstrun=True Else stream.WriteSizedString(sendLine) Endif sendLine="" Endif if(receiveLength<client.CanReceive) chatView.AppendText(stream.ReadSizedString()+"~n") receiveLength=client.CanReceive Endif Fiber.Sleep(.01) Forever Print "Client:Bye" stream.Close() End End '--Main Function Main()   New AppInstance New ClientDemo App.Run()   End

[Author]

Posts