Multithread listen in server

[vanhaodev]

I want to create a while loop in async method for every client. But i see this lib only for single while loop to listen of all client request. Thanks

[alec1o]

Multithreading? Netly is multithreading... that is, each client runs in "parallel"

• 1x thread per server
• 1x thread per connected client (clientside or serverside)
  Netly 3 use ThreadPool for running client sockets in "parallel"

Netly 4:

• Client (client-side and server-side) - don't use ThreadPool/Task/Thread on clients it's all async and have big performance improved and very low cpu usage than Netly 3.
• Server - don't use ThreadPool/Task on server it's all block method using 1x thread and have big performance improved.

---

Hi, feel free to interact here, hope to solve your problem... but I'm confused, I can't understand what you mean!

Can you give pseudocode with this feature example?

Write what is the Netly behavior you wish to achieve (even if it is not supported)?

while (...?)
{
    ...?
}
...?

[vanhaodev]

Like this. Just a example. I dont want client wait other's client task on server

void Test()
{
      Server.onNewClient((newClient) =>
      {
          Listen(newClient);
      });
}
public async void Listen(Client client)
{
       while (client.isConnecting)
      {
          var packet = client.ListenPacket();
         if (packet == null) continue;
         HandlePacket(packet);
      }
}

thanks u. I wrote for mmorpg, if u have anyway to handle pls help me, thanks u. This lib so amazing

[alec1o]

Huh ok it's possible.

[vanhaodev]

server.On.Accept((client) => { Listen(client)});
is it ok?

[alec1o]

Exactly 💯

but this look more good.

Netly 4.x ([CURRENTLY] Unstable and undergoing changes)
Branch: https://github.com/alec1o/Netly/tree/v3.1.0

server.On.Accept((client) => Listen(ref client));

void Listen(ref ITCP.Client|IUDP.Client client)
{
    ...?
}

Netly 3.x (Stable) - Nuget & Unity Asset Store
Branch: https://github.com/alec1o/Netly/tree/dev

server.OnEnter((client) => Listen(ref client));

void Listen(ref TcpClient|UdpClient client)
{
    ...?
}

[alec1o]

v3.x

Example Code

• Your way

  public void Start()
  {
      var server = new TcpServer() | UdpServer();
      
      server.OnEnter((client) =>
      {
          Task.Run(Listen(client));
      });
  }
  
  public async void Listen(TcpClient|UdpClient client)
  {
      List<byte[]> packages = new List<byte[]>();
  
      // this client have internal thread to receive and send package
      // it means: don't have server overhead
      client.OnData(data => packages.Add(data));
  
      while (client.IsOpened)
      {
          if (packages.Count <= 0) continue;
          byte[] package = packages[0];
          packages.RemoveAt(0); // remove used package
          HandlePacket(package);
      }
  }

• My Way

  var server = new TcpServer() | UdpServer();
  
  server.OnEnter((client) =>
  {
      // wanna client loop... called once per client
      Task.Run(async () =>
      {
          while (client.IsOpened)
          {
              ...?
          }
      });
  
      // handle package on my way
      client.OnData(data => HandlePacket(data));
  });

or

v4.x

Example Code

• Your way

  public void Start()
  {
      var server = new TCP.Server() | UDP.Server();
  
      server.On.Accept((client) =>
      {
          Task.Run(Listen(client));
      });
  }
  
  public async void Listen(TCP.Client|UDP.Client client)
  {
      List<byte[]> packages = new List<byte[]>();
  
      // this client have internal thread to receive and send package
      // it means: don't have server overhead
      client.On.Data(data => packages.Add(data));
  
      while (client.IsOpened)
      {
          if (packages.Count <= 0) continue;
          byte[] package = packages[0];
          packages.RemoveAt(0); // remove used package
          HandlePacket(package);
      }
  }

• My Way

  var server = new TCP.Server() | UDP.Server() | RUDP.Server();
  
  server.On.Accept((client) =>
  {
      // wanna client loop... called once per client
      Task.Run(async () =>
      {
          while (client.IsOpened)
          {
              ...?
          }
      });
  
      // handle package on my way
      client.On.Data(data => HandlePacket(data));
  });

Apologies for the delay! 😄
Test and give feedback if it's working... 🥇

(Maybe it's a bit complex, I would make more effective examples for your specific use case, but i don't know your scope, that's why i did a generic example, feel free to refine it to your use case). 👩‍💻

[vanhaodev]

Thank u so much, I will have so many topic for this library :)))